wip: example typeorm

libs/skeleton/src/entities/index.ts

@@ -1 +0,0 @@
-export * from './pagination.entity';

libs/skeleton/src/entities/pagination.entity.ts

@@ -1,13 +0,0 @@
-export interface IPaginationEntity<T> {
-  // Data related
-  data: T[];
-  totalData: number;
-
-  // Page related
-  totalPage: number;
-  currentPage: number;
-  lastPage: number;
-  perPage: number;
-  nextPage: number | null;
-  previousPage: number | null;
-}

libs/skeleton/src/index.ts

@@ -1,8 +1,6 @@
 export * from './constants';
 export * from './dto';
-export * from './entities';
 export * from './executors';
 export * from './interfaces';
 export * from './processes';
 export * from './skeleton-crud.controller';
-

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

@@ -1,8 +1,13 @@
-import { EntityTarget, FindOptionsWhere, ObjectLiteral } from "typeorm";
+import { EntityTarget, ObjectLiteral } from 'typeorm';
 
 export interface TypeORMModuleOptions<T extends ObjectLiteral> {
   entity: EntityTarget<T>;
+  processCreate?;
+  processDelete?;
+  processList?;
+  processPagination?;
+  processRead?;
+  processUpdate?;
   synchronize?: boolean;
-  entities: string[];
-  uniqueWhereClause: FindOptionsWhere<T>;
+  entities?: string[];
 }

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

@@ -9,6 +9,6 @@ export class TypeORMDeleteProcess<T>
   public identityKey: string = 'id';
 
   async process() {
-    this.result = await this.service.getRepository().delete(this.uniqueWhereClause);
+    this.result = await this.service.getRepository().delete(this.identityData);
   }
 }

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

@@ -6,8 +6,6 @@ export class TypeORMReadProcess<T> extends TypeORMProcess<T> implements ReadProc
   public identityKey: string = 'id';
 
   async process() {
-    this.result = await this.service.getRepository().findOne({
-      where: this.uniqueWhereClause,
-    });
+    this.result = await this.service.getRepository().findOne(this.identityData);
   }
 }

libs/typeorm/src/processes/typeorm.process.ts

@@ -1,16 +1,10 @@
 import { DefaultProcess } from '@aditama-labs/nest-autocrud/skeleton';
-import { Inject, Injectable } from '@nestjs/common';
+import { Injectable } from '@nestjs/common';
 import { TypeORMService } from '../typeorm.service';
-import { TYPEORM_WHERE_CLAUSE } from '../constants';
-import { FindOptionsWhere } from 'typeorm';
 
 @Injectable()
 export class TypeORMProcess<T> extends DefaultProcess {
-  constructor(
-    public service: TypeORMService<T>,
-    @Inject(TYPEORM_WHERE_CLAUSE)
-    public uniqueWhereClause: FindOptionsWhere<T>,
-  ) {
+  constructor(public service: TypeORMService<T>) {
     super();
   }
 }

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

@@ -12,6 +12,6 @@ export class TypeORMUpdateProcess<T>
   async process() {
     this.result = await this.service
       .getRepository()
-      .update(this.uniqueWhereClause, this.payload);
+      .update(this.identityData, this.payload);
   }
 }

libs/typeorm/src/typeorm.module.ts

@@ -1,12 +1,25 @@
 import { DynamicModule, Module } from '@nestjs/common';
 import { DataSource, ObjectLiteral } from 'typeorm';
-import {
-  TYPEORM_DATASOURCE,
-  TYPEORM_REPOSITORY,
-  TYPEORM_WHERE_CLAUSE,
-} from './constants';
+import { TYPEORM_DATASOURCE, TYPEORM_REPOSITORY } from './constants';
 import { TypeORMModuleOptions } from './interfaces';
 import { TypeORMService } from './typeorm.service';
