425 lines
18 KiB
JavaScript
425 lines
18 KiB
JavaScript
var expect = require("chai").expect;
|
|
var allTests = typeof window === "undefined" ?
|
|
!!process.env.ALL_TESTS :
|
|
window.ALL_TESTS;
|
|
|
|
var bufferEqual = require("buffer-equal");
|
|
var bitmessage = require("./lib");
|
|
var bmcrypto = require("./lib/crypto");
|
|
var structs = bitmessage.structs;
|
|
var message = structs.message;
|
|
var var_int = structs.var_int;
|
|
var var_str = structs.var_str;
|
|
var var_int_list = structs.var_int_list;
|
|
var net_addr = structs.net_addr;
|
|
var encrypted = structs.encrypted;
|
|
var messageEncodings = structs.messageEncodings;
|
|
var serviceFeatures = structs.serviceFeatures;
|
|
var pubkeyFeatures = structs.pubkeyFeatures;
|
|
var WIF = bitmessage.WIF;
|
|
var POW = bitmessage.POW;
|
|
var Address = bitmessage.Address;
|
|
var UserAgent = bitmessage.UserAgent;
|
|
|
|
describe("Crypto", function() {
|
|
it("should implement SHA-512 hash", function() {
|
|
expect(bmcrypto.sha512(Buffer("test")).toString("hex")).to.equal("ee26b0dd4af7e749aa1a8ee3c10ae9923f618980772e473f8819a5d4940e0db27ac185f8a0e1d5f84f88bc887fd67b143732c304cc5fa9ad8e6f57f50028a8ff");
|
|
});
|
|
|
|
it("should implement SHA-256 hash", function() {
|
|
expect(bmcrypto.sha256(Buffer("test")).toString("hex")).to.equal("9f86d081884c7d659a2feaa0c55ad015a3bf4f1b2b0b822cd15d6c15b0f00a08");
|
|
});
|
|
|
|
it("should implement RIPEMD-160 hash", function() {
|
|
expect(bmcrypto.ripemd160(Buffer("test")).toString("hex")).to.equal("5e52fee47e6b070565f74372468cdc699de89107");
|
|
});
|
|
|
|
it("should implement cryptographically secure PRNG", function() {
|
|
var size = 100;
|
|
var rnd = bmcrypto.randomBytes(size);
|
|
expect(Buffer.isBuffer(rnd)).to.be.true;
|
|
expect(rnd.length).to.equal(size);
|
|
// Very simple statistical test.
|
|
var bytes = {};
|
|
var sum = 0;
|
|
var value;
|
|
for (var i = 0; i < size; i++) {
|
|
value = rnd[i];
|
|
sum += value;
|
|
if (!bytes[value]) {
|
|
bytes[value] = 0;
|
|
}
|
|
bytes[value]++;
|
|
expect(bytes[value]).to.be.below(7);
|
|
}
|
|
// Ideal sum = (255 / 2) * size = 12750
|
|
expect(sum).to.be.above(10000);
|
|
expect(sum).to.be.below(15000);
|
|
});
|
|
});
|
|
|
|
describe("Common structures", function() {
|
|
describe("message", function() {
|
|
it("should decode", function() {
|
|
var res;
|
|
res = message.decode(Buffer("e9beb4d97465737400000000000000000000000770b33ce97061796c6f6164", "hex"));
|
|
expect(res.command).to.equal("test");
|
|
expect(res.payload.toString()).to.equal("payload");
|
|
expect(res.length).to.equal(31);
|
|
expect(res.rest.toString("hex")).to.equal("");
|
|
|
|
res = message.decode(Buffer("e9beb4d90000000000000000000000000000000770b33ce97061796c6f6164", "hex"));
|
|
expect(res.command).to.equal("");
|
|
});
|
|
|
|
it("should encode", function() {
|
|
expect(message.encode({command: "test", payload: Buffer("payload")}).toString("hex")).to.equal("e9beb4d97465737400000000000000000000000770b33ce97061796c6f6164");
|
|
});
|
|
});
|
|
|
|
describe("var_int", function() {
|
|
it("should decode", function() {
|
|
var res;
|
|
expect(var_int.decode.bind(null, Buffer([]))).to.throw(Error);
|
|
expect(var_int.decode.bind(null, Buffer("fd00", "hex"))).to.throw(Error);
|
|
expect(var_int.decode.bind(null, Buffer("ff004170706e9b0368", "hex"))).to.throw(Error);
|
|
|
|
res = var_int.decode(Buffer([123]));
|
|
expect(res.value).to.equal(123);
|
|
expect(res.length).to.equal(1);
|
|
expect(res.rest.toString("hex")).to.equal("")
|
|
|
|
res = var_int.decode(Buffer("fd123456", "hex"));
|
|
expect(res.value).to.equal(0x1234);
|
|
expect(res.length).to.equal(3);
|
|
expect(res.rest.toString("hex")).to.equal("56");
|
|
|
|
res = var_int.decode(Buffer("fe1234567890", "hex"));
|
|
expect(res.value).to.equal(0x12345678);
|
|
expect(res.length).to.equal(5);
|
|
expect(res.rest.toString("hex")).to.equal("90");
|
|
|
|
res = var_int.decode(Buffer("ff0000001234567890", "hex"));
|
|
expect(res.value).to.equal(0x1234567890);
|
|
expect(res.length).to.equal(9);
|
|
expect(res.rest.length).to.equal(0);
|
|
});
|
|
|
|
it("should check for lowest length on decode", function() {
|
|
expect(var_int.decode.bind(null, Buffer("fd00fc", "hex"))).to.throw(Error);
|
|
expect(var_int.decode.bind(null, Buffer("fe0000ffff", "hex"))).to.throw(Error);
|
|
expect(var_int.decode.bind(null, Buffer("ff00000000ffffffff", "hex"))).to.throw(Error);
|
|
});
|
|
|
|
it("should encode", function() {
|
|
expect(var_int.encode(123).toString("hex")).to.equal("7b");
|
|
expect(var_int.encode(0x1234).toString("hex")).to.equal("fd1234");
|
|
expect(var_int.encode(0x12345678).toString("hex")).to.equal("fe12345678");
|
|
expect(var_int.encode(0x1234567890).toString("hex")).to.equal("ff0000001234567890");
|
|
expect(var_int.encode(Buffer("1234567890", "hex")).toString("hex")).to.equal("ff0000001234567890");
|
|
expect(var_int.encode.bind(null, -123)).to.throw(Error);
|
|
expect(var_int.encode.bind(null, 0x4170706e9b0368)).to.throw(Error);
|
|
expect(var_int.encode.bind(null, Buffer("123456789012345678", "hex"))).to.throw(Error);
|
|
expect(var_int.encode.bind(null, "test")).to.throw(Error);
|
|
});
|
|
});
|
|
|
|
describe("var_str", function() {
|
|
it("should decode", function() {
|
|
var res;
|
|
res = var_str.decode(Buffer("00", "hex"));
|
|
expect(res.str).to.equal("");
|
|
expect(res.length).to.equal(1);
|
|
expect(res.rest.toString("hex")).to.equal("");
|
|
|
|
res = var_str.decode(Buffer("0474657374", "hex"));
|
|
expect(res.str).to.equal("test");
|
|
expect(res.length).to.equal(5);
|
|
expect(res.rest.toString("hex")).to.equal("");
|
|
|
|
res = var_str.decode(Buffer("0474657374ffffff", "hex"));
|
|
expect(res.str).to.equal("test");
|
|
expect(res.length).to.equal(5);
|
|
expect(res.rest.toString("hex")).to.equal("ffffff");
|
|
|
|
// Truncated input.
|
|
expect(var_str.decode.bind(null, Buffer("04746573", "hex"))).to.throw(Error);
|
|
});
|
|
|
|
it("should encode", function() {
|
|
expect(var_str.encode("test").toString("hex")).to.equal("0474657374");
|
|
expect(var_str.encode("").toString("hex")).to.equal("00");
|
|
});
|
|
});
|
|
|
|
describe("var_int_list", function() {
|
|
it("should decode", function() {
|
|
var res;
|
|
res = var_int_list.decode(Buffer("00", "hex"));
|
|
expect(res.list).to.deep.equal([]);
|
|
expect(res.length).to.equal(1);
|
|
expect(res.rest.toString("hex")).to.equal("");
|
|
|
|
res = var_int_list.decode(Buffer("0501fd0400ff0004000000000000fd9c40fe000186a0", "hex"));
|
|
expect(res.length).to.equal(22);
|
|
expect(res.list.length).to.equal(5);
|
|
expect(res.list[0]).to.equal(1);
|
|
expect(res.list[1]).to.equal(1024);
|
|
expect(res.list[2] == 1125899906842624).to.be.true;
|
|
expect(res.list[3]).to.equal(40000);
|
|
expect(res.list[4]).to.equal(100000);
|
|
expect(res.rest.toString("hex")).to.equal("");
|
|
|
|
res = var_int_list.decode(Buffer("0501fd0400ff0004000000000000fd9c40fe000186a0ffffff", "hex"));
|
|
expect(res.length).to.equal(22);
|
|
expect(res.list.length).to.equal(5);
|
|
expect(res.rest.toString("hex")).to.equal("ffffff");
|
|
|
|
// Truncated input.
|
|
expect(var_int_list.decode.bind(null, Buffer("0501fd0400ff0004000000000000fd9c40fe000186", "hex"))).to.throw(Error);
|
|
});
|
|
|
|
it("should encode", function() {
|
|
expect(var_int_list.encode([]).toString("hex")).to.equal("00");
|
|
expect(var_int_list.encode([1, 1024, 1125899906842624, 40000, 100000]).toString("hex")).to.equal("0501fd0400ff0004000000000000fd9c40fe000186a0");
|
|
});
|
|
});
|
|
|
|
// FIXME(Kagami): Add more tests for inet_pton, inet_ntop; add more
|
|
// fail tests.
|
|
describe("net_addr", function() {
|
|
it("should decode", function() {
|
|
var res;
|
|
res = net_addr.decode(Buffer("0000000054aaf6c000000001000000000000000100000000000000000000ffff7f00000120fc", "hex"));
|
|
expect(res.time.getTime()).to.equal(1420490432000);
|
|
expect(res.stream).to.equal(1);
|
|
expect(res.services).to.have.members([serviceFeatures.NODE_NETWORK]);
|
|
expect(res.host).to.equal("127.0.0.1");
|
|
expect(res.port).to.equal(8444);
|
|
|
|
expect(net_addr.decode.bind(null, Buffer("000000000000000100000000000000000000ffff7f00000120fc", "hex"))).to.throw(Error);;
|
|
|
|
res = net_addr.decode(Buffer("000000000000000100000000000000000000ffff7f00000120fc", "hex"), {short: true});
|
|
expect(res.services).to.have.members([serviceFeatures.NODE_NETWORK]);
|
|
expect(res.host).to.equal("127.0.0.1");
|
|
expect(res.port).to.equal(8444);
|
|
|
|
res = net_addr.decode(Buffer("000000000000000100000000000000000000000000000001fde8", "hex"), {short: true});
|
|
expect(res.services).to.have.members([serviceFeatures.NODE_NETWORK]);
|
|
expect(res.host).to.equal("0:0:0:0:0:0:0:1");
|
|
expect(res.port).to.equal(65000);
|
|
});
|
|
|
|
it("should encode", function() {
|
|
var time = new Date(1420490432000);
|
|
expect(net_addr.encode({time: time, stream: 1, services: [serviceFeatures.NODE_NETWORK], host: "127.0.0.1", port: 8444}).toString("hex")).to.equal("0000000054aaf6c000000001000000000000000100000000000000000000ffff7f00000120fc");
|
|
expect(net_addr.encode({short: true, services: [serviceFeatures.NODE_NETWORK], host: "127.0.0.1", port: 8444}).toString("hex")).to.equal("000000000000000100000000000000000000ffff7f00000120fc");
|
|
expect(net_addr.encode({short: true, host: "::1", port: 65000}).toString("hex")).to.equal("000000000000000100000000000000000000000000000001fde8");
|
|
});
|
|
});
|
|
|
|
describe("Encrypted", function() {
|
|
it("should encode and decode", function() {
|
|
var iv = Buffer(16);
|
|
var ephemPublicKey = Buffer(65);
|
|
ephemPublicKey[0] = 0x04;
|
|
var cipherText = Buffer("test");
|
|
var mac = Buffer(32);
|
|
var inopts = {
|
|
iv: iv,
|
|
ephemPublicKey: ephemPublicKey,
|
|
cipherText: cipherText,
|
|
mac: mac,
|
|
};
|
|
|
|
var encoded = encrypted.encode(inopts);
|
|
expect(encoded.length).to.equal(122);
|
|
var outopts = encrypted.decode(encoded);
|
|
expect(bufferEqual(iv, outopts.iv)).to.be.true;
|
|
expect(bufferEqual(ephemPublicKey, outopts.ephemPublicKey)).to.be.true;
|
|
expect(cipherText.toString()).to.equal("test");
|
|
expect(bufferEqual(mac, outopts.mac)).to.be.true;
|
|
});
|
|
});
|
|
|
|
describe("Message encodings", function() {
|
|
it("should decode", function() {
|
|
expect(messageEncodings.decode(Buffer([2])).value).to.equal(messageEncodings.SIMPLE);
|
|
});
|
|
|
|
it("should encode", function() {
|
|
expect(messageEncodings.encode(messageEncodings.SIMPLE).toString("hex")).to.equal("02");
|
|
});
|
|
});
|
|
|
|
describe("Service features", function() {
|
|
it("should decode", function() {
|
|
expect(serviceFeatures.decode(Buffer("0000000000000001", "hex"))).to.have.members([serviceFeatures.NODE_NETWORK]);
|
|
});
|
|
|
|
it("should encode", function() {
|
|
expect(serviceFeatures.encode([serviceFeatures.NODE_NETWORK]).toString("hex")).to.equal("0000000000000001");
|
|
});
|
|
});
|
|
|
|
describe("Pubkey features", function() {
|
|
it("should decode", function() {
|
|
expect(pubkeyFeatures.decode(Buffer("c0000000", "hex"))).to.have.members([pubkeyFeatures.DOES_ACK, pubkeyFeatures.INCLUDE_DESTINATION]);
|
|
});
|
|
|
|
it("should encode", function() {
|
|
expect(pubkeyFeatures.encode([pubkeyFeatures.INCLUDE_DESTINATION, pubkeyFeatures.DOES_ACK]).toString("hex")).to.equal("c0000000");
|
|
});
|
|
});
|
|
});
|
|
|
|
describe("WIF", function() {
|
|
var wifSign = "5JgQ79vTBusc61xYPtUEHYQ38AXKdDZgQ5rFp7Cbb4ZjXUKFZEV";
|
|
var wifEnc = "5K2aL8cnsEWHwHfHnUrPo8QdYyRfoYUBmhAnWY5GTpDLbeyusnE";
|
|
var signPrivateKey = Buffer("71c95d26c716a5e85e9af9efe26fb5f744dc98005a13d05d23ee92c77e038d9f", "hex");
|
|
var encPrivateKey = Buffer("9f9969c93c2d186787a7653f70e49be34c03c4a853e6ad0c867db0946bc433c6", "hex");
|
|
|
|
it("should decode", function() {
|
|
var key1 = WIF.decode(wifSign);
|
|
expect(Buffer.isBuffer(key1)).to.be.true;
|
|
expect(key1.length).to.equal(32);
|
|
expect(key1.toString("hex")).to.equal(signPrivateKey.toString("hex"));
|
|
var key2 = WIF.decode(wifEnc);
|
|
expect(Buffer.isBuffer(key2)).to.be.true;
|
|
expect(key2.length).to.equal(32);
|
|
expect(key2.toString("hex")).to.equal(encPrivateKey.toString("hex"));
|
|
var addrStr = Address({signPrivateKey: key1, encPrivateKey: key2}).encode();
|
|
expect(addrStr).to.equal("BM-2cTux3PGRqHTEH6wyUP2sWeT4LrsGgy63z");
|
|
});
|
|
|
|
it("should encode", function() {
|
|
var wif1 = WIF.encode(signPrivateKey);
|
|
expect(wif1).to.equal(wifSign);
|
|
var wif2 = WIF.encode(encPrivateKey);
|
|
expect(wif2).to.equal(wifEnc);
|
|
});
|
|
});
|
|
|
|
describe("POW", function() {
|
|
it("should calculate target", function() {
|
|
expect(POW.getTarget({ttl: 2418984, payloadLength: 628, nonceTrialsPerByte: 1000, payloadLengthExtraBytes: 1000})).to.equal(297422593171);
|
|
expect(POW.getTarget({ttl: 86400, payloadLength: 628})).to.equal(4864647698763);
|
|
});
|
|
|
|
it("should check a POW", function() {
|
|
expect(POW.check({nonce: 21997550, target: 297422593171, initialHash: Buffer("8ff2d685db89a0af2e3dbfd3f700ae96ef4d9a1eac72fd778bbb368c7510cddda349e03207e1c4965bd95c6f7265e8f1a481a08afab3874eaafb9ade09a10880", "hex")})).to.be.true;
|
|
expect(POW.check({nonce: 3122437, target: 4864647698763, initialHash: Buffer("8ff2d685db89a0af2e3dbfd3f700ae96ef4d9a1eac72fd778bbb368c7510cddda349e03207e1c4965bd95c6f7265e8f1a481a08afab3874eaafb9ade09a10880", "hex")})).to.be.true;
|
|
expect(POW.check({nonce: 3122436, target: 4864647698763, initialHash: Buffer("8ff2d685db89a0af2e3dbfd3f700ae96ef4d9a1eac72fd778bbb368c7510cddda349e03207e1c4965bd95c6f7265e8f1a481a08afab3874eaafb9ade09a10880", "hex")})).to.be.false;
|
|
});
|
|
|
|
it("should fail on bad POW arguments", function() {
|
|
expect(POW.doAsync.bind(null, {target: 123, initialHash: 0})).to.throw(Error);
|
|
expect(POW.doAsync.bind(null, {target: 123, initialHash: Buffer("test")})).to.throw(Error);
|
|
expect(POW.doAsync.bind(null, {poolSize: -1, target: 123, initialHash: Buffer(64)})).to.throw(Error);
|
|
});
|
|
|
|
if (allTests) {
|
|
it("should do a POW", function() {
|
|
this.timeout(300000);
|
|
var target = typeof window === "undefined" ? 297422593171 : 10693764680411;
|
|
var validNonces = typeof window === "undefined" ?
|
|
[21997550] :
|
|
[2373146, 2543600, 3593915];
|
|
return POW.doAsync({target: target, initialHash: Buffer("8ff2d685db89a0af2e3dbfd3f700ae96ef4d9a1eac72fd778bbb368c7510cddda349e03207e1c4965bd95c6f7265e8f1a481a08afab3874eaafb9ade09a10880", "hex")})
|
|
.then(function(computedNonce) {
|
|
// Multiple valid nonces.
|
|
expect(validNonces).to.include(computedNonce);
|
|
});
|
|
});
|
|
}
|
|
});
|
|
|
|
describe("High-level classes", function() {
|
|
// FIXME(Kagami): Add more fail tests.
|
|
describe("Address", function() {
|
|
it("should decode Bitmessage address", function() {
|
|
var addr = Address.decode("BM-2cTux3PGRqHTEH6wyUP2sWeT4LrsGgy63z")
|
|
expect(addr.version).to.equal(4);
|
|
expect(addr.stream).to.equal(1);
|
|
expect(addr.ripe.toString("hex")).to.equal("003ab6655de4bd8c603eba9b00dd5970725fdd56");
|
|
});
|
|
|
|
it("should decode Bitmessage address badly formatted", function() {
|
|
var addr = Address.decode(" 2cTux3PGRqHTEH6wyUP2sWeT4LrsGgy63z ")
|
|
expect(addr.version).to.equal(4);
|
|
expect(addr.stream).to.equal(1);
|
|
expect(addr.ripe.toString("hex")).to.equal("003ab6655de4bd8c603eba9b00dd5970725fdd56");
|
|
});
|
|
|
|
it("should allow to generate new Bitmessage address", function() {
|
|
this.timeout(60000);
|
|
var addr = Address.fromRandom();
|
|
expect(addr.version).to.equal(4);
|
|
expect(addr.stream).to.equal(1);
|
|
expect(addr.signPrivateKey.length).to.equal(32);
|
|
expect(addr.encPrivateKey.length).to.equal(32);
|
|
var str = addr.encode();
|
|
expect(str.slice(0, 3)).to.equal("BM-");
|
|
var addr2 = Address.decode(str);
|
|
expect(addr2.version).to.equal(4);
|
|
expect(addr2.stream).to.equal(1);
|
|
expect(addr2.ripe.length).to.equal(20);
|
|
expect(addr2.ripe[0]).to.equal(0);
|
|
});
|
|
|
|
// FIXME(Kagami): Don't run it in browser currently because it's
|
|
// very slow. This need to be fixed.
|
|
if (allTests && typeof window === "undefined") {
|
|
it("should allow to generate shorter address", function() {
|
|
this.timeout(300000);
|
|
var addr = Address.fromRandom({ripelen: 18});
|
|
var ripe = addr.getRipe({short: true});
|
|
expect(ripe.length).to.be.at.most(18);
|
|
});
|
|
}
|
|
});
|
|
|
|
describe("User Agent", function() {
|
|
var pybm = {name: "PyBitmessage", version: "0.4.4"};
|
|
var bnode = {name: "bitchan-node", version: "0.0.1"};
|
|
var bweb = {name: "bitchan-web"};
|
|
|
|
it("should decode", function() {
|
|
var ua = var_str.encode("/cBitmessage:0.2(iPad; U; CPU OS 3_2_1)/AndroidBuild:0.8/");
|
|
var res = UserAgent.decode(ua);
|
|
expect(res.software).to.deep.equal([
|
|
{name: "cBitmessage", version: "0.2", comments: "iPad; U; CPU OS 3_2_1"},
|
|
{name: "AndroidBuild", version: "0.8"},
|
|
]);
|
|
expect(res.length).to.equal(58);
|
|
expect(res.rest.toString("hex")).to.equal("");
|
|
});
|
|
|
|
it("should encode", function() {
|
|
var ua = UserAgent.encode([pybm]);
|
|
expect(var_str.decode(ua).str).to.equal("/PyBitmessage:0.4.4/");
|
|
var res = UserAgent.decode(ua);
|
|
expect(res.software).to.deep.equal([pybm]);
|
|
expect(res.length).to.equal(21);
|
|
expect(res.rest.toString("hex")).to.equal("");
|
|
|
|
ua = UserAgent.encode([{name: "test", "comments": "linux"}]);
|
|
expect(var_str.decode(ua).str).to.equal("/test:0.0.0(linux)/");
|
|
});
|
|
|
|
it("should encode bitmessage's user agent", function() {
|
|
var res = UserAgent.decode(UserAgent.encodeSelf())
|
|
var software = res.software;
|
|
expect(software[0].name).to.equal("bitmessage");
|
|
expect(software[0]).to.have.property("version");
|
|
|
|
res = UserAgent.decode(UserAgent.encodeSelfWith([bnode, bweb]));
|
|
software = res.software;
|
|
expect(software[0].name).to.equal("bitmessage");
|
|
expect(software[1]).to.deep.equal(bnode);
|
|
expect(software[2].name).to.equal(bweb.name);
|
|
expect(software[2].version).to.equal("0.0.0");
|
|
});
|
|
});
|
|
});
|