fix: inventory: aggregate IDs are provided by the caller #112

Merged
realaravinth merged 9 commits from inventory-fix-aggregate-id into master 2024-09-21 16:45:44 +05:30
5 changed files with 88 additions and 62 deletions
Showing only changes of commit d727d0b5b0 - Show all commits

View file

@ -14,12 +14,11 @@ use crate::inventory::{
category_id_exists::*, category_name_exists_for_store::*, store_id_exists::*, category_id_exists::*, category_name_exists_for_store::*, store_id_exists::*,
}, },
domain::{ domain::{
add_category_command::AddCategoryCommand, add_category_command::*,
category_added_event::{CategoryAddedEvent, CategoryAddedEventBuilder}, category_added_event::{CategoryAddedEvent, CategoryAddedEventBuilder},
category_aggregate::*, category_aggregate::*,
}, },
}; };
use crate::utils::uuid::*;
#[automock] #[automock]
#[async_trait::async_trait] #[async_trait::async_trait]
@ -34,7 +33,6 @@ pub struct AddCategoryService {
db_store_id_exists: StoreIDExistsDBPortObj, db_store_id_exists: StoreIDExistsDBPortObj,
db_category_name_exists_for_store: CategoryNameExistsForStoreDBPortObj, db_category_name_exists_for_store: CategoryNameExistsForStoreDBPortObj,
db_category_id_exists: CategoryIDExistsDBPortObj, db_category_id_exists: CategoryIDExistsDBPortObj,
get_uuid: GetUUIDInterfaceObj,
} }
#[async_trait::async_trait] #[async_trait::async_trait]
@ -48,27 +46,19 @@ impl AddCategoryUseCase for AddCategoryService {
return Err(InventoryError::StoreIDNotFound); return Err(InventoryError::StoreIDNotFound);
} }
let mut category_id = self.get_uuid.get_uuid();
loop {
if self if self
.db_category_id_exists .db_category_id_exists
.category_id_exists(&category_id) .category_id_exists(cmd.category_id())
.await? .await?
{ {
category_id = self.get_uuid.get_uuid(); return Err(InventoryError::DuplicateCategoryID);
continue;
} else {
break;
}
} }
let category = CategoryBuilder::default() let category = CategoryBuilder::default()
.name(cmd.name().into()) .name(cmd.name().into())
.description(cmd.description().as_ref().map(|s| s.to_string())) .description(cmd.description().as_ref().map(|s| s.to_string()))
.store_id(*cmd.store_id()) .store_id(*cmd.store_id())
.category_id(category_id) .category_id(*cmd.category_id())
.build() .build()
.unwrap(); .unwrap();
@ -97,8 +87,8 @@ pub mod tests {
use uuid::Uuid; use uuid::Uuid;
use crate::tests::bdd::*;
use crate::utils::uuid::tests::UUID; use crate::utils::uuid::tests::UUID;
use crate::{tests::bdd::*, utils::uuid::tests::mock_get_uuid};
pub fn mock_add_category_service( pub fn mock_add_category_service(
times: Option<usize>, times: Option<usize>,
@ -111,7 +101,7 @@ pub mod tests {
.description(cmd.description().as_ref().map(|s| s.to_string())) .description(cmd.description().as_ref().map(|s| s.to_string()))
.added_by_user(*cmd.adding_by()) .added_by_user(*cmd.adding_by())
.store_id(*cmd.store_id()) .store_id(*cmd.store_id())
.category_id(UUID) .category_id(*cmd.category_id())
.build() .build()
.unwrap(); .unwrap();
@ -133,8 +123,13 @@ pub mod tests {
let user_id = UUID; let user_id = UUID;
let store_id = Uuid::new_v4(); let store_id = Uuid::new_v4();
// description = None let cmd = AddCategoryCommandBuilder::default()
let cmd = AddCategoryCommand::new(name.into(), Some(description.into()), store_id, user_id) .name(name.into())
.description(Some(description.into()))
.store_id(store_id)
.adding_by(user_id)
.category_id(UUID)
.build()
.unwrap(); .unwrap();
let s = AddCategoryServiceBuilder::default() let s = AddCategoryServiceBuilder::default()
@ -143,7 +138,6 @@ pub mod tests {
IS_CALLED_ONLY_ONCE, IS_CALLED_ONLY_ONCE,
)) ))
.db_category_id_exists(mock_category_id_exists_db_port_false(IS_CALLED_ONLY_ONCE)) .db_category_id_exists(mock_category_id_exists_db_port_false(IS_CALLED_ONLY_ONCE))
.get_uuid(mock_get_uuid(IS_CALLED_ONLY_ONCE))
.build() .build()
.unwrap(); .unwrap();
@ -162,8 +156,13 @@ pub mod tests {
let user_id = UUID; let user_id = UUID;
let store_id = Uuid::new_v4(); let store_id = Uuid::new_v4();
// description = None let cmd = AddCategoryCommandBuilder::default()
let cmd = AddCategoryCommand::new(name.into(), Some(description.into()), store_id, user_id) .name(name.into())
.description(Some(description.into()))
.store_id(store_id)
.adding_by(user_id)
.category_id(UUID)
.build()
.unwrap(); .unwrap();
let s = AddCategoryServiceBuilder::default() let s = AddCategoryServiceBuilder::default()
@ -172,7 +171,6 @@ pub mod tests {
IS_CALLED_ONLY_ONCE, IS_CALLED_ONLY_ONCE,
)) ))
.db_category_id_exists(mock_category_id_exists_db_port_false(IS_CALLED_ONLY_ONCE)) .db_category_id_exists(mock_category_id_exists_db_port_false(IS_CALLED_ONLY_ONCE))
.get_uuid(mock_get_uuid(IS_CALLED_ONLY_ONCE))
.build() .build()
.unwrap(); .unwrap();
@ -189,8 +187,13 @@ pub mod tests {
let user_id = UUID; let user_id = UUID;
let store_id = Uuid::new_v4(); let store_id = Uuid::new_v4();
// description = None let cmd = AddCategoryCommandBuilder::default()
let cmd = AddCategoryCommand::new(name.into(), Some(description.into()), store_id, user_id) .name(name.into())
.description(Some(description.into()))
.store_id(store_id)
.adding_by(user_id)
.category_id(UUID)
.build()
.unwrap(); .unwrap();
let s = AddCategoryServiceBuilder::default() let s = AddCategoryServiceBuilder::default()
@ -199,7 +202,6 @@ pub mod tests {
IS_NEVER_CALLED, IS_NEVER_CALLED,
)) ))
.db_category_id_exists(mock_category_id_exists_db_port_false(IS_NEVER_CALLED)) .db_category_id_exists(mock_category_id_exists_db_port_false(IS_NEVER_CALLED))
.get_uuid(mock_get_uuid(IS_NEVER_CALLED))
.build() .build()
.unwrap(); .unwrap();

