Function process_queue_item

src/worker.rs:88–166

Claim and process one item from claw.queue. Returns true if an item was processed.

()

/// Claim and process one item from claw.queue.
/// Returns true if an item was processed.
fn process_queue_item() -> bool {
    let item = BackgroundWorker::transaction(|| {
        Spi::connect(|client| {
            let result = client.select(
                "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 false,
    };

    let result = if item.agent_type == "claudecode" {
        process_claudecode_queue_item(&item)
    } else {
        process_model_queue_item(&item)
    };

    BackgroundWorker::transaction(|| {
        Spi::connect(|mut client| {
            match &result {
                Ok(()) => {
                    client
                        .update(
                            &format!(
                                "UPDATE claw.queue SET done_at = now() WHERE id = {}",
                                item.id
                            ),
                            None,
                            None,
                        )