Introduce InterfaceEndpointClient(IEC), InterfaceEndpointHandle and

mojo/public/js/lib/control_message_proxy.js

 // Copyright 2017 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.
 
 define("mojo/public/js/lib/control_message_proxy", [
   "mojo/public/interfaces/bindings/interface_control_messages.mojom",
   "mojo/public/js/codec",
   "mojo/public/js/validator",
 ], function(controlMessages, codec, validator) {
 
   var Validator = validator.Validator;
 
-  function sendRunOrClosePipeMessage(receiver, runOrClosePipeMessageParams) {
+  function constructRunOrClosePipeMessage(runOrClosePipeInput) {
+    var runOrClosePipeMessageParams = new
+        controlMessages.RunOrClosePipeMessageParams();
+    runOrClosePipeMessageParams.input = runOrClosePipeInput;
+
     var messageName = controlMessages.kRunOrClosePipeMessageId;
     var payloadSize = controlMessages.RunOrClosePipeMessageParams.encodedSize;
     var builder = new codec.MessageBuilder(messageName, payloadSize);
     builder.encodeStruct(controlMessages.RunOrClosePipeMessageParams,
                          runOrClosePipeMessageParams);
     var message = builder.finish();
-    receiver.accept(message);
+    return message;
   }
 
   function validateControlResponse(message) {
     var messageValidator = new Validator(message);
     var error = messageValidator.validateMessageIsResponse();
     if (error != validator.validationError.NONE) {
       throw error;
     }
 
     if (message.getName() != controlMessages.kRunMessageId) {
@@ skipping 33 matching lines @@
     // |requestID| is set to 0, but is later properly set by Router.
     var builder = new codec.MessageWithRequestIDBuilder(messageName,
         payloadSize, codec.kMessageExpectsResponse, 0);
     builder.encodeStruct(controlMessages.RunMessageParams, runMessageParams);
     var message = builder.finish();
 
     return receiver.acceptAndExpectResponse(message).then(acceptRunResponse);
   }
 
   function ControlMessageProxy(receiver) {
-    this.receiver = receiver;
+    this.receiver_ = receiver;
   }
 
   ControlMessageProxy.prototype.queryVersion = function() {
     var runMessageParams = new controlMessages.RunMessageParams();
     runMessageParams.input = new controlMessages.RunInput();
     runMessageParams.input.query_version = new controlMessages.QueryVersion();
 
-    return sendRunMessage(this.receiver, runMessageParams).then(function(
+    return sendRunMessage(this.receiver_, runMessageParams).then(function(
         runResponseMessageParams) {
       return runResponseMessageParams.output.query_version_result.version;
     });
   };
 
   ControlMessageProxy.prototype.requireVersion = function(version) {
-    var runOrClosePipeMessageParams = new
-        controlMessages.RunOrClosePipeMessageParams();
-    runOrClosePipeMessageParams.input = new
-        controlMessages.RunOrClosePipeInput();
-    runOrClosePipeMessageParams.input.require_version = new
-        controlMessages.RequireVersion({'version': version});
-    sendRunOrClosePipeMessage(this.receiver, runOrClosePipeMessageParams);
+    var runOrClosePipeInput = new controlMessages.RunOrClosePipeInput();
+    runOrClosePipeInput.require_version = new controlMessages.RequireVersion({
+        'version': version});
+    var message = constructRunOrClosePipeMessage(runOrClosePipeInput);
+    this.receiver_.accept(message);
   };
 
   var exports = {};
   exports.ControlMessageProxy = ControlMessageProxy;
 
   return exports;
 });