wip: full fledge of API CRUD

libs/prisma/src/interfaces/config-module-options.interface.ts

@@ -1,7 +1,19 @@
 import { PrismaService } from '../prisma.service';
+import {
+  PrismaCreateProcess,
+  PrismaDeleteProcess,
+  PrismaPaginationProcess,
+  PrismaReadProcess,
+  PrismaUpdateProcess,
+} from '../processes';
 import { PrismaListProcess } from '../processes/list.process';
 
 export interface PrismaModuleOptions {
   delegate: (prisma: PrismaService) => any;
-  processList: typeof PrismaListProcess;
+  processCreate?: typeof PrismaCreateProcess;
+  processDelete?: typeof PrismaDeleteProcess;
+  processList?: typeof PrismaListProcess;
+  processPagination?: typeof PrismaPaginationProcess;
+  processRead?: typeof PrismaReadProcess;
+  processUpdate?: typeof PrismaUpdateProcess;
 }

libs/prisma/src/prisma.module.ts

@@ -1,4 +1,4 @@
-import { READ_ENTIRE_PROCESS } from '@aditama-labs/nest-autocrud/skeleton';
+import { LIST_PROCESS } from '@aditama-labs/nest-autocrud/skeleton';
 import { DynamicModule, Module } from '@nestjs/common';
 import { ConfigurableModuleClass } from './config.module-definition';
 import { PRISMA_DELEGATE } from './constants';
