fix/schema migration

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

Author: sujitaw

apps/verification/src/repositories/verification.repository.ts

@@ -87,7 +87,7 @@ export class VerificationRepository {
     proofRequestsSearchCriteria: IProofRequestSearchCriteria
   ): Promise<IProofPresentationsListCount> {
     try {
-      const proofRequestsListData = await this.prisma.presentations.findMany({
+      const proofRequestsList = await this.prisma.presentations.findMany({
         where: {
           orgId,
           OR: [
@@ -106,7 +106,12 @@ export class VerificationRepository {
           presentationId: true,
           schemaId: true,
           emailId: true,
-          errorMessage: true
+          errorMessage: true,
+          connections: {
+            select: {
+              theirLabel: true
+            }
+          }
         },
         orderBy: {
           [proofRequestsSearchCriteria.sortField]: SortValue.ASC === proofRequestsSearchCriteria.sortBy ? 'asc' : 'desc'
@@ -116,22 +121,6 @@ export class VerificationRepository {
         skip: (proofRequestsSearchCriteria.pageNumber - 1) * proofRequestsSearchCriteria.pageSize
       });
 
-      const proofRequestsList = await Promise.all(
-        proofRequestsListData.map(async (presentation) => {
-          if (!presentation.connectionId) {
-            return { ...presentation, theirLabel: null };
-          }
-          const connection = await this.prisma.connections.findUnique({
-            where: { connectionId: presentation.connectionId },
-            select: { theirLabel: true }
-          });
-          return {
-            ...presentation,
-            theirLabel: connection?.theirLabel ?? null
-          };
-        })
-      );
-
       const proofRequestsCount = await this.prisma.presentations.count({
         where: {
           orgId,
@@ -309,17 +298,16 @@ export class VerificationRepository {
     }
   }
 
-  async addEmailAfterVerification(emailList: IEmailResponse[]): Promise<void> {
+  async saveEmail(emailList: IEmailResponse[]): Promise<void> {
     try {
       for (const { proofRecordThId, email } of emailList) {
         await this.prisma.presentations.updateMany({
           where: { threadId: proofRecordThId },
           data: { emailId: email }
         });
       }
-      // return this.prisma.organisation.findFirst({ where: { id: orgId } });
     } catch (error) {
-      this.logger.error(`[getOrganization] - error: ${JSON.stringify(error)}`);
+      this.logger.error(`[Verification Save Email] - error: ${JSON.stringify(error)}`);
       throw error;
     }
   }

apps/verification/src/verification.service.ts

@@ -570,7 +570,7 @@ export class VerificationService {
       }
       if (emailId) {
         const emailResponse = await this.sendEmailInBatches(payload, emailId, getAgentDetails, getOrganization);
-        await this.verificationRepository.addEmailAfterVerification(emailResponse as IEmailResponse[]);
+        await this.verificationRepository.saveEmail(emailResponse as IEmailResponse[]);
         return emailResponse;
       } else {
         const presentationProof: IInvitation = await this.generateOOBProofReq(payload);

libs/prisma-service/prisma/migrations/20250721132721_added_relation_for_presentation_with_connection_table/migration.sql

@@ -0,0 +1,2 @@
+-- AddForeignKey
+ALTER TABLE "presentations" ADD CONSTRAINT "presentations_connectionId_fkey" FOREIGN KEY ("connectionId") REFERENCES "connections"("connectionId") ON DELETE SET NULL ON UPDATE CASCADE;

libs/prisma-service/prisma/schema.prisma

@@ -325,6 +325,7 @@ model connections {
   state               String
   orgId               String?       @db.Uuid
   organisation        organisation? @relation(fields: [orgId], references: [id])
+  presentations       presentations[]
 }
 
 model credentials {
@@ -349,7 +350,7 @@ model presentations {
   createdBy           String        @db.Uuid
   lastChangedDateTime DateTime      @default(now()) @db.Timestamptz(6)
   lastChangedBy       String        @db.Uuid
-  connectionId        String?
+  connectionId        String?       
   state               String?
   threadId            String        @unique
   isVerified          Boolean?
@@ -359,6 +360,8 @@ model presentations {
   emailId             String?
   orgId               String?       @db.Uuid
   organisation        organisation? @relation(fields: [orgId], references: [id])
+  connections         connections?  @relation(fields: [connectionId], references: [connectionId])
+
 }
 
 model file_upload {