Implementation of the basic message protocol

Cargo.toml

@@ -32,6 +32,7 @@ shared = { path = "./crates/web-plugins/didcomm-messaging/shared", version = "0.
 pickup = { path = "./crates/web-plugins/didcomm-messaging/protocols/pickup", version = "0.1.0" }
 forward = { path = "./crates/web-plugins/didcomm-messaging/protocols/forward", version = "0.1.0" }
 trust-ping = { path = "./crates/web-plugins/didcomm-messaging/protocols/trust-ping", version = "0.1.0" }
+basic-message = { path = "./crates/web-plugins/didcomm-messaging/protocols/basic-message", version = "0.1.0" }
 mediator-coordination = { path = "./crates/web-plugins/didcomm-messaging/protocols/mediator-coordination", version = "0.1.0" }
 
 # Other common dependencies
@@ -92,8 +93,6 @@ hyper.workspace = true
 tokio = { workspace = true, features = ["full"] }
 tracing-subscriber = { workspace = true, features = ["json"] }
 tower-http = { workspace = true, features = ["catch-panic", "trace"] }
-
-# optional dependencies
 chrono = { workspace = true, optional = true }
 did-endpoint = { workspace = true, optional = true }
 oob-messages = { workspace = true, optional = true }

crates/web-plugins/didcomm-messaging/Cargo.toml

@@ -23,6 +23,7 @@ thiserror.workspace = true
 tokio = { workspace = true, features = ["full"] }
 hyper = { workspace = true, features = ["full"] }
 axum = { workspace = true, features = ["macros"] }
+chrono.workspace = true
 
 
 [dev-dependencies]

crates/web-plugins/didcomm-messaging/protocols/basic-message/Cargo.toml

@@ -0,0 +1,24 @@
+[package]
+name = "basic-message"
+version = "0.1.0"
+edition = "2021"
+
+[dependencies]
+shared.workspace = true
+
+serde.workspace = true
+didcomm.workspace = true
+mongodb.workspace = true
+serde_json.workspace = true
+thiserror.workspace = true
+uuid = { workspace = true, features = ["v4"] }
+axum = { workspace = true, features = ["macros"] }
+chrono.workspace = true
+
+[dev-dependencies]
+hyper = "0.14.27"
+shared = { workspace = true, features = ["test-utils"] }
+tokio = { version = "1.27.0", default-features = false, features = [
+    "macros",
+    "rt",
+] }

crates/web-plugins/didcomm-messaging/protocols/basic-message/src/error.rs

@@ -0,0 +1,9 @@
+use thiserror::Error;
+
+#[derive(Error, Debug)]
+pub enum ProtocolError {
+    #[error("Invalid message format")]
+    InvalidMessageFormat,
+    #[error("Encryption or transmission error")]
+    TransmissionError,
+}

crates/web-plugins/didcomm-messaging/protocols/basic-message/src/handler.rs

@@ -0,0 +1,37 @@
+use crate::error::ProtocolError;
+use crate::model::{BasicMessage, MessageBody};
+use chrono::Utc;
+use uuid::Uuid;
+
+///creating a new basic message
+pub fn basic_message(content: &str, lang: Option<String>) -> Result<BasicMessage, ProtocolError> {
+    Ok(BasicMessage {
+        id: Uuid::new_v4().to_string(),
+        message_type: "https://didcomm.org/basicmessage/2.0/message".to_string(),
+        locale: lang,
+        created_time: Utc::now(),
+        body: MessageBody {
+            content: content.to_string(),
+        },
+    })
+}
+
+/// Function to handle the received message
+pub fn handle_received_message(message: &BasicMessage) -> Result<(), ProtocolError> {
+    println!("Received message: {}", message.body.content);
+    Ok(())
+}
+
+#[cfg(test)]
+mod tests {
+    use crate::handler::{basic_message, handle_received_message};
+
+    #[test]
+    fn test_create_and_handle_basic_message() {
+        let message_content = "Hello, this is a basic message.";
+        let message = basic_message(message_content, Some("en".to_string())).unwrap();
+        assert_eq!(message.body.content, message_content);
+
+        handle_received_message(&message).expect("Failed to handle received message");
+    }
+}

crates/web-plugins/didcomm-messaging/protocols/basic-message/src/lib.rs

@@ -0,0 +1,4 @@
+mod error;
+mod model;
+
+pub mod handler;

crates/web-plugins/didcomm-messaging/protocols/basic-message/src/model.rs

@@ -0,0 +1,24 @@
+use chrono::{DateTime, Utc};
+use serde::{Deserialize, Serialize};
+
+#[derive(Debug, Serialize, Deserialize)]
+pub struct BasicMessage {
+    /// Message ID (unique identifier)
+    pub id: String,
+    /// Message type URI for basic messages
+    #[serde(rename = "type")]
+    pub message_type: String,
+    /// Localization information for message language
+    #[serde(rename = "lang")]
+    pub locale: Option<String>,
+    /// Timestamp for when the message was created (DIDComm V2 standard)
+    #[serde(rename = "created_time")]
+    pub created_time: DateTime<Utc>,
+    /// Main message bodsssssssssy
+    pub body: MessageBody,
+}
+
+#[derive(Debug, Serialize, Deserialize)]
+pub struct MessageBody {
+    pub content: String,
+}