+import {
+  CREATE_PROCESS,
+  DELETE_PROCESS,
+  LIST_PROCESS,
+  PAGINATION_PROCESS,
+  READ_PROCESS,
+  UPDATE_PROCESS,
+} from '@aditama-labs/nest-autocrud/skeleton';
+import {
+  TypeORMCreateProcess,
+  TypeORMDeleteProcess,
+  TypeORMListProcess,
+  TypeORMPaginationProcess,
+  TypeORMReadProcess,
+  TypeORMUpdateProcess,
+} from './processes';
+import { TypeOrmModule } from '@nestjs/typeorm';
 
 const getDatabaseCredential = (
   synchronize?: boolean,
@@ -19,8 +32,9 @@ const getDatabaseCredential = (
     entityList = entities;
   }
 
-  let protocol;
-  switch (url.protocol) {
+  const defaultProtocol = url.protocol.substring(0, url.protocol.length - 1);
+  let protocol = defaultProtocol;
+  switch (defaultProtocol) {
     case 'postgresql':
       protocol = 'postgres';
       break;
@@ -49,6 +63,27 @@ const getDatabaseCredential = (
 
 @Module({})
 export class TypeORMModule {
+  private static autoPresetProvider(providers, option, key, preset) {
+    if (option) {
+      providers = [
+        ...providers,
+        {
+          provide: key,
+          useClass: option,
+        },
+      ];
+    } else {
+      providers = [
+        ...providers,
+        {
+          provide: key,
+          useClass: preset,
+        },
+      ];
+    }
+    return providers;
+  }
+
   static forRoot<T extends ObjectLiteral>(
     options: TypeORMModuleOptions<T>,
   ): DynamicModule {
@@ -65,22 +100,69 @@ export class TypeORMModule {
       },
       {
         provide: TYPEORM_REPOSITORY,
-        useFactory: (dataSource: DataSource) =>
-          dataSource.getRepository(options.entity),
+        useFactory: (dataSource: DataSource) => {
+          return dataSource.getRepository(options.entity);
+        },
         inject: [TYPEORM_DATASOURCE],
       },
     ];
 
+    providers = TypeORMModule.autoPresetProvider(
+      providers,
+      options.processCreate,
+      CREATE_PROCESS,
+      TypeORMCreateProcess,
+    );
+
+    providers = TypeORMModule.autoPresetProvider(
+      providers,
+      options.processDelete,
+      DELETE_PROCESS,
+      TypeORMDeleteProcess,
+    );
+
+    providers = TypeORMModule.autoPresetProvider(
+      providers,
+      options.processList,
+      LIST_PROCESS,
+      TypeORMListProcess,
+    );
+
+    providers = TypeORMModule.autoPresetProvider(
+      providers,
+      options.processPagination,
+      PAGINATION_PROCESS,
+      TypeORMPaginationProcess,
+    );
+
+    providers = TypeORMModule.autoPresetProvider(
+      providers,
+      options.processRead,
+      READ_PROCESS,
+      TypeORMReadProcess,
+    );
+
+    providers = TypeORMModule.autoPresetProvider(
+      providers,
+      options.processUpdate,
+      UPDATE_PROCESS,
+      TypeORMUpdateProcess,
+    );
+
     return {
       module: TypeORMModule,
-      providers: [
-        ...providers,
-        {
-          provide: TYPEORM_WHERE_CLAUSE,
-          useValue: options.uniqueWhereClause,
-        },
+      providers: [...providers],
+      exports: [
+        TYPEORM_DATASOURCE,
+        TYPEORM_REPOSITORY,
+        // List of Process
+        CREATE_PROCESS,
+        DELETE_PROCESS,
+        LIST_PROCESS,
+        PAGINATION_PROCESS,
+        READ_PROCESS,
+        UPDATE_PROCESS,
       ],
-      exports: providers,
     };
   }
 }

src/app.module.ts

@@ -1,12 +1,10 @@
 import { Module } from '@nestjs/common';
 import { CustomModule } from './example/prisma/custom/custom.module';
 import { SimpleModule } from './example/prisma/simple/simple.module';
+import { SimpleTypeORMModule } from './example/typeorm/simple.module';
 
 @Module({
-  imports: [
-    SimpleModule,
-    CustomModule,
-  ],
+  imports: [SimpleTypeORMModule],
   controllers: [],
   providers: [],
 })

src/example/typeorm/entities/user.entity.ts

@@ -0,0 +1,13 @@
+import { Column, Entity, PrimaryGeneratedColumn } from 'typeorm';
+
+@Entity('account')
+export class UserEntity {
+  @PrimaryGeneratedColumn('uuid')
+  id: string;
+
+  @Column({ type: String })
+  username: string;
+
+  @Column({ type: String })
+  name: string;
+}

src/example/typeorm/simple.controller.ts

@@ -0,0 +1,5 @@
+import { SkeletonCRUDController } from '@aditama-labs/nest-autocrud/skeleton';
+import { Controller } from '@nestjs/common';
+
+@Controller('example/simple/typeorm')
+export class SimpleTypeORMController extends SkeletonCRUDController {}

src/example/typeorm/simple.module.ts

@@ -0,0 +1,15 @@
+import { TypeORMModule } from '@aditama-labs/nest-autocrud/typeorm';
+import { Module } from '@nestjs/common';
+import { SimpleTypeORMController } from './simple.controller';
+import { UserEntity } from './entities/user.entity';
+
+@Module({
+  imports: [
+    TypeORMModule.forRoot<UserEntity>({
+      entity: UserEntity,
+    }),
+  ],
+  controllers: [SimpleTypeORMController],
+  providers: [],
+})
+export class SimpleTypeORMModule {}