ruma_events/room/
encrypted.rs

1//! Types for the [`m.room.encrypted`] event.
2//!
3//! [`m.room.encrypted`]: https://spec.matrix.org/v1.19/client-server-api/#mroomencrypted
4
5use std::{borrow::Cow, collections::BTreeMap};
6
7use js_int::UInt;
8use ruma_common::{OwnedDeviceId, OwnedEventId, serde::JsonObject};
9use ruma_macros::EventContent;
10use serde::{Deserialize, Serialize};
11
12use super::message;
13use crate::{
14    relation::{Annotation, CustomRelation, InReplyTo, Reference, RelationType, Reply, Thread},
15    room::message::RelationWithoutReplacement,
16};
17
18mod relation_serde;
19#[cfg(feature = "unstable-msc4362")]
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, Serialize)]
90#[allow(clippy::manual_non_exhaustive)]
91#[cfg_attr(not(ruma_unstable_exhaustive_types), non_exhaustive)]
92#[serde(untagged)]
93pub enum Relation {
94    /// A reply to another event.
95    Reply(Reply),
96
97    /// An event that replaces another event.
98    Replacement(Replacement),
99
100    /// A reference to another event.
101    Reference(Reference),
102
103    /// An annotation to an event.
104    Annotation(Annotation),
105
106    /// An event that belongs to a thread.
107    Thread(Thread),
108
109    #[doc(hidden)]
110    _Custom(CustomRelation),
111}
112
113impl Relation {
114    /// The type of this `Relation`.
115    ///
116    /// Returns an `Option` because the `Reply` relation does not have a `rel_type` field.
117    pub fn rel_type(&self) -> Option<RelationType> {
118        match self {
119            Relation::Reply(_) => None,
120            Relation::Replacement(_) => Some(RelationType::Replacement),
121            Relation::Reference(_) => Some(RelationType::Reference),
122            Relation::Annotation(_) => Some(RelationType::Annotation),
123            Relation::Thread(_) => Some(RelationType::Thread),
124            Relation::_Custom(c) => c.rel_type(),
125        }
126    }
127
128    /// The associated data.
129    ///
130    /// The returned JSON object holds the contents of `m.relates_to`, including `rel_type` and
131    /// `event_id` if present, but not things like `m.new_content` for `m.replace` relations that
132    /// live next to `m.relates_to`.
133    ///
134    /// Prefer to use the public variants of `Relation` where possible; this method is meant to
135    /// be used for custom relations only.
136    pub fn data(&self) -> Cow<'_, JsonObject> {
137        if let Relation::_Custom(CustomRelation(data)) = self {
138            Cow::Borrowed(data)
139        } else {
140            Cow::Owned(self.serialize_data())
141        }
142    }
143}
144
145impl<C> From<message::Relation<C>> for Relation {
146    fn from(rel: message::Relation<C>) -> Self {
147        match rel {
148            message::Relation::Reply(r) => Self::Reply(r),
149            message::Relation::Replacement(re) => {
150                Self::Replacement(Replacement { event_id: re.event_id })
151            }
152            message::Relation::Thread(t) => Self::Thread(Thread {
153                event_id: t.event_id,
154                in_reply_to: t.in_reply_to,
155                is_falling_back: t.is_falling_back,
156            }),
157            message::Relation::_Custom(c) => Self::_Custom(c),
158        }
159    }
160}
161
162impl From<RelationWithoutReplacement> for Relation {
163    fn from(value: RelationWithoutReplacement) -> Self {
164        match value {
165            RelationWithoutReplacement::Reply(r) => Self::Reply(r),
166            RelationWithoutReplacement::Thread(t) => Self::Thread(t),
167            RelationWithoutReplacement::_Custom(c) => Self::_Custom(c),
168        }
169    }
170}
171
172/// The event this relation belongs to [replaces another event].
173///
174/// In contrast to [`relation::Replacement`](crate::relation::Replacement), this
175/// struct doesn't store the new content, since that is part of the encrypted content of an
176/// `m.room.encrypted` events.
177///
178/// [replaces another event]: https://spec.matrix.org/v1.19/client-server-api/#event-replacements
179#[derive(Clone, Debug, Deserialize, Serialize)]
180#[cfg_attr(not(ruma_unstable_exhaustive_types), non_exhaustive)]
181#[serde(tag = "rel_type", rename = "m.replace")]
182pub struct Replacement {
183    /// The ID of the event being replaced.
184    pub event_id: OwnedEventId,
185}
186
187impl Replacement {
188    /// Creates a new `Replacement` with the given event ID.
189    pub fn new(event_id: OwnedEventId) -> Self {
190        Self { event_id }
191    }
192}
193
194/// The content of an `m.room.encrypted` event using the `m.olm.v1.curve25519-aes-sha2` algorithm.
195#[derive(Clone, Debug, Serialize, Deserialize)]
196#[cfg_attr(not(ruma_unstable_exhaustive_types), non_exhaustive)]
197pub struct OlmV1Curve25519AesSha2Content {
198    /// A map from the recipient Curve25519 identity key to ciphertext information.
199    pub ciphertext: BTreeMap<String, CiphertextInfo>,
200
201    /// The Curve25519 key of the sender.
202    pub sender_key: String,
203}
204
205impl OlmV1Curve25519AesSha2Content {
206    /// Creates a new `OlmV1Curve25519AesSha2Content` with the given ciphertext and sender key.
207    pub fn new(ciphertext: BTreeMap<String, CiphertextInfo>, sender_key: String) -> Self {
208        Self { ciphertext, sender_key }
209    }
210}
211
212/// Ciphertext information holding the ciphertext and message type.
213///
214/// Used for messages encrypted with the `m.olm.v1.curve25519-aes-sha2` algorithm.
215#[derive(Clone, Debug, Deserialize, Serialize)]
216#[cfg_attr(not(ruma_unstable_exhaustive_types), non_exhaustive)]
217pub struct CiphertextInfo {
218    /// The encrypted payload.
219    pub body: String,
220
221    /// The Olm message type.
222    #[serde(rename = "type")]
223    pub message_type: UInt,
224}
225
226impl CiphertextInfo {
227    /// Creates a new `CiphertextInfo` with the given body and type.
228    pub fn new(body: String, message_type: UInt) -> Self {
229        Self { body, message_type }
230    }
231}
232
233/// The content of an `m.room.encrypted` event using the `m.megolm.v1.aes-sha2` algorithm.
234///
235/// To create an instance of this type, first create a `MegolmV1AesSha2ContentInit` and convert it
236/// via `MegolmV1AesSha2Content::from` / `.into()`.
237#[derive(Clone, Debug, Serialize, Deserialize)]
238#[cfg_attr(not(ruma_unstable_exhaustive_types), non_exhaustive)]
239pub struct MegolmV1AesSha2Content {
240    /// The encrypted content of the event.
241    pub ciphertext: String,
242
243    /// The Curve25519 key of the sender.
244    #[deprecated = "Since Matrix 1.3, this field should still be sent but should not be used when received"]
245    #[serde(skip_serializing_if = "Option::is_none")]
246    pub sender_key: Option<String>,
247
248    /// The ID of the sending device.
249    #[deprecated = "Since Matrix 1.3, this field should still be sent but should not be used when received"]
250    #[serde(skip_serializing_if = "Option::is_none")]
251    pub device_id: Option<OwnedDeviceId>,
252
253    /// The ID of the session used to encrypt the message.
254    pub session_id: String,
255}
256
257/// Mandatory initial set of fields of `MegolmV1AesSha2Content`.
258///
259/// This struct will not be updated even if additional fields are added to `MegolmV1AesSha2Content`
260/// in a new (non-breaking) release of the Matrix specification.
261#[derive(Debug)]
262#[allow(clippy::exhaustive_structs)]
263pub struct MegolmV1AesSha2ContentInit {
264    /// The encrypted content of the event.
265    pub ciphertext: String,
266
267    /// The Curve25519 key of the sender.
268    pub sender_key: String,
269
270    /// The ID of the sending device.
271    pub device_id: OwnedDeviceId,
272
273    /// The ID of the session used to encrypt the message.
274    pub session_id: String,
275}
276
277impl From<MegolmV1AesSha2ContentInit> for MegolmV1AesSha2Content {
278    /// Creates a new `MegolmV1AesSha2Content` from the given init struct.
279    fn from(init: MegolmV1AesSha2ContentInit) -> Self {
280        let MegolmV1AesSha2ContentInit { ciphertext, sender_key, device_id, session_id } = init;
281        #[allow(deprecated)]
282        Self { ciphertext, sender_key: Some(sender_key), device_id: Some(device_id), session_id }
283    }
284}
285
286#[cfg(test)]
287mod tests {
288    use assert_matches::assert_matches;
289    use js_int::uint;
290    use ruma_common::{canonical_json::assert_to_canonical_json_eq, owned_event_id, serde::Raw};
291    use serde_json::{from_value as from_json_value, json};
292    use strass::{assert_let, assert_variant_eq};
293
294    use super::{
295        EncryptedEventScheme, MegolmV1AesSha2ContentInit, Relation, Reply,
296        RoomEncryptedEventContent,
297    };
298
299    #[test]
300    fn serialization() {
301        let key_verification_start_content = RoomEncryptedEventContent {
302            scheme: EncryptedEventScheme::MegolmV1AesSha2(
303                MegolmV1AesSha2ContentInit {
304                    ciphertext: "ciphertext".into(),
305                    sender_key: "sender_key".into(),
306                    device_id: "device_id".into(),
307                    session_id: "session_id".into(),
308                }
309                .into(),
310            ),
311            relates_to: Some(Relation::Reply(Reply::with_event_id(owned_event_id!(
312                "$h29iv0s8:example.com"
313            )))),
314        };
315
316        assert_to_canonical_json_eq!(
317            key_verification_start_content,
318            json!({
319                "algorithm": "m.megolm.v1.aes-sha2",
320                "ciphertext": "ciphertext",
321                "sender_key": "sender_key",
322                "device_id": "device_id",
323                "session_id": "session_id",
324                "m.relates_to": {
325                    "m.in_reply_to": {
326                        "event_id": "$h29iv0s8:example.com"
327                    }
328                },
329            }),
330        );
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_let!(EncryptedEventScheme::MegolmV1AesSha2(scheme) = content.scheme);
352        assert_eq!(scheme.ciphertext, "ciphertext");
353        assert_eq!(scheme.sender_key.as_deref(), Some("sender_key"));
354        assert_variant_eq!(scheme.device_id, Some("device_id"));
355        assert_eq!(scheme.session_id, "session_id");
356
357        assert_let!(Some(Relation::Reply(reply)) = content.relates_to);
358        assert_eq!(reply.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_let!(EncryptedEventScheme::OlmV1Curve25519AesSha2(c) = content.scheme);
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
