ruma_events/room/
encrypted.rs

1//! Types for the [`m.room.encrypted`] event.
2//!
3//! [`m.room.encrypted`]: https://spec.matrix.org/latest/client-server-api/#mroomencrypted
4
5use std::{borrow::Cow, collections::BTreeMap};
6
7use js_int::UInt;
8use ruma_common::{serde::JsonObject, OwnedDeviceId, OwnedEventId};
9use ruma_macros::EventContent;
10use serde::{Deserialize, Serialize};
11
12use super::message;
13use crate::{
14    relation::{Annotation, CustomRelation, InReplyTo, Reference, RelationType, Thread},
15    room::message::RelationWithoutReplacement,
16};
17
18mod relation_serde;
19#[cfg(feature = "unstable-msc3414")]
20pub mod unstable_state;
21
22/// The content of an `m.room.encrypted` event.
23#[derive(Clone, Debug, Deserialize, Serialize, EventContent)]
24#[cfg_attr(not(ruma_unstable_exhaustive_types), non_exhaustive)]
25#[ruma_event(type = "m.room.encrypted", kind = MessageLike)]
26pub struct RoomEncryptedEventContent {
27    /// Algorithm-specific fields.
28    #[serde(flatten)]
29    pub scheme: EncryptedEventScheme,
30
31    /// Information about related events.
32    #[serde(rename = "m.relates_to", skip_serializing_if = "Option::is_none")]
33    pub relates_to: Option<Relation>,
34}
35
36impl RoomEncryptedEventContent {
37    /// Creates a new `RoomEncryptedEventContent` with the given scheme and relation.
38    pub fn new(scheme: EncryptedEventScheme, relates_to: Option<Relation>) -> Self {
39        Self { scheme, relates_to }
40    }
41}
42
43impl From<EncryptedEventScheme> for RoomEncryptedEventContent {
44    fn from(scheme: EncryptedEventScheme) -> Self {
45        Self { scheme, relates_to: None }
46    }
47}
48
49/// The to-device content of an `m.room.encrypted` event.
50#[derive(Clone, Debug, Deserialize, Serialize, EventContent)]
51#[cfg_attr(not(ruma_unstable_exhaustive_types), non_exhaustive)]
52#[ruma_event(type = "m.room.encrypted", kind = ToDevice)]
53pub struct ToDeviceRoomEncryptedEventContent {
54    /// Algorithm-specific fields.
55    #[serde(flatten)]
56    pub scheme: EncryptedEventScheme,
57}
58
59impl ToDeviceRoomEncryptedEventContent {
60    /// Creates a new `ToDeviceRoomEncryptedEventContent` with the given scheme.
61    pub fn new(scheme: EncryptedEventScheme) -> Self {
62        Self { scheme }
63    }
64}
65
66impl From<EncryptedEventScheme> for ToDeviceRoomEncryptedEventContent {
67    fn from(scheme: EncryptedEventScheme) -> Self {
68        Self { scheme }
69    }
70}
71
72/// The encryption scheme for `RoomEncryptedEventContent`.
73#[derive(Clone, Debug, Deserialize, Serialize)]
74#[cfg_attr(not(ruma_unstable_exhaustive_types), non_exhaustive)]
75#[serde(tag = "algorithm")]
76pub enum EncryptedEventScheme {
77    /// An event encrypted with `m.olm.v1.curve25519-aes-sha2`.
78    #[serde(rename = "m.olm.v1.curve25519-aes-sha2")]
79    OlmV1Curve25519AesSha2(OlmV1Curve25519AesSha2Content),
80
81    /// An event encrypted with `m.megolm.v1.aes-sha2`.
82    #[serde(rename = "m.megolm.v1.aes-sha2")]
83    MegolmV1AesSha2(MegolmV1AesSha2Content),
84}
85
86/// Relationship information about an encrypted event.
87///
88/// Outside of the encrypted payload to support server aggregation.
89#[derive(Clone, Debug)]
90#[allow(clippy::manual_non_exhaustive)]
91#[cfg_attr(not(ruma_unstable_exhaustive_types), non_exhaustive)]
92pub enum Relation {
93    /// An `m.in_reply_to` relation indicating that the event is a reply to another event.
94    Reply {
95        /// Information about another message being replied to.
96        in_reply_to: InReplyTo,
97    },
98
99    /// An event that replaces another event.
100    Replacement(Replacement),
101
102    /// A reference to another event.
103    Reference(Reference),
104
105    /// An annotation to an event.
106    Annotation(Annotation),
107
108    /// An event that belongs to a thread.
109    Thread(Thread),
110
111    #[doc(hidden)]
112    _Custom(CustomRelation),
113}
114
115impl Relation {
116    /// The type of this `Relation`.
117    ///
118    /// Returns an `Option` because the `Reply` relation does not have a`rel_type` field.
119    pub fn rel_type(&self) -> Option<RelationType> {
120        match self {
121            Relation::Reply { .. } => None,
122            Relation::Replacement(_) => Some(RelationType::Replacement),
123            Relation::Reference(_) => Some(RelationType::Reference),
124            Relation::Annotation(_) => Some(RelationType::Annotation),
125            Relation::Thread(_) => Some(RelationType::Thread),
126            Relation::_Custom(c) => c.rel_type(),
127        }
128    }
129
130    /// The associated data.
131    ///
132    /// The returned JSON object holds the contents of `m.relates_to`, including `rel_type` and
133    /// `event_id` if present, but not things like `m.new_content` for `m.replace` relations that
134    /// live next to `m.relates_to`.
135    ///
136    /// Prefer to use the public variants of `Relation` where possible; this method is meant to
137    /// be used for custom relations only.
138    pub fn data(&self) -> Cow<'_, JsonObject> {
139        if let Relation::_Custom(CustomRelation(data)) = self {
140            Cow::Borrowed(data)
141        } else {
142            Cow::Owned(self.serialize_data())
143        }
144    }
145}
146
147impl<C> From<message::Relation<C>> for Relation {
148    fn from(rel: message::Relation<C>) -> Self {
149        match rel {
150            message::Relation::Reply { in_reply_to } => Self::Reply { in_reply_to },
151            message::Relation::Replacement(re) => {
152                Self::Replacement(Replacement { event_id: re.event_id })
153            }
154            message::Relation::Thread(t) => Self::Thread(Thread {
155                event_id: t.event_id,
156                in_reply_to: t.in_reply_to,
157                is_falling_back: t.is_falling_back,
158            }),
159            message::Relation::_Custom(c) => Self::_Custom(c),
160        }
161    }
162}
163
164impl From<RelationWithoutReplacement> for Relation {
165    fn from(value: RelationWithoutReplacement) -> Self {
166        match value {
167            RelationWithoutReplacement::Thread(t) => Self::Thread(t),
168            RelationWithoutReplacement::_Custom(c) => Self::_Custom(c),
169            RelationWithoutReplacement::Reply { in_reply_to } => Self::Reply { in_reply_to },
170        }
171    }
172}
173
174/// The event this relation belongs to [replaces another event].
175///
176/// In contrast to [`relation::Replacement`](crate::relation::Replacement), this
177/// struct doesn't store the new content, since that is part of the encrypted content of an
178/// `m.room.encrypted` events.
179///
180/// [replaces another event]: https://spec.matrix.org/latest/client-server-api/#event-replacements
181#[derive(Clone, Debug, Deserialize, Serialize)]
182#[cfg_attr(not(ruma_unstable_exhaustive_types), non_exhaustive)]
183#[serde(tag = "rel_type", rename = "m.replace")]
184pub struct Replacement {
185    /// The ID of the event being replaced.
186    pub event_id: OwnedEventId,
187}
188
189impl Replacement {
190    /// Creates a new `Replacement` with the given event ID.
191    pub fn new(event_id: OwnedEventId) -> Self {
192        Self { event_id }
193    }
194}
195
196/// The content of an `m.room.encrypted` event using the `m.olm.v1.curve25519-aes-sha2` algorithm.
197#[derive(Clone, Debug, Serialize, Deserialize)]
198#[cfg_attr(not(ruma_unstable_exhaustive_types), non_exhaustive)]
199pub struct OlmV1Curve25519AesSha2Content {
200    /// A map from the recipient Curve25519 identity key to ciphertext information.
201    pub ciphertext: BTreeMap<String, CiphertextInfo>,
202
203    /// The Curve25519 key of the sender.
204    pub sender_key: String,
205}
206
207impl OlmV1Curve25519AesSha2Content {
208    /// Creates a new `OlmV1Curve25519AesSha2Content` with the given ciphertext and sender key.
209    pub fn new(ciphertext: BTreeMap<String, CiphertextInfo>, sender_key: String) -> Self {
210        Self { ciphertext, sender_key }
211    }
212}
213
214/// Ciphertext information holding the ciphertext and message type.
215///
216/// Used for messages encrypted with the `m.olm.v1.curve25519-aes-sha2` algorithm.
217#[derive(Clone, Debug, Deserialize, Serialize)]
218#[cfg_attr(not(ruma_unstable_exhaustive_types), non_exhaustive)]
219pub struct CiphertextInfo {
220    /// The encrypted payload.
221    pub body: String,
222
223    /// The Olm message type.
224    #[serde(rename = "type")]
225    pub message_type: UInt,
226}
227
228impl CiphertextInfo {
229    /// Creates a new `CiphertextInfo` with the given body and type.
230    pub fn new(body: String, message_type: UInt) -> Self {
231        Self { body, message_type }
232    }
233}
234
235/// The content of an `m.room.encrypted` event using the `m.megolm.v1.aes-sha2` algorithm.
236///
237/// To create an instance of this type, first create a `MegolmV1AesSha2ContentInit` and convert it
238/// via `MegolmV1AesSha2Content::from` / `.into()`.
239#[derive(Clone, Debug, Serialize, Deserialize)]
240#[cfg_attr(not(ruma_unstable_exhaustive_types), non_exhaustive)]
241pub struct MegolmV1AesSha2Content {
242    /// The encrypted content of the event.
243    pub ciphertext: String,
244
245    /// The Curve25519 key of the sender.
246    #[deprecated = "Since Matrix 1.3, this field should still be sent but should not be used when received"]
247    #[serde(skip_serializing_if = "Option::is_none")]
248    pub sender_key: Option<String>,
249
250    /// The ID of the sending device.
251    #[deprecated = "Since Matrix 1.3, this field should still be sent but should not be used when received"]
252    #[serde(skip_serializing_if = "Option::is_none")]
253    pub device_id: Option<OwnedDeviceId>,
254
255    /// The ID of the session used to encrypt the message.
256    pub session_id: String,
257}
258
259/// Mandatory initial set of fields of `MegolmV1AesSha2Content`.
260///
261/// This struct will not be updated even if additional fields are added to `MegolmV1AesSha2Content`
262/// in a new (non-breaking) release of the Matrix specification.
263#[derive(Debug)]
264#[allow(clippy::exhaustive_structs)]
265pub struct MegolmV1AesSha2ContentInit {
266    /// The encrypted content of the event.
267    pub ciphertext: String,
268
269    /// The Curve25519 key of the sender.
270    pub sender_key: String,
271
272    /// The ID of the sending device.
273    pub device_id: OwnedDeviceId,
274
275    /// The ID of the session used to encrypt the message.
276    pub session_id: String,
277}
278
279impl From<MegolmV1AesSha2ContentInit> for MegolmV1AesSha2Content {
280    /// Creates a new `MegolmV1AesSha2Content` from the given init struct.
281    fn from(init: MegolmV1AesSha2ContentInit) -> Self {
282        let MegolmV1AesSha2ContentInit { ciphertext, sender_key, device_id, session_id } = init;
283        #[allow(deprecated)]
284        Self { ciphertext, sender_key: Some(sender_key), device_id: Some(device_id), session_id }
285    }
286}
287
288#[cfg(test)]
289mod tests {
290    use assert_matches2::assert_matches;
291    use js_int::uint;
292    use ruma_common::{device_id, owned_event_id, serde::Raw};
293    use serde_json::{from_value as from_json_value, json, to_value as to_json_value};
294
295    use super::{
296        EncryptedEventScheme, InReplyTo, MegolmV1AesSha2ContentInit, Relation,
297        RoomEncryptedEventContent,
298    };
299
300    #[test]
301    fn serialization() {
302        let key_verification_start_content = RoomEncryptedEventContent {
303            scheme: EncryptedEventScheme::MegolmV1AesSha2(
304                MegolmV1AesSha2ContentInit {
305                    ciphertext: "ciphertext".into(),
306                    sender_key: "sender_key".into(),
307                    device_id: "device_id".into(),
308                    session_id: "session_id".into(),
309                }
310                .into(),
311            ),
312            relates_to: Some(Relation::Reply {
313                in_reply_to: InReplyTo { event_id: owned_event_id!("$h29iv0s8:example.com") },
314            }),
315        };
316
317        let json_data = json!({
318            "algorithm": "m.megolm.v1.aes-sha2",
319            "ciphertext": "ciphertext",
320            "sender_key": "sender_key",
321            "device_id": "device_id",
322            "session_id": "session_id",
323            "m.relates_to": {
324                "m.in_reply_to": {
325                    "event_id": "$h29iv0s8:example.com"
326                }
327            },
328        });
329
330        assert_eq!(to_json_value(&key_verification_start_content).unwrap(), json_data);
331    }
332
333    #[test]
334    #[allow(deprecated)]
335    fn deserialization() {
336        let json_data = json!({
337            "algorithm": "m.megolm.v1.aes-sha2",
338            "ciphertext": "ciphertext",
339            "sender_key": "sender_key",
340            "device_id": "device_id",
341            "session_id": "session_id",
342            "m.relates_to": {
343                "m.in_reply_to": {
344                    "event_id": "$h29iv0s8:example.com"
345                }
346            },
347        });
348
349        let content: RoomEncryptedEventContent = from_json_value(json_data).unwrap();
350
351        assert_matches!(content.scheme, EncryptedEventScheme::MegolmV1AesSha2(scheme));
352        assert_eq!(scheme.ciphertext, "ciphertext");
353        assert_eq!(scheme.sender_key.as_deref(), Some("sender_key"));
354        assert_eq!(scheme.device_id.as_deref(), Some(device_id!("device_id")));
355        assert_eq!(scheme.session_id, "session_id");
356
357        assert_matches!(content.relates_to, Some(Relation::Reply { in_reply_to }));
358        assert_eq!(in_reply_to.event_id, "$h29iv0s8:example.com");
359    }
360
361    #[test]
362    fn deserialization_olm() {
363        let json_data = json!({
364            "sender_key": "test_key",
365            "ciphertext": {
366                "test_curve_key": {
367                    "body": "encrypted_body",
368                    "type": 1
369                }
370            },
371            "algorithm": "m.olm.v1.curve25519-aes-sha2"
372        });
373        let content: RoomEncryptedEventContent = from_json_value(json_data).unwrap();
374
375        assert_matches!(content.scheme, EncryptedEventScheme::OlmV1Curve25519AesSha2(c));
376        assert_eq!(c.sender_key, "test_key");
377        assert_eq!(c.ciphertext.len(), 1);
378        assert_eq!(c.ciphertext["test_curve_key"].body, "encrypted_body");
379        assert_eq!(c.ciphertext["test_curve_key"].message_type, uint!(1));
380
381        assert_matches!(content.relates_to, None);
382    }
383
384    #[test]
385    fn deserialization_failure() {
386        from_json_value::<Raw<RoomEncryptedEventContent>>(
387            json!({ "algorithm": "m.megolm.v1.aes-sha2" }),
388        )
389        .unwrap()
390        .deserialize()
391        .unwrap_err();
392    }
393}
ruma_events/room/encrypted.rs

ruma_events/room/
encrypted.rs
