feat manual entry

apps/api/src/app/review/dtos/index.ts

@@ -1,3 +1,3 @@
 export * from './delete-records.dto';
-export * from './update-cell.dto';
+export * from './update-record.dto';
 export * from './replace.dto';

apps/api/src/app/review/dtos/update-cell.dto.ts → apps/api/src/app/review/dtos/update-record.dto.ts

@@ -1,7 +1,7 @@
 import { ApiProperty } from '@nestjs/swagger';
 import { IsDefined } from 'class-validator';
 
-export class UpdateCellDto {
+export class UpdateRecordDto {
   @ApiProperty({
     description: 'Record index',
   })

apps/api/src/app/review/review.controller.ts

@@ -1,5 +1,16 @@
 import { ApiOperation, ApiTags, ApiSecurity, ApiQuery, ApiOkResponse } from '@nestjs/swagger';
-import { BadRequestException, Body, Controller, Get, Param, Post, Put, Query, UseGuards } from '@nestjs/common';
+import {
+  BadRequestException,
+  Body,
+  Controller,
+  Get,
+  Param,
+  ParseArrayPipe,
+  Post,
+  Put,
+  Query,
+  UseGuards,
+} from '@nestjs/common';
 
 import { APIMessages } from '@shared/constants';
 import { JwtAuthGuard } from '@shared/framework/auth.gaurd';
@@ -15,11 +26,12 @@ import {
   StartProcess,
   DeleteRecord,
   GetUploadData,
+  UpdateRecords,
 } from './usecases';
 
 import { UserSession } from '@shared/framework/user.decorator';
 import { validateNotFound } from '@shared/helpers/common.helper';
-import { DeleteRecordsDto, UpdateCellDto, ReplaceDto } from './dtos';
+import { DeleteRecordsDto, UpdateRecordDto, ReplaceDto } from './dtos';
 import { PaginationResponseDto } from '@shared/dtos/pagination-response.dto';
 import { ValidateMongoId } from '@shared/validations/valid-mongo-id.validation';
 
@@ -35,6 +47,7 @@ export class ReviewController {
     private deleteRecord: DeleteRecord,
     private startProcess: StartProcess,
     private updateRecord: UpdateRecord,
+    private updateRecords: UpdateRecords,
     private getFileInvalidData: GetUploadData
   ) {}
 
@@ -131,8 +144,20 @@ export class ReviewController {
   @ApiOperation({
     summary: 'Update review record for ongoing import',
   })
-  async updateReviewData(@Param('uploadId', ValidateMongoId) _uploadId: string, @Body() body: UpdateCellDto) {
-    await this.updateRecord.execute(_uploadId, body);
+  async updateReviewData(@Param('uploadId') _uploadId: string, @Body() body: UpdateRecordDto) {
+    return this.updateRecord.execute(_uploadId, body);
+  }
+
+  @Put(':uploadId/records')
+  @UseGuards(JwtAuthGuard)
+  @ApiOperation({
+    summary: 'Delete review records for ongoing import',
+  })
+  async updateRecordsRoute(
+    @Param('uploadId') _uploadId: string,
+    @Body(new ParseArrayPipe({ items: UpdateRecordDto })) body: UpdateRecordDto[]
+  ) {
+    await this.updateRecords.execute(_uploadId, body);
   }
 
   @Post(':uploadId/delete-records')

apps/api/src/app/review/usecases/do-review/do-review.usecase.ts

@@ -16,6 +16,7 @@ import {
   DalService,
   TemplateEntity,
   TemplateRepository,
+  RecordEntity,
 } from '@impler/dal';
 
 interface ISaveResults {
@@ -28,7 +29,7 @@ interface ISaveResults {
 
 @Injectable()
 export class DoReview extends BaseReview {
-  private _modal: Model<unknown>;
+  private _modal: Model<RecordEntity>;
 
   constructor(
     private templateRepository: TemplateRepository,
@@ -44,7 +45,7 @@ export class DoReview extends BaseReview {
   }
 
   async execute(_uploadId: string) {
-    this._modal = await this.dalService.createRecordCollection(_uploadId);
+    this._modal = this.dalService.getRecordCollection(_uploadId);
     const userEmail = await this.uploadRepository.getUserEmailFromUploadId(_uploadId);
 
     const uploadInfo = await this.uploadRepository.getUploadWithTemplate(_uploadId, ['name']);

apps/api/src/app/review/usecases/do-review/re-review-data.usecase.ts

@@ -147,9 +147,9 @@ export class DoReReview extends BaseReview {
     });
     let result: ISaveResults = {
       uploadId: _uploadId,
-      totalRecords: uploadInfo.totalRecords,
-      validRecords: uploadInfo.validRecords,
-      invalidRecords: uploadInfo.invalidRecords,
+      totalRecords: uploadInfo.totalRecords || 0,
+      validRecords: uploadInfo.validRecords || 0,
+      invalidRecords: uploadInfo.invalidRecords || 0,
     };
 
     if (validations && validations.onBatchInitialize) {
@@ -223,8 +223,8 @@ export class DoReReview extends BaseReview {
     const response: ISaveResults = {
       uploadId,
       totalRecords: 0,
-      validRecords: result.validRecords,
-      invalidRecords: result.invalidRecords,
+      validRecords: result.validRecords || 0,
+      invalidRecords: result.invalidRecords || 0,
     };
 
     for await (const record of this._modal.find({ updated: { $ne: {}, $exists: true } })) {

apps/api/src/app/review/usecases/index.ts

@@ -1,9 +1,10 @@
 import { PaymentAPIService } from '@impler/services';
 import { Replace } from './replace/replace.usecase';
 import { DoReview } from './do-review/do-review.usecase';
-import { UpdateRecord } from './update-cell/update-cell.usecase';
-import { DeleteRecord } from './delete-record/delete-record.usecase';
 import { DoReReview } from './do-review/re-review-data.usecase';
+import { UpdateRecord } from './update-record/update-record.usecase';
+import { UpdateRecords } from './update-records/update-records.usecase';
+import { DeleteRecord } from './delete-record/delete-record.usecase';
 import { StartProcess } from './start-process/start-process.usecase';
 import { GetUploadData } from './get-upload-data/get-upload-data.usecase';
 import { GetUpload } from '@shared/usecases/get-upload/get-upload.usecase';
@@ -16,6 +17,7 @@ export const USE_CASES = [
   DeleteRecord,
   UpdateRecord,
   StartProcess,
+  UpdateRecords,
   GetUploadData,
   PaymentAPIService,
 ];
@@ -29,5 +31,6 @@ export {
   UpdateRecord,
   StartProcess,
   GetUploadData,
+  UpdateRecords,
   PaymentAPIService,
 };

apps/api/src/app/review/usecases/update-cell/update-cell.command.ts → apps/api/src/app/review/usecases/update-record/update-record.command.ts

@@ -1,4 +1,4 @@
-export class UpdateCellCommand {
+export class UpdateRecordCommand {
   index: number;
 
   record: Record<string, any>;

apps/api/src/app/review/usecases/update-record/update-record.usecase.ts

@@ -0,0 +1,12 @@
+import { Injectable } from '@nestjs/common';
+import { DalService } from '@impler/dal';
+import { UpdateRecordCommand } from './update-record.command';
+
+@Injectable()
+export class UpdateRecord {
+  constructor(private dalService: DalService) {}
+
+  async execute(_uploadId: string, data: UpdateRecordCommand) {
+    return this.dalService.updateRecord(_uploadId, data.index, data.record, data.updated);
+  }
+}

apps/api/src/app/review/usecases/update-records/update-records.usecase.ts

@@ -0,0 +1,26 @@
+import { Injectable } from '@nestjs/common';
+import { DalService, UploadRepository } from '@impler/dal';
+import { UpdateRecordCommand } from '../update-record/update-record.command';
+
+@Injectable()
+export class UpdateRecords {
+  constructor(
+    private dalService: DalService,
+    private uploadRepository: UploadRepository
+  ) {}
+
+  async execute(_uploadId: string, data: UpdateRecordCommand[]) {
+    const result = await this.dalService.updateRecords(_uploadId, data);
+    await this.uploadRepository.update(
+      {
+        _id: _uploadId,
+      },
+      {
+        $inc: {
+          totalRecords: result.upsertedCount,
+          invalidRecords: result.upsertedCount,
+        },
+      }
+    );
+  }
+}

apps/api/src/app/shared/validations/valid-import-file.validation.ts

@@ -7,7 +7,7 @@ import { FileNotValidError } from '../exceptions/file-not-valid.exception';
 @Injectable()
 export class ValidImportFile implements PipeTransform<Express.Multer.File> {
   transform(value: Express.Multer.File) {
-    if (!SupportedFileMimeTypes.includes(value.mimetype)) {
+    if (value && !SupportedFileMimeTypes.includes(value.mimetype)) {
       throw new FileNotValidError();
     }
 

apps/api/src/app/upload/dtos/upload-request.dto.ts

@@ -6,59 +6,59 @@ export class UploadRequestDto {
     type: 'file',
     required: true,
   })
-  file: Express.Multer.File;
+  file?: Express.Multer.File;
 
   @ApiProperty({
     description: 'Auth header value to send during webhook call',
     required: false,
   })
   @IsOptional()
   @IsString()
-  authHeaderValue: string;
+  authHeaderValue?: string;
 
   @ApiProperty({
     description: 'Custom schema if wants to override default schema',
     required: false,
   })
   @IsOptional()
   @IsJSON()
-  schema: string;
+  schema?: string;
 
   @ApiProperty({
     description: 'Custom output if wants to modify how schema values are sent',
     required: false,
   })
   @IsOptional()
   @IsJSON()
-  output: string;
+  output?: string;
 
   @ApiProperty({
     description: 'Payload to send during webhook call',
     required: false,
   })
   @IsOptional()
   @IsJSON()
-  extra: string;
+  extra?: string;
 
   @ApiProperty({
     description: 'Name of the excel sheet to Import',
   })
   @IsOptional()
   @IsString()
-  selectedSheetName: string;
+  selectedSheetName?: string;
 
   @ApiProperty({
     description: 'ID of the import if already created',
   })
   @IsOptional()
   @IsMongoId()
-  importId: string;
+  importId?: string;
 
   @ApiProperty({
     description: 'Image schema for importing excel with images',
     required: false,
   })
   @IsOptional()
   @IsJSON()
-  imageSchema: string;
+  imageSchema?: string;
 }

apps/api/src/app/upload/usecases/make-upload-entry/add-upload-entry.command.ts

@@ -3,7 +3,7 @@ export class AddUploadEntryCommand {
 
   _allDataFileId?: string;
 
-  _uploadedFileId: string;
+  _uploadedFileId?: string;
 
   uploadId: string;
 
@@ -13,15 +13,13 @@ export class AddUploadEntryCommand {
 
   headings?: string[];
 
-  totalRecords?: number;
-
   schema?: string;
 
-  originalFileName: string;
+  originalFileName?: string;
 
-  originalFileType: string;
+  originalFileType?: string;
 
-  customRecordFormat?: string;
+  customRecordFormat: string;
 
-  customChunkFormat?: string;
+  customChunkFormat: string;
 }