network chunk v5

User/src/network/socket_communicator/tcp_client_communicator.ts

@@ -20,7 +20,7 @@ export class TcpClientCommunicator extends SocketCommunicatorBase {
         this.socket = socket;
         this.aesKey = null;
         this.aesIv = null;
-        this.serverPublicKey = null;c
+        this.serverPublicKey = null;
         this.isAesKeySetFlag = false;
         this.chunkBuffers = {};  // Initialize chunk buffer for reassembling messages
     }
@@ -91,6 +91,7 @@ export class TcpClientCommunicator extends SocketCommunicatorBase {
             const chunkWithHeader = `${chunkHeader}|${chunk}`;
 
             await this.writeToSocket(chunkWithHeader);
+            await new Promise((resolve) => setTimeout(resolve, 300));  // Simulate network delay
         }
     }
 

User/src/network/socket_communicator/tcp_server_communicator.ts

@@ -100,6 +100,8 @@ export class TcpServerCommunicator extends SocketCommunicatorBase {
         const [headerJson, chunkContent] = incomingMessage.split('|');
         const header = JSON.parse(headerJson);
 
+        console.log(`\n\n${incomingMessage}\n\n`);
+
         // Initialize chunk array if this is the first chunk for this messageId
         if (!this.chunkBuffers[header.messageId]) {
             this.chunkBuffers[header.messageId] = new Array(header.totalChunks);
@@ -158,6 +160,7 @@ export class TcpServerCommunicator extends SocketCommunicatorBase {
             const chunkWithHeader = `${chunkHeader}|${chunk}`;
 
             await this.writeToSocket(chunkWithHeader);
+            await new Promise((resolve) => setTimeout(resolve, 300));  // Simulate network delay
         }
     }