fluencelabs/js-libp2p-noise
1
0
Fork 0
mirror of https://github.com/fluencelabs/js-libp2p-noise synced 2025-04-25 17:12:33 +00:00
Code Issues Projects Releases Wiki Activity

fix return types

Browse Source
This commit is contained in:
Marin Petrunić 2020-02-14 10:10:42 +01:00
parent 87f641f650
commit dbb896c249
No known key found for this signature in database
GPG Key ID: 834D07135E110DA5
3 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/handshake-ik.ts
View File

@ -54,7 +54,7 @@ export class IKHandshake implements IHandshake {
logger("IK Stage 0 - Responder receiving message..."); logger("IK Stage 0 - Responder receiving message...");
const receivedMsg = await this.connection.readLP(); const receivedMsg = await this.connection.readLP();
try { try {
const receivedMessageBuffer = decode1(receivedMsg); const receivedMessageBuffer = decode1(receivedMsg.slice());
const plaintext = this.ik.recvMessage(this.session, receivedMessageBuffer); const plaintext = this.ik.recvMessage(this.session, receivedMessageBuffer);
logger("IK Stage 0 - Responder got message, going to verify payload."); logger("IK Stage 0 - Responder got message, going to verify payload.");
const decodedPayload = await decodePayload(plaintext); const decodedPayload = await decodePayload(plaintext);

6
src/handshake-xx.ts
View File

@ -57,7 +57,7 @@ export class XXHandshake implements IHandshake {
logger("Stage 0 - Initiator finished sending first message."); logger("Stage 0 - Initiator finished sending first message.");
} else { } else {
logger("Stage 0 - Responder waiting to receive first message..."); logger("Stage 0 - Responder waiting to receive first message...");
const receivedMessageBuffer = decode0(await this.connection.readLP()); const receivedMessageBuffer = decode0((await this.connection.readLP()).slice());
this.xx.recvMessage(this.session, receivedMessageBuffer); this.xx.recvMessage(this.session, receivedMessageBuffer);
logger("Stage 0 - Responder received first message."); logger("Stage 0 - Responder received first message.");
} }
@ -67,7 +67,7 @@ export class XXHandshake implements IHandshake {
public async exchange(): Promise<void> { public async exchange(): Promise<void> {
if (this.isInitiator) { if (this.isInitiator) {
logger('Stage 1 - Initiator waiting to receive first message from responder...'); logger('Stage 1 - Initiator waiting to receive first message from responder...');
const receivedMessageBuffer = decode1(await this.connection.readLP()); const receivedMessageBuffer = decode1((await this.connection.readLP()).slice());
const plaintext = this.xx.recvMessage(this.session, receivedMessageBuffer); const plaintext = this.xx.recvMessage(this.session, receivedMessageBuffer);
logger('Stage 1 - Initiator received the message. Got remote\'s static key.'); logger('Stage 1 - Initiator received the message. Got remote\'s static key.');
@ -97,7 +97,7 @@ export class XXHandshake implements IHandshake {
logger('Stage 2 - Initiator sent message with signed payload.'); logger('Stage 2 - Initiator sent message with signed payload.');
} else { } else {
logger('Stage 2 - Responder waiting for third handshake message...'); logger('Stage 2 - Responder waiting for third handshake message...');
const receivedMessageBuffer = decode1(await this.connection.readLP()); const receivedMessageBuffer = decode1((await this.connection.readLP()).slice());
const plaintext = this.xx.recvMessage(this.session, receivedMessageBuffer); const plaintext = this.xx.recvMessage(this.session, receivedMessageBuffer);
logger('Stage 2 - Responder received the message, finished handshake. Got remote\'s static key.'); logger('Stage 2 - Responder received the message, finished handshake. Got remote\'s static key.');

4
src/utils.ts
View File

@ -74,7 +74,9 @@ export async function decodePayload(payload: bytes): Promise<INoisePayload> {
) as INoisePayload; ) as INoisePayload;
} }
export const getHandshakePayload = (publicKey: bytes ) => Buffer.concat([Buffer.from("noise-libp2p-static-key:"), publicKey]); export function getHandshakePayload(publicKey: bytes): bytes {
return Buffer.concat([Buffer.from("noise-libp2p-static-key:"), publicKey]);
}
async function isValidPeerId(peerId: bytes, publicKeyProtobuf: bytes) { async function isValidPeerId(peerId: bytes, publicKeyProtobuf: bytes) {
const generatedPeerId = await PeerId.createFromPubKey(publicKeyProtobuf); const generatedPeerId = await PeerId.createFromPubKey(publicKeyProtobuf);