feat: delete exchange record

samples/cliConfig.json

@@ -23,7 +23,7 @@
       "indyNamespace": "bcovrin:testnet"
     }
   ],
-  "endpoint": ["http://localhost:4002"],
+  "endpoint": ["http://192.168.1.71:4002"],
   "autoAcceptConnections": true,
   "autoAcceptCredentials": "always",
   "autoAcceptProofs": "contentApproved",
@@ -42,5 +42,6 @@
   "schemaManagerContractAddress": "0x4742d43C2dFCa5a1d4238240Afa8547Daf87Ee7a",
   "rpcUrl": "https://rpc-amoy.polygon.technology",
   "fileServerUrl": "https://schema.credebl.id",
-  "fileServerToken": "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJBeWFuV29ya3MiLCJpZCI6ImNhZDI3ZjhjLTMyNWYtNDRmZC04ZmZkLWExNGNhZTY3NTMyMSJ9.I3IR7abjWbfStnxzn1BhxhV0OEzt1x3mULjDdUcgWHk"
+  "fileServerToken": "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJBeWFuV29ya3MiLCJpZCI6ImNhZDI3ZjhjLTMyNWYtNDRmZC04ZmZkLWExNGNhZTY3NTMyMSJ9.I3IR7abjWbfStnxzn1BhxhV0OEzt1x3mULjDdUcgWHk",
+  "isPreserveExchangeRecords": false
 }

samples/cliConfigHolder.json

@@ -0,0 +1,47 @@
+{
+    "label": "AFJ Rest Agent 2",
+    "walletId": "sampleHolder",
+    "walletKey": "sampleHolder",
+    "walletType": "postgres",
+    "walletUrl": "localhost:5432",
+    "walletAccount": "postgres",
+    "walletPassword": "postgres",
+    "walletAdminAccount": "postgres",
+    "walletAdminPassword": "postgres",
+    "walletScheme": "ProfilePerWallet",
+    "indyLedger": [
+      {
+        "genesisTransactions": "https://raw.githubusercontent.com/Indicio-tech/indicio-network/main/genesis_files/pool_transactions_testnet_genesis",
+        "indyNamespace": "indicio:testnet"
+      },
+      {
+        "genesisTransactions": "https://raw.githubusercontent.com/Indicio-tech/indicio-network/main/genesis_files/pool_transactions_demonet_genesis",
+        "indyNamespace": "indicio:demonet"
+      },
+      {
+        "genesisTransactions": "https://raw.githubusercontent.com/bcgov/von-network/main/BCovrin/genesis_test",
+        "indyNamespace": "bcovrin:testnet"
+      }
+    ],
+    "endpoint": ["http://192.168.1.71:4004"],
+    "autoAcceptConnections": true,
+    "autoAcceptCredentials": "always",
+    "autoAcceptProofs": "contentApproved",
+    "logLevel": 2,
+    "inboundTransport": [
+      {
+        "transport": "http",
+        "port": 4004
+      }
+    ],
+    "outboundTransport": ["http"],
+    "adminPort": 4003,
+    "tenancy": true,
+    "schemaFileServerURL": "https://schema.credebl.id/schemas/",
+    "didRegistryContractAddress": "0xcB80F37eDD2bE3570c6C9D5B0888614E04E1e49E",
+    "schemaManagerContractAddress": "0x4742d43C2dFCa5a1d4238240Afa8547Daf87Ee7a",
+    "rpcUrl": "https://rpc-amoy.polygon.technology",
+    "fileServerUrl": "https://schema.credebl.id",
+    "fileServerToken": "eyJhbGciOiJIUzI1NiIsInR5cCI6IkpXVCJ9.eyJpc3MiOiJBeWFuV29ya3MiLCJpZCI6ImNhZDI3ZjhjLTMyNWYtNDRmZC04ZmZkLWExNGNhZTY3NTMyMSJ9.I3IR7abjWbfStnxzn1BhxhV0OEzt1x3mULjDdUcgWHk",
+    "isPreserveExchangeRecords": false
+  }

src/cli.ts

@@ -42,6 +42,7 @@ interface Parsed {
   rpcUrl?: string
   fileServerUrl?: string
   fileServerToken?: string
+  isPreserveExchangeRecords?: boolean
 }
 
 interface InboundTransport {
@@ -252,5 +253,6 @@ export async function runCliServer() {
     rpcUrl: parsed.rpcUrl,
     fileServerUrl: parsed.fileServerUrl,
     fileServerToken: parsed.fileServerToken,
+    isPreserveExchangeRecords: parsed.isPreserveExchangeRecords,
   } as AriesRestConfig)
-}
+}

src/cliAgent.ts

