fix: harness routing, codex exec, scheduled tasks UI

Made-with: Cursor

Author: coah80

apps/server/src/git/Layers/CodexTextGeneration.ts

@@ -165,6 +165,7 @@ const makeCodexTextGeneration = Effect.gen(function* () {
         codexSettings?.binaryPath || "codex",
         [
           "exec",
+          "--skip-git-repo-check",
           "--ephemeral",
           "-s",
           "read-only",

apps/server/src/harness/cliAuthProbe.test.ts

@@ -0,0 +1,33 @@
+import assert from "node:assert";
+import { afterEach, describe, it } from "vitest";
+
+import {
+  isClaudeSubscriptionOAuthTokenConfigured,
+  probeClaudeSubscriptionAuth,
+} from "./cliAuthProbe.ts";
+
+describe("cliAuthProbe", () => {
+  afterEach(() => {
+    delete process.env.CLAUDE_CODE_OAUTH_TOKEN;
+  });
+
+  it("isClaudeSubscriptionOAuthTokenConfigured is false when unset", () => {
+    delete process.env.CLAUDE_CODE_OAUTH_TOKEN;
+    assert.strictEqual(isClaudeSubscriptionOAuthTokenConfigured(), false);
+  });
+
+  it("isClaudeSubscriptionOAuthTokenConfigured is false for whitespace", () => {
+    process.env.CLAUDE_CODE_OAUTH_TOKEN = "   \n\t  ";
+    assert.strictEqual(isClaudeSubscriptionOAuthTokenConfigured(), false);
+  });
+
+  it("isClaudeSubscriptionOAuthTokenConfigured is true when token non-empty", () => {
+    process.env.CLAUDE_CODE_OAUTH_TOKEN = "sk-ant-oat01-test";
+    assert.strictEqual(isClaudeSubscriptionOAuthTokenConfigured(), true);
+  });
+
+  it("probeClaudeSubscriptionAuth resolves true when OAuth token env is set", async () => {
+    process.env.CLAUDE_CODE_OAUTH_TOKEN = "sk-ant-oat01-test";
+    assert.strictEqual(await probeClaudeSubscriptionAuth(), true);
+  });
+});

apps/server/src/harness/cliAuthProbe.ts

@@ -0,0 +1,71 @@
+import { execFile } from "node:child_process";
+import { promisify } from "node:util";
+
+import type { CommandResult } from "../provider/providerSnapshot.ts";
+import { parseClaudeAuthStatusFromOutput } from "../provider/Layers/ClaudeProvider.ts";
+import { parseAuthStatusFromOutput } from "../provider/Layers/CodexProvider.ts";
+
+const execFileAsync = promisify(execFile);
+
+export function isClaudeSubscriptionOAuthTokenConfigured(): boolean {
+  const raw = process.env.CLAUDE_CODE_OAUTH_TOKEN;
+  if (typeof raw !== "string") {
+    return false;
+  }
+  return raw.trim().length > 0;
+}
+
+async function execFileResult(
+  file: string,
+  args: readonly string[],
+  env?: NodeJS.ProcessEnv,
+): Promise<CommandResult> {
+  try {
+    const r = await execFileAsync(file, [...args], {
+      encoding: "utf8",
+      maxBuffer: 4 * 1024 * 1024,
+      timeout: 12_000,
+      ...(env ? { env } : {}),
+    });
+    return {
+      stdout: String(r.stdout ?? ""),
+      stderr: String(r.stderr ?? ""),
+      code: 0,
+    };
+  } catch (cause: unknown) {
+    const err = cause as {
+      stdout?: string | Buffer;
+      stderr?: string | Buffer;
+      code?: number;
+    };
+    return {
+      stdout: err.stdout !== undefined ? String(err.stdout) : "",
+      stderr: err.stderr !== undefined ? String(err.stderr) : "",
+      code: typeof err.code === "number" ? err.code : 1,
+    };
+  }
+}
+
+export async function probeClaudeSubscriptionAuth(binaryPath?: string): Promise<boolean> {
+  if (isClaudeSubscriptionOAuthTokenConfigured()) {
+    return true;
+  }
+  const bin = binaryPath?.trim() || "claude";
+  const result = await execFileResult(bin, ["auth", "status"]);
+  const parsed = parseClaudeAuthStatusFromOutput(result);
+  return parsed.status === "ready" && parsed.auth.status === "authenticated";
+}
+
+export async function probeCodexSubscriptionAuth(
+  binaryPath?: string,
+  homePath?: string,
+): Promise<boolean> {
+  const bin = binaryPath?.trim() || "codex";
+  const env =
+    homePath && homePath.trim().length > 0
+      ? { ...process.env, CODEX_HOME: homePath.trim() }
+      : process.env;
+  const result = await execFileResult(bin, ["login", "status"], env);
+  const parsed = parseAuthStatusFromOutput(result);
+  return parsed.status === "ready" && parsed.auth.status === "authenticated";
+}

apps/server/src/harness/engine/loop.ts

@@ -26,6 +26,10 @@ import {
 } from "../tools/scheduledTasks";
 import { streamAnthropic } from "../providers/anthropic";
 import { streamOpenAI } from "../providers/openai";
+import {
+  runClaudeSubscriptionTurn,
+  runCodexSubscriptionTurn,
+} from "../providers/cliSubscriptionTurn";
 import { buildSystemPrompt } from "./prompt";
 import { McpManager, type McpServerConfig } from "../mcp/client";
 import { LspManager } from "../lsp/client";
@@ -113,6 +117,52 @@ export async function* runAgentLoop(options: AgentLoopOptions): AsyncGenerator<A
   const messages: ConversationMessage[] = [...conversationHistory];
   messages.push({ role: "user", content: userMessage });
 
+  if (config.provider === "anthropic" && config.upstream.kind === "claude_subscription") {
+    for await (const event of runClaudeSubscriptionTurn({
+      model: config.model,
+      cwd: config.workspaceRoot,
+      systemPrompt,
+      conversationHistory,
+      userMessage,
+      signal,
+      claudeBinaryPath: config.upstream.claudeBinaryPath,
+      mode: config.mode,
+      harnessRuntimeMode: config.harnessRuntimeMode ?? "auto-accept-edits",
+    })) {
+      yield event;
+    }
+    await mcpManager.closeAll();
+    return;
+  }
+
+  if (config.provider === "openai" && config.upstream.kind === "openai_subscription") {
+    for await (const event of runCodexSubscriptionTurn({
+      model: config.model,
+      cwd: config.workspaceRoot,
+      systemPrompt,
+      conversationHistory,
+      userMessage,
+      signal,
+      codexBinaryPath: config.upstream.codexBinaryPath,
+      codexHomePath: config.upstream.codexHomePath,
+    })) {
+      yield event;
+    }
+    await mcpManager.closeAll();
+    return;
+  }
+
+  if (config.upstream.kind !== "api_key") {
+    yield {
+      type: "error",
+      error: "Harness API routing needs an API key for this model provider.",
+    };
+    await mcpManager.closeAll();
+    return;
+  }
+
+  const apiUpstream = config.upstream;
+
   let turnNumber = 0;
   const editedFiles: Set<string> = new Set();
   let nudgeState = createNudgeState();
@@ -134,8 +184,8 @@ export async function* runAgentLoop(options: AgentLoopOptions): AsyncGenerator<A
       config.provider === "anthropic"
         ? streamAnthropic({
             model: config.model,
-            apiKey: config.apiKey,
-            ...(config.baseURL ? { baseURL: config.baseURL } : {}),
+            apiKey: apiUpstream.apiKey,
+            ...(apiUpstream.baseURL ? { baseURL: apiUpstream.baseURL } : {}),
             messages,
             tools: allTools,
             systemPrompt,
@@ -144,9 +194,9 @@ export async function* runAgentLoop(options: AgentLoopOptions): AsyncGenerator<A
           })
         : streamOpenAI({
             model: config.model,
-            apiKey: config.apiKey,
+            apiKey: apiUpstream.apiKey,
             baseURL:
-              config.baseURL ??
+              apiUpstream.baseURL ??
               (config.provider === "openrouter"
                 ? "https://openrouter.ai/api/v1"
                 : "https://api.openai.com/v1"),