feat: event handlers for client API

Cargo.toml

@@ -11,15 +11,17 @@ resolver = "1"
 [workspace.dependencies]
 anyhow = "1.0.75"
 axum = { version = "0.7.4", features = ["tokio"] }
+chrono = { version = "0.4.34", features = ["serde"] }
 dotenv = "0.15.0"
 http = "0.2.11"
-reqwest = { version = "0.11.22", default-features = false, features = ["blocking", "json", "rustls", "stream", "multipart"] }
+mime = "0.3.17"
 openssl = { version = "0.10.63", features = ["vendored"] }
 openssl-sys = { version = "0.9.99", features = ["vendored"] }
+reqwest = { version = "0.11.22", default-features = false, features = ["blocking", "json", "rustls", "multipart"] }
 serde = "1.0.192"
 serde_json = "1.0.108"
 tokio = "1.34.0"
 tracing = "0.1.40"
-tracing-subscriber = "0.3.18"
+tracing-subscriber = { version = "0.3.18", features = ["json"] }
 uuid = { version = "1.6.1", features = ["v4"] }
 url = "2.4.1"

crates/core/src/account/model.rs

@@ -1,10 +1,10 @@
 use url::Url;
 
-use matrix::admin::resources::user_id::UserId;
+use matrix::ruma_common::OwnedUserId;
 
 #[derive(Debug, Clone)]
 pub struct Account {
-    pub user_id: UserId,
+    pub user_id: OwnedUserId,
     pub username: String,
     pub email: String,
     pub display_name: String,

crates/core/src/account/service.rs

@@ -1,16 +1,15 @@
 use std::sync::Arc;
 
-use matrix::{admin::resources::user::UserService, client::resources::session::Session};
+use matrix::{
+    admin::resources::user::UserService, client::resources::session::Session, ruma_common::UserId,
+};
 use tracing::instrument;
 use url::Url;
 use uuid::Uuid;
 use validator::{Validate, ValidationError};
 
 use matrix::{
-    admin::resources::{
-        user::{CreateUserBody, ListUsersQuery, LoginAsUserBody, ThreePid},
-        user_id::UserId,
-    },
+    admin::resources::user::{CreateUserBody, ListUsersQuery, LoginAsUserBody, ThreePid},
     Client as MatrixAdminClient,
 };
 
@@ -117,7 +116,13 @@ impl AccountService {
     /// Returs `true` if the given `email address` is NOT registered in the
     /// Matrix Server
     pub async fn is_email_available(&self, email: &str) -> Result<bool> {
-        let user_id = UserId::new(email, self.admin.server_name());
+        let user_id = format!("@{}:{}", email, self.admin.server_name());
+        let user_id = <&UserId>::try_from(user_id.as_str()).map_err(|err| {
+            // TODO
+            tracing::error!(?err, "Failed to parse username");
+            Error::Unknown
+        })?;
+
         let exists = UserService::list(
             &self.admin,
             ListUsersQuery {
@@ -206,15 +211,21 @@ impl AccountService {
             return Err(AccountErrorCode::EmailTaken(dto.email).into());
         }
 
-        let user_id = UserId::new(dto.username.clone(), self.admin.server_name().to_string());
+        let user_id = format!("@{}:{}", dto.username, self.admin.server_name());
+        let user_id = <&UserId>::try_from(user_id.as_str()).map_err(|err| {
+            // TODO
+            tracing::error!(?err, "Failed to parse username");
+            Error::Unknown
+        })?;
+
         let avatar_url = Url::parse(DEFAULT_AVATAR_URL).map_err(|err| {
             tracing::error!(?err, "Failed to parse default avatar url");
             Error::Unknown
         })?;
 
         UserService::create(
             &self.admin,
-            user_id.clone(),
+            user_id,
             CreateUserBody {
                 displayname: Some(dto.username),
                 password: dto.password.to_string(),
@@ -239,14 +250,14 @@ impl AccountService {
             Error::Unknown
         })?;
 
-        let matrix_account = UserService::query_user_account(&self.admin, user_id.clone())
+        let matrix_account = UserService::query_user_account(&self.admin, user_id)
             .await
             .map_err(|err| {
                 tracing::error!(?err, "Failed to query user account");
                 Error::Unknown
             })?;
         let account = Account {
-            user_id,
+            user_id: user_id.into(),
             username: matrix_account.name,
             email: matrix_account
                 .threepids
@@ -264,9 +275,9 @@ impl AccountService {
     }
 
     /// Creates an access token for the given user
-    pub async fn issue_user_token(&self, user_id: UserId) -> Result<String> {
+    pub async fn issue_user_token(&self, user_id: &UserId) -> Result<String> {
         let credentials =
-            UserService::login_as_user(&self.admin, user_id.clone(), LoginAsUserBody::default())
+            UserService::login_as_user(&self.admin, user_id, LoginAsUserBody::default())
                 .await
                 .map_err(|err| {
                     tracing::error!(?err, ?user_id, "Failed to login as user");
@@ -283,7 +294,7 @@ impl AccountService {
                 tracing::error!(?err, "Failed to get session from matrix as client");
                 Error::Unknown
             })?;
-        let matrix_account = UserService::query_user_account(&self.admin, session.user_id.clone())
+        let matrix_account = UserService::query_user_account(&self.admin, &session.user_id)
             .await
             .map_err(|err| {
                 tracing::error!(?err, "Failed to query user account");

crates/core/src/room/service.rs

@@ -4,7 +4,7 @@ use tracing::instrument;
 
 use matrix::{
     client::resources::room::{
-        CreateRoomBody, Room as MatrixRoom, RoomCreationContent, RoomPreset,
+        CreateRoomBody, RoomCreationContent, RoomPreset, RoomService as MatrixRoomService,
     },
     Client as MatrixAdminClient,
 };
@@ -36,7 +36,7 @@ impl RoomService {
         access_token: &Secret,
         dto: CreateRoomDto,
     ) -> Result<Room> {
-        match MatrixRoom::create(
+        match MatrixRoomService::create(
             &self.admin,
             access_token.to_string(),
             CreateRoomBody {

crates/matrix/Cargo.toml

@@ -17,7 +17,10 @@ ruma-macros = "0.12.0"
 
 # Workspace Dependencies
 anyhow = { workspace = true }
+chrono = { workspace = true, features = ["serde"] }
+mime = { workspace = true }
 reqwest = { workspace = true, features = ["json"] }
 serde = { workspace = true }
+tokio = { workspace = true }
 tracing = { workspace = true }
 url = { workspace = true, features = ["serde"] }

crates/matrix/src/admin/resources/room.rs

@@ -9,7 +9,7 @@ use ruma_events::{AnyMessageLikeEvent, AnyStateEvent, AnyTimelineEvent};
 use serde::{Deserialize, Serialize};
 use tracing::instrument;
 
-use crate::{error::MatrixError, event_filter::RoomEventFilter, http::Client};
+use crate::{error::MatrixError, filter::RoomEventFilter, http::Client};
 
 #[derive(Default)]
 pub struct RoomService;
@@ -444,7 +444,7 @@ impl RoomService {
     }
 }
 
-#[derive(Default, Debug, Serialize)]
+#[derive(Debug, Default, Clone, Serialize)]
 pub enum Direction {
     #[serde(rename = "f")]
     #[default]

crates/matrix/src/admin/resources/user.rs

@@ -4,14 +4,13 @@
 //! for a server admin: see Admin API.
 
 use anyhow::Result;
+use ruma_common::UserId;
 use serde::{Deserialize, Serialize};
 use tracing::instrument;
 use url::Url;
 
 use crate::{error::MatrixError, http::Client};
 
-use super::user_id::UserId;
-
 #[derive(Default)]
 pub struct UserService;
 
@@ -149,7 +148,7 @@ impl UserService {
     ///
     /// Refer: https://matrix-org.github.io/synapse/v1.88/admin_api/user_admin_api.html#query-user-account
     #[instrument(skip(client))]
-    pub async fn query_user_account(client: &Client, user_id: UserId) -> Result<User> {
+    pub async fn query_user_account(client: &Client, user_id: &UserId) -> Result<User> {
         let resp = client
             .get(format!(
                 "/_synapse/admin/v2/users/{user_id}",
@@ -174,7 +173,7 @@ impl UserService {
     ///
     /// Refer: https://matrix-org.github.io/synapse/latest/admin_api/user_admin_api.html#create-or-modify-account
     #[instrument(skip(client, body))]
-    pub async fn create(client: &Client, user_id: UserId, body: CreateUserBody) -> Result<User> {
+    pub async fn create(client: &Client, user_id: &UserId, body: CreateUserBody) -> Result<User> {
         let resp = client
             .put_json(
                 format!("/_synapse/admin/v2/users/{user_id}", user_id = user_id),
@@ -212,7 +211,7 @@ impl UserService {
     ///
     /// Refer: https://matrix-org.github.io/synapse/latest/admin_api/user_admin_api.html#create-or-modify-account
     #[instrument(skip(client))]
-    pub async fn update(client: &Client, user_id: UserId, body: UpdateUserBody) -> Result<User> {
+    pub async fn update(client: &Client, user_id: &UserId, body: UpdateUserBody) -> Result<User> {
         let resp = client
             .put_json(
                 format!("/_synapse/admin/v2/users/{user_id}", user_id = user_id),
@@ -246,7 +245,7 @@ impl UserService {
     #[instrument(skip(client))]
     pub async fn login_as_user(
         client: &Client,
-        user_id: UserId,
+        user_id: &UserId,
         body: LoginAsUserBody,
     ) -> Result<LoginAsUserResponse> {
         let resp = client

crates/matrix/src/client/resources/events.rs

@@ -1,5 +1,5 @@
 use anyhow::Result;
-use ruma_common::{serde::Raw, EventId, OwnedEventId, RoomId, TransactionId};
+use ruma_common::{serde::Raw, EventId, OwnedEventId, OwnedTransactionId, RoomId};
 
 use ruma_events::{
     relation::RelationType, AnyMessageLikeEvent, AnyStateEvent, AnyStateEventContent,
@@ -9,25 +9,39 @@ use ruma_events::{
 use serde::{de::DeserializeOwned, Deserialize, Serialize};
 use tracing::instrument;
 
-use crate::{admin::resources::room::Direction, event_filter::RoomEventFilter, Client};
+use crate::{admin::resources::room::Direction, error::MatrixError, Client};
 
-pub struct Events;
+pub struct EventsService;
 
-#[derive(Debug, Default, Serialize)]
+#[derive(Debug, Default, Clone, Serialize)]
 pub struct GetMessagesQuery {
+    #[serde(skip_serializing_if = "Option::is_none")]
     pub from: Option<String>,
+
+    #[serde(skip_serializing_if = "Option::is_none")]
     pub to: Option<String>,
+
+    #[serde(skip_serializing_if = "Option::is_none")]
     pub limit: Option<u64>,
-    pub dir: Option<Direction>,
-    pub filter: Option<RoomEventFilter>,
+
+    pub dir: Direction,
+
+    #[serde(skip_serializing_if = "String::is_empty")]
+    pub filter: String,
 }
 
-#[derive(Debug, Default, Serialize)]
+#[derive(Debug, Default, Clone, Serialize)]
 pub struct GetRelationsQuery {
+    #[serde(skip_serializing_if = "Option::is_none")]
     pub from: Option<String>,
+
+    #[serde(skip_serializing_if = "Option::is_none")]
     pub to: Option<String>,
+
+    #[serde(skip_serializing_if = "Option::is_none")]
     pub limit: Option<u64>,
-    pub dir: Option<Direction>,
+
+    pub dir: Direction,
 }
 
 #[derive(Debug, Deserialize)]
@@ -40,7 +54,7 @@ pub struct GetMessagesResponse {
 
 #[derive(Debug, Deserialize)]
 #[serde(transparent)]
-pub struct GetStateResponse(Vec<Raw<AnyStateEvent>>);
+pub struct GetStateResponse(pub Vec<Raw<AnyStateEvent>>);
 
 #[derive(Debug, Deserialize)]
 pub struct GetRelationsResponse {
@@ -70,7 +84,7 @@ pub struct SendRedactionResponse {
     pub event_id: OwnedEventId,
 }
 
-impl Events {
+impl EventsService {
     #[instrument(skip(client, access_token))]
     pub async fn get_event(
         client: &Client,
@@ -103,10 +117,13 @@ impl Events {
         tmp.set_token(access_token)?;
 
         let resp = tmp
-            .get(format!(
-                "/_matrix/client/v3/rooms/{room_id}/messages",
-                room_id = room_id,
-            ))
+            .get_query(
+                format!(
+                    "/_matrix/client/v3/rooms/{room_id}/messages",
+                    room_id = room_id,
+                ),
+                &query,
+            )
             .await?;
 
         Ok(resp.json().await?)
@@ -199,7 +216,7 @@ impl Events {
         client: &Client,
         access_token: impl Into<String>,
         room_id: &RoomId,
-        txn_id: &TransactionId,
+        txn_id: OwnedTransactionId,
         body: T,
     ) -> Result<SendMessageResponse> {
         let mut tmp = (*client).clone();
@@ -217,7 +234,13 @@ impl Events {
             )
             .await?;
 
-        Ok(resp.json().await?)
+        if resp.status().is_success() {
+            return Ok(resp.json().await?);
+        }
+
+        let error = resp.json::<MatrixError>().await?;
+
+        Err(anyhow::anyhow!(error.error))
     }
 
     #[instrument(skip(client, access_token, body))]
@@ -243,7 +266,13 @@ impl Events {
 
         let resp = tmp.put_json(path, &body).await?;
 
-        Ok(resp.json().await?)
+        if resp.status().is_success() {
+            return Ok(resp.json().await?);
+        }
+
+        let error = resp.json::<MatrixError>().await?;
+
+        Err(anyhow::anyhow!(error.error))
     }
 
     #[instrument(skip(client, access_token, body))]
@@ -252,7 +281,7 @@ impl Events {
         access_token: impl Into<String>,
         room_id: &RoomId,
         event_id: &EventId,
-        txn_id: &TransactionId,
+        txn_id: OwnedTransactionId,
         body: SendRedactionBody,
     ) -> Result<SendRedactionResponse> {
         let mut tmp = (*client).clone();
@@ -270,6 +299,12 @@ impl Events {
             )
             .await?;
 
-        Ok(resp.json().await?)
+        if resp.status().is_success() {
+            return Ok(resp.json().await?);
+        }
+
+        let error = resp.json::<MatrixError>().await?;
+
+        Err(anyhow::anyhow!(error.error))
     }
 }

crates/matrix/src/client/resources/mod.rs

@@ -1,5 +1,6 @@
 pub mod error;
 pub mod events;
 pub mod login;
+pub mod mxc;
 pub mod room;
 pub mod session;