test blank worker

dydxprotocol · Jun 24, 2024 · 24ad8b8 · 24ad8b8
1 parent 0212d67
commit 24ad8b8
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 6 deletions.
diff --git a/indexer/services/socks/src/lib/message-forwarder.ts b/indexer/services/socks/src/lib/message-forwarder.ts
@@ -27,14 +27,14 @@ import {
 import { Index } from '../websocket/index';
 import { MAX_TIMEOUT_INTEGER } from './constants';
 import { Subscriptions } from './subscription';
-import {
+import getMessagesToForward, {
   getChannels,
 } from './workers/from-kafka-helpers';
 
 const piscina = new Piscina({
-  filename: path.resolve(__dirname, 'workers/from-kafka-helpers.js'),
-  minThreads: 4,
-  maxThreads: 4,
+  filename: path.resolve(__dirname, 'workers/blank-worker.js'),
+  minThreads: 1,
+  maxThreads: 2,
 });
 
 const BATCH_SEND_INTERVAL_MS: number = config.BATCH_SEND_INTERVAL_MS;
@@ -124,10 +124,10 @@ export class MessageForwarder {
     errProps.channels = channels;
 
     // Decode the message based on the topic
-    // const messagesToForward = getMessagesToForward(topic, message);
     const clobPairIdToTickerMap:
     Record<string, string> = perpetualMarketRefresher.getClobPairIdToTickerMap();
-    const messagesToForward = await piscina.run({ topic, message, clobPairIdToTickerMap });
+    const messagesToForward = getMessagesToForward({ topic, message, clobPairIdToTickerMap });
+    await piscina.run({});
     for (const messageToForward of messagesToForward) {
       const startForwardMessage: number = Date.now();
       this.forwardMessage(messageToForward);

diff --git a/indexer/services/socks/src/lib/workers/blank-worker.ts b/indexer/services/socks/src/lib/workers/blank-worker.ts
@@ -0,0 +1,8 @@
+import {logger} from '@dydxprotocol-indexer/base';
+
+export default function print(): void {
+  logger.info({
+    at: 'blank-worker#print',
+    message: 'Hello, World!',
+  });
+}