View file

@ -20,6 +20,7 @@ pub enum InventoryError {
DuplicateCustomizationName, DuplicateCustomizationName,
DuplicateCustomizationID, DuplicateCustomizationID,
DuplicateStoreID, DuplicateStoreID,
DuplicateCategoryID,
ProductIDNotFound, ProductIDNotFound,
CategoryIDNotFound, CategoryIDNotFound,
CustomizationIDNotFound, CustomizationIDNotFound,
@ -39,10 +40,7 @@ impl From<InventoryDBError> for InventoryError {
error!("DuplicateProductID"); error!("DuplicateProductID");
Self::InternalError Self::InternalError
} }
InventoryDBError::DuplicateCategoryID => { InventoryDBError::DuplicateCategoryID => Self::DuplicateCategoryID,
error!("DuplicateCategoryID");
Self::InternalError
}
InventoryDBError::DuplicateCustomizationID => Self::DuplicateCustomizationID, InventoryDBError::DuplicateCustomizationID => Self::DuplicateCustomizationID,
InventoryDBError::InternalError => Self::InternalError, InventoryDBError::InternalError => Self::InternalError,
InventoryDBError::ProductIDNotFound => InventoryError::ProductIDNotFound, InventoryDBError::ProductIDNotFound => InventoryError::ProductIDNotFound,

View file

@ -15,7 +15,6 @@ use crate::inventory::{
}, },
domain::{category_aggregate::*, category_updated_event::*, update_category_command::*}, domain::{category_aggregate::*, category_updated_event::*, update_category_command::*},
}; };
use crate::utils::uuid::*;
#[automock] #[automock]
#[async_trait::async_trait] #[async_trait::async_trait]

View file

