diff --git a/src/handshake-ik.ts b/src/handshake-ik.ts index 5cdf52a..9e50a0e 100644 --- a/src/handshake-ik.ts +++ b/src/handshake-ik.ts @@ -50,9 +50,9 @@ export class IKHandshake implements IHandshake { logger("IK Stage 0 - Initiator sent message."); } else { logger("IK Stage 0 - Responder receiving message..."); - const receivedMsg = (await this.connection.readLP()).slice(); + const receivedMsg = await this.connection.readLP(); try { - const receivedMessageBuffer = decode1(Buffer.from(receivedMsg)); + const receivedMessageBuffer = decode1(receivedMsg); const plaintext = this.ik.recvMessage(this.session, receivedMessageBuffer); logger("IK Stage 0 - Responder got message, going to verify payload."); diff --git a/src/handshake-xx.ts b/src/handshake-xx.ts index ed65093..1453e95 100644 --- a/src/handshake-xx.ts +++ b/src/handshake-xx.ts @@ -53,7 +53,7 @@ export class XXHandshake implements IHandshake { logger("Stage 0 - Initiator finished sending first message."); } else { logger("Stage 0 - Responder waiting to receive first message..."); - const receivedMessageBuffer = decode0((await this.connection.readLP()).slice()); + const receivedMessageBuffer = decode0(await this.connection.readLP()); this.xx.recvMessage(this.session, receivedMessageBuffer); logger("Stage 0 - Responder received first message."); } @@ -91,7 +91,7 @@ export class XXHandshake implements IHandshake { logger('Stage 2 - Initiator sent message with signed payload.'); } else { logger('Stage 2 - Responder waiting for third handshake message...'); - const receivedMessageBuffer = decode1((await this.connection.readLP()).slice()); + const receivedMessageBuffer = decode1(await this.connection.readLP()); const plaintext = this.xx.recvMessage(this.session, receivedMessageBuffer); logger('Stage 2 - Responder received the message, finished handshake. Got remote\'s static key.');