rustpbx 0.4.8

A SIP PBX implementation in Rust
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

//! CC E2E test — agent callout + CDR via RWI originate
//! Requires: --features addon-cc

#![cfg(feature = "addon-cc")]

mod helpers;

use helpers::cdr_verifier::CdrVerifier;
use helpers::rwi_collector::RwiCollector;
use helpers::sipbot_helper::TestUa;
use helpers::test_server::{TEST_TOKEN, TestPbx, TestPbxInject};
use std::time::Duration;
use tokio::time::sleep;
use uuid::Uuid;

/// Agent callout via RWI originate → CDR verification
#[tokio::test]
async fn test_cc_agent_callout_cdr() {
    let sip_port = portpicker::pick_unused_port().unwrap();
    let agent_port = portpicker::pick_unused_port().unwrap();
    let (cdr, cdr_sender) = CdrVerifier::new();

    let pbx = TestPbx::start_with_inject(
        sip_port,
        TestPbxInject {
            callrecord_sender: Some(cdr_sender),
            ..Default::default()
        },
    )
    .await;

    let mut rwi = RwiCollector::connect(&pbx.rwi_url, TEST_TOKEN).await;
    rwi.wait_for_event_type("command_completed", 3).await;

    let agent = TestUa::callee_with_username(agent_port, 1, "agent1001").await;
    let call_id = format!("cc-callout-{}", Uuid::new_v4());

    rwi.send(
        &serde_json::json!({"rwi":"1.0","action":"call.originate","action_id":"cc-orig","params":{
            "call_id":call_id,"destination":agent.sip_uri("agent1001"),
            "caller_id":format!("sip:cc-system@{}",pbx.sip_host()),
            "context":"default","timeout_secs":15
        }}),
    )
    .await;
    rwi.wait_for_event_type("command_completed", 5).await;
    rwi.wait_for_event_type("call_answered", 10).await;

    sleep(Duration::from_millis(1000)).await;

    rwi.send(&serde_json::json!({"rwi":"1.0","action":"call.hangup","action_id":"cc-hup","params":{"call_id":call_id}})).await;
    rwi.wait_for_event_type("command_completed", 5).await;
    sleep(Duration::from_millis(1000)).await;

    let r = cdr.wait_for_record(&call_id, 3).await.expect("CC CDR");
    cdr.assert_call_completed(&r);
    eprintln!(
        "[CC] ✓ Agent callout CDR: status={} dur={}s",
        r.details.status,
        (r.end_time - r.start_time).num_seconds()
    );

    agent.stop();
    pbx.stop();
}