Adapters

// packages/adapters/<name>/src/server/execute.ts
 
export type ProgressEvent =
  | { type: "tool_use"; toolName: string }
  | { type: "text"; preview: string };
 
export async function execute(
  ctx: AdapterExecutionContext,
  onProgress?: (event: ProgressEvent) => void,
): Promise<AdapterExecutionResult> { ... }

interface AdapterExecutionContext {
  config:     AdapterConfig;     // { cwd, model, timeoutSec, graceSec, ... }
  prompt:     string;
  sessionId?: string;            // resume prior session (Claude only)
  skillsDir?: string;            // temp dir with skills files (Claude only)
  agentId:    string;
  tenantId:   string;
  runId:      string;
  agentName:  string;
  tenantName: string;
}
 
interface AdapterExecutionResult {
  success:    boolean;
  output?:    string;
  error?:     string;
  sessionId?: string;
  costUsd?:   number;
  durationMs?: number;
}

// packages/agents/src/workers/setup.worker.ts
 
type AdapterExecuteFn = typeof import("@leadmetrics/adapter-claude-local/server").execute;
 
async function getAdapter(adapterType: string): Promise<AdapterExecuteFn> {
  if (adapterType === "codex_local") {
    const mod = require("@leadmetrics/adapter-codex-local/server") as { execute: AdapterExecuteFn };
    return mod.execute;
  }
  if (adapterType === "gemini_local") {
    const mod = require("@leadmetrics/adapter-gemini-local/server") as { execute: AdapterExecuteFn };
    return mod.execute;
  }
  // default: claude_local
  const mod = require("@leadmetrics/adapter-claude-local/server") as { execute: AdapterExecuteFn };
  return mod.execute;
}

const isCodex  = adapterType === "codex_local";
const isGemini = adapterType === "gemini_local";
const config = isCodex
  ? { cwd, model, dangerouslyBypassApprovalsAndSandbox: true, timeoutSec: 900 }
  : isGemini
  ? { cwd, model, yolo: true, timeoutSec: 900 }
  : { cwd, model, dangerouslySkipPermissions: true, timeoutSec: 900 };
 
// Skills injected only for Claude (Codex + Gemini don't support --add-dir)
const skillsDir = isCodex || isGemini ? undefined : await createSkillsDir(tenantId, agentRole);

// packages/agents/src/agent-events.ts
await publishAgentEvent({
  type: "agent:started",
  adapter: adapterType,   // "claude_local" | "codex_local" | "gemini_local"
  model,
  tenantId, agentRole, runId, skills, ...
});