BLUE-257: Sending auth data for socket-connection

shardeum · Sep 3, 2024 · 80a15f9 · 80a15f9
1 parent 93690fc
commit 80a15f9
Showing 1 changed file with 6 additions and 12 deletions.
diff --git a/src/Data/Data.ts b/src/Data/Data.ts
@@ -191,21 +191,15 @@ export async function unsubscribeDataSender(
 
 export function initSocketClient(node: NodeList.ConsensusNodeInfo): void {
   if (config.VERBOSE) Logger.mainLogger.debug('Node Info to socket connect', node)
-  const socketClient = ioclient.connect(`http://${node.ip}:${node.port}`)
+  const socketClient = ioclient.connect(`http://${node.ip}:${node.port}`, {
+    query: {
+      data: JSON.stringify(Crypto.sign({ publicKey: State.getNodeInfo().publicKey })),
+    },
+  })
   socketClients.set(node.publicKey, socketClient)
 
-  let archiverKeyisEmitted = false
-
   socketClient.on('connect', () => {
-    Logger.mainLogger.debug(
-      `${!archiverKeyisEmitted ? 'New connection' : 'Reconnection'} to consensus node ${node.ip}:${
-        node.port
-      } is made`
-    )
-    if (archiverKeyisEmitted) return
-    // Send ehlo event right after connect:
-    socketClient.emit('ARCHIVER_PUBLIC_KEY', config.ARCHIVER_PUBLIC_KEY)
-    archiverKeyisEmitted = true
+    Logger.mainLogger.debug(`✅ New Socket Connection to consensus node ${node.ip}:${node.port} is made`)
     if (config.VERBOSE) Logger.mainLogger.debug('Connected node', node)
     if (config.VERBOSE) Logger.mainLogger.debug('Init socketClients', socketClients.size, dataSenders.size)
   })