♻️ Change contactsChangd to integrationEntitiesChanged

Author: MalteSehmer

src/models/adapter.model.ts

@@ -14,7 +14,7 @@ import {
   LoggedIntegrationEntity,
 } from '.';
 import { IntegrationEntityType } from './integration-entity.model';
-import { ContactsChangedData } from './contacts-changed.model';
+import { IntegrationEntitiesChangedData } from './integration-entities-changed.model';
 
 export interface Adapter {
   getToken?: (config: Config) => Promise<{ apiKey: string }>;
@@ -83,5 +83,5 @@ export interface Adapter {
     req: Request,
     res?: Response,
   ) => Promise<{ apiKey: string; apiUrl: string }>;
-  handleWebhook?: (body: unknown) => Promise<ContactsChangedData>;
+  handleWebhook?: (body: unknown) => Promise<IntegrationEntitiesChangedData>;
 }

src/models/controller.model.ts

@@ -12,7 +12,7 @@ import {
   ContactDelta,
   ContactTemplate,
   ContactUpdate,
-  ContactsChangedData,
+  IntegrationEntitiesChangedData,
   ServerError,
 } from '.';
 import { calendarEventsSchema, contactsSchema } from '../schemas';
@@ -35,7 +35,7 @@ import {
   PubSubContactsMessage,
   PubSubContactsState,
 } from './pubsub-contacts-message.model';
-import { PubSubContactsChangedClient } from './pubsub-contacts-changed-client.model';
+import { PubSubIntegrationEntitiesChangedClient } from './pubsub-integration-entities-changed-client.model';
 
 const CONTACT_FETCH_TIMEOUT = 5000;
 
@@ -54,7 +54,7 @@ export class Controller {
   private contactCache: ContactCache | null;
   private ajv: Ajv;
   private pubSubClient: PubSubClient | null = null;
-  private pubSubContactsChangedClient: PubSubContactsChangedClient | null =
+  private pubSubIntegrationEntitiesChangedClient: PubSubIntegrationEntitiesChangedClient | null =
     null;
   private integrationName: string = 'UNKNOWN';
   private streamingPromises = new Map<string, Promise<void>>();
@@ -67,16 +67,19 @@ export class Controller {
     if (this.adapter.streamContacts) {
       const {
         PUBSUB_TOPIC_NAME: topicName,
-        PUBSUB_CONTACTS_CHANGED_TOPIC_NAME: contactsChangedTopicName,
+        PUBSUB_INTEGRATION_ENTITIES_CHANGED_TOPIC_NAME:
+          integrationEntitiesChangedTopicName,
         INTEGRATION_NAME: integrationName,
       } = process.env;
 
       if (!topicName) {
         throw new Error('No PUBSUB_TOPIC_NAME provided.');
       }
 
-      if (!contactsChangedTopicName) {
-        throw new Error('No PUBSUB_CONTACTS_CHANGED_TOPIC_NAME provided.');
+      if (!integrationEntitiesChangedTopicName) {
+        throw new Error(
+          'No PUBSUB_INTEGRATION_ENTITIES_CHANGED_TOPIC_NAME provided.',
+        );
       }
 
       if (!integrationName) {
@@ -90,12 +93,13 @@ export class Controller {
         `Initialized PubSub client with topic ${topicName}`,
       );
 
-      this.pubSubContactsChangedClient = new PubSubContactsChangedClient(
-        contactsChangedTopicName,
-      );
+      this.pubSubIntegrationEntitiesChangedClient =
+        new PubSubIntegrationEntitiesChangedClient(
+          integrationEntitiesChangedTopicName,
+        );
       infoLogger(
         'Controller',
-        `Initialized PubSub client with topic ${contactsChangedTopicName}`,
+        `Initialized PubSub client with topic ${integrationEntitiesChangedTopicName}`,
       );
     }
   }
@@ -1309,11 +1313,11 @@ export class Controller {
         throw new ServerError(501, 'Webhook handling not implemented');
       }
 
-      const contactsChangedData: ContactsChangedData =
+      const changedData: IntegrationEntitiesChangedData =
         await this.adapter.handleWebhook(req.body);
 
-      console.log('sending webhook to pubsub', contactsChangedData);
-      this.pubSubContactsChangedClient?.publishMessage(contactsChangedData);
+      console.log('sending webhook to pubsub', changedData);
+      this.pubSubIntegrationEntitiesChangedClient?.publishMessage(changedData);
 
       res.sendStatus(200);
     } catch (error) {

src/models/index.ts

@@ -7,7 +7,7 @@ export * from './call-event.model';
 export * from './config.model';
 export * from './contact-cache.model';
 export * from './contact.model';
-export * from './contacts-changed.model';
+export * from './integration-entities-changed.model';
 export * from './controller.model';
 export * from './custom-router.model';
 export * from './server-error.model';

src/models/contacts-changed.model.ts renamed to src/models/integration-entities-changed.model.ts

@@ -1,6 +1,6 @@
 import { IntegrationEntityType } from './integration-entity.model';
 
-export type ContactsChangedData = {
+export type IntegrationEntitiesChangedData = {
   integrationName: string;
   data: {
     integrationAccountId: string;

src/models/pubsub-contacts-changed-message.model.ts

@@ -1,10 +1,10 @@
 import { PubSub } from '@google-cloud/pubsub';
 import { timeout } from '../util/timeout';
-import { PubSubContactsChangedMessage } from './pubsub-contacts-changed-message.model';
+import { PubSubIntegrationEntitiesChangedMessage } from './pubsub-integration-entities-changed-message.model';
 
 const PUBLISH_TIMEOUT = 10_000;
 
-export class PubSubContactsChangedClient {
+export class PubSubIntegrationEntitiesChangedClient {
   private client: PubSub;
   private topicName: string;
 
@@ -13,7 +13,7 @@ export class PubSubContactsChangedClient {
     this.topicName = topicName;
   }
 
-  async publishMessage(message: PubSubContactsChangedMessage) {
+  async publishMessage(message: PubSubIntegrationEntitiesChangedMessage) {
     if (!this.topicName) {
       throw new Error('No pubsub topic name provided.');
     }

src/models/pubsub-contacts-changed-client.model.ts renamed to src/models/pubsub-integration-entities-changed-client.model.ts

@@ -0,0 +1,4 @@
+import { IntegrationEntitiesChangedData } from './integration-entities-changed.model';
+
+export type PubSubIntegrationEntitiesChangedMessage =
+  IntegrationEntitiesChangedData;