test(scale): disable debug logs to make logs readable

rosen-bridge · Apr 15, 2024 · 59362b6 · 59362b6
1 parent 312e071
commit 59362b6
Showing 1 changed file with 12 additions and 3 deletions.
diff --git a/tests/scaling/src/node/node.ts b/tests/scaling/src/node/node.ts
@@ -1,7 +1,10 @@
 import { createRoseNetNode } from '@rosen-bridge/rosenet-node';
 
 const node = await createRoseNetNode({
-  logger: console,
+  logger: {
+    ...console,
+    debug: () => {},
+  },
   relayMultiaddrs: [process.env.RELAY_MULTIADDR!],
   privateKey: process.env.PRIVATE_KEY!,
 });
@@ -42,8 +45,10 @@ setInterval(async () => {
     for (const peer of process.env.ALL_PEER_IDS!.split(',')) {
       if (peer !== process.env.NODE_PEER_ID!) {
         try {
-          await node.sendMessage(peer, `${message}->${peer.slice(-5)}`);
+          const actualMessage = `${message}->${peer.slice(-5)}`;
+          await node.sendMessage(peer, actualMessage);
           MessageCounter.increase();
+          console.info(`Message sent: ${actualMessage}`);
         } catch (error) {
           console.warn(
             `tried to send a message to ${peer.slice(-5)} but failed due to error: ${error}`,
@@ -57,10 +62,14 @@ setInterval(async () => {
 
 node.handleIncomingMessage(async (from, message) => {
   if (message?.includes('Pong')) {
+    console.info(`Pong received: ${message}`);
     MessageCounter.decrease();
   } else {
+    console.info(`Message received: ${message}`);
     try {
-      await node.sendMessage(from, `Pong:${message}`);
+      const actualMessage = `Pong@${new Date().toLocaleTimeString([], { hour12: false })}:${message}`;
+      await node.sendMessage(from, actualMessage);
+      console.info(`Pong sent: ${actualMessage}`);
     } catch (error) {
       console.warn(
         `tried to pong message ${message} but failed due to error: ${error}`,