feat(loop): cross-repo auto mode with work-source and drain-complete

fork/manifest.json

@@ -70,6 +70,7 @@
     "packages/opencode/src/local/sync.ts",
     "packages/opencode/src/loop/completion.ts",
     "packages/opencode/src/loop/continuation.ts",
+    "packages/opencode/src/loop/crew/route.ts",
     "packages/opencode/src/loop/loop.ts",
     "packages/opencode/src/loop/similarity.ts",
     "packages/opencode/src/loop/spec-queue/authority.ts",
@@ -78,6 +79,7 @@
     "packages/opencode/src/loop/spec-queue/personas.ts",
     "packages/opencode/src/loop/spec-queue/queue.ts",
     "packages/opencode/src/loop/spec-queue/tasks-md.ts",
+    "packages/opencode/src/loop/spec-queue/work-source.ts",
     "packages/opencode/src/loop/spec-queue/branch-read.ts",
     "packages/opencode/src/loop/stop-reason.ts",
     "packages/opencode/src/peer/lead-confirm.ts",
@@ -137,16 +139,20 @@
     "packages/opencode/test/local/skein-independence.test.ts",
     "packages/opencode/test/local/ctx-fit.test.ts",
     "packages/opencode/test/local/llama-skein-client-smoke.test.ts",
+    "packages/opencode/test/loop/auto-mode.test.ts",
     "packages/opencode/test/loop/completion.test.ts",
     "packages/opencode/test/loop/continuation.test.ts",
+    "packages/opencode/test/loop/crew/route.test.ts",
     "packages/opencode/test/loop/loop-args.test.ts",
+    "packages/opencode/test/loop/cross-repo-config.test.ts",
     "packages/opencode/test/loop/loop.test.ts",
     "packages/opencode/test/loop/personas.test.ts",
     "packages/opencode/test/loop/queue-authority.test.ts",
     "packages/opencode/test/loop/queue-mode.test.ts",
     "packages/opencode/test/loop/similarity.test.ts",
     "packages/opencode/test/loop/spec-queue.test.ts",
     "packages/opencode/test/loop/branch-read.test.ts",
+    "packages/opencode/test/loop/work-source.test.ts",
     "packages/opencode/test/util/git-branch-repo.test.ts",
     "packages/opencode/test/mcp/fixtures.test.ts",
     "packages/opencode/test/mcp/protocol-mode.test.ts",

packages/opencode/src/cli/cmd/loop.ts

@@ -79,6 +79,27 @@ export const LoopCommand = effectCmd({
           "Pass change slugs to restrict/order the queue; bare --queue takes every eligible change. " +
           "Stuck changes are quarantined via .skein/blocker.md and the run continues.",
       })
