rustpbx 0.4.2

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
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
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143

use crate::call::app::{
    AppAction, ApplicationContext, CallApp, CallAppType, CallController, RecordingInfo,
};
use crate::callrecord::CallRecordHangupReason;
use async_trait::async_trait;
use std::time::Duration;
use tracing::{info, warn};

/// Voicemail application that records a message for a specific extension.
pub struct VoicemailApp {
    extension: String,
    greeting_path: String,
    state: VoicemailState,
    recording_path: Option<String>,
}

#[derive(Debug, Clone, PartialEq, Eq)]
enum VoicemailState {
    Greeting,
    Recording,
    Done,
}

impl VoicemailApp {
    pub fn new(extension: impl Into<String>) -> Self {
        Self {
            extension: extension.into(),
            greeting_path: "sounds/voicemail/greeting.wav".to_string(),
            state: VoicemailState::Greeting,
            recording_path: None,
        }
    }

    pub fn with_greeting_path(mut self, path: impl Into<String>) -> Self {
        self.greeting_path = path.into();
        self
    }
}

#[async_trait]
impl CallApp for VoicemailApp {
    fn app_type(&self) -> CallAppType {
        CallAppType::Voicemail
    }

    fn name(&self) -> &str {
        "voicemail"
    }

    async fn on_enter(
        &mut self,
        ctrl: &mut CallController,
        _ctx: &ApplicationContext,
    ) -> anyhow::Result<AppAction> {
        info!(extension = %self.extension, "Voicemail app entered");
        ctrl.answer().await?;
        ctrl.play_audio(&self.greeting_path, false).await?;
        Ok(AppAction::Continue)
    }

    async fn on_audio_complete(
        &mut self,
        _track_id: String,
        ctrl: &mut CallController,
        ctx: &ApplicationContext,
    ) -> anyhow::Result<AppAction> {
        if self.state == VoicemailState::Greeting {
            self.state = VoicemailState::Recording;
            // Use session_id as trace_id for full lifecycle tracking
            let path = format!(
                "/tmp/voicemail_{}_{}.wav",
                self.extension, ctx.call_info.session_id
            );
            info!(
                path = %path,
                session_id = %ctx.call_info.session_id,
                "Starting voicemail recording"
            );
            ctrl.start_recording(&path, Some(Duration::from_secs(300)), true)
                .await?;
            self.recording_path = Some(path);
        }
        Ok(AppAction::Continue)
    }

    async fn on_dtmf(
        &mut self,
        digit: String,
        ctrl: &mut CallController,
        _ctx: &ApplicationContext,
    ) -> anyhow::Result<AppAction> {
        if digit == "#" && self.state == VoicemailState::Recording {
            info!("DTMF # received, stopping voicemail recording");
            ctrl.stop_recording().await.ok();
            self.state = VoicemailState::Done;
            return Ok(AppAction::Hangup {
                reason: Some(CallRecordHangupReason::BySystem),
                code: None,
            });
        }
        Ok(AppAction::Continue)
    }

    async fn on_record_complete(
        &mut self,
        info: RecordingInfo,
        _ctrl: &mut CallController,
        _ctx: &ApplicationContext,
    ) -> anyhow::Result<AppAction> {
        info!(
            path = %info.path,
            duration = ?info.duration,
            size = info.size_bytes,
            "Voicemail recording completed"
        );
        if self.state != VoicemailState::Done {
            self.state = VoicemailState::Done;
            return Ok(AppAction::Hangup {
                reason: Some(CallRecordHangupReason::BySystem),
                code: None,
            });
        }
        Ok(AppAction::Continue)
    }

    async fn on_timeout(
        &mut self,
        _timeout_id: String,
        ctrl: &mut CallController,
        _ctx: &ApplicationContext,
    ) -> anyhow::Result<AppAction> {
        if self.state == VoicemailState::Recording {
            warn!("Voicemail recording timed out, stopping");
            ctrl.stop_recording().await.ok();
            self.state = VoicemailState::Done;
            return Ok(AppAction::Hangup {
                reason: Some(CallRecordHangupReason::BySystem),
                code: None,
            });
        }
        Ok(AppAction::Continue)
    }
}