Fix formatting issues.

Author: taeold

spec/common/providers/https.spec.ts

@@ -811,14 +811,13 @@ describe("onCallHandler", () => {
         { accept: "text/event-stream" }
       ) as any;
 
-
       const fn = https.onCallHandler(
         {
           cors: { origin: true, methods: "POST" },
         },
-        async (req, resp) => {
+        (req, resp) => {
           resp.write("initial message");
-          mockReq.emit('close');
+          mockReq.emit("close");
           resp.write("should not be sent");
           return "done";
         },
@@ -852,18 +851,18 @@ describe("onCallHandler", () => {
         const fn = https.onCallHandler(
           {
             cors: { origin: true, methods: "POST" },
-            heartbeatSeconds: 5
+            heartbeatSeconds: 5,
           },
           async () => {
             // Simulate long-running operation
-            await new Promise(resolve => setTimeout(resolve, 11_000));
+            await new Promise((resolve) => setTimeout(resolve, 11_000));
             return "done";
           },
           "gcfv2"
         );
 
         const handlerPromise = runHandler(fn, mockReq as any);
-        await clock.tickAsync(11_000)
+        await clock.tickAsync(11_000);
         const resp = await handlerPromise;
         expect(resp.body).to.include(': ping\n: ping\ndata: {"result":"done"}');
       });
@@ -879,10 +878,10 @@ describe("onCallHandler", () => {
         const fn = https.onCallHandler(
           {
             cors: { origin: true, methods: "POST" },
-            heartbeatSeconds: null
+            heartbeatSeconds: null,
           },
           async () => {
-            await new Promise(resolve => setTimeout(resolve, 31_000));
+            await new Promise((resolve) => setTimeout(resolve, 31_000));
             return "done";
           },
           "gcfv2"

spec/helper.ts

@@ -53,7 +53,7 @@ export function runHandler(
       private callback: () => void;
 
       constructor() {
-        request.on("close", () => this.end())
+        request.on("close", () => this.end());
       }
 
       public status(code: number) {

src/common/providers/https.ts

@@ -713,7 +713,7 @@ export interface CallableOptions {
    *
    * Defaults to 30 seconds.
    */
-  heartbeatSeconds?: number | null
+  heartbeatSeconds?: number | null;
 }
 
 /** @internal */
@@ -752,9 +752,9 @@ function wrapOnCallHandler<Req = any, Res = any>(
         clearInterval(heartbeatInterval);
         heartbeatInterval = null;
       }
-    }
+    };
 
-    req.on('close', () => {
+    req.on("close", () => {
       clearHeartbeatInterval();
       abortController.abort();
     });
@@ -832,27 +832,24 @@ function wrapOnCallHandler<Req = any, Res = any>(
           write(chunk): boolean {
             // if client doesn't accept sse-protocol, response.write() is no-op.
             if (!acceptsStreaming) {
-              return false
+              return false;
             }
             // if connection is already closed, response.write() is no-op.
             if (abortController.signal.aborted) {
-              return false
+              return false;
             }
             const formattedData = encodeSSE({ message: chunk });
             return res.write(formattedData);
           },
           acceptsStreaming,
-          signal: abortController.signal
+          signal: abortController.signal,
         };
         if (acceptsStreaming) {
           // SSE always responds with 200
           res.status(200);
           const heartbeatSeconds = options.heartbeatSeconds ?? DEFAULT_HEARTBEAT_SECONDS;
           if (heartbeatSeconds !== null && heartbeatSeconds > 0) {
-            heartbeatInterval = setInterval(
-              () => res.write(": ping\n"),
-              heartbeatSeconds * 1000
-            );
+            heartbeatInterval = setInterval(() => res.write(": ping\n"), heartbeatSeconds * 1000);
           }
         }
         // For some reason the type system isn't picking up that the handler

src/v2/providers/https.ts

@@ -205,7 +205,7 @@ export interface CallableOptions extends HttpsOptions {
    *
    * Defaults to 30 seconds.
    */
-  heartbeatSeconds?: number | null
+  heartbeatSeconds?: number | null;
 }
 
 /**