feat: db port to check for duplicate order IDs

This commit is contained in:
Aravinth Manivannan 2024-07-23 19:18:58 +05:30
parent de81f09af8
commit 95dcf0bae1
Signed by: realaravinth
GPG key ID: F8F50389936984FF
4 changed files with 150 additions and 0 deletions

View file

@ -0,0 +1,89 @@
// SPDX-FileCopyrightText: 2024 Aravinth Manivannan <realaravinth@batsense.net>
//
// SPDX-License-Identifier: AGPL-3.0-or-later
use uuid::Uuid;
use super::OrderingDBPostgresAdapter;
use crate::ordering::application::port::output::db::{errors::*, order_id_exists::*};
#[async_trait::async_trait]
impl OrderIDExistsDBPort for OrderingDBPostgresAdapter {
async fn order_id_exists(&self, order_id: &Uuid) -> OrderingDBResult<bool> {
let res = sqlx::query!(
"SELECT EXISTS (
SELECT 1
FROM cqrs_ordering_order_query
WHERE
order_id = $1
);",
order_id
)
.fetch_one(&self.pool)
.await?;
if let Some(x) = res.exists {
Ok(x)
} else {
Ok(false)
}
}
}
#[cfg(test)]
pub mod tests {
use super::*;
// use crate::ordering::domain::add_order_command::tests::get_customizations;
use crate::ordering::domain::order_aggregate::*;
async fn create_dummy_order(order: &Order, db: &OrderingDBPostgresAdapter) {
sqlx::query!(
"INSERT INTO cqrs_ordering_order_query (
version,
order_id,
customer_name,
created_time,
deleted
) VALUES (
$1, $2, $3, $4, $5
);",
1,
order.order_id(),
order.customer_name(),
order.created_time(),
order.deleted().clone(),
)
.execute(&db.pool)
.await
.unwrap();
}
#[actix_rt::test]
async fn test_postgres_order_exists() {
let settings = crate::settings::tests::get_settings().await;
settings.create_db().await;
let db = super::OrderingDBPostgresAdapter::new(
sqlx::postgres::PgPool::connect(&settings.database.url)
.await
.unwrap(),
);
let order = Order::default();
// state doesn't exist
assert!(!db
.order_id_exists(order.order_id())
.await
.unwrap());
create_dummy_order(&order, &db).await;
// state exists
assert!(db
.order_id_exists(order.order_id())
.await
.unwrap());
settings.drop_db().await;
}
}

View file

@ -12,4 +12,7 @@ pub enum OrderingDBError {
DuplicateLineItemID, DuplicateLineItemID,
LineItemIDNotFound, LineItemIDNotFound,
InternalError, InternalError,
DuplicateOrderID,
OrderIDNotFound,
} }

View file

@ -4,3 +4,4 @@
pub mod errors; pub mod errors;
pub mod line_item_id_exists; pub mod line_item_id_exists;
pub mod order_id_exists;

View file

@ -0,0 +1,57 @@
// SPDX-FileCopyrightText: 2024 Aravinth Manivannan <realaravinth@batsense.net>
//
// SPDX-License-Identifier: AGPL-3.0-or-later
use mockall::predicate::*;
use mockall::*;
use uuid::Uuid;
use super::errors::*;
#[cfg(test)]
#[allow(unused_imports)]
pub use tests::*;
#[automock]
#[async_trait::async_trait]
pub trait OrderIDExistsDBPort: Send + Sync {
async fn order_id_exists(&self, order_id: &Uuid) -> OrderingDBResult<bool>;
}
pub type OrderIDExistsDBPortObj = std::sync::Arc<dyn OrderIDExistsDBPort>;
#[cfg(test)]
pub mod tests {
use super::*;
use std::sync::Arc;
pub fn mock_order_id_exists_db_port_false(
times: Option<usize>,
) -> OrderIDExistsDBPortObj {
let mut m = MockOrderIDExistsDBPort::new();
if let Some(times) = times {
m.expect_order_id_exists()
.times(times)
.returning(|_| Ok(false));
} else {
m.expect_order_id_exists().returning(|_| Ok(false));
}
Arc::new(m)
}
pub fn mock_order_id_exists_db_port_true(
times: Option<usize>,
) -> OrderIDExistsDBPortObj {
let mut m = MockOrderIDExistsDBPort::new();
if let Some(times) = times {
m.expect_order_id_exists()
.times(times)
.returning(|_| Ok(true));
} else {
m.expect_order_id_exists().returning(|_| Ok(true));
}
Arc::new(m)
}
}