[Gastown] Phase 2: Town config, integrations, multi-polecat, refinery, molecules, convoys, escalations

cloudflare-gastown/container/Dockerfile

@@ -17,7 +17,9 @@ RUN apt-get update && \
 # Install Kilo CLI globally via npm (needs real Node.js runtime).
 # npm's global install does not resolve optionalDependencies, so we must
 # explicitly install the platform-specific binary package alongside the CLI.
-RUN npm install -g @kilocode/cli @kilocode/cli-linux-x64
+# Also install @kilocode/plugin globally so repo-local tools (e.g.
+# .opencode/tool/*.ts) can resolve it without a local node_modules.
+RUN npm install -g @kilocode/cli @kilocode/cli-linux-x64 @kilocode/plugin
 
 # Create workspace directories
 RUN mkdir -p /workspace/rigs /app

cloudflare-gastown/container/package.json

@@ -11,12 +11,12 @@
     "typecheck": "bun x tsc --noEmit"
   },
   "dependencies": {
+    "@kilocode/plugin": "1.0.23",
+    "@kilocode/sdk": "1.0.23",
     "hono": "^4.11.4",
     "zod": "^4.3.5"
   },
   "devDependencies": {
-    "@opencode-ai/plugin": "^1.1.64",
-    "@opencode-ai/sdk": "^1.1.64",
     "@types/bun": "^1.2.17",
     "typescript": "^5.9.3",
     "vitest": "^3.2.4"

cloudflare-gastown/container/plugin/client.ts

@@ -141,6 +141,34 @@ export class GastownClient {
       body: JSON.stringify(input),
     });
   }
+
+  async getMoleculeCurrentStep(): Promise<{
+    moleculeId: string;
+    currentStep: number;
+    totalSteps: number;
+    step: { title: string; instructions: string };
+    status: string;
+  } | null> {
+    try {
+      return await this.request(this.rigPath(`/agents/${this.agentId}/molecule/current`));
+    } catch (err) {
+      if (err instanceof GastownApiError && err.status === 404) return null;
+      throw err;
+    }
+  }
+
+  async advanceMoleculeStep(summary: string): Promise<{
+    moleculeId: string;
+    previousStep: number;
+    currentStep: number;
+    totalSteps: number;
+    completed: boolean;
+  }> {
+    return this.request(this.rigPath(`/agents/${this.agentId}/molecule/advance`), {
+      method: 'POST',
+      body: JSON.stringify({ summary }),
+    });
+  }
 }
 
 /**

cloudflare-gastown/container/plugin/index.ts

@@ -1,4 +1,4 @@
-import type { Plugin } from '@opencode-ai/plugin';
+import type { Plugin } from '@kilocode/plugin';
 import { createClientFromEnv, createMayorClientFromEnv, GastownApiError } from './client';
 import { createTools } from './tools';
 import { createMayorTools } from './mayor-tools';

cloudflare-gastown/container/plugin/mayor-tools.ts

@@ -1,4 +1,4 @@
-import { tool } from '@opencode-ai/plugin';
+import { tool } from '@kilocode/plugin';
 import type { MayorGastownClient } from './client';
 
 function parseJsonObject(value: string, label: string): Record<string, unknown> {

cloudflare-gastown/container/plugin/package.json

@@ -1,13 +1,13 @@
 {
-  "name": "opencode-gastown",
+  "name": "gastown-plugin",
   "version": "0.1.0",
   "type": "module",
   "private": true,
-  "description": "OpenCode plugin exposing Gastown tools to agents",
+  "description": "Kilo plugin exposing Gastown tools to agents",
   "main": "index.ts",
   "dependencies": {
-    "@opencode-ai/plugin": "^1.1.64",
-    "@opencode-ai/sdk": "^1.1.64",
+    "@kilocode/plugin": "^1.0.23",
+    "@kilocode/sdk": "^1.0.23",
     "zod": "^4.3.5"
   }
 }

cloudflare-gastown/container/plugin/tools.test.ts

@@ -2,7 +2,7 @@ import { describe, it, expect, vi, beforeEach } from 'vitest';
 import type { GastownClient } from './client';
 import type { Bead, Mail, PrimeContext } from './types';
 
-// Mock the @opencode-ai/plugin module to avoid its broken ESM import chain.
+// Mock the @kilocode/plugin module to avoid its broken ESM import chain.
 // The real `tool` is a passthrough that attaches `tool.schema = z`.
 import { z } from 'zod';
 
@@ -11,7 +11,7 @@ function toolFn(def: Record<string, unknown>) {
 }
 toolFn.schema = z;
 
-vi.mock('@opencode-ai/plugin', () => ({
+vi.mock('@kilocode/plugin', () => ({
   tool: toolFn,
 }));
 

cloudflare-gastown/container/plugin/tools.ts

@@ -1,4 +1,4 @@
-import { tool } from '@opencode-ai/plugin';
+import { tool } from '@kilocode/plugin';
 import type { GastownClient } from './client';
 
 function parseJsonArg(value: string, label: string): unknown {
@@ -152,5 +152,37 @@ export function createTools(client: GastownClient) {
         return 'Checkpoint saved.';
       },
     }),
+
+    gt_mol_current: tool({
+      description:
+        'Get the current molecule step for your hooked bead. Returns the step title, ' +
+        'instructions, step number (N of M), and molecule status. ' +
+        'Returns null if no molecule is attached to your current bead.',
+      args: {},
+      async execute() {
+        const step = await client.getMoleculeCurrentStep();
+        if (!step) return 'No molecule attached to your current bead.';
+        return JSON.stringify(step, null, 2);
+      },
+    }),
+
+    gt_mol_advance: tool({
+      description:
+        'Complete the current molecule step and advance to the next one. ' +
+        'Provide a summary of what you accomplished in this step. ' +
+        'If this is the final step, the molecule is marked as completed.',
+      args: {
+        summary: tool.schema
+          .string()
+          .describe('Brief summary of what you accomplished in this step'),
+      },
+      async execute(args) {
+        const result = await client.advanceMoleculeStep(args.summary);
+        if (result.completed) {
+          return `Molecule completed! All ${result.totalSteps} steps are done.`;
+        }
+        return `Advanced to step ${result.currentStep + 1} of ${result.totalSteps}.`;
+      },
+    }),
   };
 }