matrix-bridge-teams 0.1.0

A bridge between Matrix and Microsoft Teams written in Rust
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

use anyhow::Result;

use crate::matrix::message::MatrixMessage;
use crate::teams::TeamsMessage;

pub struct MessageFlow;

impl MessageFlow {
    pub fn new() -> Self {
        Self
    }

    pub async fn teams_to_matrix(&self, teams_message: TeamsMessage) -> Result<MatrixMessage> {
        Ok(MatrixMessage {
            event_id: format!("$teams_{}", teams_message.id),
            room_id: format!("!teams_{}:localhost", teams_message.channel_id.unwrap_or_default()),
            sender: format!("@teams_{}:localhost", teams_message.sender_id),
            content: crate::matrix::message::MessageContent {
                msgtype: "m.text".to_string(),
                body: teams_message.content.clone(),
                formatted_body: None,
                format: None,
            },
            origin_server_ts: chrono::Utc::now().timestamp_millis() as u64,
        })
    }

    pub async fn matrix_to_teams(&self, matrix_message: MatrixMessage) -> Result<TeamsMessage> {
        Ok(TeamsMessage {
            id: matrix_message.event_id.clone(),
            channel_id: None,
            chat_id: None,
            sender_id: matrix_message.sender.clone(),
            sender_name: String::new(),
            content: matrix_message.content.body.clone(),
            content_type: "text".to_string(),
            attachments: vec![],
            reply_to: None,
            created_at: chrono::Utc::now().to_rfc3339(),
            updated_at: None,
        })
    }

    pub async fn handle_teams_message(&self, message: TeamsMessage) -> Result<()> {
        let matrix_message = self.teams_to_matrix(message).await?;
        Ok(())
    }

    pub async fn handle_matrix_message(&self, message: MatrixMessage) -> Result<()> {
        let teams_message = self.matrix_to_teams(message).await?;
        Ok(())
    }
}