cal-core 0.2.158

Callable core lib
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

// File: cal-core/src/websocket.rs

use crate::{agent::{AgentStatus, AgentStatusUpdate}, RecordReference};
use serde::{Deserialize, Serialize};

#[derive(Debug, Clone, Serialize, Deserialize)]
#[serde(tag = "type", content = "data")]
pub enum WebSocketMessage {
    // Authentication (required for WebSocket security)
    Auth(AuthMessage),
    AuthResponse(AuthResponse),

    // Agent Status
    AgentStatus(AgentStatus),
    AgentStatusUpdate(AgentStatusUpdate),

    // Typing Indicators
    IsTyping(IsTypingMessage),
    IsTypingUpdate(IsTypingUpdate),

    // Queue
    QueueGroup(crate::queue::QueueGroup),

    // Conversation
    ConversationNotification(crate::conversation::ConversationNotification),

    // System
    Ping,
    Pong,
    Error(ErrorMessage),
    Reconnect(ReconnectMessage),
}

// ==================== Authentication Messages ====================

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct AuthMessage {
    pub token: String,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct AuthResponse {
    pub success: bool,
    pub user_id: Option<String>,
    pub agent_id: Option<String>,
    pub permissions: Vec<String>,
    pub error: Option<String>,
}

// ==================== Typing Messages ====================

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct IsTypingMessage {
    pub account: RecordReference,
    pub user: RecordReference,
    pub agent_name: String,
    pub from: String,
    pub action: String, // "typing" or "stopped"
    pub timestamp: i64,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct IsTypingUpdate {
    pub conversation_id: String,
    pub user_id: String,
    pub is_typing: bool,
    pub timestamp: i64,
}

// ==================== System Messages ====================

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct ErrorMessage {
    pub code: String,
    pub message: String,
    pub details: Option<serde_json::Value>,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
pub struct ReconnectMessage {
    pub reason: String,
    pub retry_after: u32, // seconds
}

// ==================== Helper Implementations ====================

impl WebSocketMessage {
    pub fn ping() -> Self {
        WebSocketMessage::Ping
    }

    pub fn pong() -> Self {
        WebSocketMessage::Pong
    }

    pub fn error(code: String, message: String) -> Self {
        WebSocketMessage::Error(ErrorMessage {
            code,
            message,
            details: None,
        })
    }

    pub fn is_ping(&self) -> bool {
        matches!(self, WebSocketMessage::Ping)
    }

    pub fn is_pong(&self) -> bool {
        matches!(self, WebSocketMessage::Pong)
    }
}