feat: refactor

packages/network-support/src/scoreManager.ts

@@ -10,7 +10,6 @@ import {
   getLatencyScoreWeight,
 } from './utils/score';
 import { Version } from './utils/version';
-import timeBarrier from './utils/timeBarer';
 
 type Options = {
   logger: Logger;
@@ -164,17 +163,14 @@ export class ScoreManager {
     this.scoreStore.set(key, score);
     extraLog = extraLog || {};
 
-    if (score.score <= 1) {
-      const inserted = timeBarrier.set(`${this.projectId}_${runner}`);
-      if (inserted && this.notifyFunc) {
-        this.notifyFunc({
-          text: `*Title*: score down from ${before} to ${score.score}\n*DeploymentId*: ${
-            this.projectId
-          }\n*Indexer*: ${runner}\n*Info*: ${errorType} - ${JSON.stringify(
-            extraLog
-          )}\n*TimeBarrier*: ${timeBarrier.inspect()}\n*Time*: ${new Date().toISOString()}`,
-        });
-      }
+    if (score.score <= 1 && this.notifyFunc) {
+      this.notifyFunc(`${this.projectId}_${runner}`, {
+        text: `*Title*: score down from ${before} to ${score.score}\n*DeploymentId*: ${
+          this.projectId
+        }\n*Indexer*: ${runner}\n*Info*: ${errorType} - ${JSON.stringify(
+          extraLog
+        )}\n*Time*: ${new Date().toISOString()}`,
+      });
     }
 
     this.logger?.info({

packages/network-support/src/types.ts

@@ -84,4 +84,4 @@ export type ScoreWithDetail = {
   scoreDetail: Record<SCORE_DETAIL_TYPE, number>;
 };
 
-export type NotifyFunc = (data: any, headers?: Record<string, string>) => Promise<void>;
+export type NotifyFunc = (id: string, data: any, headers?: Record<string, string>) => Promise<void>;

packages/network-support/src/utils/index.ts

@@ -8,4 +8,3 @@ export * from './auth';
 export * from './uniqueId';
 export * from './common';
 export * from './score';
-export * from './timeBarer';