stop pinging when stop is called

Author: parthlambdatest

src/lib/server.ts

@@ -4,6 +4,7 @@ import fastify, { FastifyInstance, RouteShorthandOptions } from 'fastify';
 import { readFileSync } from 'fs'
 import { Context } from '../types.js'
 import { validateSnapshot } from './schemaValidation.js'
+import { pingIntervalId } from './utils.js';
 
 export default async (ctx: Context): Promise<FastifyInstance<Server, IncomingMessage, ServerResponse>> => {
 
@@ -71,6 +72,11 @@ export default async (ctx: Context): Promise<FastifyInstance<Server, IncomingMes
 			}
 			let resp = await ctx.client.getS3PreSignedURL(ctx);
             await ctx.client.uploadLogs(ctx, resp.data.url);
+
+			if (pingIntervalId !== null) {
+				clearInterval(pingIntervalId);
+				ctx.log.debug('Ping polling stopped immediately.');
+			}
 			replyCode = 200;
 			replyBody = { data: { message: "success", type: "DELETE" } };
 		} catch (error: any) {

src/lib/utils.ts

@@ -305,6 +305,8 @@ export async function startPolling(ctx: Context): Promise<void> {
     }, 5000);
 }
 
+export let pingIntervalId: NodeJS.Timeout | null = null;
+
 export async function startPingPolling(ctx: Context): Promise<void> {
     try {
         ctx.log.debug('Sending initial ping to server...');
@@ -314,14 +316,17 @@ export async function startPingPolling(ctx: Context): Promise<void> {
         ctx.log.error(`Error during initial ping: ${error.message}`);
     }
 
-    setInterval(async () => {
+    // Start the polling interval
+    pingIntervalId = setInterval(async () => {
         try {
             ctx.log.debug('Sending ping to server...');
             await ctx.client.ping(ctx.build.id, ctx.log);
             ctx.log.debug('Ping sent successfully.');
         } catch (error: any) {
             ctx.log.error(`Error during ping polling: ${error.message}`);
         }
-    }, 10 * 60 * 1000);
+    }, 10 * 60 * 1000); // 10 minutes interval
 }
 
+
+