chore: initial commit

.gitignore

@@ -53,6 +53,7 @@ test/*.js
 
 # Ignore Open API generated packages
 packages/credential-showcase-openapi/src
+packages/credential-showcase-traction-openapi/src
 packages/**/dist
 packages/**/target
 /packages/*/dist
@@ -61,3 +62,4 @@ packages/**/target
 **/.env
 **/.env.*
 !**/.env.example
+

.husky/pre-commit

@@ -1 +1,4 @@
 pnpm prettier
+
+# Stage the files that were modified by prettier
+git add -u

README.md

@@ -10,6 +10,14 @@ the backend server for the Credential Showcase application. It provides REST API
 
 Defines the OpenAPI specification for the Credential Showcase application. It provides the API contract for the backend services and can be used to generate client code, validate requests, and document the API.
 
+# credential-showcase-traction-openapi
+
+Defines the OpenAPI specification for the Traction backend and contains the generated client code for that.
+
+# credential-showcase-traction-adapter
+
+Picks up Credential Showcase messages from a AMQ v1.0 message broker and translates the actions to Traction API calls
+
 # credential-showcase-ts-sdk
 
 Contains the generated TypeScript SDK client code for interacting with the Credential Showcase API. It provides a set of functions and utilities to connect with the backend services.

apps/credential-showcase-api-server/package.json

