save m.room.encryption events

Author: ricardogarim

packages/federation-sdk/src/index.ts

@@ -163,6 +163,13 @@ export type HomeserverEventSignatures = {
 		last_active_ago?: number;
 		origin?: string;
 	};
+	'homeserver.matrix.encryption': {
+		event_id: EventID;
+		event: PduForType<'m.room.encryption'>;
+		room_id: string;
+		sender: string;
+		origin_server_ts: number;
+	};
 	'homeserver.matrix.encrypted': {
 		event_id: EventID;
 		event: PduForType<'m.room.encrypted'>;

packages/federation-sdk/src/services/staging-area.service.ts

@@ -308,6 +308,15 @@ export class StagingAreaService {
 					},
 				});
 				break;
+			case event.event.type === 'm.room.encryption':
+				this.eventEmitterService.emit('homeserver.matrix.encryption', {
+					event_id: eventId,
+					event: event.event,
+					room_id: roomId,
+					sender: event.event.sender,
+					origin_server_ts: event.event.origin_server_ts,
+				});
+				break;
 			case event.event.type === 'm.room.encrypted':
 				this.eventEmitterService.emit('homeserver.matrix.encrypted', {
 					event_id: eventId,

packages/room/src/types/v3-11.ts

@@ -537,6 +537,13 @@ const EncryptedContentSchema = BaseTimelineContentSchema.extend({
 		.optional(),
 });
 
+export const PduEncryptionEventContentSchema = z.object({
+	algorithm: z
+		.enum(['m.megolm.v1.aes-sha2'])
+		.describe('The algorithm used to encrypt the content.'),
+	ciphertext: z.string().describe('The encrypted content.'),
+});
+
 export type PduMessageEventContent = z.infer<
 	typeof PduMessageEventContentSchema
 >;
@@ -706,6 +713,12 @@ const EventPduTypeRoomEncrypted = z.object({
 	content: EncryptedContentSchema,
 });
 
+const EventPduTypeRoomEncryption = z.object({
+	...PduNoContentTimelineEventSchema,
+	type: z.literal('m.room.encryption'),
+	content: PduEncryptionEventContentSchema,
+});
+
 const EventPduTypeRoomMessage = z.object({
 	...PduNoContentTimelineEventSchema,
 	type: z.literal('m.room.message'),
@@ -749,6 +762,8 @@ export const PduStateEventSchema = z.discriminatedUnion('type', [
 	EventPduTypeRoomServerAcl,
 
 	EventPduTypeRoomTombstone,
+
+	EventPduTypeRoomEncryption,
 ]);
 
 export const PduTimelineSchema = z.discriminatedUnion('type', [
@@ -774,6 +789,7 @@ export function isTimelineEventType(type: PduType) {
 	return (
 		type === 'm.room.message' ||
 		type === 'm.room.encrypted' ||
+		type === 'm.room.encryption' ||
 		type === 'm.reaction' ||
 		type === 'm.room.redaction'
 	);