feat: add fetch indy schema method

packages/core/package.json

@@ -30,7 +30,7 @@
     "@stablelib/ed25519": "^1.0.2",
     "@stablelib/random": "^1.0.1",
     "@stablelib/sha256": "^1.0.1",
-    "@types/indy-sdk": "1.16.24",
+    "@types/indy-sdk": "1.16.26",
     "@types/node-fetch": "^2.5.10",
     "@types/ws": "^7.4.6",
     "abort-controller": "^3.0.0",

packages/indy-sdk/package.json

@@ -26,7 +26,7 @@
   "dependencies": {
     "@aries-framework/anoncreds": "0.3.3",
     "@aries-framework/core": "0.3.3",
-    "@types/indy-sdk": "1.16.24",
+    "@types/indy-sdk": "1.16.26",
     "class-transformer": "^0.5.1",
     "class-validator": "^0.14.0",
     "rxjs": "^7.2.0",

packages/indy-sdk/src/anoncreds/services/IndySdkAnonCredsRegistry.ts

@@ -160,7 +160,7 @@ export class IndySdkAnonCredsRegistry implements AnonCredsRegistry {
         schemaMetadata: {
           // NOTE: the seqNo is required by the indy-sdk even though not present in AnonCreds v1.
           // For this reason we return it in the metadata.
-          indyLedgerSeqNo: schema.seqNo,
+          indyLedgerSeqNo: response.result.txnMetadata.seqNo,
           didIndyNamespace: pool.didIndyNamespace,
         },
       }
@@ -219,11 +219,13 @@ export class IndySdkAnonCredsRegistry implements AnonCredsRegistry {
         }
       )
 
