Function run

src/agents/claude-code.ts:63–117

(model, prompt, options)

const claudeCodeAgent: Agent.Definition = {
  async run(model, prompt, options) {
    options.logger.log(`claude-agent-sdk --model ${model} ${prompt}`);

    const cacheKey = sessionKey(model, options.cwd);
    const existingSessionID = sessionCache.get(cacheKey);

    const actions: string[] = [];
    const usage = {
      input: 0,
      output: 0,
      cost: 0,
    };

    try {
      const result = query({
        prompt,
        options: {
          model,
          cwd: options.cwd,
          // Resume existing session if available
          ...(existingSessionID ? { resume: existingSessionID } : {}),
          allowedTools: ["Read", "Write", "Edit", "Grep", "Glob", "Bash"],
        },
      });

      // Stream and log messages
      for await (const message of result) {
        // Extract and cache session ID from messages
        sessionCache.set(cacheKey, message.session_id);

        // Accumulate token usage if available (only SDKResultMessage has usage)
        if (message.type === "result" && "usage" in message) {
          usage.input += message.usage.input_tokens || 0;
          usage.output += message.usage.output_tokens || 0;
          usage.cost += message.total_cost_usd || 0;
        }

        actions.push(JSON.stringify(message));
        logJson(message, options);
      }
    } catch (error) {
      // Clear session cache on error, like other agents do
      sessionCache.delete(cacheKey);
      logError(
        {
          error: "claude_agent_sdk_failed",
          details: serializeError(error),
        },
        options,
      );
      throw error;
    }

    return { actions, usage };
  },
};

export default claudeCodeAgent;