rustpbx 0.4.9

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

use crate::console::ConsoleState;
use crate::proxy::presence::{PresenceState, PresenceStatus};
use axum::{
    Json, Router,
    extract::{Path, State},
    routing::get,
};
use serde::{Deserialize, Serialize};
use std::sync::Arc;

/// API routes (nested under api_prefix)
pub fn api_urls() -> Router<Arc<ConsoleState>> {
    Router::new().route(
        "/presence/{extension}",
        get(get_presence).post(set_presence),
    )
}

#[derive(Serialize)]
pub struct PresenceResponse {
    pub success: bool,
    pub data: Option<PresenceState>,
}

pub async fn get_presence(
    State(state): State<Arc<ConsoleState>>,
    Path(extension): Path<String>,
) -> Json<PresenceResponse> {
    if let Some(sip_server) = state.get_sip_server() {
        let presence = sip_server.presence_manager.get_state(&extension);
        Json(PresenceResponse {
            success: true,
            data: Some(presence),
        })
    } else {
        Json(PresenceResponse {
            success: false,
            data: None,
        })
    }
}

#[derive(Deserialize)]
pub struct SetPresenceRequest {
    pub status: PresenceStatus,
    pub note: Option<String>,
    pub activity: Option<String>,
}

pub async fn set_presence(
    State(state): State<Arc<ConsoleState>>,
    Path(extension): Path<String>,
    Json(payload): Json<SetPresenceRequest>,
) -> Json<PresenceResponse> {
    if let Some(sip_server) = state.get_sip_server() {
        let new_state = PresenceState {
            status: payload.status,
            note: payload.note,
            activity: payload.activity,
            last_updated: chrono::Utc::now().timestamp(),
        };
        sip_server
            .presence_manager
            .update_state(
                &extension,
                new_state.clone(),
                &crate::proxy::cluster_event::EventSource::Local,
            )
            .await;
        Json(PresenceResponse {
            success: true,
            data: Some(new_state),
        })
    } else {
        Json(PresenceResponse {
            success: false,
            data: None,
        })
    }
}