Merge branch 'staging' into merge-owned
ansuz
5 years ago
commit
f63e787fc6
@ -0,0 +1,116 @@
|
||||
/* globals process */
|
||||
var Client = require("../../lib/client");
|
||||
var Nacl = require("tweetnacl/nacl-fast");
|
||||
var nThen = require("nthen");
|
||||
var CPNetflux = require("../../www/bower_components/chainpad-netflux/chainpad-netflux");
|
||||
var Hash = require("../../www/common/common-hash");
|
||||
var Rpc = require("../../www/common/rpc");
|
||||
var HK = require("../../lib/hk-util");
|
||||
|
||||
|
||||
var identity = function (x) {
|
||||
return x;
|
||||
};
|
||||
var crypto = {
|
||||
encrypt: identity,
|
||||
decrypt: identity,
|
||||
};
|
||||
|
||||
var N = 2;
|
||||
var BREAK;
|
||||
|
||||
BREAK = 1;
|
||||
|
||||
var client;
|
||||
nThen(function (w) {
|
||||
//console.log("Creating client");
|
||||
Client.create(w(function (err, _client) {
|
||||
if (err) {
|
||||
console.error(err);
|
||||
process.exit(1);
|
||||
}
|
||||
client = _client;
|
||||
}));
|
||||
}).nThen(function (w) {
|
||||
//console.log("Creating RPC module");
|
||||
Rpc.createAnonymous(client.config.network, w(function (err, rpc) {
|
||||
if (err) {
|
||||
w.abort();
|
||||
return void console.error('ANON_RPC_CONNECT_ERR');
|
||||
}
|
||||
client.anonRpc = rpc;
|
||||
}));
|
||||
}).nThen(function (w) {
|
||||
var done = w();
|
||||
|
||||
//console.log("sending random messages");
|
||||
|
||||
client.channel = Hash.createChannelId();
|
||||
|
||||
if (BREAK) {
|
||||
CPNetflux.start({
|
||||
//lastKnownHash: HK.getHash(client.sent[0]),
|
||||
network: client.config.network,
|
||||
channel: client.channel,
|
||||
crypto: crypto,
|
||||
noChainPad: true,
|
||||
onReady: w(),
|
||||
//onMessage: onMessage,
|
||||
});
|
||||
}
|
||||
|
||||
// send a few random messages to a channel
|
||||
client.sent = [];
|
||||
var i = N;
|
||||
var send = function () {
|
||||
//console.log(i);
|
||||
if (i-- <= 0) { return void done(); }
|
||||
|
||||
var ciphertext = Nacl.util.encodeBase64(Nacl.randomBytes(256));
|
||||
|
||||
client.anonRpc.send('WRITE_PRIVATE_MESSAGE', [
|
||||
client.channel,
|
||||
ciphertext
|
||||
], function (err) {
|
||||
if (err) {
|
||||
console.error(err);
|
||||
process.exit(1);
|
||||
}
|
||||
client.sent.push(ciphertext);
|
||||
console.log("sent: %s", ciphertext);
|
||||
//setTimeout(send, 500);
|
||||
send();
|
||||
});
|
||||
};
|
||||
send();
|
||||
}).nThen(function () {
|
||||
//process.exit(1);
|
||||
// connect to that channel with a lastKnownHash
|
||||
// check if the first message received has the hash that you asked for
|
||||
|
||||
console.log();
|
||||
|
||||
var lkh = HK.getHash(client.sent[0]);
|
||||
|
||||
var i = 0;
|
||||
var onMessage = function (msg, user, vKey, isCp, hash /*, author */) {
|
||||
if (i === 0 && hash !== lkh) {
|
||||
console.error('incorrect hash: [%s]', hash);
|
||||
process.exit(1);
|
||||
}
|
||||
console.log(msg);
|
||||
if (++i >= N) {
|
||||
process.exit(1);
|
||||
}
|
||||
};
|
||||
|
||||
CPNetflux.start({
|
||||
lastKnownHash: lkh,
|
||||
network: client.config.network,
|
||||
channel: client.channel,
|
||||
crypto: crypto,
|
||||
noChainPad: true,
|
||||
onMessage: onMessage,
|
||||
});
|
||||
});
|
||||
|
||||
@ -0,0 +1 @@
|
||||
{}
|
||||
Loading…
Reference in New Issue