Update agent modules setup + remove mediator functionality

Signed-off-by: Alexander Shenshin <alexander.shenshin@dsr-corporation.com>

Author: AlexanderShenshin

heka-identity-service/docs/setup.md

@@ -38,11 +38,6 @@ You can modify JWT verification options by setting the following environment var
 
 While integration with external auth providers is supported, it's recommended to use [Heka Auth Service](https://github.com/hiero-ledger/heka-identity-platform/tree/main/heka-auth-service) for basic deployments.
 
-## Mediator
-
-Heka Identity Service can also function as a Credo Mediator. To enable this functionality
-set `AGENT_AUTO_ACCEPT_MEDIATION_REQUESTS` environment variable to `true`
-
 ## Persistence
 
 For persistence this backend uses `MikroORM` with `Postgres` and requires access to pre-configured `Postgres` instance.

heka-identity-service/jest.config.ts

@@ -35,7 +35,9 @@ const config: Config = {
     // Force CJS builds for other @hiero-did-sdk packages which expose ESM via .js extension without "type":"module"
     '^@hiero-did-sdk/(.+)$': '<rootDir>/node_modules/@hiero-did-sdk/$1/dist/index.cjs.js',
   },
-  transformIgnorePatterns: ['/node_modules/(?!(@credo-ts|@openid4vc|dcql|@noble|@sphereon|@sd-jwt|@stablelib|@digitalcredentials|uuid)/)'],
+  transformIgnorePatterns: [
+    '/node_modules/(?!(@credo-ts|@openid4vc|dcql|@noble|@sphereon|@sd-jwt|@stablelib|@digitalcredentials|uuid)/)',
+  ],
   verbose: true,
 }
 

heka-identity-service/package.json

@@ -28,15 +28,15 @@
     "postinstall": "patch-package"
   },
   "dependencies": {
-    "@credo-ts/anoncreds": "v0.6.2",
-    "@credo-ts/askar": "v0.6.2",
-    "@credo-ts/core": "v0.6.2",
-    "@credo-ts/didcomm": "v0.6.2",
-    "@credo-ts/hedera": "0.6.0",
-    "@credo-ts/indy-vdr": "v0.6.2",
-    "@credo-ts/node": "v0.6.2",
-    "@credo-ts/openid4vc": "v0.6.2",
-    "@credo-ts/tenants": "v0.6.2",
+    "@credo-ts/anoncreds": "0.6.2",
+    "@credo-ts/askar": "0.6.2",
+    "@credo-ts/core": "0.6.2",
+    "@credo-ts/didcomm": "0.6.2",
+    "@credo-ts/hedera": "0.6.2",
+    "@credo-ts/indy-vdr": "0.6.2",
+    "@credo-ts/node": "0.6.2",
+    "@credo-ts/openid4vc": "0.6.2",
+    "@credo-ts/tenants": "0.6.2",
     "@digitalcredentials/bitstring": "^3.1.2",
     "@hyperledger/anoncreds-nodejs": "^0.3.1",
     "@hyperledger/indy-vdr-nodejs": "^0.2.2",
@@ -128,9 +128,7 @@
   },
   "resolutions": {
     "@types/jsonwebtoken": "^9.0.10",
-    "reflect-metadata": "0.2.2",
-    "@credo-ts/core": "v0.6.2",
-    "@credo-ts/anoncreds": "v0.6.2"
+    "reflect-metadata": "0.2.2"
   },
   "packageManager": "yarn@4.9.4"
 }

heka-identity-service/src/app.module.ts

@@ -15,9 +15,6 @@ import { VerificationTemplateModule } from 'verification-template/verification-t
 import { LoggerModule } from './common/logger'
 import { OCAModule } from './common/oca/oca.module'
 import { fileStorageConfigDefaults } from './config/file-storage'
-
-// eslint-disable-next-line @typescript-eslint/no-unnecessary-condition
-const _appRoot = typeof __dirname !== 'undefined' ? resolve(__dirname, '..') : process.cwd()
 import { ConnectionModule } from './connection'
 import { CoreModule } from './core'
 import { CredentialModule } from './credential'
