add-status

src/status/providers/status.provider.ts → src/status/providers/registration-status.provider.ts

@@ -3,7 +3,7 @@ import { RegistrationStatusSchema } from '../schema/status.schema';
 
 export const statusProviders = [
   {
-    provide: 'REGISTRATIONSTATUS_MODEL',
+    provide: 'STATUS_MODEL',
     useFactory: (connection: Connection) =>
       connection.model('RegistrationStatus', RegistrationStatusSchema),
     inject: ['APPDATABASECONNECTIONS'],

src/status/repository/status.repository.ts

@@ -1,16 +1,24 @@
-import { Injectable } from '@nestjs/common';
-import { InjectModel } from '@nestjs/mongoose';
-import { FilterQuery, Model } from 'mongoose';
-import { RegistrationStatus } from '../schema/status.schema';
+import { Inject, Injectable } from '@nestjs/common';
+import { FilterQuery, Model, ProjectionType, QueryOptions } from 'mongoose';
+import { RegistrationStatusDocument } from '../schema/status.schema';
+import { skip } from 'rxjs';
 
 @Injectable()
 export class TxnStatusRepository {
   constructor(
-    @InjectModel('REGISTRATION_STATUS')
-    private registatiationStatusModel: Model<RegistrationStatus>,
+    @Inject('STATUS_MODEL')
+    private readonly registatiationStatusModel: Model<RegistrationStatusDocument>,
   ) {}
 
-  async createOrUpdate(registrationStatus: FilterQuery<RegistrationStatus>) {
-    return this.registatiationStatusModel.insertMany(registrationStatus);
+  async find(
+    registrationStatus: FilterQuery<RegistrationStatusDocument>,
+    projection?: ProjectionType<RegistrationStatusDocument>,
+    option?: QueryOptions<RegistrationStatusDocument>,
+  ) {
+    return this.registatiationStatusModel.find(
+      registrationStatus,
+      projection,
+      option,
+    );
   }
 }

src/status/status.controller.ts

@@ -1,14 +1,22 @@
-import { Controller, Get, Param, UseGuards, Query } from '@nestjs/common';
+import {
+  Controller,
+  Get,
+  Param,
+  UseGuards,
+  Query,
+  UseFilters,
+} from '@nestjs/common';
 import { StatusService } from './status.service';
 
 import { ApiBearerAuth, ApiParam, ApiQuery, ApiTags } from '@nestjs/swagger';
 import { AuthGuard } from '@nestjs/passport';
 import { PaginationDto } from 'src/utils/pagination.dto';
-
+import { AllExceptionsFilter } from 'src/utils/utils';
+@UseFilters(AllExceptionsFilter)
 @ApiTags('Status')
 @ApiBearerAuth('Authorization')
-@UseGuards(AuthGuard('jwt'))
 @Controller('status')
+@UseGuards(AuthGuard('jwt'))
 export class StatusController {
   constructor(private readonly statusService: StatusService) {}
 

src/status/status.module.ts

@@ -1,19 +1,26 @@
-import { Module } from '@nestjs/common';
+import { MiddlewareConsumer, Module, NestModule } from '@nestjs/common';
 import { StatusService } from './status.service';
 import { StatusController } from './status.controller';
 import { databaseProviders } from 'src/mongoose/tenant-mongoose-connections';
 import { TxnStatusRepository } from './repository/status.repository';
-import { statusProviders } from './providers/status.provider';
+import { statusProviders } from './providers/registration-status.provider';
+import { WhitelistSSICorsMiddleware } from 'src/utils/middleware/cors.middleware';
+import { TrimMiddleware } from 'src/utils/middleware/trim.middleware';
 
 @Module({
   imports: [],
   controllers: [StatusController],
   providers: [
     StatusService,
+    TxnStatusRepository,
     ...databaseProviders,
     ...statusProviders,
-    TxnStatusRepository,
   ],
   exports: [],
 })
-export class StatusModule {}
+export class StatusModule implements NestModule {
+  configure(consumer: MiddlewareConsumer) {
+    consumer.apply(WhitelistSSICorsMiddleware).forRoutes(StatusController);
+    consumer.apply(TrimMiddleware).forRoutes(StatusController);
+  }
+}

src/status/status.service.ts

@@ -7,12 +7,23 @@ export class StatusService {
   findBySsiId(id: string, option) {
     const skip = (option.page - 1) * option.limit;
     option['skip'] = skip;
-    return `This action returns a #${id} status`;
+    return this.txnStatusRepository.find({
+      id,
+    });
   }
 
   findByTxnId(id: string, option) {
     const skip = (option.page - 1) * option.limit;
     option['skip'] = skip;
-    return `This action returns a #${id} status`;
+    return this.txnStatusRepository.find(
+      {
+        txnHash: id,
+      },
+      {},
+      {
+        skip: option.skip,
+        limit: option.limit,
+      },
+    );
   }
 }