cueloop 0.4.1

A Rust CLI for managing AI agent loops with a structured JSON task queue
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

//! Webhook delivery worker thread loop.
//!
//! Purpose:
//! - Webhook delivery worker thread loop.
//!
//! Responsibilities:
//! - Provide focused implementation or regression coverage for this file's owning feature.
//!
//! Scope:
//! - Limited to this file's owning feature boundary.
//!
//!
//! Usage:
//! - Used through the crate module tree or integration test harness.
//!
//! Invariants/Assumptions:
//! - Keep behavior aligned with CueLoop's canonical CLI, machine-contract, and queue semantics.

use crossbeam_channel::{Receiver, Sender};
use std::sync::Weak;

use super::types::{DeliveryTask, ScheduledRetry};
use crate::webhook::diagnostics;
use crate::webhook::worker::delivery::handle_delivery_task;

pub(super) fn worker_loop(
    ready_receiver: Receiver<DeliveryTask>,
    retry_sender: Weak<Sender<ScheduledRetry>>,
) {
    while let Ok(task) = ready_receiver.recv() {
        diagnostics::note_queue_dequeue();
        handle_delivery_task(task, &retry_sender);
    }
}