ruma_client_api/delayed_events/
update_delayed_event.rs

Help
1//! `POST /_matrix/client/*/delayed_events/{delayed_id}`
2//!
3//! Send a delayed event update. This can be a updateing/canceling/sending the associated delayed
4//! event.
5
6pub mod unstable {
7    //! `msc3814` ([MSC])
8    //!
9    //! [MSC]: https://github.com/matrix-org/matrix-spec-proposals/pull/4140
10
11    use ruma_common::{
12        api::{request, response, Metadata},
13        metadata,
14        serde::StringEnum,
15    };
16
17    use crate::PrivOwnedStr;
18
19    const METADATA: Metadata = metadata! {
20        method: POST,
21        rate_limited: true,
22        authentication: AccessToken,
23        history: {
24            unstable => "/_matrix/client/unstable/org.matrix.msc4140/delayed_events/:delay_id",
25        }
26    };
27
28    /// The possible update actions we can do for updating a delayed event.
29    #[derive(Clone, StringEnum)]
30    #[ruma_enum(rename_all = "lowercase")]
31    #[cfg_attr(not(ruma_unstable_exhaustive_types), non_exhaustive)]
32    pub enum UpdateAction {
33        /// Restart the delayed event timeout. (heartbeat ping)
34        Restart,
35        /// Send the delayed event immediately independent of the timeout state. (deletes all
36        /// timers)
37        Send,
38        /// Delete the delayed event and never send it. (deletes all timers)
39        Cancel,
40
41        #[doc(hidden)]
42        _Custom(PrivOwnedStr),
43    }
44    /// Request type for the [`update_delayed_event`](crate::delayed_events::update_delayed_event)
45    /// endpoint.
46    #[request(error = crate::Error)]
47    pub struct Request {
48        /// The delay id that we want to update.
49        #[ruma_api(path)]
50        pub delay_id: String,
51        /// Which kind of update we want to request for the delayed event.
52        pub action: UpdateAction,
53    }
54
55    impl Request {
56        /// Creates a new `Request` to update a delayed event.
57        pub fn new(delay_id: String, action: UpdateAction) -> Self {
58            Self { delay_id, action }
59        }
60    }
61
62    /// Response type for the [`update_delayed_event`](crate::delayed_events::update_delayed_event)
63    /// endpoint.
64    #[response(error = crate::Error)]
65    pub struct Response {}
66    impl Response {
67        /// Creates a new empty response for the
68        /// [`update_delayed_event`](crate::delayed_events::update_delayed_event) endpoint.
69        pub fn new() -> Self {
70            Self {}
71        }
72    }
73
74    #[cfg(all(test, feature = "client"))]
75    mod tests {
76        use ruma_common::api::{MatrixVersion, OutgoingRequest, SendAccessToken};
77        use serde_json::{json, Value as JsonValue};
78
79        use super::{Request, UpdateAction};
80        #[test]
81        fn serialize_update_delayed_event_request() {
82            let request: http::Request<Vec<u8>> =
83                Request::new("1234".to_owned(), UpdateAction::Cancel)
84                    .try_into_http_request(
85                        "https://homeserver.tld",
86                        SendAccessToken::IfRequired("auth_tok"),
87                        &[MatrixVersion::V1_1],
88                    )
89                    .unwrap();
90
91            let (parts, body) = request.into_parts();
92
93            assert_eq!(
94                "https://homeserver.tld/_matrix/client/unstable/org.matrix.msc4140/delayed_events/1234",
95                parts.uri.to_string()
96            );
97            assert_eq!("POST", parts.method.to_string());
98            assert_eq!(
99                json!({"action": "cancel"}),
100                serde_json::from_str::<JsonValue>(std::str::from_utf8(&body).unwrap()).unwrap()
101            );
102        }
103    }
104}
ruma_client_api/delayed_events/update_delayed_event.rs

ruma_client_api/delayed_events/
update_delayed_event.rs
