♻️ pubsub timeout

Author: fgladisch

src/models/pubsub-client.model.ts

@@ -1,8 +1,9 @@
 import { PubSub } from "@google-cloud/pubsub";
+import { timeout } from "../util/timeout";
 import { PubSubContactsMessage } from "./pubsub-contacts-message.model";
-import { ServerError } from "./server-error.model";
 
 const PUBLISH_TIMEOUT = 10_000;
+
 export class PubSubClient {
   private client: PubSub;
   private topicName: string;
@@ -17,27 +18,16 @@ export class PubSubClient {
       throw new Error("No pubsub topic name provided.");
     }
 
-    const timeout = (ms: number) =>
-      new Promise((_, reject) =>
-        setTimeout(
-          () =>
-            reject(
-              new ServerError(
-                500,
-                "Could not publish message in time, did you forget to run gcloud auth application-default login?"
-              )
-            ),
-          ms
-        )
-      );
-
     const json = JSON.stringify(message);
     const dataBuffer = Buffer.from(json);
     const topic = this.client.topic(this.topicName);
 
     await Promise.race([
       topic.publishMessage({ data: dataBuffer }),
-      timeout(PUBLISH_TIMEOUT),
+      timeout(
+        PUBLISH_TIMEOUT,
+        "Could not publish message in time. Did you forget to authenticate with GCP? (gcloud auth application-default login)"
+      ),
     ]);
   }
 }

src/util/timeout.ts

@@ -0,0 +1,6 @@
+import { ServerError } from "../models";
+
+export const timeout = (timeMs: number, errorMessage: string) =>
+  new Promise((_, reject) =>
+    setTimeout(() => reject(new ServerError(500, errorMessage)), timeMs)
+  );