diff --git a/User/src/network/socket_communicator/tcp_client_communicator.ts b/User/src/network/socket_communicator/tcp_client_communicator.ts index 66bcc1c..235d569 100644 --- a/User/src/network/socket_communicator/tcp_client_communicator.ts +++ b/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 } } diff --git a/User/src/network/socket_communicator/tcp_server_communicator.ts b/User/src/network/socket_communicator/tcp_server_communicator.ts index 89741ba..63ea4b0 100644 --- a/User/src/network/socket_communicator/tcp_server_communicator.ts +++ b/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 } }