feat(chat): move conversations to another workspace (single & batch)

crates/agent-gateway/internal/protocol/pbws/guard.go

@@ -34,6 +34,7 @@ func vetAgentRequest(sm session.AgentView, env *gatewayv2.GatewayEnvelope) error
 		*gatewayv2.GatewayEnvelope_HistoryDelete,
 		*gatewayv2.GatewayEnvelope_HistoryPrefix,
 		*gatewayv2.GatewayEnvelope_HistoryPin,
+		*gatewayv2.GatewayEnvelope_HistorySetCwd,
 		*gatewayv2.GatewayEnvelope_HistoryShareGet,
 		*gatewayv2.GatewayEnvelope_HistoryShareSet,
 		*gatewayv2.GatewayEnvelope_HistoryWorkdirs,

crates/agent-gateway/proto/v2/gateway.proto

@@ -61,6 +61,7 @@ message GatewayEnvelope {
     HistoryBranchRequest history_branch = 92;
     ProviderUsageRequest provider_usage = 93;
     ChatFileOpenRequest chat_file_open = 94;
+    HistorySetCwdRequest history_set_cwd = 95;
   }
 
   // Legacy tunnel control/frame payloads (pre-rewrite protocol) and the
@@ -135,6 +136,7 @@ message AgentEnvelope {
     ChatIngressFragment chat_ingress_fragment = 97;
     ChatFileOpenResponse chat_file_open_resp = 98;
     ErrorResponse error = 99;
+    HistorySetCwdResponse history_set_cwd_resp = 100;
   }
 
   // Legacy tunnel control/frame payloads (pre-rewrite protocol) and the
@@ -1280,3 +1282,12 @@ message ChatIngressAck {
     REJECTED = 4;
   }
 }
+
+message HistorySetCwdRequest {
+  string conversation_id = 1;
+  string cwd = 2;
+}
+
+message HistorySetCwdResponse {
+  ConversationSummary conversation = 1;
+}

crates/agent-gateway/test/webui/gateway-socket-client.test.mjs

@@ -1043,6 +1043,44 @@ test("GatewayWebSocketClient sends history branch requests with the base message
   resetGatewayWebSocketClient();
 });
 
+test("GatewayWebSocketClient sends history cwd update requests", async () => {
+  installBrowser();
+  const { codec, getGatewayWebSocketClient, resetGatewayWebSocketClient } = loadGatewaySocket();
+  resetGatewayWebSocketClient();
+
+  const client = getGatewayWebSocketClient("token");
+  const updatePromise = client.setHistoryCwd("conversation-1", "/tmp/project-b");
+  const socket = await connectAndAuth(codec);
+  await waitFor(() => findAgentRequest(codec, socket, "history_set_cwd"), "history cwd frame");
+  const request = findAgentRequest(codec, socket, "history_set_cwd");
+  assert.deepEqual(request.json.agent_request.history_set_cwd, {
+    conversation_id: "conversation-1",
+    cwd: "/tmp/project-b",
+  });
+  socket.receiveBinary(
+    codec.encodeServerFrame({
+      request_id: request.requestId,
+      agent_response: {
+        history_set_cwd_resp: {
+          conversation: {
+            id: "conversation-1",
+            title: "Moved conversation",
+            cwd: "/tmp/project-b",
+            message_count: 6,
+            created_at: 1700000000100,
+            updated_at: 1700000000200,
+          },
+        },
+      },
+    }),
+  );
+  const updated = await updatePromise;
+  assert.equal(updated.id, "conversation-1");
+  assert.equal(updated.cwd, "/tmp/project-b");
+
+  resetGatewayWebSocketClient();
+});
+
 test("GatewayWebSocketClient reconnects before read requests when an authenticated socket goes stale", async () => {
   installBrowser();
   const { codec, getGatewayWebSocketClient, resetGatewayWebSocketClient } = loadGatewaySocket();

crates/agent-gateway/web/src/app/sidebar/GatewaySidebarContainer.tsx

@@ -214,6 +214,27 @@ export function GatewaySidebarContainer(props: GatewaySidebarContainerProps) {
     void store.setPinned(id, isPinned);
   });
 
+  const handleMoveToWorkspace = useStableCallback((id: string, cwd: string) => {
+    if (sectionsDisabled) {
+      return;
+    }
+    clearMutationErrors();
+    void store.setCwd(id, cwd);
+  });
+
+  const handleMoveConversationsToWorkspace = useStableCallback(
+    async (ids: readonly string[], cwd: string) => {
+      if (sectionsDisabled) {
+        return ids;
+      }
+      clearMutationErrors();
+      const results = await Promise.all(
+        ids.map(async (id) => ({ id, moved: await store.setCwd(id, cwd) })),
+      );
+      return results.filter((result) => !result.moved).map((result) => result.id);
+    },
+  );
+
   const handleDeleteConversation = useStableCallback((id: string) => {
     if (sectionsDisabled) {
       return;
@@ -369,6 +390,8 @@ export function GatewaySidebarContainer(props: GatewaySidebarContainerProps) {
       onCommitRename={handleCommitRename}
       onCancelRename={handleCancelRename}
       onSetPinned={handleSetPinned}
+      onMoveToWorkspace={handleMoveToWorkspace}
+      onMoveConversationsToWorkspace={handleMoveConversationsToWorkspace}
       canShareConversations={props.canShareConversations}
       sharedConversationCount={props.sharedConversationCount}
       onShareConversation={props.onShareConversation}