♻️ pubsub message type

Author: fgladisch

src/models/controller.model.ts

@@ -29,6 +29,7 @@ import { CacheItemStateType } from "./cache-item-state.model";
 import { CalendarFilterOptions } from "./calendar-filter-options.model";
 import { IntegrationErrorType } from "./integration-error.model";
 import { PubSubClient } from "./pubsub-client.model";
+import { PubSubContactsMessage } from "./pubsub-contacts-message.model";
 
 const CONTACT_FETCH_TIMEOUT = 3000;
 
@@ -55,7 +56,7 @@ export class Controller {
 
     const { PUBSUB_TOPIC_NAME: topicName } = process.env;
 
-    if (isProduction()) {
+    if (isProduction() && typeof this.adapter.streamContacts === "function") {
       if (!topicName) {
         throw new Error("No pubsub topic name provided.");
       }
@@ -202,7 +203,7 @@ export class Controller {
               throw new Error("Invalid contacts received");
             }
 
-            const message = {
+            const message: PubSubContactsMessage = {
               userId: providerConfig.userId,
               timestamp,
               contacts: contacts.map((contact) =>

src/models/pubsub-client.model.ts

@@ -1,5 +1,6 @@
 import { PubSub } from "@google-cloud/pubsub";
 import { errorLogger, infoLogger } from "../util";
+import { PubSubContactsMessage } from "./pubsub-contacts-message.model";
 
 export class PubSubClient {
   private client: PubSub;
@@ -10,7 +11,7 @@ export class PubSubClient {
     this.topicName = topicName;
   }
 
-  async publishMessage(message: unknown) {
+  async publishMessage(message: PubSubContactsMessage) {
     try {
       if (!this.topicName) {
         throw new Error("No pubsub topic name provided.");
@@ -23,7 +24,7 @@ export class PubSubClient {
 
       infoLogger(
         PubSubClient.name,
-        `Published message ${json} to topic ${this.topicName}`
+        `Published ${message.contacts.length} contacts for user ${message.userId} to topic ${this.topicName}`
       );
     } catch (error) {
       console.error(error);

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

@@ -0,0 +1,7 @@
+import { Contact } from "./contact.model";
+
+export type PubSubContactsMessage = {
+  userId: string;
+  timestamp: number;
+  contacts: Contact[];
+};