162 move the repository module of the mediator coordination crate to a separate crate

crates/database/src/lib.rs

@@ -5,7 +5,7 @@ use thiserror::Error;
 use mongodb::error::Error as MongoError;
 /// A trait representing an abstract resource.
 /// Any type implementing this trait should also implement `Serialize`.
-pub trait Entity: Sized + Serialize {}
+pub trait Entity: Sized + Serialize {} 
 
 /// Definition of custom errors for repository operations
 #[derive(Debug, Serialize, Deserialize, Error)]

crates/plugins/mediator-coordination/src/plugin.rs

@@ -5,7 +5,7 @@ use mongodb::{ options::ClientOptions, Client, Database};
 use std::sync::Arc;
 
 use crate::{
-    repository::stateful::{MongoConnectionRepository, MongoSecretsRepository},
+    repository::stateful::{MongoConnectionRepository, MongoMessagesRepository, MongoSecretsRepository},
     util,
     web::{self, AppState, AppStateRepository},
 };

crates/plugins/mediator-coordination/src/repository/stateful.rs

@@ -6,7 +6,7 @@ use mongodb::{
 };
 
 use crate::{
-    model::stateful::entity::{Connection, Secrets},
+    model::stateful::entity::{Connection, RoutedMessage, Secrets},
 };
 
 impl Entity for Connection {}

crates/plugins/mediator-coordination/src/web/handler.rs

@@ -87,7 +87,9 @@ pub mod tests {
 
     use crate::{
         didcomm::bridge::LocalSecretsResolver,
-        repository::stateful::tests::{MockConnectionRepository, MockSecretsRepository},
+        repository::stateful::tests::{ 
+            MockConnectionRepository, MockMessagesRepository, MockSecretsRepository,
+        },
         util::{self, MockFileSystem},
         web::{self, AppStateRepository},
     };
@@ -102,7 +104,7 @@ pub mod tests {
         let repository = AppStateRepository {
             connection_repository: Arc::new(MockConnectionRepository::from(vec![])),
             secret_repository: Arc::new(MockSecretsRepository::from(vec![])),
-            message_repository: Arc::new(MockMessagesRepository::from(vec![])),
+            message_repository: Arc::new(MockMessagesRepository::from(vec![])), // Merged from origin
         };
 
         let state = Arc::new(AppState::from(
@@ -191,6 +193,7 @@ pub mod tests {
     }
 }
 
+
 #[cfg(test)]
 mod tests2 {
     use super::{tests as global, *};

crates/plugins/mediator-coordination/src/web/mod.rs

@@ -11,8 +11,7 @@
 
 use crate::{
     didcomm::bridge::{LocalDIDResolver, LocalSecretsResolver},
-    model::stateful::entity::Connection,
-    model::stateful::entity::Secrets,
+    model::stateful::entity::{Connection, RoutedMessage, Secrets},
     util,
 };
 
@@ -49,7 +48,7 @@
 pub struct AppStateRepository {
     pub connection_repository: Arc<dyn Repository<Connection>>,
     pub secret_repository: Arc<dyn Repository<Secrets>>,
     pub message_repository: Arc<dyn Repository<RoutedMessage>>,
 }
 
 impl AppState {