✨ add on-connected route

Author: vogelskamp

src/index.ts

@@ -7,6 +7,7 @@ import { TokenCacheStorage } from './cache';
 import { errorHandlerMiddleware, extractHeaderMiddleware } from './middlewares';
 import {
   Adapter,
+  BridgeRequest,
   BridgeRequestWithTimestamp,
   ContactCache,
   Controller,
@@ -137,6 +138,10 @@ export function start(
     controller.handleWebhook(req, res, next),
   );
 
+  app.post('/on-connected', (req: BridgeRequest<unknown>, res, next) =>
+    controller.handleConnectedEvent(req, res, next),
+  );
+
   app.use(errorHandlerMiddleware);
 
   customRouters.forEach(({ path, router }) => app.use(path, router));

src/models/adapter.model.ts

@@ -88,6 +88,7 @@ export interface Adapter {
     req: Request,
     res?: Response,
   ) => Promise<{ apiKey: string; apiUrl: string }>;
+  onConnected?: (config: Config) => Promise<void>;
   handleWebhook?: (req: Request) => Promise<IntegrationsEvent[]>;
   verifyWebhookRequest?: (req: Request) => Promise<boolean>;
 }

src/models/controller.model.ts

@@ -1462,4 +1462,37 @@ export class Controller {
       next(error);
     }
   }
+
+  public async onConnected(
+    req: BridgeRequest<unknown>,
+    res: Response,
+    next: NextFunction,
+  ) {
+    const { providerConfig } = req;
+
+    try {
+      if (!providerConfig) {
+        throw new ServerError(400, 'Missing parameters');
+      }
+
+      if (!this.adapter.onConnected) {
+        infoLogger(
+          'onConnected',
+          'No onConnected handler defined',
+          providerConfig.apiKey,
+        );
+        return;
+      }
+
+      await this.adapter.onConnected(providerConfig);
+    } catch (error) {
+      errorLogger(
+        'onConnected',
+        'Could not handle onConnected event',
+        '',
+        error || 'Unknown',
+      );
+      next(error);
+    }
+  }
 }