continuwuity/src/core/pdu/builder.rs

use std::{collections::BTreeMap, sync::Arc};

use ruma::{
	events::{EventContent, MessageLikeEventType, StateEventType, TimelineEventType},
	EventId, MilliSecondsSinceUnixEpoch,
};
use serde::Deserialize;
use serde_json::value::{to_raw_value, RawValue as RawJsonValue};

/// Build the start of a PDU in order to add it to the Database.
#[derive(Debug, Deserialize)]
pub struct Builder {
	#[serde(rename = "type")]
	pub event_type: TimelineEventType,

	pub content: Box<RawJsonValue>,

	pub unsigned: Option<Unsigned>,

	pub state_key: Option<String>,

	pub redacts: Option<Arc<EventId>>,

	/// For timestamped messaging, should only be used for appservices.
	/// Will be set to current time if None
	pub timestamp: Option<MilliSecondsSinceUnixEpoch>,
}

type Unsigned = BTreeMap<String, serde_json::Value>;

impl Builder {
	pub fn state<T>(state_key: String, content: &T) -> Self
	where
		T: EventContent<EventType = StateEventType>,
	{
		Self {
			event_type: content.event_type().into(),
			content: to_raw_value(content).expect("Builder failed to serialize state event content to RawValue"),
			state_key: Some(state_key),
			..Self::default()
		}
	}

	pub fn timeline<T>(content: &T) -> Self
	where
		T: EventContent<EventType = MessageLikeEventType>,
	{
		Self {
			event_type: content.event_type().into(),
			content: to_raw_value(content).expect("Builder failed to serialize timeline event content to RawValue"),
			..Self::default()
		}
	}
}

impl Default for Builder {
	fn default() -> Self {
		Self {
			event_type: "m.room.message".into(),
			content: Box::<RawJsonValue>::default(),
			unsigned: None,
			state_key: None,
			redacts: None,
			timestamp: None,
		}
	}
}