From af394e742e72a26259d408f7c3f18d5a8e5b8c8a Mon Sep 17 00:00:00 2001
From: cauta <trongcauhcmus@gmail.com>
Date: Fri, 10 May 2024 18:14:04 +0700
Subject: [PATCH] revert to no control

---
 .../src/worker-service.controller.ts          | 52 ++++++++++---------
 1 file changed, 28 insertions(+), 24 deletions(-)

diff --git a/app/apps/worker-service/src/worker-service.controller.ts b/app/apps/worker-service/src/worker-service.controller.ts
index bcce77c..5035fee 100644
--- a/app/apps/worker-service/src/worker-service.controller.ts
+++ b/app/apps/worker-service/src/worker-service.controller.ts
@@ -27,41 +27,45 @@ export class WorkerServiceController {
 
   @EventPattern(TopicName.ETH_DETECTED_BLOCK)
   async ethDetectBlock(data: any) {
-    await Promise.race([
-      this.ethereumWorker.ethHandleDetectedBlock(data),
-      this.delay(1000).then(() => {
-        return;
-      }),
-    ]);
+    this.ethereumWorker.ethHandleDetectedBlock(data);
+    // await Promise.race([
+    //   this.ethereumWorker.ethHandleDetectedBlock(data),
+    //   this.delay(1000).then(() => {
+    //     return;
+    //   }),
+    // ]);
   }
 
   @EventPattern(TopicName.ETH_CONFIRMED_BLOCK)
   async ethConfirmBlock(data: any) {
-    await Promise.race([
-      this.ethereumWorker.ethHandleConfirmedBlock(data),
-      this.delay(1000).then(() => {
-        return;
-      }),
-    ]);
+    this.ethereumWorker.ethHandleConfirmedBlock(data);
+    // await Promise.race([
+    //   this.ethereumWorker.ethHandleConfirmedBlock(data),
+    //   this.delay(1000).then(() => {
+    //     return;
+    //   }),
+    // ]);
   }
 
   @EventPattern(TopicName.POLYGON_DETECTED_BLOCK)
   async polygonDetectBlock(data: any) {
-    await Promise.race([
-      this.polygonWorker.ethHandleDetectedBlock(data),
-      this.delay(1000).then(() => {
-        return;
-      }),
-    ]);
+    this.polygonWorker.ethHandleDetectedBlock(data);
+    // await Promise.race([
+    //   this.polygonWorker.ethHandleDetectedBlock(data),
+    //   this.delay(1000).then(() => {
+    //     return;
+    //   }),
+    // ]);
   }
 
   @EventPattern(TopicName.POLYGON_CONFIRMED_BLOCK)
   async polygonConfirmBlock(data: any) {
-    await Promise.race([
-      this.polygonWorker.ethHandleConfirmedBlock(data),
-      this.delay(1000).then(() => {
-        return;
-      }),
-    ]);
+    this.polygonWorker.ethHandleConfirmedBlock(data);
+    // await Promise.race([
+    //   this.polygonWorker.ethHandleConfirmedBlock(data),
+    //   this.delay(1000).then(() => {
+    //     return;
+    //   }),
+    // ]);
   }
 }