ralph-agent-loop 0.4.0

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
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70

//! Shared webhook test fixtures.
//!
//! Responsibilities:
//! - Provide reusable sample failure records and default webhook config builders.
//! - Reset global dispatcher/diagnostics state between serial tests.
//!
//! Does NOT handle:
//! - Assertions for specific webhook behavior.
//! - Delivery transport simulation logic.
//!
//! Invariants:
//! - Fixture timestamps remain fixed for deterministic assertions.
//! - Default config keeps retries/timeouts low for unit tests.

use super::super::*;
use crate::contracts::WebhookConfig;
use crate::webhook::types::{WebhookContext, WebhookPayload};
use crate::webhook::worker::reset_dispatcher_for_tests;

pub(super) fn sample_failure_record(
    id: &str,
    event: &str,
    task_id: Option<&str>,
    replay_count: u32,
) -> WebhookFailureRecord {
    WebhookFailureRecord {
        id: id.to_string(),
        failed_at: "2026-02-13T00:00:00Z".to_string(),
        event: event.to_string(),
        task_id: task_id.map(std::string::ToString::to_string),
        destination: Some("https://hooks.example.com/…".to_string()),
        error: "HTTP 500: endpoint failed".to_string(),
        attempts: 3,
        replay_count,
        payload: WebhookPayload {
            event: event.to_string(),
            timestamp: "2026-02-13T00:00:00Z".to_string(),
            task_id: task_id.map(std::string::ToString::to_string),
            task_title: Some("Test task".to_string()),
            previous_status: None,
            current_status: None,
            note: None,
            context: WebhookContext::default(),
        },
    }
}

pub(super) fn reset_webhook_test_state() {
    crate::webhook::diagnostics::reset_webhook_metrics_for_tests();
    reset_dispatcher_for_tests();
}

pub(super) fn webhook_test_config() -> WebhookConfig {
    use crate::contracts::WebhookEventSubscription;

    WebhookConfig {
        enabled: Some(true),
        url: Some("http://127.0.0.1:9/webhook".to_string()),
        allow_insecure_http: Some(true),
        allow_private_targets: Some(true),
        secret: None,
        events: Some(vec![WebhookEventSubscription::Wildcard]),
        timeout_secs: Some(1),
        retry_count: Some(0),
        retry_backoff_ms: Some(1),
        queue_capacity: Some(100),
        parallel_queue_multiplier: None,
        queue_policy: Some(WebhookQueuePolicy::DropNew),
    }
}