feat: archive schema for deleted wallet (#1078)

* feat: archive schemas

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

* refactor: update function name

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

---------

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

Author: bhavanakarwade

apps/agent-service/src/agent-service.service.ts

@@ -1722,6 +1722,11 @@ export class AgentServiceService {
                 { records: deleteOrgAgent ? 1 : 0, tableName: 'org_agents' }
             ];
 
+            const did = orgAgent?.orgDid;
+
+            //archive schemas
+            await this._updateIsSchemaArchivedFlag(did);
+
             const logDeletionActivity = async (records, tableName): Promise<void> => {
                 if (records) {
                     const txnMetadata = {
@@ -1745,6 +1750,30 @@ export class AgentServiceService {
     }
 }
 
+async _updateIsSchemaArchivedFlag(did: string): Promise<{
+  count: number
+}> {
+  const pattern = { cmd: 'archive-schemas' };
+
+  const payload = {
+    did
+  };
+  const updatedSchemaInfo = await this.agentServiceProxy
+    .send(pattern, payload)
+    .toPromise()
+    .catch((error) => {
+      this.logger.error(`catch: ${JSON.stringify(error)}`);
+      throw new HttpException(
+        {
+          status: error.status,
+          error: error.message
+        },
+        error.status
+      );
+    });
+  return updatedSchemaInfo;
+}
+
   async receiveInvitationUrl(receiveInvitationUrl: IReceiveInvitationUrl, url: string, orgId: string): Promise<string> {
     try {
       const getApiKey = await this.getOrgAgentApiKey(orgId);

apps/ledger/src/credential-definition/credential-definition.service.ts

@@ -341,14 +341,18 @@ export class CredentialDefinitionService extends BaseService {
 
                 return schemaResponse;
             }
-            const credDefSchemaList: CredDefSchema[] =
+            const credDefSchemaList =
                 await this.credentialDefinitionRepository.getAllCredDefsByOrgIdForBulk(
                     payload
                 );
+ 
             if (!credDefSchemaList) {
                 throw new NotFoundException(ResponseMessages.credentialDefinition.error.NotFound);
             }
-            return credDefSchemaList;
+
+            const activeCredDefSchemaList = credDefSchemaList.filter((item) => !item?.['isSchemaArchived']);
+            
+            return activeCredDefSchemaList;
         } catch (error) {
             this.logger.error(
                 `get Cred-Defs and schema List By OrgId for bulk operations: ${JSON.stringify(error)}`

apps/ledger/src/credential-definition/repositories/credential-definition.repository.ts

@@ -243,7 +243,8 @@ export class CredentialDefinitionRepository {
                     version: true,
                     schemaLedgerId: true,
                     orgId: true,
-                    attributes: true
+                    attributes: true,
+                    isSchemaArchived: true
                 }
             });
 
@@ -254,11 +255,13 @@ export class CredentialDefinitionRepository {
                 if (matchingSchema) {
                     return {
                         credentialDefinitionId: credDef.credentialDefinitionId,
+                        credentialDefinition: credDef.tag,
                         schemaCredDefName: `${matchingSchema.name}:${matchingSchema.version}-${credDef.tag}`,
                         schemaName: matchingSchema.name,
                         schemaVersion: matchingSchema.version,
                         schemaAttributes: matchingSchema.attributes,
-                        credentialDefinition: credDef.tag
+                        schemaLedgerId: matchingSchema.schemaLedgerId,
+                        isSchemaArchived: matchingSchema.isSchemaArchived
                     };
                 }
                 return null;
@@ -277,6 +280,7 @@ export class CredentialDefinitionRepository {
             return await this.prisma.schema.findMany({
                 where: {
                     orgId,
+                    isSchemaArchived: false,
                     type: schemaType 
                 },
                 select: {

apps/ledger/src/schema/repositories/schema.repository.ts

@@ -1,7 +1,7 @@
 /* eslint-disable camelcase */
 import { ConflictException, Injectable, InternalServerErrorException, Logger } from '@nestjs/common';
 import { PrismaService } from '@credebl/prisma-service';
-import { ledgers, org_agents, org_agents_type, organisation, schema } from '@prisma/client';
+import { ledgers, org_agents, org_agents_type, organisation, Prisma, schema } from '@prisma/client';
 import { ISchema, ISchemaExist, ISchemaSearchCriteria, ISaveSchema } from '../interfaces/schema-payload.interface';
 import { ResponseMessages } from '@credebl/common/response-messages';
 import { AgentDetails, ISchemasWithCount } from '../interfaces/schema.interface';
@@ -36,7 +36,8 @@ export class SchemaRepository {
             publisherDid: schemaResult.issuerId.split(':')[4] || schemaResult.issuerId,
             orgId: schemaResult.orgId,
             ledgerId: schemaResult.ledgerId,
-            type: schemaResult.type
+            type: schemaResult.type,
+            isSchemaArchived: false
           }
         });
         return saveResult;
@@ -77,6 +78,7 @@ export class SchemaRepository {
       return this.prisma.schema.findMany({
         where: {
           type: SchemaType.INDY,
+          isSchemaArchived: false,
           name: {
             contains: schemaName,
             mode: 'insensitive'
@@ -98,6 +100,7 @@ export class SchemaRepository {
       const schemasResult = await this.prisma.schema.findMany({
         where: {
           organisation: { id: orgId },
+          isSchemaArchived: false,
           OR: [
             { name: { contains: payload.searchByText, mode: 'insensitive' } },
             { version: { contains: payload.searchByText, mode: 'insensitive' } },
@@ -176,6 +179,24 @@ export class SchemaRepository {
     }
   }
 
+  async archiveSchemasByDid(did: string): Promise<Prisma.BatchPayload> {
+    try {
+      const schemasResult = await this.prisma.schema.updateMany({
+        where: {
+          issuerId: did
+        },
+        data: {
+          isSchemaArchived: true
+        }
+      });
+
+      return schemasResult;
+    } catch (error) {
+      this.logger.error(`Error in archive schemas: ${error}`);
+      throw error;
+    }
+  }
+
   async getAgentDetailsByOrgId(orgId: string): Promise<AgentDetails> {
     try {
       const schemasResult = await this.prisma.org_agents.findFirst({
@@ -275,6 +296,7 @@ export class SchemaRepository {
         schemaResult = await this.prisma.schema.findMany({
           where: {
             ledgerId,
+            isSchemaArchived: false,
             type: schemaType,
             OR: [
               { name: { contains: searchByText, mode: 'insensitive' } },
@@ -289,6 +311,7 @@ export class SchemaRepository {
             version: true,
             attributes: true,
             schemaLedgerId: true,
+            isSchemaArchived: true,
             createdBy: true,
             publisherDid: true,
             orgId: true,  // This field can be null
@@ -307,6 +330,7 @@ export class SchemaRepository {
         schemaResult = await this.prisma.schema.findMany({
           where: {
             ledgerId,
+            isSchemaArchived: false,
             type: schemaType
           },
           select: {
@@ -315,6 +339,7 @@ export class SchemaRepository {
             version: true,
             attributes: true,
             schemaLedgerId: true,
+            isSchemaArchived: true,
             createdBy: true,
             publisherDid: true,
             orgId: true,  // This field can be null

apps/ledger/src/schema/schema.controller.ts

@@ -8,7 +8,7 @@ import {
   ISchemaSearchPayload,
   SaveSchemaPayload
 } from './interfaces/schema-payload.interface';
-import { schema } from '@prisma/client';
+import { Prisma, schema } from '@prisma/client';
 import {
   ICredDefWithPagination,
   ISchemaData,
@@ -75,6 +75,11 @@ export class SchemaController {
     return this.schemaService.schemaExist(payload);
   }
 
+  @MessagePattern({ cmd: 'archive-schemas' })
+  async archiveSchemas(payload: {did: string}): Promise<Prisma.BatchPayload> {
+    return this.schemaService.archiveSchemas(payload.did);
+  }
+
   @MessagePattern({ cmd: 'store-schema-record' })
   async saveSchemaRecord(payload: SaveSchemaPayload): Promise<schema> {
     return this.schemaService.storeSchemaDetails(payload.schemaDetails);

apps/ledger/src/schema/schema.service.ts

@@ -9,7 +9,7 @@ import {
 import { ClientProxy, RpcException } from '@nestjs/microservices';
 import { BaseService } from 'libs/service/base.service';
 import { SchemaRepository } from './repositories/schema.repository';
-import { schema } from '@prisma/client';
+import { Prisma, schema } from '@prisma/client';
 import { ISaveSchema, ISchema, ISchemaCredDeffSearchInterface, ISchemaExist, ISchemaSearchCriteria, W3CCreateSchema } from './interfaces/schema-payload.interface';
 import { ResponseMessages } from '@credebl/common/response-messages';
 import { ICreateSchema, ICreateW3CSchema, IGenericSchema, IUserRequestInterface } from './interfaces/schema.interface';
@@ -54,6 +54,7 @@ export class SchemaService extends BaseService {
           schema.schemaName,
           schema.schemaVersion
            );
+
            if (0 !== schemaExists.length) {
              this.logger.error(ResponseMessages.schema.error.exists);
              throw new ConflictException(
@@ -886,6 +887,15 @@ export class SchemaService extends BaseService {
     }
   }
 
+  async archiveSchemas(did: string): Promise<Prisma.BatchPayload> {
+    try {
+      const schemaDetails = await this.schemaRepository.archiveSchemasByDid(did);
+      return schemaDetails;
+    } catch (error) {
+      this.logger.error(`Error in archive schemas: ${error}`);
+      throw new RpcException(error.response ? error.response : error);
+    }
+  }
 
   async storeSchemaDetails(schemaDetails: ISaveSchema): Promise<schema> {
     try {

apps/organization/repositories/organization.repository.ts

@@ -500,9 +500,12 @@ export class OrganizationRepository {
       );
 
       const schemasCount = await this.prisma.schema.count({
-        ...query
+        where: {
+          orgId,
+          isSchemaArchived: false
+        }
       });
-
+      
       const credentialsCount = await this.prisma.credentials.count({
         ...query
       });

apps/organization/src/organization.service.ts

@@ -28,7 +28,7 @@ import { CreateOrganizationDto } from '../dtos/create-organization.dto';
 import { BulkSendInvitationDto } from '../dtos/send-invitation.dto';
 import { UpdateInvitationDto } from '../dtos/update-invitation.dt';
 import { DidMethod, Invitation, Ledgers, PrismaTables, transition } from '@credebl/enum/enum';
-import { IGetOrgById, IGetOrganization, IUpdateOrganization, IOrgAgent, IClientCredentials, ICreateConnectionUrl, IOrgRole, IDidList, IPrimaryDidDetails, IEcosystemOrgStatus, IOrgDetails } from '../interfaces/organization.interface';
+import { IGetOrgById, IGetOrganization, IUpdateOrganization, IClientCredentials, ICreateConnectionUrl, IOrgRole, IDidList, IPrimaryDidDetails, IEcosystemOrgStatus, IOrgDetails } from '../interfaces/organization.interface';
 import { UserActivityService } from '@credebl/user-activity';
 import { ClientRegistrationService } from '@credebl/client-registration/client-registration.service';
 import { map } from 'rxjs/operators';
@@ -1659,38 +1659,6 @@ export class OrganizationService {
     return isEmailSent;
   }
 
-  async _deleteWallet(payload: IOrgAgent): Promise<{
-    response;
-  }> {
-    try {
-      const pattern = {
-        cmd: 'delete-wallet'
-      };
-
-      return this.organizationServiceProxy
-        .send<string>(pattern, payload)
-        .pipe(
-          map((response) => ({
-            response
-          }))
-        )
-        .toPromise()
-        .catch((error) => {
-          this.logger.error(`catch: ${JSON.stringify(error)}`);
-          throw new HttpException(
-            {
-              status: error.statusCode,
-              error: error.message
-            },
-            error.error
-          );
-        });
-    } catch (error) {
-      this.logger.error(`[_deleteWallet] - error in delete wallet : ${JSON.stringify(error)}`);
-      throw error;
-    }
-  }
-
   async getUserKeycloakIdByEmail(userEmails: string[]): Promise<{
     response;
   }> {

libs/prisma-service/prisma/migrations/20241114081928_added_is_schema_archived_flag_schema/migration.sql

@@ -0,0 +1,2 @@
+-- AlterTable
+ALTER TABLE "schema" ADD COLUMN     "isSchemaArchived" BOOLEAN NOT NULL DEFAULT false;

libs/prisma-service/prisma/schema.prisma

@@ -267,6 +267,7 @@ model schema {
   ledgers               ledgers?                @relation(fields: [ledgerId], references: [id])
   ledgerId              String?                 @db.Uuid
   type                  String?                 @db.VarChar
+  isSchemaArchived      Boolean                 @default(false)
   credential_definition credential_definition[]
 }