@@ -14,6 +14,7 @@
   "dependencies": {
     "cors": "^2.8.5",
     "credential-showcase-openapi": "workspace:*",
+    "credential-showcase-adapter-client-api": "workspace:*",
     "dotenv-flow": "^4.1.0",
     "drizzle-orm": "^0.39.3",
     "express": "^4.21.2",

apps/credential-showcase-api-server/src/controllers/ShowcaseController.ts

@@ -1,21 +1,29 @@
-import { BadRequestError, Body, Delete, Get, HttpCode, JsonController, OnUndefined, Param, Post, Put } from 'routing-controllers'
+import { BadRequestError, Body, Delete, Get, HeaderParam, HttpCode, JsonController, OnUndefined, Param, Post, Put } from 'routing-controllers'
 import { Service } from 'typedi'
 import {
-  ShowcaseResponse,
-  ShowcaseResponseFromJSONTyped,
+  instanceOfShowcaseRequest,
+  IssuanceScenario,
+  Issuer,
+  Showcase,
   ShowcaseRequest,
   ShowcaseRequestToJSONTyped,
+  ShowcaseResponse,
+  ShowcaseResponseFromJSONTyped,
   ShowcasesResponse,
   ShowcasesResponseFromJSONTyped,
-  instanceOfShowcaseRequest,
+  ShowcaseStatus,
 } from 'credential-showcase-openapi'
 import ShowcaseService from '../services/ShowcaseService'
 import { showcaseDTOFrom } from '../utils/mappers'
+import { AdapterClientApi } from 'credential-showcase-adapter-client-api'
 
 @JsonController('/showcases')
 @Service()
 class ShowcaseController {
-  constructor(private showcaseService: ShowcaseService) {}
+  constructor(
+    private showcaseService: ShowcaseService,
+    private adapterClientApi: AdapterClientApi,
+  ) {}
 
   @Get('/')
   public async getAll(): Promise<ShowcasesResponse> {
@@ -47,12 +55,15 @@ class ShowcaseController {
 
   @HttpCode(201)
   @Post('/')
-  public async post(@Body() showcaseRequest: ShowcaseRequest): Promise<ShowcaseResponse> {
+  public async post(@HeaderParam('authorization') authHeader: string, @Body() showcaseRequest: ShowcaseRequest): Promise<ShowcaseResponse> {
     try {
       if (!instanceOfShowcaseRequest(showcaseRequest)) {
         return Promise.reject(new BadRequestError())
       }
       const result = await this.showcaseService.createShowcase(ShowcaseRequestToJSONTyped(showcaseRequest))
+      if (showcaseRequest.status === ShowcaseStatus.Active) {
+        void (await this.publishFromShowcase(showcaseDTOFrom(result), authHeader))
+      }
       return ShowcaseResponseFromJSONTyped({ showcase: showcaseDTOFrom(result) }, false)
     } catch (e) {
       if (e.httpCode !== 404) {
@@ -70,6 +81,9 @@ class ShowcaseController {
         return Promise.reject(new BadRequestError())
       }
       const result = await this.showcaseService.updateShowcase(id, ShowcaseRequestToJSONTyped(showcaseRequest))
+      if (showcaseRequest.status === ShowcaseStatus.Active) {
+        void (await this.publishFromShowcase(showcaseDTOFrom(result), authHeader))
+      }
       return ShowcaseResponseFromJSONTyped({ showcase: showcaseDTOFrom(result) }, false)
     } catch (e) {
       if (e.httpCode !== 404) {
@@ -79,6 +93,61 @@ class ShowcaseController {
     }
   }
 
+  private async publishFromShowcase(showcase: Showcase, authHeader: string) {
+    console.log(`Publishing showcase ${showcase.name} to Traction`)
+
+    // Get issuers from scenarios
+    const issuers: Array<Issuer> = showcase.scenarios
+      ?.filter((scenario) => 'issuer' in scenario && scenario.issuer)
+      .map((scenario) => (scenario as IssuanceScenario).issuer)
+
+    // Process each issuer
+    const processedIssuerIds = new Set<string>()
+
+    for (const issuer of issuers) {
+      // Skip if we've already processed this issuer
+      if (processedIssuerIds.has(issuer.id)) {
+        continue
+      }
+      processedIssuerIds.add(issuer.id)
+
+      const newIssuer: Issuer = {
+        id: issuer.id,
+        name: issuer.name,
+        description: issuer.description,
+        type: issuer.type,
+        organization: issuer.organization,
+        identifierType: issuer.identifierType,
+        identifier: issuer.identifier,
+        logo: issuer.logo,
+        credentialDefinitions: [],
+        credentialSchemas: [],
+        createdAt: issuer.createdAt,
+        updatedAt: issuer.updatedAt,
+      }
+
+      // Find matching credential definitions from showcase
+      const matchingCredDefs = showcase.credentialDefinitions.filter((credDef) =>
+        issuer.credentialDefinitions.some((issuerCredDef) => issuerCredDef.id === credDef.id),
+      )
+
+      newIssuer.credentialDefinitions = matchingCredDefs
+
+      // Get schema IDs from matching credential definitions
+      const schemaIds = matchingCredDefs.map((credDef) => credDef.credentialSchema.id)
+
+      // Look up schemas from ALL issuers (not just the current one)
+      newIssuer.credentialSchemas = issuers
+        .flatMap((i) => i.credentialSchemas || [])
+        .filter((schema) => schemaIds.includes(schema.id))
+        // Remove duplicates
+        .filter((schema, index, self) => index === self.findIndex((s) => s.id === schema.id))
+
+      // Publish the issuer
+      void (await this.adapterClientApi.publishIssuer(newIssuer, authHeader)) // TODO create reduced type
+    }
+  }
+
   @OnUndefined(204)
   @Delete('/:slug')
   public async delete(@Param('slug') slug: string): Promise<void> {

apps/credential-showcase-api-server/src/controllers/__tests__/IssuanceScenarioController.integration.test.ts

@@ -87,7 +87,7 @@ describe('IssuanceScenarioController Integration Tests', () => {
       name: 'Test Definition',
       version: '1.0',
       identifierType: IdentifierType.DID,
-      identifier: 'did:test:123',
+      identifier: 'did:sov:YUeUZauFLeBNofY3NhaZCA',
       icon: asset.id,
       type: CredentialType.ANONCRED,
       credentialSchema: credentialSchema.id,

apps/credential-showcase-api-server/src/controllers/__tests__/IssuerController.integration.test.ts

@@ -90,7 +90,7 @@ describe('IssuerController Integration Tests', () => {
       name: 'Test Definition',
       version: '1.0',
       identifierType: IdentifierType.DID,
-      identifier: 'did:test:123',
+      identifier: 'did:sov:YUeUZauFLeBNofY3NhaZCA',
       icon: asset.id,
       type: CredentialType.ANONCRED,
       credentialSchema: credentialSchema.id,
@@ -224,7 +224,7 @@ describe('IssuerController Integration Tests', () => {
       name: 'Test Definition 1',
       version: '1.0',
       identifierType: IdentifierType.DID,
-      identifier: 'did:test:123',
+      identifier: 'did:sov:YUeUZauFLeBNofY3NhaZCA',
       icon: asset.id,
       type: CredentialType.ANONCRED,
       credentialSchema: credentialSchema.id,

apps/credential-showcase-api-server/src/controllers/__tests__/PresentationScenarioController.integration.test.ts

@@ -77,7 +77,7 @@ describe('PresentationScenarioController Integration Tests', () => {
       name: 'Test Definition',
       version: '1.0',
       identifierType: IdentifierType.DID,
-      identifier: 'did:test:123',
+      identifier: 'did:sov:YUeUZauFLeBNofY3NhaZCA',
       icon: asset.id,
       type: CredentialType.ANONCRED,
       credentialSchema: credentialSchema.id,

apps/credential-showcase-api-server/src/controllers/__tests__/RelyingPartyController.integration.test.ts

@@ -83,7 +83,7 @@ describe('RelyingPartyController Integration Tests', () => {
       name: 'Test Definition',
       version: '1.0',
       identifierType: IdentifierType.DID,
-      identifier: 'did:test:123',
+      identifier: 'did:sov:YUeUZauFLeBNofY3NhaZCA',
       icon: asset.id,
       type: CredentialType.ANONCRED,
       credentialSchema: credentialSchema.id,
@@ -204,7 +204,7 @@ describe('RelyingPartyController Integration Tests', () => {
       name: 'Test Definition 1',
       version: '1.0',
       identifierType: IdentifierType.DID,
-      identifier: 'did:test:123',
+      identifier: 'did:sov:YUeUZauFLeBNofY3NhaZCA',
       icon: asset.id,
       type: CredentialType.ANONCRED,
       credentialSchema: credentialSchema.id,

apps/credential-showcase-api-server/src/controllers/__tests__/ShowcaseController.integration.test.ts

@@ -20,6 +20,7 @@ import * as schema from '../../database/schema'
 import { NodePgDatabase } from 'drizzle-orm/node-postgres'
 import { migrate } from 'drizzle-orm/node-postgres/migrator'
 import DatabaseService from '../../services/DatabaseService'
+import { AdapterClientApi } from 'credential-showcase-adapter-client-api'
 
 describe('ShowcaseController Integration Tests', () => {
   let client: PGlite
@@ -34,6 +35,13 @@ describe('ShowcaseController Integration Tests', () => {
       getConnection: jest.fn().mockResolvedValue(database),
     }
     Container.set(DatabaseService, mockDatabaseService)
+
+    const mockAdapterClientApi = {
+      publishIssuer: jest.fn().mockResolvedValue(undefined),
+      close: jest.fn().mockResolvedValue(undefined),
+    }
+    Container.set(AdapterClientApi, mockAdapterClientApi)
+
     useContainer(Container)
     Container.get(AssetRepository)
     Container.get(CredentialSchemaRepository)
@@ -89,7 +97,7 @@ describe('ShowcaseController Integration Tests', () => {
       name: 'Test Definition',
       version: '1.0',
       identifierType: IdentifierType.DID,
-      identifier: 'did:test:123',
+      identifier: 'did:sov:YUeUZauFLeBNofY3NhaZCA',
       icon: asset.id,
       type: CredentialType.ANONCRED,
       credentialSchema: credentialSchema.id,

apps/credential-showcase-api-server/src/services/DatabaseService.ts

@@ -19,7 +19,15 @@ export class DatabaseService {
   public async getConnection(): Promise<NodePgDatabase<typeof schema>> {
     if (!this.db) {
       const pool = new Pool({ connectionString: this.getDbUrl() })
-      this.db = drizzle(pool, { schema })
+      this.db = drizzle(pool, {
+        schema,
+        /*logger: {
+          logQuery: (query, params) => {
+            console.log('Query:', query)
+            console.log('Params:', params)
+          },
+        },*/
+      })
 
       const migrationsFolder = path.resolve(__dirname, '../database/migrations')
       await migrate(this.db, { migrationsFolder })

apps/credential-showcase-api-server/src/types/schema/index.ts

@@ -142,6 +142,7 @@ export type IssuanceScenario = Omit<typeof scenarios.$inferSelect, 'relyingParty
   issuer?: Issuer | null
   bannerImage?: Asset | null
 }
+
 export type NewIssuanceScenario = Omit<typeof scenarios.$inferInsert, 'relyingParty' | 'scenarioType' | 'slug'> & {
   personas: string[]
   issuer: string
@@ -203,6 +204,7 @@ export type Showcase = Omit<typeof showcases.$inferSelect, 'bannerImage'> & {
   personas: Persona[]
   bannerImage?: Asset | null
 }
+
 export type NewShowcase = Omit<typeof showcases.$inferInsert, 'slug'> & {
   scenarios: string[]
   credentialDefinitions: string[]

apps/credential-showcase-api-server/tsconfig.json

@@ -8,6 +8,9 @@
   "references": [
     {
       "path": "../../packages/credential-showcase-openapi"
+    },
+    {
+      "path": "../../packages/credential-showcase-adapter-client-api"
     }
   ],
   "exclude": ["**/__tests__/**/*", "**/dist/**/*", "**/drizzle.config.ts"]

packages/credential-showcase-adapter-client-api/package.json

@@ -0,0 +1,36 @@
+{
+  "name": "credential-showcase-adapter-client-api",
+  "version": "0.1.0",
+  "source": "src/index.ts",
+  "main": "dist/index.js",
+  "types": "dist/index.d.ts",
+  "scripts": {
+    "start": "ts-node src/index.ts",
+    "build": "tsc",
+    "build:clean": "tsc --build --clean && tsc --build",
+    "generate-key": "ts-node src/util/CypherUtil.ts generate-key"
+  },
+  "dependencies": {
+    "credential-showcase-openapi": "workspace:*",
+    "bs58": "^6.0.0",
+    "rhea": "^3.0.3",
+    "rhea-promise": "^3.0.3",
+    "typedi": "^0.10.0"
+  },
+  "devDependencies": {
+    "@types/node": "^22.13.1"
+  },
+  "files": [
+    "dist/**/*",
+    "README.md",
+    "LICENSE"
+  ],
+  "private": false,
+  "publishConfig": {
+    "access": "public"
+  },
+  "repository": "git@github.com:Sphereon-Opensource/credential-showcase-api.git",
+  "author": "4Sure",
+  "license": "Apache-2.0",
+  "keywords": []
+}