present proof protocol (openwallet-foundation#170)

Co-authored-by: Parth <[email protected]>

Author: TimoGlastra

Diff for: jest.config.js

@@ -13,5 +13,5 @@ module.exports = {
   },
   collectCoverageFrom: ['src/lib/**/*.{js,jsx,tsx,ts}'],
   coveragePathIgnorePatterns: ['/node_modules/', '/__tests__/'],
-  testTimeout: 45000,
+  testTimeout: 60000,
 };

Diff for: src/lib/__tests__/credentials.test.ts

@@ -5,9 +5,15 @@ import { Subject } from 'rxjs';
 import path from 'path';
 import indy from 'indy-sdk';
 import { Agent } from '..';
-import { SubjectInboundTransporter, SubjectOutboundTransporter } from './helpers';
+import {
+  ensurePublicDidIsOnLedger,
+  makeConnection,
+  registerDefinition,
+  registerSchema,
+  SubjectInboundTransporter,
+  SubjectOutboundTransporter,
+} from './helpers';
 import { CredentialRecord } from '../storage/CredentialRecord';
-import { SchemaTemplate, CredDefTemplate } from '../agent/LedgerService';
 import {
   CredentialPreview,
   CredentialPreviewAttribute,
@@ -199,46 +205,3 @@ describe('credentials', () => {
     });
   });
 });
-
-async function registerSchema(agent: Agent, schemaTemplate: SchemaTemplate): Promise<[SchemaId, Schema]> {
-  const [schemaId] = await agent.ledger.registerCredentialSchema(schemaTemplate);
-  console.log('schemaId', schemaId);
-  const ledgerSchema = await agent.ledger.getSchema(schemaId);
-  console.log('ledgerSchemaId, ledgerSchema', schemaId, ledgerSchema);
-  return [schemaId, ledgerSchema];
-}
-
-async function registerDefinition(agent: Agent, definitionTemplate: CredDefTemplate): Promise<[CredDefId, CredDef]> {
-  const [credDefId] = await agent.ledger.registerCredentialDefinition(definitionTemplate);
-  const ledgerCredDef = await agent.ledger.getCredentialDefinition(credDefId);
-  console.log('ledgerCredDefId, ledgerCredDef', credDefId, ledgerCredDef);
-  return [credDefId, ledgerCredDef];
-}
-
-async function ensurePublicDidIsOnLedger(agent: Agent, publicDid: Did) {
-  try {
-    console.log(`Ensure test DID ${publicDid} is written to ledger`);
-    const agentPublicDid = await agent.ledger.getPublicDid(publicDid);
-    console.log(`Ensure test DID ${publicDid} is written to ledger: Success`, agentPublicDid);
-  } catch (error) {
-    // Unfortunately, this won't prevent from the test suite running because of Jest runner runs all tests
-    // regardless thorwn errors. We're more explicit about the problem with this error handling.
-    throw new Error(`Test DID ${publicDid} is not written on ledger or ledger is not available.`);
-  }
-}
-
-async function makeConnection(agentA: Agent, agentB: Agent) {
-  // eslint-disable-next-line prefer-const
-  let { invitation, connectionRecord: agentAConnection } = await agentA.connections.createConnection();
-
-  let agentBConnection = await agentB.connections.receiveInvitation(invitation);
-
-  agentAConnection = await agentA.connections.returnWhenIsConnected(agentAConnection.id);
-
-  agentBConnection = await agentB.connections.returnWhenIsConnected(agentBConnection.id);
-
-  return {
-    agentAConnection,
-    agentBConnection,
-  };
-}

Diff for: src/lib/__tests__/helpers.ts

@@ -1,8 +1,20 @@
 /* eslint-disable no-console */
+// @ts-ignore
+import { poll } from 'await-poll';
+import logger from '../logger';
+import path from 'path';
 import { Subject } from 'rxjs';
 import { ConnectionRecord } from '../storage/ConnectionRecord';
 import { Agent, InboundTransporter, OutboundTransporter } from '..';
 import { OutboundPackage, WireMessage } from '../types';
