fluencelabs/js-libp2p-noise
1
0
Fork 0
mirror of https://github.com/fluencelabs/js-libp2p-noise synced 2025-06-26 08:01:49 +00:00
Code Issues Projects Releases Wiki Activity

switch proto definitions into json definitions

Browse Source
This commit is contained in:
Marin Petrunić
2020-02-06 09:51:39 +01:00
parent 2f6cc39888
commit b5100f3e47
4 changed files with 36 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
src/proto/payload.json Normal file
View File

@ -0,0 +1,24 @@
{
"nested": {
"NoiseHandshakePayload": {
"fields": {
"libp2pKey": {
"type": "bytes",
"id": 1
},
"noiseStaticKeySignature": {
"type": "bytes",
"id": 2
},
"libp2pData": {
"type": "bytes",
"id": 3
},
"libp2pDataSignature": {
"type": "bytes",
"id": 4
}
}
}
}
}

16
src/utils.ts
View File

@ -3,14 +3,14 @@ import protobuf from "protobufjs";
import { Buffer } from "buffer";
import PeerId from "peer-id";
import * as crypto from 'libp2p-crypto';
import { KeyPair } from "./@types/libp2p";
import {bytes, bytes32} from "./@types/basic";
import {Hkdf} from "./@types/handshake";
import payloadProto from "./proto/payload.json";
export async function loadPayloadProto () {
const payloadProtoBuf = await protobuf.load("protos/payload.proto");
return payloadProtoBuf.lookupType("pb.NoiseHandshakePayload");
const payloadProtoBuf = await protobuf.Root.fromJSON(payloadProto);
return payloadProtoBuf.lookupType("NoiseHandshakePayload");
}
export function generateKeypair(): KeyPair {
@ -92,9 +92,15 @@ export async function verifySignedPayload(noiseStaticKey: bytes, plaintext: byte
let receivedPayload;
try {
const NoiseHandshakePayload = await loadPayloadProto();
receivedPayload = NoiseHandshakePayload.toObject(NoiseHandshakePayload.decode(plaintext));
receivedPayload = NoiseHandshakePayload.toObject(
NoiseHandshakePayload.decode(plaintext)
);
//temporary fix until protobufsjs conversion options starts working
//by default it ends up as Uint8Array
receivedPayload.libp2pKey = Buffer.from(receivedPayload.libp2pKey);
receivedPayload.noiseStaticKeySignature = Buffer.from(receivedPayload.noiseStaticKeySignature);
} catch (e) {
throw new Error("Failed to decode received payload.");
throw new Error("Failed to decode received payload. Reason: " + e.message);
}
if (!(await isValidPeerId(peerId, receivedPayload.libp2pKey)) ) {