fix: database duplicate key error handling

libs/auth-domain/src/lib/services/auth.service.ts

@@ -51,14 +51,12 @@ export class AuthService {
 
 	async createUser(data: AuthData): Promise<Result<AuthAnemic>> {
 		try {
-			const checkEmail = await this.repository.findByEmail(data.email);
-			const checkUsername = await this.repository.findByUsername(
-				data.username,
-			);
-			if (checkEmail !== null) {
+			const checkEmail = await this.findByEmail(data.email);
+			if (checkEmail.isSuccess) {
 				return Result.fail<AuthAnemic>(AuthErrorCodes.EMAIL_FOUND);
 			}
-			if (checkUsername !== null) {
+			const checkUsername = await this.findByUsername(data.username);
+			if (checkUsername.isSuccess) {
 				return Result.fail<AuthAnemic>(AuthErrorCodes.USERNAME_FOUND);
 			}
 			const aggregate = this.factory.createDomain(data);
@@ -73,26 +71,22 @@ export class AuthService {
 		password: string,
 	): Promise<Result<AuthAnemic>> {
 		try {
-			const checkUsername =
-				await this.repository.findByUsername(username);
-			if (checkUsername === null) {
+			const checkUsername = await this.findByUsername(username);
+			if (checkUsername.isFailure) {
 				return Result.fail<AuthAnemic>(UserErrorCodes.NOT_FOUND);
 			}
-			if (checkUsername.password !== password) {
+			if (checkUsername.value.password !== password) {
 				return Result.fail<AuthAnemic>(AuthErrorCodes.INVALID_PASSWORD);
 			}
-			if (checkUsername.isBanned) {
+			if (checkUsername.value.isBanned) {
 				return Result.fail<AuthAnemic>(UserErrorCodes.IS_BANNED);
 			}
-			if (!checkUsername.isActive) {
+			if (!checkUsername.value.isActive) {
 				return Result.fail<AuthAnemic>(UserErrorCodes.NOT_ACTIVE);
 			}
-			//
-			const aggregate = this.factory.reconstitute(checkUsername);
+			const aggregate = this.factory.reconstitute(checkUsername.value);
 			aggregate.updateLogin();
-			await this.save(aggregate.toAnemic());
-			//
-			return Result.ok(checkUsername);
+			return await this.save(aggregate.toAnemic());
 		} catch (error) {
 			return Result.fail<AuthAnemic>(error);
 		}
@@ -103,17 +97,17 @@ export class AuthService {
 		token: string,
 	): Promise<Result<AuthAnemic>> {
 		try {
-			const result = await this.repository.findByEmail(email);
-			if (result !== null) {
-				if (result.isActive) {
+			const result = await this.findByEmail(email);
+			if (result.isSuccess) {
+				if (result.value.isActive) {
 					return Result.fail<AuthAnemic>(AuthErrorCodes.IS_ACTIVE);
 				}
-				if (result.activation_token !== token) {
+				if (result.value.activation_token !== token) {
 					return Result.fail<AuthAnemic>(
 						AuthErrorCodes.TOKEN_UNMATCH,
 					);
 				}
-				const aggregate = this.factory.reconstitute(result);
+				const aggregate = this.factory.reconstitute(result.value);
 				aggregate.updateActivation();
 				return await this.save(aggregate.toAnemic());
 			}

libs/foodfolio-domain/src/lib/repositories/category.repository.ts

@@ -3,10 +3,11 @@ import { CategoryAnemic } from '../anemics';
 import { Chainable, Nullable } from '@toxictoast/azkaban-base-types';
 
 interface CategoryAdditions {
-    findByParentId(parentId: Nullable<string>): Promise<Array<CategoryAnemic>>;
+	findByParentId(parentId: Nullable<string>): Promise<Array<CategoryAnemic>>;
+	findByTitle(title: string): Promise<CategoryAnemic>;
 }
 
 export type CategoryRepository = Chainable<
-    CategoryAdditions,
-    Repository<CategoryAnemic>
+	CategoryAdditions,
+	Repository<CategoryAnemic>
 >;

libs/foodfolio-domain/src/lib/repositories/company.repository.ts

@@ -1,4 +1,12 @@
 import { Repository } from '@toxictoast/azkaban-base-domain';
 import { CompanyAnemic } from '../anemics';
+import { Chainable } from '@toxictoast/azkaban-base-types';
 
-export type CompanyRepository = Repository<CompanyAnemic>;
+interface CompanyAdditions {
+	findByTitle(title: string): Promise<CompanyAnemic>;
+}
+
+export type CompanyRepository = Chainable<
+	CompanyAdditions,
+	Repository<CompanyAnemic>
+>;

libs/foodfolio-domain/src/lib/repositories/item-variant.repository.ts

@@ -18,6 +18,7 @@ interface ItemVariantAdditions {
 	findByWarehouseId(
 		warehouseId: Nullable<string>,
 	): Promise<Array<ItemVariantAnemic>>;
+	findByTitle(title: string): Promise<ItemVariantAnemic>;
 }
 
 export type ItemVariantRepository = Chainable<

libs/foodfolio-domain/src/lib/repositories/item.repository.ts

@@ -1,4 +1,9 @@
 import { Repository } from '@toxictoast/azkaban-base-domain';
 import { ItemAnemic } from '../anemics';
+import { Chainable } from '@toxictoast/azkaban-base-types';
 
-export type ItemRepository = Repository<ItemAnemic>;
+interface ItemAdditions {
+	findByTitle(title: string): Promise<ItemAnemic>;
+}
+
+export type ItemRepository = Chainable<ItemAdditions, Repository<ItemAnemic>>;

libs/foodfolio-domain/src/lib/repositories/location.repository.ts

@@ -3,11 +3,12 @@ import { LocationAnemic } from '../anemics';
 import { Chainable, Nullable } from '@toxictoast/azkaban-base-types';
 
 interface LocationAdditions {
-    findByParentId(parentId: Nullable<string>): Promise<Array<LocationAnemic>>;
-    findByFreezer(freezer: boolean): Promise<Array<LocationAnemic>>;
+	findByParentId(parentId: Nullable<string>): Promise<Array<LocationAnemic>>;
+	findByFreezer(freezer: boolean): Promise<Array<LocationAnemic>>;
+	findByTitle(title: string): Promise<LocationAnemic>;
 }
 
 export type LocationRepository = Chainable<
-    LocationAdditions,
-    Repository<LocationAnemic>
+	LocationAdditions,
+	Repository<LocationAnemic>
 >;

libs/foodfolio-domain/src/lib/repositories/size.repository.ts

@@ -1,4 +1,9 @@
 import { Repository } from '@toxictoast/azkaban-base-domain';
 import { SizeAnemic } from '../anemics';
+import { Chainable } from '@toxictoast/azkaban-base-types';
 
-export type SizeRepository = Repository<SizeAnemic>;
+interface SizeAdditions {
+	findByTitle(title: string): Promise<SizeAnemic>;
+}
+
+export type SizeRepository = Chainable<SizeAdditions, Repository<SizeAnemic>>;

libs/foodfolio-domain/src/lib/repositories/type.repository.ts

@@ -1,4 +1,9 @@
 import { Repository } from '@toxictoast/azkaban-base-domain';
 import { TypeAnemic } from '../anemics';
+import { Chainable } from '@toxictoast/azkaban-base-types';
 
-export type TypeRepository = Repository<TypeAnemic>;
+interface TypeAdditions {
+	findByTitle(title: string): Promise<TypeAnemic>;
+}
+
+export type TypeRepository = Chainable<TypeAdditions, Repository<TypeAnemic>>;

libs/foodfolio-domain/src/lib/repositories/warehouse.repository.ts

@@ -1,4 +1,12 @@
 import { Repository } from '@toxictoast/azkaban-base-domain';
 import { WarehouseAnemic } from '../anemics';
+import { Chainable } from '@toxictoast/azkaban-base-types';
 
-export type WarehouseRepository = Repository<WarehouseAnemic>;
+interface WarehouseAdditions {
+	findByTitle(title: string): Promise<WarehouseAnemic>;
+}
+
+export type WarehouseRepository = Chainable<
+	WarehouseAdditions,
+	Repository<WarehouseAnemic>
+>;