add more EJSON tests

Author: emgee3

test/ddp-client.js

@@ -1,7 +1,8 @@
 var assert = require('assert'),
     sinon  = require('sinon'),
     rewire = require('rewire'),
-    events = require('events');
+    events = require('events'),
+    EJSON  = require('meteor-ejson');
 
 var DDPClient = rewire("../lib/ddp-client");
 
@@ -109,23 +110,46 @@ describe("Network errors", function() {
 
 
 describe('EJSON', function() {
-  beforeEach(function() {
-    prepareMocks();
-  });
 
-  var DDPMessage = JSON.stringify(
-      {"msg":"added","collection":"posts","id":"2trpvcQ4pn32ZYXco","fields":{"date":{"$date":1371591394454}}}
-    );
+  var DDPMessage = '{"msg":"added","collection":"posts","id":"2trpvcQ4pn32ZYXco","fields":{"date":{"$date":1371591394454},"bindata":{"$binary":"QUJDRA=="}}}';
+  var EJSONObject = EJSON.parse(DDPMessage);
 
-  it('should not be endabled by default', function(done) {
+  it('should not be enabled by default', function(done) {
     var ddpclient = new DDPClient();
 
     assert(!ddpclient.use_ejson);
 
+    done();
+  });
+
+  it('should not be used when disabled', function(done) {
+    var ddpclient = new DDPClient({ use_ejson : false });
+
+    assert(!ddpclient.use_ejson);
+
     ddpclient._message(DDPMessage);
 
+    // ensure received dates not decoded from EJSON
     assert.deepEqual(ddpclient.collections.posts['2trpvcQ4pn32ZYXco'].date, {"$date":1371591394454});
 
+    // ensure received binary data not decoded from EJSON date
+    assert.deepEqual(ddpclient.collections.posts['2trpvcQ4pn32ZYXco'].bindata, {"$binary":"QUJDRA=="});
+
+    ddpclient.socket = {};
+    ddpclient.socket.send = function (opts) {
+      // ensure sent dates not encoded into EJSON
+      assert(opts.indexOf("date")          !== -1);
+      assert(opts.indexOf("$date")         === -1);
+      assert(opts.indexOf("1371591394454") === -1);
+
+      // ensure sent binary data not encoded into EJSON
+      assert(opts.indexOf("bindata")       !== -1);
+      assert(opts.indexOf("$binary")       === -1);
+      assert(opts.indexOf("QUJDRA==")      === -1);
+    };
+
+    ddpclient._send(EJSONObject.fields);
+
     done();
   });
 
@@ -138,7 +162,23 @@ describe('EJSON', function() {
 
     assert.deepEqual(ddpclient.collections.posts['2trpvcQ4pn32ZYXco'].date, new Date(1371591394454));
 
+    assert.deepEqual(ddpclient.collections.posts['2trpvcQ4pn32ZYXco'].bindata, new Uint8Array([65, 66, 67, 68]));
+
+    ddpclient.socket = {};
+    ddpclient.socket.send = function (opts) {
+      assert(opts.indexOf("date")          !== -1);
+      assert(opts.indexOf("$date")         !== -1);
+      assert(opts.indexOf("1371591394454") !== -1);
+
+      assert(opts.indexOf("bindata")       !== -1);
+      assert(opts.indexOf("$binary")       !== -1);
+      assert(opts.indexOf("QUJDRA==")      !== -1);
+    };
+
+    ddpclient._send(EJSONObject.fields);
+
     done();
   });
+
 });