converge-kernel 3.9.2

The curated in-process kernel API for Converge
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
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90

use std::collections::HashMap;

use converge_kernel::{
    BudgetResource, DecisionStep, ExperienceEvent, ExperienceEventEnvelope, ExperienceEventKind,
    StopReason,
    formation::{Capability, FormationRequest, ProviderRequest, SuggestorRole},
};

#[test]
fn kernel_reexports_stop_reason_for_outcome_events() {
    let envelope = ExperienceEventEnvelope::new(
        "evt-outcome",
        ExperienceEvent::OutcomeRecorded {
            chain_id: "chain:test".into(),
            step: DecisionStep::Planning,
            passed: false,
            stop_reason: Some(StopReason::CycleBudgetExhausted {
                cycles_executed: 5,
                limit: 5,
            }),
            latency_ms: Some(12),
            tokens: Some(34),
            cost_microdollars: None,
            backend: Some("kernel-test".into()),
            metadata: HashMap::new(),
        },
    );

    assert_eq!(envelope.event.kind(), ExperienceEventKind::OutcomeRecorded);

    match envelope.event {
        ExperienceEvent::OutcomeRecorded {
            stop_reason:
                Some(StopReason::CycleBudgetExhausted {
                    cycles_executed,
                    limit,
                }),
            ..
        } => {
            assert_eq!(cycles_executed, 5);
            assert_eq!(limit, 5);
        }
        other => panic!("unexpected event shape: {other:?}"),
    }
}

#[test]
fn kernel_reexports_budget_resource_for_budget_events() {
    let envelope = ExperienceEventEnvelope::new(
        "evt-budget",
        ExperienceEvent::BudgetExceeded {
            chain_id: "chain:test".into(),
            resource: BudgetResource::Tokens,
            limit: "100".into(),
            observed: Some("144".into()),
        },
    );

    assert_eq!(envelope.event.kind(), ExperienceEventKind::BudgetExceeded);

    match envelope.event {
        ExperienceEvent::BudgetExceeded {
            resource: BudgetResource::Tokens,
            limit,
            observed,
            ..
        } => {
            assert_eq!(limit, "100");
            assert_eq!(observed.as_deref(), Some("144"));
        }
        other => panic!("unexpected event shape: {other:?}"),
    }
}

#[test]
fn kernel_formation_module_exposes_grouped_surface() {
    let formation = FormationRequest {
        id: "req-1".to_string(),
        required_roles: vec![SuggestorRole::Analysis, SuggestorRole::Planning],
        required_capabilities: vec![],
    };
    let provider = ProviderRequest {
        id: "provider-1".to_string(),
        required_capabilities: vec![Capability::Reasoning],
        backend_requirements: None,
    };

    assert_eq!(formation.required_roles.len(), 2);
    assert_eq!(provider.required_capabilities, vec![Capability::Reasoning]);
}