Function executeAgent

packages/agent-runtime/src/runtime.ts:603–642

(config: AgentConfig, params: {
  message: string
  images?: Array<{ base64: string; mediaType: string }>
  sessionId?: string
  streamId: string
  threadId?: string
  options?: AgentRequestOptions
})

// --- Entry point (SDK path) ---

export async function executeAgent(config: AgentConfig, params: {
  message: string
  images?: Array<{ base64: string; mediaType: string }>
  sessionId?: string
  streamId: string
  threadId?: string
  options?: AgentRequestOptions
}) {
  const traceId = params.threadId ?? params.streamId
  initTrace(params.streamId, traceId, publish)
  const agentName = (config as { name?: string }).name || "main"

  const rootKey = "root"
  const rootSpanId = spanManager.startSpan(rootKey, {
    name: "agent:" + agentName,
    kind: "agent",
    attributes: {
      "agent.name": agentName,
      ...(config.model ? { "agent.model": config.model } : {}),
      "stream.id": params.streamId,
      "tool.input": JSON.stringify({ message: params.message }).slice(0, 10_000),
    },
  })
  spanManager.setRootSpanId(rootSpanId)

  try {
    const sdkOptions = buildSdkOptions(config, { sessionId: params.sessionId, requestOptions: params.options })
    const prompt = buildPrompt(params.message, params.images)
    const queryStream = claudeQuery({ prompt, options: sdkOptions })

    await processStream(queryStream, params.streamId, config)

    spanManager.endSpan(rootKey, { status: "completed" })
  } catch (error: any) {
    spanManager.endSpan(rootKey, { status: "error", error: error?.message ?? String(error) })
    throw error
  } finally {
    flushTrace()
  }
}

// --- Entry point (ACP path) ---