Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(70)

Side by Side Diff: remoting/webapp/background/it2me_helper_channel.js

Issue 473073002: Move hello message from It2MeService to It2MeChannel (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Address CR feedback Created 6 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright 2014 The Chromium Authors. All rights reserved. 1 // Copyright 2014 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 /** 5 /**
6 * @fileoverview 6 * @fileoverview
7 * 7 *
8 * It2MeHelperChannel relays messages between Hangouts and Chrome Remote Desktop 8 * It2MeHelperChannel relays messages between Hangouts and Chrome Remote Desktop
9 * (webapp) for the helper (the Hangouts participant who is giving remote 9 * (webapp) for the helper (the Hangouts participant who is giving remote
10 * assistance). 10 * assistance).
11 * 11 *
12 * It runs in the background page and contains two chrome.runtime.Port objects, 12 * It runs in the background page and contains two chrome.runtime.Port objects,
13 * respresenting connections to the webapp and hangout, respectively. 13 * representing connections to the webapp and hangout, respectively.
14 * 14 *
15 * Connection is always initiated from Hangouts. 15 * Connection is always initiated from Hangouts by calling
16 * var port = chrome.runtime.connect({name:'it2me.helper.hangout'}, extId).
17 * port.postMessage('hello')
18 * If the webapp is not installed, |port.onDisconnect| will fire.
19 * If the webapp is installed, Hangouts will receive a hello response with the
20 * list of supported features.
16 * 21 *
17 * Hangout It2MeHelperChannel Chrome Remote Desktop 22 * Hangout It2MeHelperChannel Chrome Remote Desktop
18 * |-----runtime.connect() ------>| | 23 * |-----runtime.connect() ------>| |
19 * |------connect message-------->| | 24 * |--------hello message-------->| |
25 * | |<-----helloResponse message-----|
26 * |-------connect message------->| |
20 * | |-------appLauncher.launch()---->| 27 * | |-------appLauncher.launch()---->|
21 * | |<------runtime.connect()------- | 28 * | |<------runtime.connect()------- |
22 * | |<-----sessionStateChanged------ | 29 * | |<-----sessionStateChanged------ |
23 * |<----sessionStateChanged------| | 30 * |<----sessionStateChanged------| |
24 * 31 *
25 * Disconnection can be initiated from either side: 32 * Disconnection can be initiated from either side:
26 * 1. In the normal flow initiated from hangout 33 * 1. In the normal flow initiated from hangout
27 * Hangout It2MeHelperChannel Chrome Remote Desktop 34 * Hangout It2MeHelperChannel Chrome Remote Desktop
28 * |-----disconnect message------>| | 35 * |-----disconnect message------>| |
29 * |<-sessionStateChanged(CLOSED)-| | 36 * |<-sessionStateChanged(CLOSED)-| |
(...skipping 72 matching lines...) Expand 10 before | Expand all | Expand 10 after
102 this.onDisconnectCallback_ = onDisconnectCallback; 109 this.onDisconnectCallback_ = onDisconnectCallback;
103 110
104 this.onWebappMessageRef_ = this.onWebappMessage_.bind(this); 111 this.onWebappMessageRef_ = this.onWebappMessage_.bind(this);
105 this.onWebappDisconnectRef_ = this.onWebappDisconnect_.bind(this); 112 this.onWebappDisconnectRef_ = this.onWebappDisconnect_.bind(this);
106 this.onHangoutMessageRef_ = this.onHangoutMessage_.bind(this); 113 this.onHangoutMessageRef_ = this.onHangoutMessage_.bind(this);
107 this.onHangoutDisconnectRef_ = this.onHangoutDisconnect_.bind(this); 114 this.onHangoutDisconnectRef_ = this.onHangoutDisconnect_.bind(this);
108 }; 115 };
109 116
110 /** @enum {string} */ 117 /** @enum {string} */
111 remoting.It2MeHelperChannel.HangoutMessageTypes = { 118 remoting.It2MeHelperChannel.HangoutMessageTypes = {
119 HELLO: 'hello',
120 HELLO_RESPONSE: 'helloResponse',
112 CONNECT: 'connect', 121 CONNECT: 'connect',
113 DISCONNECT: 'disconnect' 122 DISCONNECT: 'disconnect',
123 SESSION_STATE_CHANGED: 'sessionStateChanged',
124 ERROR: 'error'
125 };
126
127 /** @enum {string} */
128 remoting.It2MeHelperChannel.Features = {
129 REMOTE_ASSISTANCE: 'remoteAssistance'
114 }; 130 };
115 131
116 /** @enum {string} */ 132 /** @enum {string} */
117 remoting.It2MeHelperChannel.WebappMessageTypes = { 133 remoting.It2MeHelperChannel.WebappMessageTypes = {
118 SESSION_STATE_CHANGED: 'sessionStateChanged' 134 SESSION_STATE_CHANGED: 'sessionStateChanged',
135 ERROR: 'error'
119 }; 136 };
120 137
121 remoting.It2MeHelperChannel.prototype.init = function() { 138 remoting.It2MeHelperChannel.prototype.init = function() {
122 this.hangoutPort_.onMessage.addListener(this.onHangoutMessageRef_); 139 this.hangoutPort_.onMessage.addListener(this.onHangoutMessageRef_);
123 this.hangoutPort_.onDisconnect.addListener(this.onHangoutDisconnectRef_); 140 this.hangoutPort_.onDisconnect.addListener(this.onHangoutDisconnectRef_);
124 }; 141 };
125 142
126 /** @return {string} */ 143 /** @return {string} */
127 remoting.It2MeHelperChannel.prototype.instanceId = function() { 144 remoting.It2MeHelperChannel.prototype.instanceId = function() {
128 return this.instanceId_; 145 return this.instanceId_;
129 }; 146 };
130 147
131 /** 148 /**
132 * @param {{method:string, data:Object.<string,*>}} message 149 * @param {{method:string, data:Object.<string,*>}} message
133 * @return {boolean} whether the message is handled or not. 150 * @return {boolean} whether the message is handled or not.
134 * @private 151 * @private
135 */ 152 */
136 remoting.It2MeHelperChannel.prototype.onHangoutMessage_ = function(message) { 153 remoting.It2MeHelperChannel.prototype.onHangoutMessage_ = function(message) {
137 try { 154 try {
138 var MessageTypes = remoting.It2MeHelperChannel.HangoutMessageTypes; 155 var MessageTypes = remoting.It2MeHelperChannel.HangoutMessageTypes;
139 switch (message.method) { 156 switch (message.method) {
140 case MessageTypes.CONNECT: 157 case MessageTypes.CONNECT:
141 this.launchWebapp_(message); 158 this.launchWebapp_(message);
142 return true; 159 return true;
143 case MessageTypes.DISCONNECT: 160 case MessageTypes.DISCONNECT:
144 this.closeWebapp_(message); 161 this.closeWebapp_(message);
145 return true; 162 return true;
163 case MessageTypes.HELLO:
164 this.hangoutPort_.postMessage({
165 method: MessageTypes.HELLO_RESPONSE,
166 supportedFeatures: base.values(remoting.It2MeHelperChannel.Features)
167 });
168 return true;
146 } 169 }
170 throw new Error('Unknown message method=' + message.method);
147 } catch(e) { 171 } catch(e) {
148 var error = /** @type {Error} */ e; 172 var error = /** @type {Error} */ e;
149 console.error(error); 173 console.error(error);
150 this.hangoutPort_.postMessage({ 174 this.hangoutPort_.postMessage({
151 method: message.method + 'Response', 175 method: MessageTypes.ERROR,
Jamie 2014/08/15 21:57:31 My comment about appending "Response" was just in
kelvinp 2014/08/15 23:25:01 I will make the change in error in later CL's
152 error: error.message 176 error: error.message
153 }); 177 });
154 } 178 }
155 return false; 179 return false;
156 }; 180 };
157 181
158 /** 182 /**
159 * Disconnect the existing connection to the helpee. 183 * Disconnect the existing connection to the helpee.
160 * 184 *
161 * @param {{method:string, data:Object.<string,*>}} message 185 * @param {{method:string, data:Object.<string,*>}} message
162 * @private 186 * @private
163 */ 187 */
164 remoting.It2MeHelperChannel.prototype.closeWebapp_ = 188 remoting.It2MeHelperChannel.prototype.closeWebapp_ =
165 function(message) { 189 function(message) {
166 // TODO(kelvinp): Closing the v2 app currently doesn't disconnect the IT2me 190 // TODO(kelvinp): Closing the v2 app currently doesn't disconnect the IT2me
167 // session (crbug.com/402137), so send an explicit notification to Hangouts. 191 // session (crbug.com/402137), so send an explicit notification to Hangouts.
192 var MessageTypes = remoting.It2MeHelperChannel.HangoutMessageTypes;
168 this.sessionState_ = remoting.ClientSession.State.CLOSED; 193 this.sessionState_ = remoting.ClientSession.State.CLOSED;
169 this.hangoutPort_.postMessage({ 194 this.hangoutPort_.postMessage({
170 method: 'sessionStateChanged', 195 method: MessageTypes.SESSION_STATE_CHANGED,
171 state: this.sessionState_ 196 state: this.sessionState_
172 }); 197 });
173 this.appLauncher_.close(this.instanceId_); 198 this.appLauncher_.close(this.instanceId_);
174 }; 199 };
175 200
176 /** 201 /**
177 * Launches the web app. 202 * Launches the web app.
178 * 203 *
179 * @param {{method:string, data:Object.<string,*>}} message 204 * @param {{method:string, data:Object.<string,*>}} message
180 * @private 205 * @private
(...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after
221 port.onMessage.addListener(this.onWebappMessageRef_); 246 port.onMessage.addListener(this.onWebappMessageRef_);
222 port.onDisconnect.addListener(this.onWebappDisconnectRef_); 247 port.onDisconnect.addListener(this.onWebappDisconnectRef_);
223 this.webappPort_ = port; 248 this.webappPort_ = port;
224 }; 249 };
225 250
226 /** @param {chrome.runtime.Port} port The webapp port. */ 251 /** @param {chrome.runtime.Port} port The webapp port. */
227 remoting.It2MeHelperChannel.prototype.onWebappDisconnect_ = function(port) { 252 remoting.It2MeHelperChannel.prototype.onWebappDisconnect_ = function(port) {
228 // If the webapp port got disconnected while the session is still connected, 253 // If the webapp port got disconnected while the session is still connected,
229 // treat it as an error. 254 // treat it as an error.
230 var States = remoting.ClientSession.State; 255 var States = remoting.ClientSession.State;
256 var HangoutMessageTypes = remoting.It2MeHelperChannel.HangoutMessageTypes;
231 if (this.sessionState_ === States.CONNECTING || 257 if (this.sessionState_ === States.CONNECTING ||
232 this.sessionState_ === States.CONNECTED) { 258 this.sessionState_ === States.CONNECTED) {
233 this.sessionState_ = States.FAILED; 259 this.sessionState_ = States.FAILED;
234 this.hangoutPort_.postMessage({ 260 this.hangoutPort_.postMessage({
235 method: 'sessionStateChanged', 261 method: HangoutMessageTypes.SESSION_STATE_CHANGED,
236 state: this.sessionState_ 262 state: this.sessionState_
237 }); 263 });
238 } 264 }
239 this.unhookPorts_(); 265 this.unhookPorts_();
240 }; 266 };
241 267
242 /** 268 /**
243 * @param {{method:string, data:Object.<string,*>}} message 269 * @param {{method:string, data:Object.<string,*>}} message
244 * @private 270 * @private
245 */ 271 */
246 remoting.It2MeHelperChannel.prototype.onWebappMessage_ = function(message) { 272 remoting.It2MeHelperChannel.prototype.onWebappMessage_ = function(message) {
247 try { 273 try {
248 console.log('It2MeHelperChannel id=' + this.instanceId_ + 274 console.log('It2MeHelperChannel id=' + this.instanceId_ +
249 ' incoming message method=' + message.method); 275 ' incoming message method=' + message.method);
250 var MessageTypes = remoting.It2MeHelperChannel.WebappMessageTypes; 276 var WebappMessageTypes = remoting.It2MeHelperChannel.WebappMessageTypes;
277 var HangoutMessageTypes = remoting.It2MeHelperChannel.HangoutMessageTypes;
251 switch (message.method) { 278 switch (message.method) {
252 case MessageTypes.SESSION_STATE_CHANGED: 279 case WebappMessageTypes.SESSION_STATE_CHANGED:
253 var state = getNumberAttr(message, 'state'); 280 var state = getNumberAttr(message, 'state');
254 this.sessionState_ = 281 this.sessionState_ = /** @type {remoting.ClientSession.State} */ state;
255 /** @type {remoting.ClientSession.State} */ state; 282 this.hangoutPort_.postMessage({
256 this.hangoutPort_.postMessage(message); 283 method: HangoutMessageTypes.SESSION_STATE_CHANGED,
284 state: state
285 });
Jamie 2014/08/15 21:57:31 As above, I like this change, but it doesn't reall
257 return true; 286 return true;
258 } 287 }
259 throw new Error('Unknown message method=' + message.method); 288 throw new Error('Unknown message method=' + message.method);
260 } catch(e) { 289 } catch(e) {
261 var error = /** @type {Error} */ e; 290 var error = /** @type {Error} */ e;
262 console.error(error); 291 console.error(error);
263 this.webappPort_.postMessage({ 292 this.webappPort_.postMessage({
264 method: message.method + 'Response', 293 method: WebappMessageTypes.ERROR,
265 error: error.message 294 error: error.message
266 }); 295 });
267 } 296 }
268 return false; 297 return false;
269 }; 298 };
270 299
271 remoting.It2MeHelperChannel.prototype.unhookPorts_ = function() { 300 remoting.It2MeHelperChannel.prototype.unhookPorts_ = function() {
272 if (this.webappPort_) { 301 if (this.webappPort_) {
273 this.webappPort_.onMessage.removeListener(this.onWebappMessageRef_); 302 this.webappPort_.onMessage.removeListener(this.onWebappMessageRef_);
274 this.webappPort_.onDisconnect.removeListener(this.onWebappDisconnectRef_); 303 this.webappPort_.onDisconnect.removeListener(this.onWebappDisconnectRef_);
275 this.webappPort_.disconnect(); 304 this.webappPort_.disconnect();
276 this.webappPort_ = null; 305 this.webappPort_ = null;
277 } 306 }
278 307
279 if (this.hangoutPort_) { 308 if (this.hangoutPort_) {
280 this.hangoutPort_.onMessage.removeListener(this.onHangoutMessageRef_); 309 this.hangoutPort_.onMessage.removeListener(this.onHangoutMessageRef_);
281 this.hangoutPort_.onDisconnect.removeListener(this.onHangoutDisconnectRef_); 310 this.hangoutPort_.onDisconnect.removeListener(this.onHangoutDisconnectRef_);
282 this.hangoutPort_.disconnect(); 311 this.hangoutPort_.disconnect();
283 this.hangoutPort_ = null; 312 this.hangoutPort_ = null;
284 } 313 }
285 314
286 if (this.onDisconnectCallback_) { 315 if (this.onDisconnectCallback_) {
287 this.onDisconnectCallback_(this); 316 this.onDisconnectCallback_(this);
288 this.onDisconnectCallback_ = null; 317 this.onDisconnectCallback_ = null;
289 } 318 }
290 }; 319 };
OLDNEW
« no previous file with comments | « no previous file | remoting/webapp/background/it2me_service.js » ('j') | remoting/webapp/unittests/it2me_helper_channel_unittest.js » ('J')

Powered by Google App Engine
This is Rietveld 408576698