feat(web): import individual Claude sessions from a project

apps/server/src/auth/RpcAuthorization.test.ts

@@ -44,6 +44,15 @@ describe("RPC authorization scopes", () => {
   });
 
   it("requires write access to import agent session history", () => {
+    expect(requiredScopeForRpcMethod(WS_METHODS.agentSessionsList)).toBe(
+      AuthOrchestrationReadScope,
+    );
+    expect(requiredScopeForRpcMethod(WS_METHODS.agentSessionsPreview)).toBe(
+      AuthOrchestrationReadScope,
+    );
+    expect(requiredScopeForRpcMethod(WS_METHODS.agentSessionsAttach)).toBe(
+      AuthOrchestrationOperateScope,
+    );
     expect(requiredScopeForRpcMethod(WS_METHODS.agentSessionsScan)).toBe(
       AuthOrchestrationReadScope,
     );

apps/server/src/auth/RpcAuthorization.ts

@@ -102,6 +102,9 @@ export const RPC_REQUIRED_SCOPES = {
   [WS_METHODS.filesystemBrowse]: AuthOrchestrationReadScope,
   [WS_METHODS.agentSessionsScan]: AuthOrchestrationReadScope,
   [WS_METHODS.agentSessionsImport]: AuthOrchestrationOperateScope,
+  [WS_METHODS.agentSessionsList]: AuthOrchestrationReadScope,
+  [WS_METHODS.agentSessionsPreview]: AuthOrchestrationReadScope,
+  [WS_METHODS.agentSessionsAttach]: AuthOrchestrationOperateScope,
   [WS_METHODS.assetsCreateUrl]: AuthOrchestrationReadScope,
   [WS_METHODS.attachmentsCreateUploadUrl]: AuthOrchestrationOperateScope,
   [WS_METHODS.attachmentsDelete]: AuthOrchestrationOperateScope,

apps/server/src/checkpointing/CheckpointDiffQuery.test.ts

@@ -91,6 +91,7 @@ describe("CheckpointDiffQuery.layer", () => {
             getProjectShellById: () => Effect.succeed(Option.none()),
             getFirstActiveThreadIdByProjectId: () => Effect.succeed(Option.none()),
             getImportedAgentSessionSources: () => Effect.die("unused"),
+            getThreadProjectIds: () => Effect.die("unused"),
             getThreadCheckpointContext: () =>
               Effect.sync(() => {
                 getThreadCheckpointContextCalls += 1;
@@ -205,6 +206,7 @@ describe("CheckpointDiffQuery.layer", () => {
             getProjectShellById: () => Effect.succeed(Option.none()),
             getFirstActiveThreadIdByProjectId: () => Effect.succeed(Option.none()),
             getImportedAgentSessionSources: () => Effect.die("unused"),
+            getThreadProjectIds: () => Effect.die("unused"),
             getThreadCheckpointContext: () => Effect.succeed(Option.some(threadCheckpointContext)),
             getFullThreadDiffContext: () => Effect.die("unused"),
             getThreadRuntimeContext: () => Effect.die("unused"),
@@ -294,6 +296,7 @@ describe("CheckpointDiffQuery.layer", () => {
             getProjectShellById: () => Effect.succeed(Option.none()),
             getFirstActiveThreadIdByProjectId: () => Effect.succeed(Option.none()),
             getImportedAgentSessionSources: () => Effect.die("unused"),
+            getThreadProjectIds: () => Effect.die("unused"),
             getThreadCheckpointContext: () => Effect.succeed(Option.some(threadCheckpointContext)),
             getFullThreadDiffContext: () => Effect.die("unused"),
             getThreadRuntimeContext: () => Effect.die("unused"),
@@ -368,6 +371,7 @@ describe("CheckpointDiffQuery.layer", () => {
             getProjectShellById: () => Effect.succeed(Option.none()),
             getFirstActiveThreadIdByProjectId: () => Effect.succeed(Option.none()),
             getImportedAgentSessionSources: () => Effect.die("unused"),
+            getThreadProjectIds: () => Effect.die("unused"),
             getThreadCheckpointContext: () => Effect.succeed(Option.some(threadCheckpointContext)),
             getFullThreadDiffContext: () => Effect.die("unused"),
             getThreadRuntimeContext: () => Effect.die("unused"),
@@ -427,6 +431,7 @@ describe("CheckpointDiffQuery.layer", () => {
             getProjectShellById: () => Effect.succeed(Option.none()),
             getFirstActiveThreadIdByProjectId: () => Effect.succeed(Option.none()),
             getImportedAgentSessionSources: () => Effect.die("unused"),
+            getThreadProjectIds: () => Effect.die("unused"),
             getThreadCheckpointContext: () => Effect.succeed(Option.none()),
             getFullThreadDiffContext: () => Effect.succeed(Option.none()),
             getThreadRuntimeContext: () => Effect.die("unused"),

apps/server/src/orchestration/Layers/OrchestrationEngine.test.ts

@@ -420,6 +420,7 @@ describe("OrchestrationEngine", () => {
           getProjectShellById: () => Effect.succeed(Option.none()),
           getFirstActiveThreadIdByProjectId: () => Effect.succeed(Option.none()),
           getImportedAgentSessionSources: () => Effect.die("unused"),
+          getThreadProjectIds: () => Effect.die("unused"),
           getThreadCheckpointContext: () => Effect.succeed(Option.none()),
           getFullThreadDiffContext: () => Effect.succeed(Option.none()),
           getThreadRuntimeContext: () => Effect.die("unused"),

apps/server/src/orchestration/Layers/ProjectionSnapshotQuery.test.ts

@@ -909,11 +909,24 @@ projectionSnapshotLayer("ProjectionSnapshotQuery", (it) => {
           "None",
         );
       }
+      const candidateIds = [
+        ...Array.from({ length: 501 }, (_, index) => ThreadId.make(`missing-${index}`)),
+        ThreadId.make("thread-active"),
+        ThreadId.make("thread-archived"),
+      ];
+      assert.deepEqual(yield* snapshotQuery.getThreadProjectIds(candidateIds), [
+        {
+          threadId: ThreadId.make("thread-active"),
+          projectId: asProjectId("project-archive-test"),
+        },
+      ]);
+      assert.deepEqual(yield* snapshotQuery.getThreadProjectIds([]), []);
       yield* sql`UPDATE projection_threads SET deleted_at = '2026-04-06T00:00:08.000Z' WHERE thread_id = 'thread-active'`;
       assert.equal(
         (yield* snapshotQuery.getThreadRuntimeContext(ThreadId.make("thread-active")))._tag,
         "None",
       );
+      assert.deepEqual(yield* snapshotQuery.getThreadProjectIds(candidateIds), []);
     }),
   );
 

apps/server/src/orchestration/Layers/ProjectionSnapshotQuery.ts

@@ -1102,6 +1102,18 @@ const makeProjectionSnapshotQuery = Effect.gen(function* () {
       `,
   });
 
+  const getThreadProjectIdRows = SqlSchema.findAll({
+    Request: Schema.Array(ThreadId),
+    Result: Schema.Struct({ threadId: ThreadId, projectId: ProjectId }),
+    execute: (threadIds) => sql`
+      SELECT thread_id AS "threadId", project_id AS "projectId"
+      FROM projection_threads
+      WHERE ${sql.in("thread_id", threadIds)}
+        AND deleted_at IS NULL
+        AND archived_at IS NULL
+    `,
+  });
+
   const getThreadRuntimeContextRow = SqlSchema.findOneOption({
     Request: ThreadIdLookupInput,
     Result: ProjectionThreadRuntimeContextDbRowSchema,
@@ -2930,6 +2942,24 @@ pending_approval_requests AS (
       } satisfies OrchestrationThreadShell);
     });
 
+  const getThreadProjectIds: ProjectionSnapshotQueryShape["getThreadProjectIds"] = (threadIds) =>
+    Effect.gen(function* () {
+      const rows: Array<{ threadId: ThreadId; projectId: ProjectId }> = [];
+      for (const batch of Arr.chunksOf(threadIds, 500)) {
+        rows.push(
+          ...(yield* getThreadProjectIdRows(batch).pipe(
+            Effect.mapError(
+              toPersistenceSqlOrDecodeError(
+                "ProjectionSnapshotQuery.getThreadProjectIds:query",
+                "ProjectionSnapshotQuery.getThreadProjectIds:decodeRows",
+              ),
+            ),
+          )),
+        );
+      }
+      return rows;
+    });
+
   const getThreadRuntimeContext: ProjectionSnapshotQueryShape["getThreadRuntimeContext"] =
     Effect.fn("ProjectionSnapshotQuery.getThreadRuntimeContext")(function* (threadId) {
       const context = yield* getThreadRuntimeContextRow({ threadId }).pipe(
@@ -3413,6 +3443,7 @@ pending_approval_requests AS (
     getThreadCheckpointContext,
     getFullThreadDiffContext,
     getThreadShellById,
+    getThreadProjectIds,
     getThreadRuntimeContext,
     getTurnStartMessage,
     getThreadDetailById,

apps/server/src/orchestration/Services/ProjectionSnapshotQuery.ts

@@ -205,6 +205,14 @@ export interface ProjectionSnapshotQueryShape {
     threadId: ThreadId,
   ) => Effect.Effect<Option.Option<OrchestrationThreadShell>, ProjectionRepositoryError>;
 
+  /** Read project ownership for active candidate threads without hydrating their shells. */
+  readonly getThreadProjectIds: (
+    threadIds: ReadonlyArray<ThreadId>,
+  ) => Effect.Effect<
+    ReadonlyArray<{ readonly threadId: ThreadId; readonly projectId: ProjectId }>,
+    ProjectionRepositoryError
+  >;
+
   /** Read the active thread and session facts used to ingest provider events. */
   readonly getThreadRuntimeContext: (
     threadId: ThreadId,