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..53aa34dbb83fedbbf76c8b4caf8910edfe34037c 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 = mojoBindings.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; |
+})(); |