feat: implement unique identifier when searching to database

Author: supanadit

libs/prisma/src/processes/delete.process.ts

@@ -5,11 +5,12 @@ export class PrismaDeleteProcess
   extends PrismaProcess
   implements DeleteProcess
 {
-  public identity;
+  public identityData;
+  public identityKey: string = 'id';
 
   async process() {
     this.result = await this.getDelegate().delete({
-      where: { id: this.identity },
+      where: { [this.identityKey]: this.identityData },
     });
   }
 }

libs/prisma/src/processes/read.process.ts

@@ -2,11 +2,12 @@ import { ReadProcess } from '@aditama-labs/nest-autocrud/skeleton';
 import { PrismaProcess } from './prisma.process';
 
 export class PrismaReadProcess extends PrismaProcess implements ReadProcess {
-  public identity;
+  public identityData;
+  public identityKey: string = 'id';
 
   async process() {
     this.result = await this.getDelegate().findUnique({
-      where: { id: this.identity },
+      where: { [this.identityKey]: this.identityData },
     });
   }
 }

libs/prisma/src/processes/update.process.ts

@@ -5,13 +5,14 @@ export class PrismaUpdateProcess
   extends PrismaProcess
   implements UpdateProcess
 {
-  public identity;
+  public identityData;
+  public identityKey: string = 'id';
   public payload;
 
   async process() {
     this.result = await this.getDelegate().update({
       data: this.payload,
-      where: { id: this.identity },
+      where: { [this.identityKey]: this.identityData },
     });
   }
 }

libs/skeleton/src/executors/delete.executor.ts

