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 |