@ -2,6 +2,7 @@
// //
// SPDX-License-Identifier: AGPL-3.0-or-later // SPDX-License-Identifier: AGPL-3.0-or-later
use derive_builder::Builder;
use derive_getters::Getters; use derive_getters::Getters;
use derive_more::{Display, Error}; use derive_more::{Display, Error};
use serde::{Deserialize, Serialize}; use serde::{Deserialize, Serialize};
@ -12,21 +13,22 @@ pub enum AddCategoryCommandError {
NameIsEmpty, NameIsEmpty,
} }
#[derive(Clone, Debug, Serialize, Deserialize, Eq, PartialEq, Ord, PartialOrd, Getters)] #[derive(
Clone, Debug, Builder, Serialize, Deserialize, Eq, PartialEq, Ord, PartialOrd, Getters,
)]
#[builder(build_fn(validate = "Self::validate"))]
pub struct AddCategoryCommand { pub struct AddCategoryCommand {
#[builder(setter(custom))]
name: String, name: String,
#[builder(setter(custom))]
description: Option<String>, description: Option<String>,
store_id: Uuid, store_id: Uuid,
category_id: Uuid,
adding_by: Uuid, adding_by: Uuid,
} }
impl AddCategoryCommand { impl AddCategoryCommandBuilder {
pub fn new( pub fn description(&mut self, description: Option<String>) -> &mut Self {
name: String,
description: Option<String>,
store_id: Uuid,
adding_by: Uuid,
) -> Result<Self, AddCategoryCommandError> {
let description: Option<String> = if let Some(description) = description { let description: Option<String> = if let Some(description) = description {
let description = description.trim(); let description = description.trim();
if description.is_empty() { if description.is_empty() {
@ -37,18 +39,22 @@ impl AddCategoryCommand {
} else { } else {
None None
}; };
self.description = Some(description);
let name = name.trim().to_owned(); self
if name.is_empty() {
return Err(AddCategoryCommandError::NameIsEmpty);
} }
Ok(Self { pub fn name(&mut self, name: String) -> &mut Self {
name, let name = name.trim().to_owned();
store_id, self.name = Some(name);
description, self
adding_by, }
})
pub fn validate(&self) -> Result<(), String> {
if self.name.as_ref().unwrap().is_empty() {
return Err(AddCategoryCommandError::NameIsEmpty.to_string());
}
Ok(())
} }
} }
@ -65,26 +71,41 @@ mod tests {
let adding_by = UUID; let adding_by = UUID;
let store_id = Uuid::new_v4(); let store_id = Uuid::new_v4();
// description = None let cmd = AddCategoryCommandBuilder::default()
let cmd = AddCategoryCommand::new(name.into(), None, store_id, adding_by).unwrap(); .name(name.into())
.description(None)
.store_id(store_id)
.adding_by(adding_by)
.category_id(UUID)
.build()
.unwrap();
assert_eq!(cmd.name(), name); assert_eq!(cmd.name(), name);
assert_eq!(cmd.description(), &None); assert_eq!(cmd.description(), &None);
assert_eq!(cmd.adding_by(), &adding_by); assert_eq!(cmd.adding_by(), &adding_by);
assert_eq!(cmd.store_id(), &store_id); assert_eq!(cmd.store_id(), &store_id);
// description = Some let cmd = AddCategoryCommandBuilder::default()
let cmd = .name(name.into())
AddCategoryCommand::new(name.into(), Some(description.into()), store_id, adding_by) .description(Some(description.into()))
.store_id(store_id)
.adding_by(adding_by)
.category_id(UUID)
.build()
.unwrap(); .unwrap();
assert_eq!(cmd.name(), name); assert_eq!(cmd.name(), name);
assert_eq!(cmd.description(), &Some(description.to_owned())); assert_eq!(cmd.description(), &Some(description.to_owned()));
assert_eq!(cmd.adding_by(), &adding_by); assert_eq!(cmd.adding_by(), &adding_by);
assert_eq!(cmd.store_id(), &store_id); assert_eq!(cmd.store_id(), &store_id);
// AddCategoryCommandError::NameIsEmpty // AddCategoryCommandError::NameIsEmpty
assert_eq!( assert!(AddCategoryCommandBuilder::default()
AddCategoryCommand::new("".into(), Some(description.into()), store_id, adding_by,), .name("".into())
Err(AddCategoryCommandError::NameIsEmpty) .description(Some(description.into()))
) .store_id(store_id)
.adding_by(adding_by)
.category_id(UUID)
.build()
.is_err())
} }
} }

View file

@ -107,8 +107,14 @@ mod aggregate_tests {
let store_id = Uuid::new_v4(); let store_id = Uuid::new_v4();
let category_id = UUID; let category_id = UUID;
let cmd = let cmd = AddCategoryCommandBuilder::default()
AddCategoryCommand::new(name.into(), description.clone(), store_id, adding_by).unwrap(); .name(name.into())
.description(description.clone())
.store_id(store_id)
.adding_by(adding_by)
.category_id(category_id)
.build()
.unwrap();
let expected = CategoryAddedEventBuilder::default() let expected = CategoryAddedEventBuilder::default()
.name(cmd.name().into()) .name(cmd.name().into())