@@ -3,14 +3,23 @@ import { DefaultExecutor } from './default.executor';
 
 // @TODO: ReadExecutor and DeleteExecutor can be merged into one executor
 export class DeleteExecutor extends DefaultExecutor {
-  constructor(process: DeleteProcess, id) {
+  constructor(
+    process: DeleteProcess,
+    identityData,
+    identityKey: string = 'id',
+  ) {
     super(process);
     // Set the id of the data
-    process.identity = id;
+    process.identityData = identityData;
+    process.identityKey = identityKey;
   }
 
-  static async bootstrap(process: DeleteProcess, id) {
-    const executor = new DeleteExecutor(process, id);
+  static async bootstrap(
+    process: DeleteProcess,
+    identityData,
+    identityKey: string = 'id',
+  ) {
+    const executor = new DeleteExecutor(process, identityData, identityKey);
     await executor.execute();
     return executor.getOutput();
   }

libs/skeleton/src/executors/read.executor.ts

@@ -2,14 +2,19 @@ import { ReadProcess } from '../processes';
 import { DefaultExecutor } from './default.executor';
 
 export class ReadExecutor extends DefaultExecutor {
-  constructor(process: ReadProcess, id) {
+  constructor(process: ReadProcess, identityData, identityKey: string = 'id') {
     super(process);
     // Set the id of the data
-    process.identity = id;
+    process.identityData = identityData;
+    process.identityKey = identityKey;
   }
 
-  static async bootstrap(process: ReadProcess, id) {
-    const executor = new ReadExecutor(process, id);
+  static async bootstrap(
+    process: ReadProcess,
+    identityData,
+    identityKey: string = 'id',
+  ) {
+    const executor = new ReadExecutor(process, identityData, identityKey);
     await executor.execute();
     return executor.getOutput();
   }

libs/skeleton/src/executors/update.executor.ts

@@ -3,15 +3,31 @@ import { DefaultExecutor } from './default.executor';
 
 // @TODO: This executor should be able to extend from ReadExecutor and CreateExecutor
 export class UpdateExecutor extends DefaultExecutor {
-  constructor(process: UpdateProcess, id, data) {
+  constructor(
+    process: UpdateProcess,
+    identityData,
+    data,
+    identityKey: string = 'id',
+  ) {
     super(process);
     // Set the id and data to process
-    process.identity = id;
+    process.identityData = identityData;
     process.payload = data;
+    process.identityKey = identityKey;
   }
 
-  static async bootstrap(process: UpdateProcess, id, data) {
-    const executor = new UpdateExecutor(process, id, data);
+  static async bootstrap(
+    process: UpdateProcess,
+    identityData,
+    data,
+    identityKey: string = 'id',
+  ) {
+    const executor = new UpdateExecutor(
+      process,
+      identityData,
+      data,
+      identityKey,
+    );
     await executor.execute();
     return executor.getOutput();
   }

libs/skeleton/src/processes/delete.process.ts

@@ -2,5 +2,6 @@ import { DefaultProcess } from './default.process';
 
 // @TODO: DeleteProcess and ReadProcess are the same, should be refactored next
 export class DeleteProcess extends DefaultProcess {
-  public identity;
+  public identityData;
+  public identityKey: string = 'id';
 }

libs/skeleton/src/processes/read.process.ts

@@ -1,5 +1,6 @@
 import { DefaultProcess } from './default.process';
 
 export class ReadProcess extends DefaultProcess {
-  public identity;
+  public identityData;
+  public identityKey: string = 'id';
 }

libs/skeleton/src/processes/update.process.ts

@@ -2,7 +2,8 @@ import { DefaultProcess } from './default.process';
 
 export class UpdateProcess extends DefaultProcess {
   // @TODO: The property of id can be take from ReadProcess which is extended
-  public identity;
+  public identityData;
+  public identityKey: string = 'id';
   // @TODO: The property of data can be take from CreateProcess which is extended
   public payload;
 }

libs/skeleton/src/skeleton-crud.controller.ts

@@ -95,8 +95,12 @@ export const CustomCRUDController = (options?: ControllerOption) => {
     }
 
     @Delete(`:${uniqueIdentifier}`)
-    async delete(@Param(uniqueIdentifier) id) {
-      return await super.delete(id);
+    async delete(@Param(uniqueIdentifier) identityData) {
+      return await DeleteExecutor.bootstrap(
+        this.deleteProcess,
+        identityData,
+        uniqueIdentifier,
+      );
     }
 
     @Get('list')
@@ -111,13 +115,22 @@ export const CustomCRUDController = (options?: ControllerOption) => {
     }
 
     @Get(`:${uniqueIdentifier}`)
-    async read(@Param(uniqueIdentifier) id) {
-      return await super.read(id);
+    async read(@Param(uniqueIdentifier) identityData) {
+      return await ReadExecutor.bootstrap(
+        this.readProcess,
+        identityData,
+        uniqueIdentifier,
+      );
     }
 
     @Patch(`:${uniqueIdentifier}`)
-    async update(@Param(uniqueIdentifier) id, @Body() body) {
-      return await super.update(id, body);
+    async update(@Param(uniqueIdentifier) identityData, @Body() body) {
+      return await UpdateExecutor.bootstrap(
+        this.updateProcess,
+        identityData,
+        body,
+        uniqueIdentifier,
+      );
     }
   }
 

prisma/migrations/20241102024042_account_username/migration.sql

@@ -0,0 +1,12 @@
+/*
+  Warnings:
+
+  - A unique constraint covering the columns `[username]` on the table `account` will be added. If there are existing duplicate values, this will fail.
+  - Added the required column `username` to the `account` table without a default value. This is not possible if the table is not empty.
+
+*/
+-- AlterTable
+ALTER TABLE "account" ADD COLUMN     "username" TEXT NOT NULL;
+
+-- CreateIndex
+CREATE UNIQUE INDEX "account_username_key" ON "account"("username");

prisma/schema.prisma

@@ -16,9 +16,10 @@ datasource db {
 }
 
 model User {
-  id   String @id @default(dbgenerated("gen_random_uuid()")) @db.Uuid
-  name String
-  Todo Todo[]
+  id       String @id @default(dbgenerated("gen_random_uuid()")) @db.Uuid
+  username String @unique
+  name     String
+  Todo     Todo[]
 
   @@map("account")
 }

src/example/custom/domain/custom.read.process.ts

@@ -4,7 +4,7 @@ export class CustomReadProcess extends PrismaReadProcess {
   customResult;
 
   async before(): Promise<any> {
-    console.log('The ID requested in path parameter', this.identity);
+    console.log('The ID requested in path parameter', this.identityData);
   }
   async after(): Promise<any> {
     this.customResult = {