fix: delete file_upload records (#803)

* feat: delete issuance records

Signed-off-by: bhavanakarwade <[email protected]>

* reafctor: variables names

Signed-off-by: bhavanakarwade <[email protected]>

* feat: delete issuance records by orgid

Signed-off-by: bhavanakarwade <[email protected]>

* fix: file upload delete changes

Signed-off-by: bhavanakarwade <[email protected]>

---------

Signed-off-by: bhavanakarwade <[email protected]>
Signed-off-by: KulkarniShashank <[email protected]>

apps/api-gateway/src/connection/connection.controller.ts

@@ -332,7 +332,7 @@ export class ConnectionController {
     return res.status(HttpStatus.CREATED).json(finalResponse);
   }
 
-  @Delete('/:orgId/connections')
+  @Delete('/orgs/:orgId/connections')
   @ApiOperation({ summary: 'Delete connection record', description: 'Delete connections by orgId' })
   @ApiResponse({ status: HttpStatus.OK, description: 'Success', type: ApiResponseDto })
   @ApiBearerAuth()

apps/api-gateway/src/issuance/issuance.controller.ts

@@ -759,7 +759,7 @@ issueCredentialDto.type = 'Issuance';
     return res.status(HttpStatus.CREATED).json(finalResponse);
     }   
 
-    @Delete('/:orgId/issuance-records')
+    @Delete('/orgs/:orgId/issuance-records')
     @ApiOperation({ summary: 'Delete issuance record', description: 'Delete issuance records by orgId' })
     @ApiResponse({ status: HttpStatus.OK, description: 'Success', type: ApiResponseDto })
     @ApiBearerAuth()

apps/api-gateway/src/verification/verification.controller.ts

@@ -340,7 +340,7 @@ export class VerificationController {
 
 }
 
-@Delete('/:orgId/verification-records')
+@Delete('/orgs/:orgId/verification-records')
 @ApiOperation({ summary: 'Delete verification record', description: 'Delete verification records by orgId' })
 @ApiResponse({ status: HttpStatus.OK, description: 'Success', type: ApiResponseDto })
 @ApiBearerAuth()

apps/issuance/interfaces/issuance.interfaces.ts

@@ -1,7 +1,7 @@
 // eslint-disable-next-line camelcase
 import { AutoAccept, SchemaType } from '@credebl/enum/enum';
 import { IUserRequest } from '@credebl/user-request/user-request.interface';
-import { organisation } from '@prisma/client';
+import { Prisma, organisation } from '@prisma/client';
 import { IUserRequestInterface } from 'apps/agent-service/src/interface/agent-service.interface';
 import { IssueCredentialType } from 'apps/api-gateway/src/issuance/interfaces';
 
@@ -315,4 +315,8 @@ export interface IQueuePayload{
   totalJobs: number;
   isRetry: boolean;
   isLastData: boolean;
+}
+export interface IDeletedFileUploadRecords {
+  deleteFileDetails: Prisma.BatchPayload;
+  deleteFileUploadDetails: Prisma.BatchPayload;
 }

apps/issuance/src/issuance.repository.ts

@@ -16,6 +16,7 @@ import { ResponseMessages } from '@credebl/common/response-messages';
 import {
   FileUpload,
   FileUploadData,
+  IDeletedFileUploadRecords,
   IssueCredentialWebhookPayload,
   OrgAgent,
   PreviewRequest,
@@ -590,6 +591,47 @@ export class IssuanceRepository {
     }
   }
 
+  async getFileUploadDataByOrgId(orgId: string): Promise<file_upload[]> {
+    try {
+      const fileDetails = await this.prisma.file_upload.findMany({
+        where: {
+          orgId
+        }
+      });
+      return fileDetails;
+    } catch (error) {
+      this.logger.error(`[getting file upload details] - error: ${JSON.stringify(error)}`);
+      throw error;
+    }
+  }
+
+  async deleteFileUploadData(fileUploadIds: string[], orgId: string): Promise<IDeletedFileUploadRecords> {
+    try {
+      return await this.prisma.$transaction(async (prisma) => {
+
+        const deleteFileDetails = await prisma.file_data.deleteMany({
+          where: {
+            fileUploadId: {
+              in: fileUploadIds
+            }
+          }
+        });
+
+        const deleteFileUploadDetails = await prisma.file_upload.deleteMany({
+          where: {
+            orgId
+          }
+        });
+
+        return { deleteFileDetails, deleteFileUploadDetails };
+
+      });
+    } catch (error) {
+      this.logger.error(`[Error in deleting file data] - error: ${JSON.stringify(error)}`);
+      throw error;
+    }
+  }
+
   async deleteIssuanceRecordsByOrgId(orgId: string): Promise<IDeletedIssuanceRecords> {
     try {
       const tablesToCheck = [`${PrismaTables.PRESENTATIONS}`];

apps/issuance/src/issuance.service.ts

@@ -1448,11 +1448,18 @@ async sendEmailForCredentialOffer(sendEmailCredentialOffer: SendEmailCredentialO
 
   async deleteIssuanceRecords(orgId: string, userDetails: user): Promise<IDeletedIssuanceRecords> {
     try {
+
+      const getFileUploadData = await this.issuanceRepository.getFileUploadDataByOrgId(orgId);
+
+      const getFileUploadIds = getFileUploadData.map(fileData => fileData.id);
+
+      await this.issuanceRepository.deleteFileUploadData(getFileUploadIds, orgId);
+
       const deletedCredentialsRecords = await this.issuanceRepository.deleteIssuanceRecordsByOrgId(orgId);
 
       if (0 === deletedCredentialsRecords?.deleteResult?.count) {
         throw new NotFoundException(ResponseMessages.issuance.error.issuanceRecordsNotFound);
-    }
+      }
 
     const statusCounts = {
         [IssuanceProcessState.REQUEST_SENT]: 0,
@@ -1482,7 +1489,7 @@ async sendEmailForCredentialOffer(sendEmailCredentialOffer: SendEmailCredentialO
       }; 
 
       await this.userActivityRepository._orgDeletedActivity(orgId, userDetails, deletedIssuanceData, RecordType.ISSUANCE_RECORD);
-
+    
       return deletedCredentialsRecords;
     } catch (error) {
       this.logger.error(`[deleteIssuanceRecords] - error in deleting issuance records: ${JSON.stringify(error)}`);