Function process_claudecode_queue_item

src/worker.rs:237–347

Process a single claudecode-type queue item: set up workspace, spawn Claude Code agent.

(item: &QueueItem)

/// Process a single claudecode-type queue item: set up workspace, spawn Claude Code agent.
fn process_claudecode_queue_item(item: &QueueItem) -> Result<(), String> {
    // Resolve agent config (need workspace path, soul, instructions)
    let agent = load_full_agent_config(item)?;

    // Resolve workspace path
    let workspace_path = resolve_workspace_path(&agent, item)?;

    // Create workspace directory
    std::fs::create_dir_all(&workspace_path)
        .map_err(|e| format!("failed to create workspace: {}", e))?;

    // Write agent files into workspace
    if let Some(soul) = &agent.soul {
        if !soul.is_empty() {
            std::fs::write(workspace_path.join("SOUL.md"), soul)
                .map_err(|e| format!("write SOUL.md: {}", e))?;
        }
    }
    if let Some(instructions) = &agent.instructions {
        if !instructions.is_empty() {
            std::fs::write(workspace_path.join("AGENTS.md"), instructions)
                .map_err(|e| format!("write AGENTS.md: {}", e))?;
        }
    }
    std::fs::write(workspace_path.join("context.json"), &item.row_data)
        .map_err(|e| format!("write context.json: {}", e))?;

    // Build system prompt
    let system_prompt = build_system_prompt(
        &agent.soul,
        &agent.instructions,
        &agent.user_context,
        &agent.memory,
    );

    // Build the prompt for Claude Code
    let prompt = format!(
        "Event: {} on table (oid={}), row pk={}.\n\n\
         Current row state (also in context.json):\n{}\n\n\
         Respond with a JSON object of columns to update, e.g. {{\"column\": \"value\"}}.\n\
         Or {{}} if no changes needed.\n\
         To update agent memory, include {{\"__memory\": {{...}}}}.",
        item.event, item.table_oid.as_u32(), item.pk_value, item.row_data
    );

    // Spawn Claude Code agent via SDK
    let mut options = claude_agent_sdk::ClaudeAgentOptions::builder()
        .system_prompt(system_prompt.clone())
        .cwd(workspace_path)
        .permission_mode(claude_agent_sdk::PermissionMode::AcceptEdits)
        .build();
    options.model = Some(agent.model.clone());

    let response = http::runtime().block_on(async {
        let stream = claude_agent_sdk::query(&prompt, Some(options))
            .await
            .map_err(|e| format!("Claude Code spawn error: {}", e))?;
        pin!(stream);