+      const { schema } = await this.fetchIndySchemaWithSeqNo(agentContext, Number(credentialDefinition.schemaId), did)
+
       return {
         credentialDefinitionId: credentialDefinition.id,
         credentialDefinition: {
           issuerId: didFromCredentialDefinitionId(credentialDefinition.id),
-          schemaId: credentialDefinition.schemaId,
+          schemaId: schema.schemaId,
           tag: credentialDefinition.tag,
           type: 'CL',
           value: credentialDefinition.value,
@@ -305,7 +307,7 @@ export class IndySdkAnonCredsRegistry implements AnonCredsRegistry {
 
       const request = await indySdk.buildCredDefRequest(options.credentialDefinition.issuerId, {
         id: credentialDefinitionId,
-        schemaId: options.credentialDefinition.schemaId,
+        schemaId: schemaMetadata.indyLedgerSeqNo.toString(),
         tag: options.credentialDefinition.tag,
         type: options.credentialDefinition.type,
         value: options.credentialDefinition.value,
@@ -509,6 +511,47 @@ export class IndySdkAnonCredsRegistry implements AnonCredsRegistry {
       }
     }
   }
+
+  private async fetchIndySchemaWithSeqNo(agentContext: AgentContext, seqNo: number, did: string) {
+    const indySdkPoolService = agentContext.dependencyManager.resolve(IndySdkPoolService)
+    const indySdk = agentContext.dependencyManager.resolve<IndySdk>(IndySdkSymbol)
+
+    const { pool } = await indySdkPoolService.getPoolForDid(agentContext, did)
+    agentContext.config.logger.debug(`Getting transaction with seqNo '${seqNo}' from ledger '${pool.didIndyNamespace}'`)
+
+    const request = await indySdk.buildGetTxnRequest(did, 'DOMAIN', seqNo)
+
+    agentContext.config.logger.trace(`Submitting get transaction request to ledger '${pool.didIndyNamespace}'`)
+    const response = await indySdkPoolService.submitReadRequest(pool, request)
+
+    const schema = response.result.data as SchemaType
+
+    const schemaId = getLegacySchemaId(did, schema.txn.data.data.name, schema.txn.data.data.version)
+
+    return {
+      schema: {
+        schemaId,
+        attr_name: schema.txn.data.data.attr_names,
+        name: schema.txn.data.data.name,
+        version: schema.txn.data.data.version,
+        issuerId: did,
+        seqNo,
+      },
+      indyNamespace: pool.didIndyNamespace,
+    }
+  }
+}
+
+interface SchemaType {
+  txn: {
+    data: {
+      data: {
+        attr_names: string[]
+        version: string
+        name: string
+      }
+    }
+  }
 }
 
 export interface IndySdkRegisterSchemaOptions extends RegisterSchemaOptions {

packages/indy-sdk/src/ledger/IndySdkPool.ts

@@ -54,7 +54,7 @@ export class IndySdkPool {
   }
 
   public get didIndyNamespace(): string {
-    return this.didIndyNamespace
+    return this.config.indyNamespace
   }
 
   public get id() {

packages/indy-vdr/src/anoncreds/IndyVdrAnonCredsRegistry.ts

@@ -17,6 +17,7 @@ import {
   SchemaRequest,
   GetCredentialDefinitionRequest,
   CredentialDefinitionRequest,
+  GetTransactionRequest,
 } from '@hyperledger/indy-vdr-shared'
 
 import { IndyVdrPoolService } from '../pool'
@@ -218,12 +219,14 @@ export class IndyVdrAnonCredsRegistry implements AnonCredsRegistry {
 
       const response = await pool.submitReadRequest(request)
 
-      if (response.result.data) {
+      const schema = await this.fetchIndySchemaWithSeqNo(agentContext, response.result.ref, did, 1)
+
+      if (response.result.data && schema) {
         return {
           credentialDefinitionId: credentialDefinitionId,
           credentialDefinition: {
             issuerId: didFromCredentialDefinitionId(credentialDefinitionId),
-            schemaId: response.result.ref.toString(),
+            schemaId: schema.schema.schemaId,
             tag: response.result.tag,
             type: 'CL',
             value: response.result.data,
@@ -416,6 +419,47 @@ export class IndyVdrAnonCredsRegistry implements AnonCredsRegistry {
       revocationRegistryDefinitionMetadata: {},
     }
   }
+
+  public async fetchIndySchemaWithSeqNo(agentContext: AgentContext, seqNo: number, did: string, type: number) {
+    const indyVdrPoolService = agentContext.dependencyManager.resolve(IndyVdrPoolService)
+
+    const pool = await indyVdrPoolService.getPoolForDid(agentContext, did)
+
+    agentContext.config.logger.debug(`Getting transaction with seqNo '${seqNo}' from ledger '${pool.indyNamespace}'`)
+    const request = new GetTransactionRequest({ ledgerType: type, seqNo })
+
+    agentContext.config.logger.trace(`Submitting get transaction request to ledger '${pool.indyNamespace}'`)
+    const response = await pool.submitReadRequest(request)
+
+    if (response.result.data?.txn.type !== '101') {
+      agentContext.config.logger.error(`Could not get schema from ledger for seq no ${seqNo}'`)
+      return null
+    }
+
+    const schema = response.result.data?.txn.data as SchemaType
+
+    const schemaId = getLegacySchemaId(did, schema.data.name, schema.data.version)
+
+    return {
+      schema: {
+        schemaId,
+        attr_name: schema.data.attr_names,
+        name: schema.data.name,
+        version: schema.data.version,
+        issuerId: did,
+        seqNo,
+      },
+      indyNamespace: pool.indyNamespace,
+    }
+  }
+}
+
+interface SchemaType {
+  data: {
+    attr_names: string[]
+    version: string
+    name: string
+  }
 }
 
 export interface IndyVdrRegisterSchemaOptions extends RegisterSchemaOptions {

packages/indy-vdr/tests/indy-vdr-anoncreds-registry.e2e.test.ts

@@ -154,8 +154,7 @@ describe('IndyVdrAnonCredsRegistry', () => {
       credentialDefinitionId: `TL1EaPFCZ8Si5aUrqScBDt:3:CL:${schemaResponse.schemaMetadata.indyLedgerSeqNo}:TAG`,
       credentialDefinition: {
         issuerId: 'TL1EaPFCZ8Si5aUrqScBDt',
-        // FIXME: this will change when https://github.com/hyperledger/aries-framework-javascript/issues/1259 is merged
-        schemaId: `${schemaResponse.schemaMetadata.indyLedgerSeqNo}`,
+        schemaId: `TL1EaPFCZ8Si5aUrqScBDt:2:test:${dynamicVersion}`,
         tag: 'TAG',
         type: 'CL',
         value: {

packages/react-native/package.json

@@ -29,9 +29,9 @@
     "events": "^3.3.0"
   },
   "devDependencies": {
-    "@types/indy-sdk-react-native": "npm:@types/[email protected].24",
+    "@types/indy-sdk-react-native": "npm:@types/[email protected].26",
     "@types/react-native": "^0.64.10",
-    "indy-sdk-react-native": "^0.3.0",
+    "indy-sdk-react-native": "^0.3.1",
     "react": "17.0.1",
     "react-native": "0.64.2",
     "react-native-fs": "^2.18.0",
@@ -40,7 +40,7 @@
     "typescript": "~4.9.4"
   },
   "peerDependencies": {
-    "indy-sdk-react-native": "^0.3.0",
+    "indy-sdk-react-native": "^0.3.1",
     "react-native-fs": "^2.18.0",
     "react-native-get-random-values": "^1.7.0"
   }