#cqrs #pattern #command #query #adapter #context #bus

kti_cqrs_rs

Implementation of CQRS pattern in Rust

3 releases (breaking)

0.2.0 Mar 16, 2024
0.1.0 Mar 3, 2024
0.0.1 Nov 4, 2023

#33 in #bus

Download history 86/week @ 2024-07-05 28/week @ 2024-07-12 25/week @ 2024-07-19 38/week @ 2024-07-26 75/week @ 2024-08-02 9/week @ 2024-08-09 3/week @ 2024-08-16 33/week @ 2024-08-23 57/week @ 2024-08-30 25/week @ 2024-09-06 46/week @ 2024-09-13 40/week @ 2024-09-20 16/week @ 2024-09-27 8/week @ 2024-10-04 29/week @ 2024-10-11 28/week @ 2024-10-18

92 downloads per month
Used in kti_cqrs_provider_rs

MIT/Apache

5KB
62 lines

Implementation of CQRS pattern in Rust

Currently the crate contains only query & command handlers

Simple example (existed in repo)

#[cfg(test)]
mod tests {
  use std::sync::Arc;

  use kti_cqrs_rs::core::bus::{command_bus::CommandBus, query_bus::QueryBus};
  use tokio::sync::Mutex;

  use super::{
    adapters::{
      mutex_repository_adapter::MutexRepositoryAdapter, mutex_service_adapter::MutexServiceAdapter,
    },
    contexts::mutex_context::MutexContext,
    ports::mutex_service_port::MutexServicePort,
  };

  fn create_service() -> Box<dyn MutexServicePort> {
    let store = Arc::new(Mutex::new(vec![]));

    let query_repository = Box::new(MutexRepositoryAdapter::new(store.clone()));
    let command_repository = Box::new(MutexRepositoryAdapter::new(store));

    Box::new(MutexServiceAdapter::new(
      Arc::new(Mutex::new(MutexContext::new(
        query_repository,
        command_repository,
      ))),
      CommandBus,
      QueryBus,
    ))
  }

  #[tokio::test]
  async fn should_be_empty_vector() {
    let service = create_service();

    let count = service.get_count().await.unwrap();

    assert_eq!(count, 0);
  }

  #[tokio::test]
  async fn should_be_one_element() {
    let service = create_service();

    service.add_element(1).await.unwrap();

    let count = service.get_count().await.unwrap();

    assert_eq!(count, 1);
  }

  #[tokio::test]
  async fn should_be_empty_after_remove() {
    let service = create_service();

    service.add_element(1).await.unwrap();
    service.remove_element(1).await.unwrap();

    let count = service.get_count().await.unwrap();

    assert_eq!(count, 0);
  }

  #[tokio::test]
  async fn should_be_error_on_remove_not_existed_element() {
    let service = create_service();

    let res = service.remove_element(1).await;

    assert!(res.is_err());
  }
}

Dependencies

~2.7–8.5MB
~75K SLoC