Merge pull request #6 from Bhutan-NDI/reuse-connection

Added reuse connection event

src/events/ReuseConnectionEvents.ts

@@ -0,0 +1,34 @@
+import type { ServerConfig } from '../utils/ServerConfig'
+import type { Agent, HandshakeReusedEvent } from '@credo-ts/core'
+
+import { OutOfBandEventTypes } from '@credo-ts/core'
+
+import { sendWebSocketEvent } from './WebSocketEvents'
+import { sendWebhookEvent } from './WebhookEvent'
+
+export const reuseConnectionEvents = async (agent: Agent, config: ServerConfig) => {
+  agent.events.on(OutOfBandEventTypes.HandshakeReused, async (event: HandshakeReusedEvent) => {
+    const body = {
+      connectionRecord: event.payload.connectionRecord.toJSON(),
+      outOfBandRecord: event.payload.outOfBandRecord.toJSON(),
+      reuseThreadId: event.payload.reuseThreadId,
+      ...event.metadata,
+    }
+
+    // Only send webhook if webhook url is configured
+    if (config.webhookUrl) {
+      await sendWebhookEvent(config.webhookUrl + '/connections', body, agent.config.logger)
+    }
+
+    if (config.socketServer) {
+      // Always emit websocket event to clients (could be 0)
+      sendWebSocketEvent(config.socketServer, {
+        ...event,
+        payload: {
+          ...event.payload,
+          connectionRecord: body,
+        },
+      })
+    }
+  })
+}

src/server.ts

@@ -20,6 +20,7 @@ import { questionAnswerEvents } from './events/QuestionAnswerEvents'
 import { RegisterRoutes } from './routes/routes'
 import { SecurityMiddleware } from './securityMiddleware'
 import { maxRateLimit, windowMs } from './utils/util'
+import { reuseConnectionEvents } from './events/ReuseConnectionEvents'
 
 import { ValidateError, type Exception } from 'tsoa'
 
@@ -35,6 +36,7 @@ export const setupServer = async (agent: Agent, config: ServerConfig, apiKey?: s
     connectionEvents(agent, config)
     credentialEvents(agent, config)
     proofEvents(agent, config)
+    reuseConnectionEvents(agent, config)
   }
 
   // Use body parser to read sent json payloads