mas_matrix/
readonly.rs

1// Copyright 2025 New Vector Ltd.
2//
3// SPDX-License-Identifier: AGPL-3.0-only
4// Please see LICENSE in the repository root for full details.
5
6use std::collections::HashSet;
7
8use crate::{HomeserverConnection, MatrixUser, ProvisionRequest};
9
10/// A wrapper around a [`HomeserverConnection`] that only allows read
11/// operations.
12pub struct ReadOnlyHomeserverConnection<C> {
13    inner: C,
14}
15
16impl<C> ReadOnlyHomeserverConnection<C> {
17    pub fn new(inner: C) -> Self
18    where
19        C: HomeserverConnection,
20    {
21        Self { inner }
22    }
23}
24
25#[async_trait::async_trait]
26impl<C: HomeserverConnection> HomeserverConnection for ReadOnlyHomeserverConnection<C> {
27    fn homeserver(&self) -> &str {
28        self.inner.homeserver()
29    }
30
31    async fn query_user(&self, mxid: &str) -> Result<MatrixUser, anyhow::Error> {
32        self.inner.query_user(mxid).await
33    }
34
35    async fn provision_user(&self, _request: &ProvisionRequest) -> Result<bool, anyhow::Error> {
36        anyhow::bail!("Provisioning is not supported in read-only mode");
37    }
38
39    async fn is_localpart_available(&self, localpart: &str) -> Result<bool, anyhow::Error> {
40        self.inner.is_localpart_available(localpart).await
41    }
42
43    async fn create_device(
44        &self,
45        _mxid: &str,
46        _device_id: &str,
47        _initial_display_name: Option<&str>,
48    ) -> Result<(), anyhow::Error> {
49        anyhow::bail!("Device creation is not supported in read-only mode");
50    }
51
52    async fn update_device_display_name(
53        &self,
54        _mxid: &str,
55        _device_id: &str,
56        _display_name: &str,
57    ) -> Result<(), anyhow::Error> {
58        anyhow::bail!("Device display name update is not supported in read-only mode");
59    }
60
61    async fn delete_device(&self, _mxid: &str, _device_id: &str) -> Result<(), anyhow::Error> {
62        anyhow::bail!("Device deletion is not supported in read-only mode");
63    }
64
65    async fn sync_devices(
66        &self,
67        _mxid: &str,
68        _devices: HashSet<String>,
69    ) -> Result<(), anyhow::Error> {
70        anyhow::bail!("Device synchronization is not supported in read-only mode");
71    }
72
73    async fn delete_user(&self, _mxid: &str, _erase: bool) -> Result<(), anyhow::Error> {
74        anyhow::bail!("User deletion is not supported in read-only mode");
75    }
76
77    async fn reactivate_user(&self, _mxid: &str) -> Result<(), anyhow::Error> {
78        anyhow::bail!("User reactivation is not supported in read-only mode");
79    }
80
81    async fn set_displayname(&self, _mxid: &str, _displayname: &str) -> Result<(), anyhow::Error> {
82        anyhow::bail!("User displayname update is not supported in read-only mode");
83    }
84
85    async fn unset_displayname(&self, _mxid: &str) -> Result<(), anyhow::Error> {
86        anyhow::bail!("User displayname update is not supported in read-only mode");
87    }
88
89    async fn allow_cross_signing_reset(&self, _mxid: &str) -> Result<(), anyhow::Error> {
90        anyhow::bail!("Allowing cross-signing reset is not supported in read-only mode");
91    }
92}
mas_matrix/readonly.rs

mas_matrix/
readonly.rs
