Fix heartbeat

src/services/PriceFeed/ws/PriceFeedAllTickersWS.ts

@@ -9,13 +9,15 @@ const schema = z.array(z.union([
 export default class PriceFeedAllTickersWS {
   private pairsWebSocket: WebSocket;
 
+  private heartbeatInterval: ReturnType<typeof setInterval>;
+
   constructor(
     url: string,
     updateData: (pairs: z.infer<typeof tickerInfoSchema>[]) => void,
   ) {
     this.pairsWebSocket = new WebSocket(url);
 
-    setInterval(() => {
+    this.heartbeatInterval = setInterval(() => {
       this.pairsWebSocket.send('heartbeat');
     }, 15000);
 
@@ -31,6 +33,7 @@ export default class PriceFeedAllTickersWS {
   }
 
   kill() {
+    clearInterval(this.heartbeatInterval);
     this.pairsWebSocket.close();
   }
 }

src/services/PriceFeed/ws/PriceFeedLastPriceWS.ts

@@ -9,6 +9,8 @@ const schema = z.tuple([
 export default class PriceFeedLastPriceWS {
   private pairsWebSocket: WebSocket;
 
+  private heartbeatInterval: ReturnType<typeof setInterval>;
+
   constructor(
     url: string,
     pair: string,
@@ -16,7 +18,7 @@ export default class PriceFeedLastPriceWS {
   ) {
     this.pairsWebSocket = new WebSocket(url + pair);
 
-    setInterval(() => {
+    this.heartbeatInterval = setInterval(() => {
       this.pairsWebSocket.send('heartbeat');
     }, 15000);
 
@@ -30,6 +32,7 @@ export default class PriceFeedLastPriceWS {
   }
 
   kill() {
+    clearInterval(this.heartbeatInterval);
     this.pairsWebSocket.close();
   }
 }