test that GET_HISTORY with a lastKnownHash includes the message with the specified hash

scripts/tests/test-lkh.js

@@ -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,
+    });
+});
+