@@ -7,7 +7,7 @@ import { PrismaService } from './prisma.service';
 import { PrismaListProcess } from './processes/list.process';
 
 @Module({
-  exports: [PrismaService, PRISMA_DELEGATE, READ_ENTIRE_PROCESS],
+  exports: [PrismaService, PRISMA_DELEGATE, LIST_PROCESS],
 })
 export class PrismaModule extends ConfigurableModuleClass {
   static forRoot(options: PrismaModuleOptions): DynamicModule {
@@ -25,7 +25,7 @@ export class PrismaModule extends ConfigurableModuleClass {
       providers = [
         ...providers,
         {
-          provide: READ_ENTIRE_PROCESS,
+          provide: LIST_PROCESS,
           useClass: options.processList,
         },
       ];
@@ -33,7 +33,7 @@ export class PrismaModule extends ConfigurableModuleClass {
       providers = [
         ...providers,
         {
-          provide: READ_ENTIRE_PROCESS,
+          provide: LIST_PROCESS,
           useClass: PrismaListProcess,
         },
       ];

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

@@ -1,3 +0,0 @@
-import { BatchDeleteProcess } from '@aditama-labs/nest-autocrud/skeleton';
-
-export class PrismaBatchDeleteProcess extends BatchDeleteProcess {}

libs/prisma/src/processes/batch/index.ts

@@ -1,2 +0,0 @@
-export * from './delete.process';
-export * from './update.process';

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

@@ -1,3 +0,0 @@
-import { BatchUpdateProcess } from '@aditama-labs/nest-autocrud/skeleton';
-
-export class PrismaBatchUpdateProcess extends BatchUpdateProcess {}

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

@@ -5,13 +5,18 @@ export class PrismaCreateProcess
   extends PrismaProcess
   implements CreateProcess
 {
-  private data;
+  private dataInsert;
+  private dataResult;
 
   setData(data) {
-    this.data = data;
+    this.dataInsert = data;
   }
 
   async process(): Promise<any> {
-    await this.getDelegate().create(this.data);
+    this.dataResult = await this.getDelegate().create(this.dataInsert);
+  }
+
+  result() {
+    this.dataResult;
   }
 }

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

@@ -1,3 +1,20 @@
-import { DeleteProcess } from '@aditama-labs/nest-autocrud/skeleton';
+import { CreateProcess } from '@aditama-labs/nest-autocrud/skeleton';
+import { PrismaProcess } from './prisma.process';
 
-export class PrismaDeleteProcess extends DeleteProcess {}
+export class PrismaDeleteProcess
+  extends PrismaProcess
+  implements CreateProcess
+{
+  private dataResult: any;
+  private id: any;
+
+  async process(): Promise<any> {
+    this.dataResult = await this.getDelegate().delete({
+      where: { id: this.id },
+    });
+  }
+
+  result() {
+    return this.dataResult;
+  }
+}

libs/prisma/src/processes/index.ts

@@ -1,9 +1,7 @@
-export * from './batch';
 export * from './create.process';
 export * from './delete.process';
 export * from './list.process';
 export * from './pagination.process';
-export * from './partial';
 export * from './read.process';
 export * from './update.process';
 

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

@@ -9,7 +9,6 @@ export class PrismaListProcess extends PrismaProcess implements ListProcess {
   }
 
   result() {
-    console.log('ASDASDASDASD');
     return this.data;
   }
 }

libs/prisma/src/processes/partial/batch/index.ts

@@ -1 +0,0 @@
-export * from './update.process';

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

@@ -1,3 +0,0 @@
-import { PartialBatchUpdateProcess } from '@aditama-labs/nest-autocrud/skeleton';
-
-export class PrismaPartialBatchUpdateProcess extends PartialBatchUpdateProcess {}

libs/prisma/src/processes/partial/index.ts

@@ -1,2 +0,0 @@
-export * from './update.process';
-export * from './batch';

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

@@ -1,3 +0,0 @@
-import { PartialUpdateProcess } from '@aditama-labs/nest-autocrud/skeleton';
-
-export class PrismaPartialUpdateProcess extends PartialUpdateProcess {}

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

@@ -1,3 +1,17 @@
-import { ReadProcess } from '@aditama-labs/nest-autocrud/skeleton';
+import { CreateProcess } from '@aditama-labs/nest-autocrud/skeleton';
+import { PrismaProcess } from './prisma.process';
 
-export class PrismaReadProcess extends ReadProcess {}
+export class PrismaReadProcess extends PrismaProcess implements CreateProcess {
+  private data: any;
+  private id: any;
+
+  async process(): Promise<any> {
+    this.data = await this.getDelegate().findUnique({
+      where: { id: this.id },
+    });
+  }
+
+  result() {
+    return this.data;
+  }
+}

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

@@ -1,3 +1,22 @@
-import { UpdateProcess } from '@aditama-labs/nest-autocrud/skeleton';
+import { CreateProcess } from '@aditama-labs/nest-autocrud/skeleton';
+import { PrismaProcess } from './prisma.process';
 
-export class PrismaUpdateProcess extends UpdateProcess {}
+export class PrismaUpdateProcess
+  extends PrismaProcess
+  implements CreateProcess
+{
+  private dataResult: any;
+  private dataUpdate: any;
+  private id: any;
+
+  async process(): Promise<any> {
+    this.dataResult = await this.getDelegate().update({
+      data: this.dataUpdate,
+      where: { id: this.id },
+    });
+  }
+
+  result() {
+    return this.dataResult;
+  }
+}

libs/skeleton/src/constants.ts

@@ -1 +1,6 @@
-export const READ_ENTIRE_PROCESS = 'READ_ENTIRE_PROCESS';
+export const CREATE_PROCESS = 'CREATE_PROCESS';
+export const DELETE_PROCESS = 'DELETE_PROCESS';
+export const LIST_PROCESS = 'LIST_PROCESS';
+export const PAGINATION_PROCESS = 'PAGINATION_PROCESS';
+export const READ_PROCESS = 'READ_PROCESS';
+export const UPDATE_PROCESS = 'UPDATE_PROCESS';

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

@@ -1,3 +1,8 @@
 export interface ISkeletonCRUDController {
-  readEntire();
+  create();
+  delete();
+  list();
+  pagination();
+  read(id);
+  update();
 }

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

@@ -1,3 +0,0 @@
-import { DefaultProcess } from '../default.process';
-
-export class BatchDeleteProcess extends DefaultProcess {}

libs/skeleton/src/processes/batch/index.ts

@@ -1,2 +0,0 @@
-export * from './delete.process';
-export * from './update.process';

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

@@ -1,3 +0,0 @@
-import { DefaultProcess } from '../default.process';
-
-export class BatchUpdateProcess extends DefaultProcess {}

libs/skeleton/src/processes/index.ts

@@ -5,5 +5,3 @@ export * from './list.process';
 export * from './pagination.process';
 export * from './read.process';
 export * from './update.process';
-export * from './batch';
-export * from './partial';

libs/skeleton/src/processes/partial/batch/index.ts

@@ -1 +0,0 @@
-export * from './update.process';

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

@@ -1,3 +0,0 @@
-import { DefaultProcess } from '../../default.process';
-
-export class PartialBatchUpdateProcess extends DefaultProcess {}

libs/skeleton/src/processes/partial/index.ts

@@ -1,2 +0,0 @@
-export * from './update.process';
-export * from './batch';

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

@@ -1,3 +0,0 @@
-import { DefaultProcess } from '../default.process';
-
-export class PartialUpdateProcess extends DefaultProcess {}

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

@@ -1,16 +1,58 @@
-import { Get, Inject } from '@nestjs/common';
+import { Delete, Get, Inject, Param, Patch, Post } from '@nestjs/common';
-import { READ_ENTIRE_PROCESS } from './constants';
+import {
+  CREATE_PROCESS,
+  DELETE_PROCESS,
+  LIST_PROCESS,
+  PAGINATION_PROCESS,
+  READ_PROCESS,
+  UPDATE_PROCESS,
+} from './constants';
 import { DefaultExecutor } from './executors/default.executor';
 import { ISkeletonCRUDController } from './interfaces/controller/skeleton-crud.controller.interface';
 
 export class SkeletonCRUDController implements ISkeletonCRUDController {
   constructor(
-    @Inject(READ_ENTIRE_PROCESS)
+    @Inject(CREATE_PROCESS)
-    public readonly readEntireProcess: any,
+    public readonly createProcess,
+    @Inject(DELETE_PROCESS)
+    public readonly deleteProcess,
+    @Inject(LIST_PROCESS)
+    public readonly listProcess,
+    @Inject(PAGINATION_PROCESS)
+    public readonly paginationProcess,
+    @Inject(READ_PROCESS)
+    public readonly readProcess,
+    @Inject(UPDATE_PROCESS)
+    public readonly updateProcess,
   ) {}
 
+  @Post()
+  async create(): Promise<any> {
+    return await DefaultExecutor.bootstrap(this.createProcess);
+  }
+
+  @Delete(':id')
+  async delete() {
+    return await DefaultExecutor.bootstrap(this.deleteProcess);
+  }
+
   @Get('list')
-  async readEntire() {
+  async list() {
-    return await DefaultExecutor.bootstrap(this.readEntireProcess);
+    return await DefaultExecutor.bootstrap(this.listProcess);
+  }
+
+  @Get()
+  async pagination() {
+    return await DefaultExecutor.bootstrap(this.paginationProcess);
+  }
+
+  @Get(':id')
+  async read(@Param('id') id) {
+    return await DefaultExecutor.bootstrap(this.readProcess);
+  }
+
+  @Patch()
+  async update() {
+    return await DefaultExecutor.bootstrap(this.updateProcess);
   }
 }