acter/api/room/
account_data.rs

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
use acter_core::{events::room::UserSettingsEventContent, referencing::ExecuteReference};
use anyhow::Result;
use futures::{Stream, StreamExt};
use matrix_sdk::ruma::events::StaticEventContent;
use tokio::sync::broadcast::Receiver;
use tokio_stream::wrappers::BroadcastStream;
use tracing::error;

use crate::RUNTIME;

use super::Room;

pub struct UserRoomSettings {
    inner: UserSettingsEventContent,
    room: Room,
}

impl UserRoomSettings {
    fn new(room: Room, inner: UserSettingsEventContent) -> Self {
        Self { room, inner }
    }

    pub fn has_seen_suggested(&self) -> bool {
        self.inner.has_seen_suggested
    }

    pub async fn set_has_seen_suggested(&self, new_value: bool) -> Result<bool> {
        let mut user_settings = self.inner.clone();
        user_settings.has_seen_suggested = new_value;
        let room = self.room.clone();
        RUNTIME
            .spawn(async move {
                room.set_account_data(user_settings).await?;
                Ok(true)
            })
            .await?
    }

    pub fn include_cal_sync(&self) -> bool {
        self.inner.include_cal_sync
    }

    pub async fn set_include_cal_sync(&self, new_value: bool) -> Result<bool> {
        let mut user_settings = self.inner.clone();
        user_settings.include_cal_sync = new_value;
        let room = self.room.clone();
        RUNTIME
            .spawn(async move {
                room.set_account_data(user_settings).await?;
                Ok(true)
            })
            .await?
    }

    pub fn subscribe_stream(&self) -> impl Stream<Item = bool> {
        BroadcastStream::new(self.subscribe()).map(|f| true)
    }

    pub fn subscribe(&self) -> Receiver<()> {
        self.room.subscribe(ExecuteReference::RoomAccountData(
            self.room.room_id().to_owned(),
            UserSettingsEventContent::TYPE.into(),
        ))
    }
}

impl Room {
    pub async fn user_settings(&self) -> Result<UserRoomSettings> {
        let room = self.clone();
        RUNTIME
            .spawn(async move {
                Ok(UserRoomSettings::new(
                    room.clone(),
                    match room
                        .account_data_static::<UserSettingsEventContent>()
                        .await?
                        .map(|r| r.deserialize())
                    {
                        Some(Ok(e)) => e.content,
                        Some(Err(error)) => {
                            error!(
                                ?error,
                                room_id = ?room.room_id(),
                                "Deserializing user settings failed"
                            );
                            Default::default()
                        }
                        _ => Default::default(),
                    },
                ))
            })
            .await?
    }
}