@@ -100,6 +100,7 @@ export interface AriesRestConfig {
   fileServerToken?: string
   walletScheme?: AskarMultiWalletDatabaseScheme
   schemaFileServerURL?: string
+  isPreserveExchangeRecords?: boolean
 }
 
 export async function readRestConfig(path: string) {
@@ -124,7 +125,9 @@ const getModules = (
   autoAcceptConnections: boolean,
   autoAcceptCredentials: AutoAcceptCredential,
   autoAcceptProofs: AutoAcceptProof,
-  walletScheme: AskarMultiWalletDatabaseScheme
+  walletScheme: AskarMultiWalletDatabaseScheme,
+  // eslint-disable-next-line @typescript-eslint/no-unused-vars
+  isPreserveExchangeRecords: boolean
 ) => {
   const legacyIndyCredentialFormat = new LegacyIndyCredentialFormatService()
   const legacyIndyProofFormat = new LegacyIndyProofFormatService()
@@ -189,8 +192,11 @@ const getModules = (
 
     questionAnswer: new QuestionAnswerModule(),
     polygon: new PolygonModule({
-      didContractAddress: didRegistryContractAddress ? didRegistryContractAddress : (process.env.DID_CONTRACT_ADDRESS as string),
-      schemaManagerContractAddress: schemaManagerContractAddress || (process.env.SCHEMA_MANAGER_CONTRACT_ADDRESS as string),
+      didContractAddress: didRegistryContractAddress
+        ? didRegistryContractAddress
+        : (process.env.DID_CONTRACT_ADDRESS as string),
+      schemaManagerContractAddress:
+        schemaManagerContractAddress || (process.env.SCHEMA_MANAGER_CONTRACT_ADDRESS as string),
       fileServerToken: fileServerToken ? fileServerToken : (process.env.FILE_SERVER_TOKEN as string),
       rpcUrl: rpcUrl ? rpcUrl : (process.env.RPC_URL as string),
       serverUrl: fileServerUrl ? fileServerUrl : (process.env.SERVER_URL as string),
@@ -209,7 +215,8 @@ const getWithTenantModules = (
   autoAcceptConnections: boolean,
   autoAcceptCredentials: AutoAcceptCredential,
   autoAcceptProofs: AutoAcceptProof,
-  walletScheme: AskarMultiWalletDatabaseScheme
+  walletScheme: AskarMultiWalletDatabaseScheme,
+  isPreserveExchangeRecords: boolean
 ) => {
   const modules = getModules(
     networkConfig,
@@ -221,7 +228,8 @@ const getWithTenantModules = (
     autoAcceptConnections,
     autoAcceptCredentials,
     autoAcceptProofs,
-    walletScheme
+    walletScheme,
+    isPreserveExchangeRecords
   )
   return {
     tenants: new TenantsModule<typeof modules>({
@@ -268,6 +276,7 @@ export async function runRestAgent(restConfig: AriesRestConfig) {
     autoAcceptCredentials,
     autoAcceptProofs,
     walletScheme,
+    isPreserveExchangeRecords,
     ...afjConfig
   } = restConfig
 
@@ -281,6 +290,8 @@ export async function runRestAgent(restConfig: AriesRestConfig) {
     },
     ...afjConfig,
     logger,
+    isPreserveExchangeRecords:
+      isPreserveExchangeRecords || (process.env.IS_PRESERVE_EXCHANGE_RECORD as unknown as boolean) || true,
     autoUpdateStorageOnStartup: true,
     // As backup is only supported for sqlite storage
     // we need to manually take backup of the storage before updating the storage
@@ -352,7 +363,8 @@ export async function runRestAgent(restConfig: AriesRestConfig) {
     autoAcceptConnections || true,
     autoAcceptCredentials || AutoAcceptCredential.Always,
     autoAcceptProofs || AutoAcceptProof.ContentApproved,
-    walletScheme || AskarMultiWalletDatabaseScheme.ProfilePerWallet
+    walletScheme || AskarMultiWalletDatabaseScheme.ProfilePerWallet,
+    isPreserveExchangeRecords || (process.env.IS_PRESERV_EXCHANGE_RECORD as unknown as boolean)
   )
   const modules = getModules(
     networkConfig,
@@ -364,7 +376,8 @@ export async function runRestAgent(restConfig: AriesRestConfig) {
     autoAcceptConnections || true,
     autoAcceptCredentials || AutoAcceptCredential.Always,
     autoAcceptProofs || AutoAcceptProof.ContentApproved,
-    walletScheme || AskarMultiWalletDatabaseScheme.ProfilePerWallet
+    walletScheme || AskarMultiWalletDatabaseScheme.ProfilePerWallet,
+    isPreserveExchangeRecords || (process.env.IS_PRESERV_EXCHANGE_RECORD as unknown as boolean)
   )
   const agent = new Agent({
     config: agentConfig,
@@ -440,4 +453,4 @@ export async function runRestAgent(restConfig: AriesRestConfig) {
   app.listen(adminPort, () => {
     logger.info(`Successfully started server on port ${adminPort}`)
   })
-}
+}

src/controllers/credentials/CredentialController.ts

@@ -211,6 +211,7 @@ export class CredentialController extends Controller {
         credentialFormats: outOfBandOption.credentialFormats,
         autoAcceptCredential: outOfBandOption.autoAcceptCredential,
         comment: outOfBandOption.comment,
+        isPreserveExchangeRecord: outOfBandOption.isPreserveExchangeRecord,
       })
 
       const credentialMessage = offerOob.message
@@ -295,4 +296,4 @@ export class CredentialController extends Controller {
       throw ErrorHandlingService.handle(error)
     }
   }
-}
+}

src/controllers/multi-tenancy/MultiTenancyController.ts

@@ -1279,6 +1279,7 @@ export class MultiTenancyController extends Controller {
           protocolVersion: createOfferOptions.protocolVersion as CredentialProtocolVersionType<[]>,
           credentialFormats: createOfferOptions.credentialFormats,
           autoAcceptCredential: createOfferOptions.autoAcceptCredential,
+          isPreserveExchangeRecord: createOfferOptions.isPreserveExchangeRecord,
         })
       })
 
@@ -1328,6 +1329,7 @@ export class MultiTenancyController extends Controller {
           credentialFormats: createOfferOptions.credentialFormats,
           autoAcceptCredential: createOfferOptions.autoAcceptCredential,
           comment: createOfferOptions.comment,
+          isPreserveExchangeRecord: createOfferOptions.isPreserveExchangeRecord,
         })
 
         const credentialMessage = offerOob.message
@@ -1526,6 +1528,7 @@ export class MultiTenancyController extends Controller {
           parentThreadId: createRequestOptions.parentThreadId,
           autoAcceptProof: createRequestOptions.autoAcceptProof,
           comment: createRequestOptions.comment,
+          isPreserveExchangeRecord: createRequestOptions.isPreserveExchangeRecord,
         })
 
         const proofMessage = proof.message
@@ -1888,4 +1891,4 @@ export class MultiTenancyController extends Controller {
       throw ErrorHandlingService.handle(error)
     }
   }
-}
+}