@@ -32,6 +29,8 @@ import { SchemaModule } from './schema'
 import { SchemaV2Module } from './schema-v2'
 import { UserModule } from './user'
 
+const _appRoot = typeof __dirname !== 'undefined' ? resolve(__dirname, '..') : process.cwd()
+
 @Module({
   imports: [
     ServeStaticModule.forRoot({

heka-identity-service/src/common/agent/agent-modules.provider.ts

@@ -21,14 +21,8 @@ import {
 import {
   DidCommAutoAcceptCredential,
   DidCommAutoAcceptProof,
-  DidCommConnectionsModule,
-  DidCommCredentialsModule,
   DidCommModule,
   DidCommDifPresentationExchangeProofFormatService,
-  DidCommMediatorModule,
-  DidCommMessagePickupModule,
-  DidCommOutOfBandModule,
-  DidCommProofsModule,
   DidCommCredentialV2Protocol,
   DidCommProofV2Protocol,
 } from '@credo-ts/didcomm'
@@ -39,7 +33,7 @@ import {
   IndyVdrIndyDidResolver,
   IndyVdrModule,
 } from '@credo-ts/indy-vdr'
-import { OpenId4VcIssuerModule, OpenId4VcVerifierModule } from '@credo-ts/openid4vc'
+import { OpenId4VcModule } from '@credo-ts/openid4vc'
 import { TenantsModule } from '@credo-ts/tenants'
 import { anoncreds } from '@hyperledger/anoncreds-nodejs'
 import { indyVdr } from '@hyperledger/indy-vdr-nodejs'
@@ -62,80 +56,79 @@ function getTenantModulesMap(appConfig: ConfigType<typeof AppConfig>, agencyConf
   const presentationExchangeProofFormatService = new DidCommDifPresentationExchangeProofFormatService()
 
   const didResolvers: DidResolver[] = [new KeyDidResolver()]
-  const didRegisters: DidRegistrar[] = [new KeyDidRegistrar()]
-  const anoncredsRegstries: AnonCredsRegistry[] = []
+  const didRegistrars: DidRegistrar[] = [new KeyDidRegistrar()]
+  const anoncredsRegistries: AnonCredsRegistry[] = []
 
   if (agencyConfig.didMethods.includes('indy')) {
     didResolvers.push(new IndyVdrIndyDidResolver())
-    didRegisters.push(new IndyVdrIndyDidRegistrar())
-    anoncredsRegstries.push(new IndyVdrAnonCredsRegistry())
+    didRegistrars.push(new IndyVdrIndyDidRegistrar())
+    anoncredsRegistries.push(new IndyVdrAnonCredsRegistry())
   }
   if (agencyConfig.didMethods.includes('indybesu')) {
     didResolvers.push(new IndyBesuDidResolver())
-    didRegisters.push(new IndyBesuDidRegistrar())
-    anoncredsRegstries.push(new IndyBesuAnonCredsRegistry())
+    didRegistrars.push(new IndyBesuDidRegistrar())
+    anoncredsRegistries.push(new IndyBesuAnonCredsRegistry())
   }
   if (agencyConfig.didMethods.includes('hedera')) {
     didResolvers.push(new HederaDidResolver())
-    didRegisters.push(new HederaDidRegistrar())
-    anoncredsRegstries.push(new HederaAnonCredsRegistry())
+    didRegistrars.push(new HederaDidRegistrar())
+    anoncredsRegistries.push(new HederaAnonCredsRegistry())
   }
 
   return {
-    connections: new DidCommConnectionsModule({
-      autoAcceptConnections: true,
-    }),
-    credentials: new DidCommCredentialsModule({
-      autoAcceptCredentials: DidCommAutoAcceptCredential.ContentApproved,
-      credentialProtocols: [
-        new DidCommCredentialV2Protocol({
-          credentialFormats: [
-            credentialFormatService,
-            legacyIndyCredentialFormatService,
-            dataIntegrityCredentialFormatService,
-            // new JsonLdCredentialFormatService()
-          ],
-        }),
-      ],
-    }),
-    proofs: new DidCommProofsModule({
-      autoAcceptProofs: DidCommAutoAcceptProof.ContentApproved,
-      proofProtocols: [
-        new DidCommProofV2Protocol({
-          proofFormats: [legacyIndyProofFormatService, proofFormatService, presentationExchangeProofFormatService],
-        }),
-      ],
-    }),
-    didcomm: new DidCommModule(agencyConfig.didCommConfig),
-    oob: new DidCommOutOfBandModule(),
-    messagePickup: new DidCommMessagePickupModule(),
-    mediator: new DidCommMediatorModule({
-      autoAcceptMediationRequests: agencyConfig.autoAcceptMediationRequests,
+    didcomm: new DidCommModule({
+      ...agencyConfig.didCommConfig,
+      messagePickup: true,
+      connections: {
+        autoAcceptConnections: true,
+      },
+      credentials: {
+        autoAcceptCredentials: DidCommAutoAcceptCredential.ContentApproved,
+        credentialProtocols: [
+          new DidCommCredentialV2Protocol({
+            credentialFormats: [
+              credentialFormatService,
+              legacyIndyCredentialFormatService,
+              dataIntegrityCredentialFormatService,
+              // new JsonLdCredentialFormatService()
+            ],
+          }),
+        ],
+      },
+      proofs: {
+        autoAcceptProofs: DidCommAutoAcceptProof.ContentApproved,
+        proofProtocols: [
+          new DidCommProofV2Protocol({
+            proofFormats: [legacyIndyProofFormatService, proofFormatService, presentationExchangeProofFormatService],
+          }),
+        ],
+      },
     }),
     dids: new DidsModule({
       resolvers: didResolvers,
-      registrars: didRegisters,
+      registrars: didRegistrars,
     }),
     cache: new CacheModule({
       cache: new InMemoryLruCache({ limit: 100 }),
     }),
     anoncreds: new AnonCredsModule({
       // @ts-ignore
-      registries: anoncredsRegstries,
+      registries: anoncredsRegistries,
       anoncreds,
       tailsFileService: new TailsService(appConfig),
     }),
     askar: new AskarModule({
       askar,
       store: agencyConfig.askarStoreConfig,
     }),
-    openId4VcIssuer: new OpenId4VcIssuerModule({
-      baseUrl: agencyConfig.oidConfig.issuanceEndpoint,
-      app: agencyConfig.oidConfig.app,
-      credentialRequestToCredentialMapper,
-    }),
-    openId4VcVerifier: new OpenId4VcVerifierModule({
-      baseUrl: agencyConfig.oidConfig.verificationEndpoint,
+    openid4vc: new OpenId4VcModule({
+      issuer: {
+        baseUrl: agencyConfig.oidConfig.issuanceEndpoint,
+        credentialRequestToCredentialMapper,
+      },
+      verifier: {
+        baseUrl: agencyConfig.oidConfig.verificationEndpoint,
+      },
       app: agencyConfig.oidConfig.app,
     }),
     ledgerSdk: new IndyVdrModule({

heka-identity-service/src/common/agent/agent.module.ts

@@ -2,10 +2,9 @@ import { Module } from '@nestjs/common'
 
 import { agentModulesProvider } from './agent-modules.provider'
 import { agentProvider, AGENT_TOKEN } from './agent.provider'
-import { MediatorService } from './mediator.service'
 
 @Module({
-  providers: [agentModulesProvider, agentProvider, MediatorService],
+  providers: [agentModulesProvider, agentProvider],
   exports: [AGENT_TOKEN],
 })
 export class AgentModule {}

heka-identity-service/src/common/agent/agent.provider.ts

@@ -38,7 +38,9 @@ export class Agent extends CredoAgent<AgencyModulesMap> implements OnApplication
 
     this.modules.didcomm.registerOutboundTransport(new DidCommHttpOutboundTransport())
     if (this.agencyConfig.httpPort) {
-      this.modules.didcomm.registerInboundTransport(new DidCommHttpInboundTransport({ port: this.agencyConfig.httpPort }))
+      this.modules.didcomm.registerInboundTransport(
+        new DidCommHttpInboundTransport({ port: this.agencyConfig.httpPort }),
+      )
     }
 
     this.modules.didcomm.registerOutboundTransport(new DidCommWsOutboundTransport())