active-call 0.3.82

use super::ChatMessage;
use crate::call::Command;
use crate::event::SessionEvent;
use anyhow::Result;
use async_trait::async_trait;

#[async_trait]
pub trait DialogueHandler: Send + Sync {
    async fn on_start(&mut self) -> Result<Vec<Command>>;
    async fn on_event(&mut self, event: &SessionEvent) -> Result<Vec<Command>>;
    async fn get_history(&self) -> Vec<ChatMessage>;
    async fn summarize(&mut self, prompt: &str) -> Result<String>;
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::event::SessionEvent;
    use async_trait::async_trait;

    struct RecordingHandler;

    #[async_trait]
    impl DialogueHandler for RecordingHandler {
        async fn on_start(&mut self) -> Result<Vec<Command>> {
            Ok(vec![Command::Hangup {
                reason: Some("start".to_string()),
                initiator: Some("tester".to_string()),
                headers: None,
                refer: None,
            }])
        }

        async fn on_event(&mut self, event: &SessionEvent) -> Result<Vec<Command>> {
            if let SessionEvent::Hangup { .. } = event {
                Ok(vec![Command::Hangup {
                    reason: Some("event".to_string()),
                    initiator: Some("tester".to_string()),
                    headers: None,
                    refer: None,
                }])
            } else {
                Ok(vec![])
            }
        }

        async fn get_history(&self) -> Vec<ChatMessage> {
            vec![]
        }

        async fn summarize(&mut self, _prompt: &str) -> Result<String> {
            Ok("summary".to_string())
        }
    }

    #[tokio::test]
    async fn dialogue_handler_trait_works() -> Result<()> {
        let mut handler = RecordingHandler;

        let start_cmds = handler.on_start().await?;
        assert!(start_cmds.len() == 1);

        let event_cmds = handler
            .on_event(&SessionEvent::Hangup {
                track_id: "test".to_string(),
                timestamp: 0,
                reason: Some("done".to_string()),
                initiator: Some("tester".to_string()),
                start_time: "".to_string(),
                hangup_time: "".to_string(),
                answer_time: None,
                ringing_time: None,
                from: None,
                to: None,
                extra: None,
                refer: None,
            })
            .await?;
        assert!(event_cmds.len() == 1);
        Ok(())
    }
}