+import { SchemaTemplate, CredDefTemplate } from '../agent/LedgerService';
+import { CredentialOfferTemplate } from '../protocols/credentials/CredentialService';
+import { CredentialState } from '../protocols/credentials/CredentialState';
+import { CredentialRecord } from '../storage/CredentialRecord';
+
+export const genesisPath = process.env.GENESIS_TXN_PATH
+  ? path.resolve(process.env.GENESIS_TXN_PATH)
+  : path.join(__dirname, '../../../network/genesis/local-genesis.txn');
 
 // Custom matchers which can be used to extend Jest matchers via extend, e. g. `expect.extend({ toBeConnectedWith })`.
 
@@ -49,9 +61,90 @@ export class SubjectOutboundTransporter implements OutboundTransporter {
   }
 
   public async sendMessage(outboundPackage: OutboundPackage) {
-    console.log('Sending message...');
+    logger.logJson(`Sending outbound message to connection ${outboundPackage.connection.id}`, outboundPackage.payload);
     const { payload } = outboundPackage;
-    console.log(payload);
     this.subject.next(payload);
   }
 }
+
+export async function makeConnection(agentA: Agent, agentB: Agent) {
+  // eslint-disable-next-line prefer-const
+  let { invitation, connectionRecord: agentAConnection } = await agentA.connections.createConnection();
+  let agentBConnection = await agentB.connections.receiveInvitation(invitation);
+
+  agentAConnection = await agentA.connections.returnWhenIsConnected(agentAConnection.id);
+  agentBConnection = await agentB.connections.returnWhenIsConnected(agentBConnection.id);
+
+  return {
+    agentAConnection,
+    agentBConnection,
+  };
+}
+
+export async function registerSchema(agent: Agent, schemaTemplate: SchemaTemplate): Promise<[SchemaId, Schema]> {
+  const [schemaId] = await agent.ledger.registerCredentialSchema(schemaTemplate);
+  const ledgerSchema = await agent.ledger.getSchema(schemaId);
+  logger.logJson(`created schema with id ${schemaId}`, ledgerSchema);
+  return [schemaId, ledgerSchema];
+}
+
+export async function registerDefinition(
+  agent: Agent,
+  definitionTemplate: CredDefTemplate
+): Promise<[CredDefId, CredDef]> {
+  const [credDefId] = await agent.ledger.registerCredentialDefinition(definitionTemplate);
+  const ledgerCredDef = await agent.ledger.getCredentialDefinition(credDefId);
+  logger.logJson(`created credential definition with id ${credDefId}`, ledgerCredDef);
+  return [credDefId, ledgerCredDef];
+}
+
+export async function ensurePublicDidIsOnLedger(agent: Agent, publicDid: Did) {
+  try {
+    logger.log(`Ensure test DID ${publicDid} is written to ledger`);
+    await agent.ledger.getPublicDid(publicDid);
+  } catch (error) {
+    // Unfortunately, this won't prevent from the test suite running because of Jest runner runs all tests
+    // regardless of thrown errors. We're more explicit about the problem with this error handling.
+    throw new Error(`Test DID ${publicDid} is not written on ledger or ledger is not available.`);
+  }
+}
+
+export async function issueCredential({
+  issuerAgent,
+  issuerConnectionId,
+  holderAgent,
+  credentialTemplate,
+}: {
+  issuerAgent: Agent;
+  issuerConnectionId: string;
+  holderAgent: Agent;
+  credentialTemplate: CredentialOfferTemplate;
+}) {
+  const issuerConnection = await issuerAgent.connections.getById(issuerConnectionId);
+
+  await issuerAgent.credentials.issueCredential(issuerConnection, credentialTemplate);
+  // We assume that Alice has only one credential and it's a credential from Faber
+  let [holderCredential] = await poll(
+    () => holderAgent.credentials.getCredentials(),
+    (credentials: CredentialRecord[]) => credentials.length < 1,
+    100
+  );
+  // Accept credential offer from Faber
+  await holderAgent.credentials.acceptCredential(holderCredential);
+
+  // We assume that Alice has only one credential and it's a credential from Faber
+  const [issuerCredential] = await poll(
+    () => issuerAgent.credentials.getCredentials(),
+    (credentials: CredentialRecord[]) => credentials.length < 1 || credentials[0].state !== CredentialState.Done,
+    100
+  );
+
+  // We assume that Alice has only one credential and it's a credential from Faber
+  [holderCredential] = await poll(
+    () => holderAgent.credentials.getCredentials(),
+    (credentials: CredentialRecord[]) => credentials.length < 1 || credentials[0].state !== CredentialState.Done,
+    100
+  );
+
+  return { issuerCredential, holderCredential };
+}