Add provider-aware SME conversation auth and routing

apps/server/src/persistence/Layers/SmeConversations.ts

@@ -28,16 +28,18 @@ const makeSmeConversationRepository = Effect.gen(function* () {
     execute: (row) =>
       sql`
         INSERT INTO sme_conversations (
-          conversation_id, project_id, title, model,
+          conversation_id, project_id, title, provider, auth_method, model,
           created_at, updated_at, deleted_at
         )
         VALUES (
-          ${row.conversationId}, ${row.projectId}, ${row.title}, ${row.model},
+          ${row.conversationId}, ${row.projectId}, ${row.title}, ${row.provider}, ${row.authMethod}, ${row.model},
           ${row.createdAt}, ${row.updatedAt}, ${row.deletedAt}
         )
         ON CONFLICT (conversation_id)
         DO UPDATE SET
           title = excluded.title,
+          provider = excluded.provider,
+          auth_method = excluded.auth_method,
           model = excluded.model,
           updated_at = excluded.updated_at,
           deleted_at = excluded.deleted_at
@@ -53,6 +55,8 @@ const makeSmeConversationRepository = Effect.gen(function* () {
           conversation_id AS "conversationId",
           project_id AS "projectId",
           title,
+          provider,
+          auth_method AS "authMethod",
           model,
           created_at AS "createdAt",
           updated_at AS "updatedAt",
@@ -71,6 +75,8 @@ const makeSmeConversationRepository = Effect.gen(function* () {
           conversation_id AS "conversationId",
           project_id AS "projectId",
           title,
+          provider,
+          auth_method AS "authMethod",
           model,
           created_at AS "createdAt",
           updated_at AS "updatedAt",

apps/server/src/persistence/Migrations.ts

@@ -31,6 +31,7 @@ import Migration0016 from "./Migrations/016_ProjectionThreadsInteractionModeChat
 import Migration0017 from "./Migrations/017_EnvironmentVariables.ts";
 import Migration0018 from "./Migrations/018_ProjectionThreadsGithubRef.ts";
 import Migration0019 from "./Migrations/019_SmeKnowledgeBase.ts";
+import Migration0020 from "./Migrations/020_SmeConversationProviderAuth.ts";
 import { Effect } from "effect";
 
 /**
@@ -63,6 +64,7 @@ const loader = Migrator.fromRecord({
   "17_EnvironmentVariables": Migration0017,
   "18_ProjectionThreadsGithubRef": Migration0018,
   "19_SmeKnowledgeBase": Migration0019,
+  "20_SmeConversationProviderAuth": Migration0020,
 });
 
 /**

apps/server/src/persistence/Migrations/020_SmeConversationProviderAuth.ts

@@ -0,0 +1,35 @@
+import * as Effect from "effect/Effect";
+import * as SqlClient from "effect/unstable/sql/SqlClient";
+
+export default Effect.gen(function* () {
+  const sql = yield* SqlClient.SqlClient;
+
+  yield* sql`
+    ALTER TABLE sme_conversations
+    ADD COLUMN provider TEXT NOT NULL DEFAULT 'claudeAgent'
+  `.pipe(Effect.catch(() => Effect.void));
+
+  yield* sql`
+    ALTER TABLE sme_conversations
+    ADD COLUMN auth_method TEXT NOT NULL DEFAULT 'auto'
+  `.pipe(Effect.catch(() => Effect.void));
+
+  yield* sql`
+    UPDATE sme_conversations
+    SET provider = CASE
+      WHEN lower(model) LIKE 'claude-%' THEN 'claudeAgent'
+      WHEN lower(model) LIKE 'gpt-%' THEN 'codex'
+      WHEN lower(model) LIKE 'openclaw/%' OR lower(model) = 'default' THEN 'openclaw'
+      ELSE 'claudeAgent'
+    END
+    WHERE provider IS NULL
+       OR provider = ''
+       OR provider = 'claudeAgent'
+  `;
+
+  yield* sql`
+    UPDATE sme_conversations
+    SET auth_method = 'auto'
+    WHERE auth_method IS NULL OR auth_method = ''
+  `;
+});

apps/server/src/persistence/Services/SmeConversations.ts

@@ -5,7 +5,13 @@
  *
  * @module SmeConversationRepository
  */
-import { IsoDateTime, ProjectId, SmeConversationId } from "@okcode/contracts";
+import {
+  IsoDateTime,
+  ProjectId,
+  ProviderKind,
+  SmeAuthMethod,
+  SmeConversationId,
+} from "@okcode/contracts";
 import { Option, Schema, ServiceMap } from "effect";
 import type { Effect } from "effect";
 
@@ -15,6 +21,8 @@ export const SmeConversationRow = Schema.Struct({
   conversationId: SmeConversationId,
   projectId: ProjectId,
   title: Schema.String,
+  provider: ProviderKind,
+  authMethod: SmeAuthMethod,
   model: Schema.String,
   createdAt: IsoDateTime,
   updatedAt: IsoDateTime,

apps/server/src/sme/Layers/SmeChatServiceLive.test.ts

@@ -1,5 +1,5 @@
 import { ProjectId, SmeConversationId, type EnvironmentVariableEntry } from "@okcode/contracts";
-import { Effect, Layer, Option } from "effect";
+import { Effect, Layer, Option, Stream } from "effect";
 import { afterEach, describe, expect, it, vi } from "vitest";
 
 import {
@@ -21,6 +21,10 @@ import {
   type SmeMessageRepositoryShape,
   type SmeMessageRow,
 } from "../../persistence/Services/SmeMessages.ts";
+import {
+  ProviderService,
+  type ProviderServiceShape,
+} from "../../provider/Services/ProviderService.ts";
 import { SmeChatService } from "../Services/SmeChatService.ts";
 import { makeSmeChatServiceLive } from "./SmeChatServiceLive.ts";
 
@@ -154,6 +158,21 @@ function makeMessageRepository() {
   return { repository, rowsByConversation };
 }
 
+function makeProviderService(): ProviderServiceShape {
+  return {
+    startSession: () => Effect.die("unexpected provider startSession"),
+    sendTurn: () => Effect.die("unexpected provider sendTurn"),
+    interruptTurn: () => Effect.void,
+    respondToRequest: () => Effect.void,
+    respondToUserInput: () => Effect.void,
+    stopSession: () => Effect.void,
+    listSessions: () => Effect.succeed([]),
+    getCapabilities: () => Effect.die("unexpected provider getCapabilities"),
+    rollbackConversation: () => Effect.void,
+    streamEvents: Stream.empty,
+  };
+}
+
 describe("SmeChatServiceLive", () => {
   it("uses persisted Anthropic credentials for a successful send and stores the final reply", async () => {
     setAnthropicEnv({
@@ -168,6 +187,8 @@ describe("SmeChatServiceLive", () => {
       conversationId,
       projectId,
       title: "Architecture Q&A",
+      provider: "claudeAgent",
+      authMethod: "apiKey",
       model: "claude-sonnet-4-6",
       createdAt: "2026-01-01T00:00:00.000Z",
       updatedAt: "2026-01-01T00:00:00.000Z",
@@ -209,6 +230,7 @@ describe("SmeChatServiceLive", () => {
         Layer.succeed(SmeConversationRepository, makeConversationRepository([conversationRow])),
       ),
       Layer.provideMerge(Layer.succeed(SmeMessageRepository, messageRepo)),
+      Layer.provideMerge(Layer.succeed(ProviderService, makeProviderService())),
     );
 
     const events: Array<unknown> = [];
@@ -287,6 +309,8 @@ describe("SmeChatServiceLive", () => {
       conversationId,
       projectId,
       title: "Docs sync",
+      provider: "claudeAgent",
+      authMethod: "apiKey",
       model: "claude-sonnet-4-6",
       createdAt: "2026-01-01T00:00:00.000Z",
       updatedAt: "2026-01-01T00:00:00.000Z",
@@ -302,6 +326,7 @@ describe("SmeChatServiceLive", () => {
         Layer.succeed(SmeConversationRepository, makeConversationRepository([conversationRow])),
       ),
       Layer.provideMerge(Layer.succeed(SmeMessageRepository, messageRepo)),
+      Layer.provideMerge(Layer.succeed(ProviderService, makeProviderService())),
     );
 
     await expect(
@@ -314,11 +339,15 @@ describe("SmeChatServiceLive", () => {
           });
         }).pipe(Effect.provide(layer)),
       ),
-    ).rejects.toThrow(
-      "SmeChatError in sendMessage:auth: SME Chat requires ANTHROPIC_API_KEY or ANTHROPIC_AUTH_TOKEN.",
-    );
+    ).rejects.toThrow("SmeChatError in sendMessage:validate: Anthropic API key is missing.");
 
     expect(createClient).not.toHaveBeenCalled();
-    expect(rowsByConversation.get(conversationId) ?? []).toEqual([]);
+    expect(rowsByConversation.get(conversationId)).toEqual([
+      expect.objectContaining({
+        role: "user",
+        text: "Can you summarize the docs?",
+        isStreaming: false,
+      }),
+    ]);
   });
 });