| Index: mojo/public/js/new_bindings/lib/control_message_proxy.js
|
| diff --git a/mojo/public/js/new_bindings/lib/control_message_proxy.js b/mojo/public/js/new_bindings/lib/control_message_proxy.js
|
| index d6c0734fe1af43be0f802a0e37f5c223101214dd..1d57557ae27227f56324020b88070cd75092ed83 100644
|
| --- a/mojo/public/js/new_bindings/lib/control_message_proxy.js
|
| +++ b/mojo/public/js/new_bindings/lib/control_message_proxy.js
|
| @@ -2,39 +2,35 @@
|
| // 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() {
|
| + var internal = mojo.internal;
|
|
|
| function sendRunOrClosePipeMessage(receiver, runOrClosePipeMessageParams) {
|
| - var messageName = controlMessages.kRunOrClosePipeMessageId;
|
| - var payloadSize = controlMessages.RunOrClosePipeMessageParams.encodedSize;
|
| - var builder = new codec.MessageBuilder(messageName, payloadSize);
|
| - builder.encodeStruct(controlMessages.RunOrClosePipeMessageParams,
|
| + var messageName = mojo.interface_control2.kRunOrClosePipeMessageId;
|
| + var payloadSize =
|
| + mojo.interface_control2.RunOrClosePipeMessageParams.encodedSize;
|
| + var builder = new internal.MessageBuilder(messageName, payloadSize);
|
| + builder.encodeStruct(mojo.interface_control2.RunOrClosePipeMessageParams,
|
| runOrClosePipeMessageParams);
|
| var message = builder.finish();
|
| receiver.accept(message);
|
| }
|
|
|
| function validateControlResponse(message) {
|
| - var messageValidator = new Validator(message);
|
| + var messageValidator = new internal.Validator(message);
|
| var error = messageValidator.validateMessageIsResponse();
|
| - if (error != validator.validationError.NONE) {
|
| + if (error != internal.validationError.NONE) {
|
| throw error;
|
| }
|
|
|
| - if (message.getName() != controlMessages.kRunMessageId) {
|
| + if (message.getName() != mojo.interface_control2.kRunMessageId) {
|
| throw new Error("Control message name is not kRunMessageId");
|
| }
|
|
|
| // Validate payload.
|
| - error = controlMessages.RunResponseMessageParams.validate(
|
| + error = mojo.interface_control2.RunResponseMessageParams.validate(
|
| messageValidator, message.getHeaderNumBytes());
|
| - if (error != validator.validationError.NONE) {
|
| + if (error != internal.validationError.NONE) {
|
| throw error;
|
| }
|
| }
|
| @@ -42,9 +38,9 @@ define("mojo/public/js/lib/control_message_proxy", [
|
| function acceptRunResponse(message) {
|
| validateControlResponse(message);
|
|
|
| - var reader = new codec.MessageReader(message);
|
| + var reader = new internal.MessageReader(message);
|
| var runResponseMessageParams = reader.decodeStruct(
|
| - controlMessages.RunResponseMessageParams);
|
| + mojo.interface_control2.RunResponseMessageParams);
|
|
|
| return Promise.resolve(runResponseMessageParams);
|
| }
|
| @@ -59,12 +55,13 @@ define("mojo/public/js/lib/control_message_proxy", [
|
| * @return {Promise} that resolves to a RunResponseMessageParams.
|
| */
|
| function sendRunMessage(receiver, runMessageParams) {
|
| - var messageName = controlMessages.kRunMessageId;
|
| - var payloadSize = controlMessages.RunMessageParams.encodedSize;
|
| + var messageName = mojo.interface_control2.kRunMessageId;
|
| + var payloadSize = mojo.interface_control2.RunMessageParams.encodedSize;
|
| // |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 builder = new internal.MessageWithRequestIDBuilder(messageName,
|
| + payloadSize, internal.kMessageExpectsResponse, 0);
|
| + builder.encodeStruct(mojo.interface_control2.RunMessageParams,
|
| + runMessageParams);
|
| var message = builder.finish();
|
|
|
| return receiver.acceptAndExpectResponse(message).then(acceptRunResponse);
|
| @@ -75,9 +72,10 @@ define("mojo/public/js/lib/control_message_proxy", [
|
| }
|
|
|
| ControlMessageProxy.prototype.queryVersion = function() {
|
| - var runMessageParams = new controlMessages.RunMessageParams();
|
| - runMessageParams.input = new controlMessages.RunInput();
|
| - runMessageParams.input.query_version = new controlMessages.QueryVersion();
|
| + var runMessageParams = new mojo.interface_control2.RunMessageParams();
|
| + runMessageParams.input = new mojo.interface_control2.RunInput();
|
| + runMessageParams.input.query_version =
|
| + new mojo.interface_control2.QueryVersion();
|
|
|
| return sendRunMessage(this.receiver, runMessageParams).then(function(
|
| runResponseMessageParams) {
|
| @@ -87,16 +85,13 @@ define("mojo/public/js/lib/control_message_proxy", [
|
|
|
| ControlMessageProxy.prototype.requireVersion = function(version) {
|
| var runOrClosePipeMessageParams = new
|
| - controlMessages.RunOrClosePipeMessageParams();
|
| + mojo.interface_control2.RunOrClosePipeMessageParams();
|
| runOrClosePipeMessageParams.input = new
|
| - controlMessages.RunOrClosePipeInput();
|
| + mojo.interface_control2.RunOrClosePipeInput();
|
| runOrClosePipeMessageParams.input.require_version = new
|
| - controlMessages.RequireVersion({'version': version});
|
| + mojo.interface_control2.RequireVersion({'version': version});
|
| sendRunOrClosePipeMessage(this.receiver, runOrClosePipeMessageParams);
|
| };
|
|
|
| - var exports = {};
|
| - exports.ControlMessageProxy = ControlMessageProxy;
|
| -
|
| - return exports;
|
| -});
|
| + internal.ControlMessageProxy = ControlMessageProxy;
|
| +})();
|
|
|