diff --git a/packages/mcots/src/messageProcessors/processServerLogin.ts b/packages/mcots/src/messageProcessors/processServerLogin.ts index 2b5df0633..b2c6ca7e7 100644 --- a/packages/mcots/src/messageProcessors/processServerLogin.ts +++ b/packages/mcots/src/messageProcessors/processServerLogin.ts @@ -27,7 +27,8 @@ export async function processServerLogin( log.debug(`Sending LoginCompleteMessage: ${response.toString()}`); // Send response packet - const responsePacket = new ServerPacket(response.getMessageId()); + const responsePacket = new ServerPacket(); + responsePacket.setMessageId(response.getMessageId()); responsePacket.setDataBuffer(response.serialize()); responsePacket.setSequence(message.sequence); diff --git a/packages/mcots/src/messageProcessors/processStockCarInfo.ts b/packages/mcots/src/messageProcessors/processStockCarInfo.ts index 114b377fa..454ae7be7 100644 --- a/packages/mcots/src/messageProcessors/processStockCarInfo.ts +++ b/packages/mcots/src/messageProcessors/processStockCarInfo.ts @@ -51,7 +51,8 @@ export async function processStockCarInfo( responsePacket.setDealerId(lotOwnerId); responsePacket.setBrandId(brandId); - const response = new ServerPacket(141); + const response = new ServerPacket(); + response.setMessageId(141); if (inventoryCars.inventory.length > StockCarInfo.MAX_CARS_PER_MESSAGE) { log.error( diff --git a/packages/mcots/src/messageProcessors/sendSuccess.ts b/packages/mcots/src/messageProcessors/sendSuccess.ts index 16df99596..ae27e7acc 100644 --- a/packages/mcots/src/messageProcessors/sendSuccess.ts +++ b/packages/mcots/src/messageProcessors/sendSuccess.ts @@ -9,7 +9,8 @@ export function sendSuccess( pReply.setMessageId(101); pReply.msgReply = 438; - const response = new ServerPacket(101); + const response = new ServerPacket(); + response.setMessageId(101); response.setDataBuffer(pReply.serialize()); response.setSequence(message.sequence); diff --git a/packages/transactions/src/internal.ts b/packages/transactions/src/internal.ts index b8b4f44ef..29d0b8406 100644 --- a/packages/transactions/src/internal.ts +++ b/packages/transactions/src/internal.ts @@ -116,7 +116,7 @@ export async function receiveTransactionsData({ // Normalize the message - const inboundMessage = new ServerPacket(0); + const inboundMessage = new ServerPacket(); inboundMessage.deserialize(message.serialize()); log.debug( @@ -168,7 +168,7 @@ export async function receiveTransactionsData({ response.messages.forEach((message) => { log.debug(`[${connectionId}] Processing outbound message`); - const outboundMessage = new ServerPacket(0); + const outboundMessage = new ServerPacket(); outboundMessage.deserialize(message.serialize()); if (outboundMessage.isPayloadEncrypted()) { diff --git a/packages/transactions/src/login.ts b/packages/transactions/src/login.ts index f3b091858..30e3927c6 100644 --- a/packages/transactions/src/login.ts +++ b/packages/transactions/src/login.ts @@ -17,7 +17,7 @@ export async function login({ log, }: MessageHandlerArgs): Promise { // Normalize the packet - const incomingPacket = new ServerPacket(0); + const incomingPacket = new ServerPacket(); incomingPacket.deserialize(packet.serialize()); log.debug(