+      .option("auto", {
+        type: "boolean",
+        default: false,
+        describe:
+          "auto mode: work items across repositories from the work source (specsync or local openspec). " +
+          "Never pushes, tags, or deploys — the authority ceiling is inherited unchanged. " +
+          "Work comes from the work source: specsync query if bound, otherwise local openspec changes.",
+      })
+      .option("repos", {
+        type: "string",
+        array: true,
+        describe:
+          "auto mode: restrict which repositories to scan (comma-separated paths). " +
+          "By default, all sibling directories with openspec changes are scanned.",
+      })
+      .option("directory", {
+        type: "string",
+        describe:
+          "auto mode: directory to scan for repositories (default: the server's working directory). " +
+          "Sibling directories of this path with openspec changes are scanned.",
+      })
       .option("max", {
         type: "number",
         alias: "n",
@@ -168,8 +189,9 @@ export const LoopCommand = effectCmd({
       .command(LoopResumeCommand),
   handler: Effect.fn("Cli.loop")(function* (args) {
     const queueMode = args.queue !== undefined
+    const autoMode = args.auto === true
     const prompt = args.prompt
-    if (!prompt && !queueMode) yield* fail("prompt is required (or pass --queue)")
+    if (!prompt && !queueMode && !autoMode) yield* fail("prompt is required (or pass --queue or --auto)")
 
     const sdk = createOpencodeClient({ baseUrl: args.server })
     const created = yield* Effect.promise(() =>
@@ -179,8 +201,8 @@ export const LoopCommand = effectCmd({
         interval: args.interval,
         noProgressLimit: args["stall-limit"],
         completionToken: args["completion-token"],
-        mode: queueMode ? "queue" : undefined,
-        eternal: !queueMode && args.eternal === false ? false : undefined,
+        mode: queueMode ? "queue" : autoMode ? ("auto" as "prompt") : undefined,
+        eternal: !queueMode && !autoMode && args.eternal === false ? false : undefined,
         queue: queueMode && args.queue && args.queue.length > 0 ? args.queue : undefined,
         queueSync: queueMode && args.sync ? true : undefined,
         queuePush: queueMode && args.push === false ? false : undefined,
@@ -194,6 +216,8 @@ export const LoopCommand = effectCmd({
                 verifyCommand: args["verify-command"],
               }
             : undefined,
+        autoDirectory: autoMode && args.directory ? args.directory : undefined,
+        autoRepos: autoMode && args.repos && args.repos.length > 0 ? args.repos : undefined,
       }),
     )
     // Say WHY. "failed to create loop" on its own sent me hunting for a

packages/opencode/src/loop/crew/route.ts

@@ -0,0 +1,82 @@
+// Routing a piece of work to warm capacity (crew-loop Phase 2a.1).
+//
+// Pure function over the peer roster and local host capacity. The decision
+// order is: warm member (provider already serves the model, idle), then cloud
+// member (not bound to a local host), then free host (reachable, free slot),
+// otherwise leave it on the board.
+//
+// This is the "last branch" the design warns about: an agent that spawns when
+// nothing is free feels productive and is not. "Leave it on the board" is a
+// real outcome.
+
+import type { PeerCandidate } from "../../peer/delegate"
+import type { HostCapacity } from "../../local/placement"
+
+export interface RouteInput {
+  /** The model ID this work needs. */
+  modelID: string
+  /** Live peers (opencode-skein and claude-code sessions). */
+  peers: readonly PeerCandidate[]
+  /** Local host capacity (reachable hosts with free slots). */
+  hosts: readonly HostCapacity[]
+  /** Provider IDs that are local (LAN/loopback). */
+  localProviderIDs: ReadonlySet<string>
+}
+
+export type RouteDecision =
+  | { kind: "warm"; peer: PeerCandidate }
+  | { kind: "cloud"; peer: PeerCandidate }
+  | { kind: "free-host"; host: HostCapacity }
+  | { kind: "board" }
+
+/**
+ * Decide where to route a piece of work.
+ *
+ * Order: warm member > cloud member > free host > board.
+ * "Board" means: do not spawn; leave the item on the board for someone to
+ * pick up when capacity frees.
+ */
+export function route(input: RouteInput): RouteDecision {
+  const { modelID, peers, hosts, localProviderIDs } = input
+
+  // Warm: a peer whose provider already serves this model and is idle.
+  // "Serves the model" means the peer's provider is local and has the model
+  // loaded (or is idle — an idle local host can load it without a queue).
+  const warm = peers.filter((peer) => {
+    if (peer.status !== "idle") return false
+    if (!peer.provider) return false
+    if (!localProviderIDs.has(peer.provider)) return false
+    // The peer's provider is local and idle — it can serve the model.
+    return true
+  })
+  if (warm.length > 0) {
+    // Freshest warm member (most recently idle).
+    warm.sort((a, b) => (b.idleForMs ?? 0) - (a.idleForMs ?? 0))
+    return { kind: "warm", peer: warm[0] }
+  }
+
+  // Cloud: a peer not bound to a local host.
+  const cloud = peers.filter((peer) => {
+    if (peer.status !== "idle") return false
+    if (peer.owner === "claude-code") return true
+    if (peer.provider && !localProviderIDs.has(peer.provider)) return true
+    return false
+  })
+  if (cloud.length > 0) {
+    cloud.sort((a, b) => (b.idleForMs ?? 0) - (a.idleForMs ?? 0))
+    return { kind: "cloud", peer: cloud[0] }
+  }
+
+  // Free host: a reachable local host with a free slot.
+  const free = hosts.filter((h) => h.reachable && h.free > 0)
+  if (free.length > 0) {
+    // Most free slots first.
+    free.sort((a, b) => b.free - a.free)
+    return { kind: "free-host", host: free[0] }
+  }
+
+  // Nothing free: leave it on the board. Do not spawn into a queue.
+  return { kind: "board" }
+}
+
+export * as CrewRoute from "./route"