feat(matrix/space): implemented space.board events

Cargo.toml

@@ -9,6 +9,7 @@ default-members = ["crates/server"]
 resolver = "1"
 
 [workspace.dependencies]
+assert_matches2 = "0.1.2"
 anyhow = "1.0.75"
 axum = { version = "0.7.4", features = ["tokio"] }
 dotenv = "0.15.0"

crates/core/Cargo.toml

@@ -14,15 +14,18 @@ lettre = "0.11"
 rand = "0.8.5"
 redis = { version = "0.24.0", features = ["aio", "tokio-comp"] }
 thiserror = "1.0.50"
+tokio-postgres = { version = "0.7.10", features = ["with-serde_json-1"] }
 validator = { version = "0.16", features = ["derive"] }
 
 # Workspace
 http = { workspace = true }
+reqwest = { workspace = true }
 serde = { workspace = true, features = ["derive"] }
 serde_json = { workspace = true }
 tracing = { workspace = true }
 uuid = { workspace = true, features= ["serde"] }
 url = { workspace = true, features = ["serde"] }
+tokio = { workspace = true, features = ["full"] }
 
 # Local Dependencies
 matrix = { path = "../matrix" }

crates/core/src/error.rs

@@ -3,6 +3,7 @@ use thiserror::Error;
 
 use crate::account::error::AccountErrorCode;
 use crate::auth::error::AuthErrorCode;
+use crate::events::error::BoardErrorCode;
 use crate::mail::error::MailErrorCode;
 use crate::room::error::RoomErrorCode;
 
@@ -23,6 +24,8 @@ pub enum Error {
     Room(RoomErrorCode),
     #[error("{0}")]
     Mail(#[from] MailErrorCode),
+    #[error("{0}")]
+    Board(BoardErrorCode),
     #[error("An error occured while starting up. {0}")]
     Startup(String),
     #[error("Unknown Error Occured")]
@@ -35,13 +38,20 @@ impl From<AccountErrorCode> for Error {
     }
 }
 
+impl From<BoardErrorCode> for Error {
+    fn from(err: BoardErrorCode) -> Self {
+        Error::Board(err)
+    }
+}
+
 impl HttpStatusCode for Error {
     fn status_code(&self) -> StatusCode {
         match self {
             Error::Auth(err) => err.status_code(),
             Error::User(err) => err.status_code(),
             Error::Mail(err) => err.status_code(),
             Error::Room(err) => err.status_code(),
+            Error::Board(err) => err.status_code(),
             Error::Startup(_) | Error::Unknown => StatusCode::INTERNAL_SERVER_ERROR,
         }
     }
@@ -52,6 +62,7 @@ impl HttpStatusCode for Error {
             Error::User(err) => err.error_code(),
             Error::Mail(err) => err.error_code(),
             Error::Room(err) => err.error_code(),
+            Error::Board(err) => err.error_code(),
             Error::Startup(_) => "SERVER_STARTUP_ERROR",
             Error::Unknown => "UNKNOWN_ERROR",
         }

crates/core/src/events/error.rs

@@ -0,0 +1,41 @@
+use http::StatusCode;
+use matrix::events::{exports::ruma_common::OwnedRoomId, relation::RelationType};
+use thiserror::Error;
+
+use crate::error::HttpStatusCode;
+
+#[derive(Debug, Error)]
+pub enum BoardErrorCode {
+    #[error("Failed to parse BoardId")]
+    MalformedBoardId,
+    #[error("Failed to parse the EventId")]
+    MalformedEventId,
+    #[error("Failed to parse content body")]
+    MalformedContent(#[from] serde_json::Error),
+    #[error("You are not a member of the board")]
+    NoMembership(OwnedRoomId),
+    #[error("You provided an empty or incorrect relation")]
+    WrongRelation(Option<RelationType>),
+}
+
+impl HttpStatusCode for BoardErrorCode {
+    fn status_code(&self) -> StatusCode {
+        match self {
+            BoardErrorCode::WrongRelation(_)
+            | BoardErrorCode::MalformedBoardId
+            | BoardErrorCode::MalformedEventId
+            | BoardErrorCode::MalformedContent(_) => StatusCode::BAD_REQUEST,
+            BoardErrorCode::NoMembership(_) => StatusCode::FORBIDDEN,
+        }
+    }
+
+    fn error_code(&self) -> &'static str {
+        match self {
+            BoardErrorCode::WrongRelation(_)
+            | BoardErrorCode::MalformedBoardId
+            | BoardErrorCode::MalformedEventId
+            | BoardErrorCode::MalformedContent(_) => "BAD_REQUEST",
+            BoardErrorCode::NoMembership(_) => "FORBIDDEN",
+        }
+    }
+}

crates/core/src/events/mod.rs

@@ -0,0 +1,6 @@
+pub mod error;
+pub mod service;
+
+pub use matrix::events::{
+    space, Raw, AnyMessageLikeEvent, StateEventContent,
+};