| OLD | NEW |
| 1 // Copyright 2017 The Chromium Authors. All rights reserved. | 1 // Copyright 2017 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 define("mojo/public/js/lib/control_message_handler", [ | 5 define("mojo/public/js/lib/control_message_handler", [ |
| 6 "mojo/public/interfaces/bindings/interface_control_messages.mojom", |
| 6 "mojo/public/js/codec", | 7 "mojo/public/js/codec", |
| 7 "mojo/public/interfaces/bindings/interface_control_messages.mojom", | |
| 8 "mojo/public/js/validator", | 8 "mojo/public/js/validator", |
| 9 ], function(codec, controlMessages, validator) { | 9 ], function(controlMessages, codec, validator) { |
| 10 | 10 |
| 11 var Validator = validator.Validator; | 11 var Validator = validator.Validator; |
| 12 | 12 |
| 13 function validateControlRequestWithResponse(message) { | 13 function validateControlRequestWithResponse(message) { |
| 14 var messageValidator = new Validator(message); | 14 var messageValidator = new Validator(message); |
| 15 var error = messageValidator.validateMessageIsRequestExpectingResponse(); | 15 var error = messageValidator.validateMessageIsRequestExpectingResponse(); |
| 16 if (error !== validator.validationError.NONE) { | 16 if (error !== validator.validationError.NONE) { |
| 17 throw error; | 17 throw error; |
| 18 } | 18 } |
| 19 | 19 |
| (...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 82 responder.accept(builder.finish()); | 82 responder.accept(builder.finish()); |
| 83 return true; | 83 return true; |
| 84 } | 84 } |
| 85 | 85 |
| 86 function isControlMessage(message) { | 86 function isControlMessage(message) { |
| 87 return message.getName() == controlMessages.kRunMessageId || | 87 return message.getName() == controlMessages.kRunMessageId || |
| 88 message.getName() == controlMessages.kRunOrClosePipeMessageId; | 88 message.getName() == controlMessages.kRunOrClosePipeMessageId; |
| 89 } | 89 } |
| 90 | 90 |
| 91 function ControlMessageHandler(interface_version) { | 91 function ControlMessageHandler(interface_version) { |
| 92 this.interface_version = interface_version; | 92 this.interface_version_ = interface_version; |
| 93 } | 93 } |
| 94 | 94 |
| 95 ControlMessageHandler.prototype.accept = function(message) { | 95 ControlMessageHandler.prototype.accept = function(message) { |
| 96 validateControlRequestWithoutResponse(message); | 96 validateControlRequestWithoutResponse(message); |
| 97 return runOrClosePipe(message, this.interface_version); | 97 return runOrClosePipe(message, this.interface_version_); |
| 98 }; | 98 }; |
| 99 | 99 |
| 100 ControlMessageHandler.prototype.acceptWithResponder = function(message, | 100 ControlMessageHandler.prototype.acceptWithResponder = function(message, |
| 101 responder) { | 101 responder) { |
| 102 validateControlRequestWithResponse(message); | 102 validateControlRequestWithResponse(message); |
| 103 return run(message, responder, this.interface_version); | 103 return run(message, responder, this.interface_version_); |
| 104 }; | 104 }; |
| 105 | 105 |
| 106 var exports = {}; | 106 var exports = {}; |
| 107 exports.ControlMessageHandler = ControlMessageHandler; | 107 exports.ControlMessageHandler = ControlMessageHandler; |
| 108 exports.isControlMessage = isControlMessage; | 108 exports.isControlMessage = isControlMessage; |
| 109 | 109 |
| 110 return exports; | 110 return exports; |
| 111 }); | 111 }); |
| OLD | NEW |