✨ new route for call logging with entities

Author: LemonaOna

src/index.ts

@@ -69,6 +69,9 @@ export function start(
   app.post("/events/calls", (req, res, next) =>
     controller.handleCallEvent(req, res, next)
   );
+  app.post("/call-log", (req, res, next) =>
+    controller.createCallLogForEntities(req, res, next)
+  );
   app.put("/events/calls/:id", (req, res, next) =>
     controller.updateCallEvent(req, res, next)
   );

src/models/adapter.model.ts

@@ -4,11 +4,13 @@ import {
   CalendarEventTemplate,
   CalendarFilterOptions,
   CallEvent,
+  CallEventWithIntegrationEntities,
   Config,
   Contact,
   ContactTemplate,
   ContactUpdate,
   LabeledIntegrationEntity,
+  LoggedIntegrationEntity,
 } from ".";
 import { IntegrationEntityType } from "./integration-entity.model";
 
@@ -45,6 +47,10 @@ export interface Adapter {
   ) => Promise<void>;
   deleteCalendarEvent?: (config: Config, id: string) => Promise<void>;
   handleCallEvent?: (config: Config, event: CallEvent) => Promise<string>;
+  createCallLogsForEntities?: (
+    config: Config,
+    event: CallEventWithIntegrationEntities
+  ) => Promise<LoggedIntegrationEntity[]>;
   getEntity?: (
     providerConfig: Config,
     id: string,

src/models/call-event.model.ts

@@ -1,4 +1,4 @@
-import { CallDirection } from "./";
+import { CallDirection, IntegrationEntity } from "./";
 
 /**
  * The type of the call participant.
@@ -33,6 +33,10 @@ export interface CallEvent {
   state: CallState;
 }
 
+export interface CallEventWithIntegrationEntities extends CallEvent {
+  integrationEntities: IntegrationEntity[];
+}
+
 export interface UpdateCallEventBody {
   note: string;
 }

src/models/controller.model.ts

@@ -6,6 +6,7 @@ import {
   CalendarEvent,
   CalendarEventTemplate,
   CallEvent,
+  CallEventWithIntegrationEntities,
   Contact,
   ContactCache,
   ContactTemplate,
@@ -531,6 +532,47 @@ export class Controller {
     }
   }
 
+  public async createCallLogForEntities(
+    req: BridgeRequest<CallEventWithIntegrationEntities>,
+    res: Response,
+    next: NextFunction
+  ): Promise<void> {
+    const { providerConfig } = req;
+
+    try {
+      if (!providerConfig) {
+        throw new ServerError(400, "Missing config parameters");
+      }
+
+      if (!this.adapter.createCallLogsForEntities) {
+        throw new ServerError(501, "Creating call log is not implemented");
+      }
+
+      if (shouldSkipCallEvent(req.body)) {
+        infoLogger(
+          `Skipping call log for call id ${req.body.id}`,
+          providerConfig
+        );
+        res.status(200).send("Skipping call log");
+        return;
+      }
+
+      infoLogger(`Creating call Logs…`, providerConfig);
+
+      const entitiesWithCallLogReferences =
+        await this.adapter.createCallLogsForEntities(providerConfig, req.body);
+
+      res.status(200).send(entitiesWithCallLogReferences);
+    } catch (error) {
+      errorLogger(
+        "Could not create call logs:",
+        providerConfig,
+        error || "Unknown"
+      );
+      next(error);
+    }
+  }
+
   public async handleConnectedEvent(
     req: BridgeRequest<unknown>,
     res: Response,