feat(chat): 接入虚拟列表并实现历史分页

Author: yyg-max

.gitignore

@@ -22,6 +22,7 @@ target
 .vscode
 target
 bin
+.serena
 
 # Editor directories and files
 .vscode/*

crates/agent-gateway/internal/proto/v1/gateway.pb.go

@@ -84,6 +84,7 @@ type websocketConnection struct {
 }
 
 const recentActiveChatRetention = 5 * time.Second
+const maxHistoryListLimit = 200
 
 func NewWebSocketServer(cfg *config.Config, sm *session.Manager) http.Handler {
 	server := &websocket.Server{
@@ -486,23 +487,35 @@ func (c *websocketConnection) handleFsListDirs(req websocketRequest) {
 
 func (c *websocketConnection) handleHistoryList(req websocketRequest) {
 	type payload struct {
-		Limit  int `json:"limit"`
-		Offset int `json:"offset"`
+		Page     int `json:"page"`
+		PageSize int `json:"page_size"`
 	}
 
 	var body payload
 	if err := decodeWebSocketPayload(req.Payload, &body); err != nil {
 		_ = c.writeError(req.ID, "invalid history.list payload")
 		return
 	}
+	page := body.Page
+	if page <= 0 {
+		_ = c.writeError(req.ID, "history.list page must be greater than 0")
+		return
+	}
+	pageSize := body.PageSize
+	if pageSize <= 0 {
+		_ = c.writeError(req.ID, "history.list page_size must be greater than 0")
+		return
+	} else if pageSize > maxHistoryListLimit {
+		pageSize = maxHistoryListLimit
+	}
 
 	response, err := c.awaitAgentResponse(req.ID, &gatewayv1.GatewayEnvelope{
 		RequestId: req.ID,
 		Timestamp: time.Now().Unix(),
 		Payload: &gatewayv1.GatewayEnvelope_HistoryList{
 			HistoryList: &gatewayv1.HistoryListRequest{
-				Limit:  int32(body.Limit),
-				Offset: int32(body.Offset),
+				Page:     int32(page),
+				PageSize: int32(pageSize),
 			},
 		},
 	})
@@ -528,7 +541,7 @@ func (c *websocketConnection) handleHistoryList(req websocketRequest) {
 
 	_ = c.writeResponse(req.ID, map[string]any{
 		"conversations":            conversations,
-		"total":                    resp.GetTotal(),
+		"total_count":              resp.GetTotalCount(),
 		"running_conversation_ids": c.sm.ActiveChatRunConversationIDs(),
 	})
 }

crates/agent-gateway/internal/proto/v1/gateway_grpc.pb.go

@@ -191,13 +191,13 @@ message CronManageResponse {
 }
 
 message HistoryListRequest {
-  int32 limit = 1;
-  int32 offset = 2;
+  int32 page = 1;
+  int32 page_size = 2;
 }
 
 message HistoryListResponse {
   repeated ConversationSummary conversations = 1;
-  int32 total = 2;
+  int32 total_count = 2;
 }
 
 message ConversationSummary {

crates/agent-gateway/internal/server/websocket.go

@@ -830,23 +830,23 @@ func TestWebSocketForwardsHistorySettingsAndFsRPCs(t *testing.T) {
 	}
 
 	sendEnvelope(t, conn, "history-1", "history.list", map[string]any{
-		"limit":  25,
-		"offset": 5,
+		"page":      2,
+		"page_size": 25,
 	})
 	historyOutbound := readOutboundEnvelope(t, agentSession)
 	historyReq := historyOutbound.GetHistoryList()
 	if historyReq == nil {
 		t.Fatalf("history outbound payload = %T, want HistoryListRequest", historyOutbound.GetPayload())
 	}
-	if historyReq.GetLimit() != 25 || historyReq.GetOffset() != 5 {
+	if historyReq.GetPage() != 2 || historyReq.GetPageSize() != 25 {
 		t.Fatalf("history list request = %#v", historyReq)
 	}
 	sm.DispatchFromAgent(&gatewayv1.AgentEnvelope{
 		RequestId: historyOutbound.GetRequestId(),
 		Timestamp: time.Now().Unix(),
 		Payload: &gatewayv1.AgentEnvelope_HistoryListResp{
 			HistoryListResp: &gatewayv1.HistoryListResponse{
-				Total: 1,
+				TotalCount: 1,
 				Conversations: []*gatewayv1.ConversationSummary{
 					{
 						Id:           "conversation-1",
@@ -874,7 +874,7 @@ func TestWebSocketForwardsHistorySettingsAndFsRPCs(t *testing.T) {
 	if err := json.Unmarshal(historyResponse.Payload, &historyPayload); err != nil {
 		t.Fatalf("decode history response: %v", err)
 	}
-	if historyPayload["total"] != float64(1) {
+	if historyPayload["total_count"] != float64(1) {
 		t.Fatalf("history payload = %#v", historyPayload)
 	}
 	runningConversationIDs, ok := historyPayload["running_conversation_ids"].([]any)

crates/agent-gateway/proto/v1/gateway.proto

@@ -18,6 +18,7 @@
     "@streamdown/code": "^1.1.1",
     "@streamdown/math": "^1.0.2",
     "@streamdown/mermaid": "^1.0.2",
+    "@tanstack/react-virtual": "^3.13.25",
     "class-variance-authority": "^0.7.1",
     "clsx": "^2.1.1",
     "katex": "^0.16.45",