src/controllers/proofs/ProofController.ts

@@ -181,6 +181,7 @@ export class ProofController extends Controller {
         parentThreadId: createRequestOptions.parentThreadId,
         autoAcceptProof: createRequestOptions.autoAcceptProof,
         comment: createRequestOptions.comment,
+        isPreserveExchangeRecord: createRequestOptions.isPreserveExchangeRecord,
       })
       const proofMessage = proof.message
       const outOfBandRecord = await this.agent.oob.createInvitation({
@@ -279,4 +280,4 @@ export class ProofController extends Controller {
       throw ErrorHandlingService.handle(error)
     }
   }
-}
+}

src/controllers/types.ts

@@ -89,6 +89,7 @@ export interface AcceptCredentialProposalOptions {
 }
 
 export interface CreateOfferOptions {
+  isPreserveExchangeRecord?: boolean
   protocolVersion: ProtocolVersion
   connectionId: RecordId
   credentialFormats: CredentialFormatPayload<CredentialFormats, 'createOffer'>
@@ -99,6 +100,7 @@ export interface CreateOfferOptions {
 type CredentialFormatType = LegacyIndyCredentialFormat | JsonLdCredentialFormat | AnonCredsCredentialFormat
 
 export interface CreateOfferOobOptions {
+  isPreserveExchangeRecord?: boolean
   protocolVersion: string
   credentialFormats: CredentialFormatPayload<CredentialFormatType[], 'createOffer'>
   autoAcceptCredential?: AutoAcceptCredential
@@ -119,6 +121,7 @@ export interface CredentialCreateOfferOptions {
 }
 
 export interface CreateProofRequestOobOptions {
+  isPreserveExchangeRecord?: boolean
   protocolVersion: string
   proofFormats: any
   goalCode?: string
@@ -234,6 +237,7 @@ export interface ConnectionInvitationSchema {
 // }
 
 export interface RequestProofOptions {
+  isPreserveExchangeRecord?: boolean
   connectionId: string
   protocolVersion: string
   proofFormats: any
@@ -387,4 +391,4 @@ export interface SchemaMetadata {
 /**
  * @example "ea4e5e69-fc04-465a-90d2-9f8ff78aa71d"
  */
-export type ThreadId = string
+export type ThreadId = string

src/utils/agent.ts

@@ -41,6 +41,7 @@ export const setupAgent = async ({ name, endpoints, port }: { name: string; endp
   const logger = new TsLogger(LogLevel.debug)
 
   const config: InitConfig = {
+    isPreserveExchangeRecords: (process.env.IS_PRESERVE_EXCHANGE_RECORD as unknown as boolean) || true,
     label: name,
     endpoints: endpoints,
     walletConfig: {
@@ -146,4 +147,4 @@ export const setupAgent = async ({ name, endpoints, port }: { name: string; endp
   await agent.initialize()
 
   return agent
-}
+}