Add serialization support to the JS DataSender and DataReceiver.

extensions/test/data/data_sender_unittest.js

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 // Tests launched by extensions/renderer/api/serial/data_sender_unittest.cc
 
 var test = require('test').binding;
 var unittestBindings = require('test_environment_specific_bindings');
 
 var BUFFER_SIZE = 11;
@@ skipping 19 matching lines @@
     var serviceProvider = modules[0];
     var dataSender = modules[1];
     var dataStream = modules[2];
     return new dataSender.DataSender(
         serviceProvider.connectToService(dataStream.DataSinkProxy.NAME_),
         BUFFER_SIZE,
         FATAL_ERROR);
   }));
 }
 
+function serializeRoundTrip(sender) {
+  return Promise.all([
+    sender.serialize(),
+    requireAsync('data_sender'),
+  ]).then(function(promises) {
+    var serialized = promises[0];
+    var dataSender = promises[1];
+    return dataSender.DataSender.deserialize(serialized);
+  });
+}
+
 unittestBindings.exportTests([
   function testSend() {
     createSender().then(test.callbackPass(function(sender) {
       var seen = null;
       sender.send(generateData(1)).then(test.callbackPass(function(bytesSent) {
         test.assertEq(1, bytesSent);
         test.assertEq(null, seen);
         seen = 'first';
       }));
       sender.send(generateData(1)).then(test.callbackPass(function(bytesSent) {
@@ skipping 158 matching lines @@
         seen = 'cancel';
         sender.close();
       }));
       sender.close();
       test.assertThrows(
           sender.cancel, sender, [], 'DataSender has been closed');
       test.assertThrows(sender.send, sender, [], 'DataSender has been closed');
     }));
   },
 
+  function testSendWithSerialization() {
+    createSender().then(test.callbackPass(function(sender) {
+      return sender.send(generateData(1)).then(test.callbackPass(
+          function(bytesSent) {
+        test.assertEq(1, bytesSent);
+        return sender;
+      }));
+    })).then(test.callbackPass(serializeRoundTrip)).then(test.callbackPass(
+        function(sender) {
+      var seen = null;
+      sender.send(generateData(1)).then(test.callbackPass(function(bytesSent) {
+        test.assertEq(1, bytesSent);
+        test.assertEq(null, seen);
+        seen = 'second';
+      }));
+      sender.send(generateData(1)).then(test.callbackPass(function(bytesSent) {
+        sender.close();
+        test.assertEq(1, bytesSent);
+        test.assertEq('second', seen);
+        seen = 'third';
+      }));
+    }));
+  },
+
+  function testSendErrorWithSerialization() {
+    createSender().then(test.callbackPass(function(sender) {
+      return sender.send(generateData(BUFFER_SIZE * 3, 'b')).catch(
+          test.callbackPass(function(e) {
+        test.assertEq(1, e.error);
+        test.assertEq(0, e.bytesSent);
+        return sender.send(generateData(1));
+      })).then(test.callbackPass(function(bytesSent) {
+        test.assertEq(1, bytesSent);
+        return sender;
+      }));
+    })).then(test.callbackPass(serializeRoundTrip)).then(test.callbackPass(
+        function(sender) {
+      sender.send(generateData(BUFFER_SIZE * 3, 'b')).catch(
+          test.callbackPass(function(e) {
+        test.assertEq(3, e.error);
+        test.assertEq(0, e.bytesSent);
+        sender.send(generateData(1, 'c')).then(test.callbackPass(
+            function(bytesSent) {
+          test.assertEq(1, bytesSent);
+          sender.close();
+        }));
+      }));
+    }));
+  },
+
+  function testSendErrorPartialSuccessWithSerialization() {
+    createSender().then(test.callbackPass(function(sender) {
+      return sender.send(generateData(BUFFER_SIZE * 3, 'b')).catch(
+          test.callbackPass(function(e) {
+        test.assertEq(1, e.error);
+        test.assertEq(5, e.bytesSent);
+        return sender.send(generateData(1));
+      })).then(test.callbackPass(function(bytesSent) {
+        test.assertEq(1, bytesSent);
+        return sender;
+      }));
+    })).then(test.callbackPass(serializeRoundTrip)).then(test.callbackPass(
+        function(sender) {
+      sender.send(generateData(BUFFER_SIZE * 3, 'c')).catch(test.callbackPass(
+          function(e) {
+        test.assertEq(3, e.error);
+        test.assertEq(5, e.bytesSent);
+        return sender.send(generateData(1, 'd'));
+      })).then(test.callbackPass(function(bytesSent) {
+        test.assertEq(1, bytesSent);
+        sender.close();
+      }));
+    }));
+  },
+
+  function testSendErrorBetweenPacketsWithSerialization() {
+    createSender().then(test.callbackPass(function(sender) {
+      var first = sender.send(generateData(2, 'b')).catch(test.callbackPass(
+          function(e) {
+        test.assertEq(1, e.error);
+        test.assertEq(2, e.bytesSent);
+      }));
+      // After an error, all sends in progress will be cancelled.
+      var second = sender.send(generateData(2, 'b')).catch(test.callbackPass(
+          function(e) {
+        test.assertEq(1, e.error);
+        test.assertEq(0, e.bytesSent);
+        return sender.send(generateData(1));
+      })).then(test.callbackPass(
+        function(bytesSent) {
+        test.assertEq(1, bytesSent);
+      }));
+      return Promise.all([first, second]).then(test.callbackPass(function() {
+        return sender;
+      }));
+    })).then(test.callbackPass(serializeRoundTrip)).then(test.callbackPass(
+        function(sender) {
+      sender.send(generateData(2, 'c')).catch(test.callbackPass(function(e) {
+        test.assertEq(3, e.error);
+        test.assertEq(2, e.bytesSent);
+      }));
+      // After an error, all sends in progress will be cancelled.
+      sender.send(generateData(2, 'c')).catch(test.callbackPass(function(e) {
+        test.assertEq(3, e.error);
+        test.assertEq(0, e.bytesSent);
+        sender.send(generateData(1, 'd')).then(test.callbackPass(
+            function(bytesSent) {
+          test.assertEq(1, bytesSent);
+          sender.close();
+        }));
+      }));
+    }));
+  },
+
+  function testSendErrorInSecondPacketWithSerialization() {
+    createSender().then(test.callbackPass(function(sender) {
+      var first = sender.send(generateData(2, 'b')).then(test.callbackPass(
+          function(bytesSent) {
+        test.assertEq(2, bytesSent);
+      }));
+      var second = sender.send(generateData(2, 'b')).catch(test.callbackPass(
+          function(e) {
+        test.assertEq(1, e.error);
+        test.assertEq(1, e.bytesSent);
+        return sender.send(generateData(1)).then(test.callbackPass(
+            function(bytesSent) {
+          test.assertEq(1, bytesSent);
+        }));
+      }));
+      return Promise.all([first, second]).then(test.callbackPass(function() {
+        return sender;
+      }));
+    })).then(test.callbackPass(serializeRoundTrip)).then(test.callbackPass(
+        function(sender) {
+      sender.send(generateData(2, 'c')).then(test.callbackPass(
+          function(bytesSent) {
+        test.assertEq(2, bytesSent);
+      }));
+      sender.send(generateData(2, 'c')).catch(test.callbackPass(function(e) {
+        test.assertEq(3, e.error);
+        test.assertEq(1, e.bytesSent);
+        return sender.send(generateData(1, 'd')).then(test.callbackPass(
+            function(bytesSent) {
+          test.assertEq(1, bytesSent);
+          sender.close();
+        }));
+      }));
+    }));
+  },
+
+  function testCancelWithSerialization() {
+    createSender().then(test.callbackPass(function(sender) {
+      var seen = null;
+      sender.send(generateData(1, 'b')).catch(test.callbackPass(function(e) {
+        test.assertEq(3, e.error);
+        test.assertEq(0, e.bytesSent);
+        test.assertEq(null, seen);
+        seen = 'send';
+      }));
+      return sender.cancel(3).then(test.callbackPass(function() {
+        test.assertEq('send', seen);
+        seen = 'cancel';
+        return sender;
+      }));
+    })).then(test.callbackPass(serializeRoundTrip)).then(test.callbackPass(
+        function(sender) {
+      var seen = null;
+      sender.send(generateData(1, 'c')).catch(test.callbackPass(function(e) {
+        test.assertEq(3, e.error);
+        test.assertEq(0, e.bytesSent);
+        test.assertEq(null, seen);
+        seen = 'send';
+      }));
+      return sender.cancel(3).then(test.callbackPass(function() {
+        test.assertEq('send', seen);
+        seen = 'cancel';
+        sender.close();
+      })).then(test.callbackPass(function() {
+        return sender;
+      }));
+    }));
+  },
+
+  function testSerializeWithSendsInProgress() {
+    createSender().then(test.callbackPass(function(sender) {
+      var seen = null;
+      sender.send(generateData(1, 'b')).catch(test.callbackPass(function(e) {
+        test.assertEq(FATAL_ERROR, e.error);
+        test.assertEq(0, e.bytesSent);
+        test.assertEq(null, seen);
+        seen = 'send';
+      }));
+      sender.send(generateData(1, 'b')).catch(test.callbackPass(function(e) {
+        test.assertEq(FATAL_ERROR, e.error);
+        test.assertEq(0, e.bytesSent);
+        test.assertEq('send', seen);
+        seen = 'send2';
+      }));
+      serializeRoundTrip(sender).then(test.callbackPass(function(sender) {
+        test.assertEq('send2', seen);
+        seen = 'serialized';
+        sender.close();
+      }));
+    }));
+  },
+
+  function testSerializeWithSendAndCancelInProgress() {
+    createSender().then(test.callbackPass(function(sender) {
+      var seen = null;
+      sender.send(generateData(1, 'b')).catch(test.callbackPass(function(e) {
+        test.assertEq(3, e.error);
+        test.assertEq(0, e.bytesSent);
+        test.assertEq(null, seen);
+        seen = 'send';
+      }));
+      sender.cancel(3).then(test.callbackPass(function() {
+        test.assertEq('send', seen);
+        seen = 'cancel';
+      }));
+      serializeRoundTrip(sender).then(test.callbackPass(function(sender) {
+        test.assertEq('cancel', seen);
+        seen = 'serialized';
+        sender.close();
+      }));
+    }));
+  },
+
 ], test.runTests, exports);