Function claw_process_one

src/process.rs:15–131

(
    api_key: String,
    provider: default!(Option<String>, "NULL"),
    api_url: default!(Option<String>, "NULL"),
)

/// is not running.
#[pg_extern]
fn claw_process_one(
    api_key: String,
    provider: default!(Option<String>, "NULL"),
    api_url: default!(Option<String>, "NULL"),
) -> Option<String> {
    let provider = provider.unwrap_or_else(crate::get_provider);
    let api_url = api_url.or_else(crate::get_api_url);

    // Claim one item
    let item = Spi::connect(|mut client| {
        let result = client
            .update(
                "UPDATE claw.queue
                 SET claimed_at = now()
                 WHERE id = (
                     SELECT id FROM claw.queue
                     WHERE claimed_at IS NULL
                     ORDER BY id
                     FOR UPDATE SKIP LOCKED
                     LIMIT 1
                 )
                 RETURNING id, table_oid, pk_value, claw_col, row_data::text,
                           event, claw_value, agent_type",
                None,
                None,
            )
            .expect("SPI failed");

        let row = result.into_iter().next()?;

        Some(QueueItem {
            id: row.get::<i64>(1).ok()??,
            table_oid: row.get::<pg_sys::Oid>(2).ok()??,
            pk_value: row.get::<String>(3).ok()??,
            claw_col: row.get::<String>(4).ok()??,
            row_data: row.get::<String>(5).ok()??,
            event: row.get::<String>(6).ok()??,
            claw_value: row.get::<String>(7).ok()??,
            agent_type: row.get::<String>(8).ok()??,
        })
    });

    let item = match item {
        Some(item) => item,
        None => return None,
    };

    if item.agent_type == "claudecode" {
        mark_done(&item, "skipped: claudecode agent type");
        return Some("skipped: claudecode agent type".to_string());
    }

    // Resolve agent config
    let (model, system_prompt) = match resolve_config(&item) {
        Ok(v) => v,
        Err(e) => {
            mark_done(&item, &format!("error: {}", e));
            return Some(format!("error: {}", e));