Function testBulkSnapshotSpecificError

test/client/subscribe.js:221–300

(label, fns)

      });

      function testBulkSnapshotSpecificError(label, fns) {
        var rejectSnapshot = fns.rejectSnapshot;
        var verifyClientError = fns.verifyClientError;
        it(method + ' bulk with readSnapshots rejectSnapshotRead ' + label, function(done) {
          var backend = this.backend;
          var connection = backend.connect();
          var connection2 = backend.connect();
          async.parallel([
            function(cb) {
              connection.get('dogs', 'fido').create({age: 3}, cb);
            },
            function(cb) {
              connection.get('dogs', 'spot').create({age: 5}, cb);
            }
          ], function(err) {
            if (err) return done(err);

            backend.use('readSnapshots', function(context, cb) {
              expect(context.snapshots).to.be.an('array').of.length(2);
              expect(context.snapshots[0]).to.have.property('id', 'fido');
              rejectSnapshot(context, context.snapshots[0]);
              cb();
            });

            var fido = connection2.get('dogs', 'fido');
            var spot = connection2.get('dogs', 'spot');
            connection2.startBulk();
            async.parallel([
              function(cb) {
                fido[method](function(err) {
                  verifyClientError(err);
                  cb();
                });
              },
              function(cb) {
                spot[method](cb);
              }
            ], function(err) {
              if (err) return done(err);
              // An error for 'fido' means the data shouldn't get loaded.
              expect(fido.data).eql(undefined);
              // Data for 'spot' should still be loaded.
              expect(spot.data).eql({age: 5});

              // For subscribe, also test that further remote ops will only get sent for the doc
              // without the error.
              if (method !== 'subscribe') {
                return done();
              }
              // Add listeners on connection2 for those operations.
              fido.on('before op', function(op) {
                done(new Error('fido on connection2 should not have received any ops, got:' +
                  JSON.stringify(op)));
              });

              var fido1 = connection.get('dogs', 'fido');
              var spot1 = connection.get('dogs', 'spot');