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

Side by Side Diff: remoting/webapp/crd/js/session_connector_impl.js

Issue 1097133002: [Webapp Refactor] Remove remoting.SessionConnector. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Fix merge conflicts Created 5 years, 8 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
« no previous file with comments | « remoting/webapp/crd/js/session_connector.js ('k') | remoting/webapp/files.gni » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
(Empty)
1 // Copyright 2013 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file.
4
5 /**
6 * @fileoverview
7 * Connect set-up state machine for Me2Me and IT2Me
8 */
9
10 'use strict';
11
12 /** @suppress {duplicate} */
13 var remoting = remoting || {};
14
15 /**
16 * @param {HTMLElement} clientContainer Container element for the client view.
17 * @param {Array<string>} requiredCapabilities Connector capabilities
18 * required by this application.
19 * @param {remoting.ClientSession.EventHandler} handler
20 * @constructor
21 * @implements {remoting.SessionConnector}
22 */
23 remoting.SessionConnectorImpl =
24 function(clientContainer, requiredCapabilities, handler) {
25 /** @private {HTMLElement} */
26 this.clientContainer_ = clientContainer;
27
28 /** @private */
29 this.onError_ = handler.onError.bind(handler);
30
31 /** @private */
32 this.handler_ = handler;
33
34 /** @private {Array<string>} */
35 this.requiredCapabilities_ = [
36 remoting.ClientSession.Capability.SEND_INITIAL_RESOLUTION,
37 remoting.ClientSession.Capability.RATE_LIMIT_RESIZE_REQUESTS,
38 remoting.ClientSession.Capability.VIDEO_RECORDER
39 ];
40
41 // Append the app-specific capabilities.
42 this.requiredCapabilities_.push.apply(this.requiredCapabilities_,
43 requiredCapabilities);
44
45 // Initialize/declare per-connection state.
46 this.closeSession_();
47 };
48
49 /**
50 * Reset the per-connection state so that the object can be re-used for a
51 * second connection. Note the none of the shared WCS state is reset.
52 * @private
53 */
54 remoting.SessionConnectorImpl.prototype.closeSession_ = function() {
55 // It's OK to initialize these member variables here because the
56 // constructor calls this method.
57
58 base.dispose(this.eventHook_);
59 /** @private {base.Disposable} */
60 this.eventHook_ = null;
61
62 /** @private {remoting.Host} */
63 this.host_ = null;
64
65 /** @private {boolean} */
66 this.logHostOfflineErrors_ = false;
67
68 base.dispose(this.clientSession_);
69 /** @private {remoting.ClientSession} */
70 this.clientSession_ = null;
71
72 base.dispose(this.plugin_);
73 /** @private {remoting.ClientPlugin} */
74 this.plugin_ = null;
75
76 /** @private {remoting.CredentialsProvider} */
77 this.credentialsProvider_ = null;
78
79 base.dispose(this.signalStrategy_);
80 /** @private {remoting.SignalStrategy} */
81 this.signalStrategy_ = null;
82 };
83
84 /**
85 * Initiates a connection.
86 *
87 * @param {remoting.Application.Mode} mode
88 * @param {remoting.Host} host the Host to connect to.
89 * @param {remoting.CredentialsProvider} credentialsProvider
90 * @param {boolean=} opt_suppressOfflineError
91 * @return {void} Nothing.
92 * @private
93 */
94 remoting.SessionConnectorImpl.prototype.connect =
95 function(mode, host, credentialsProvider, opt_suppressOfflineError) {
96 // In some circumstances, the WCS <iframe> can get reloaded, which results
97 // in a new clientJid and a new callback. In this case, cancel any existing
98 // connect operation and remove the old client plugin before instantiating a
99 // new one.
100 this.closeSession_();
101 remoting.app.setConnectionMode(mode);
102 this.host_ = host;
103 this.credentialsProvider_ = credentialsProvider;
104 this.logHostOfflineErrors_ = !Boolean(opt_suppressOfflineError);
105 this.connectSignaling_();
106 };
107
108 /**
109 * @private
110 */
111 remoting.SessionConnectorImpl.prototype.connectSignaling_ = function() {
112 base.dispose(this.signalStrategy_);
113 this.signalStrategy_ = null;
114
115 /** @type {remoting.SessionConnectorImpl} */
116 var that = this;
117
118 /** @param {string} token */
119 function connectSignalingWithToken(token) {
120 remoting.identity.getUserInfo().then(
121 connectSignalingWithTokenAndUserInfo.bind(null, token),
122 remoting.Error.handler(that.onError_));
123 }
124
125 /**
126 * Success callback for when the email and fullName have been retrieved
127 * for this user.
128 * Note that the full name will be null unless the webapp has requested
129 * and been granted the userinfo.profile permission.
130 *
131 * @param {string} token
132 * @param {{email: string, name: string}} userInfo
133 */
134 function connectSignalingWithTokenAndUserInfo(token, userInfo) {
135 that.signalStrategy_.connect(remoting.settings.XMPP_SERVER, userInfo.email,
136 token);
137 }
138
139 this.signalStrategy_ = remoting.SignalStrategy.create();
140 this.signalStrategy_.setStateChangedCallback(
141 this.onSignalingState_.bind(this));
142
143 remoting.identity.getToken().then(
144 connectSignalingWithToken,
145 remoting.Error.handler(this.onError_));
146 };
147
148 /**
149 * @private
150 * @param {remoting.SignalStrategy.State} state
151 */
152 remoting.SessionConnectorImpl.prototype.onSignalingState_ = function(state) {
153 switch (state) {
154 case remoting.SignalStrategy.State.CONNECTED:
155 // Proceed only if the connection hasn't been canceled.
156 if (this.host_.jabberId) {
157 this.createSession_();
158 }
159 break;
160
161 case remoting.SignalStrategy.State.FAILED:
162 this.onError_(this.signalStrategy_.getError());
163 break;
164 }
165 };
166
167 /**
168 * Creates ClientSession object.
169 */
170 remoting.SessionConnectorImpl.prototype.createSession_ = function() {
171 var pluginContainer = this.clientContainer_.querySelector(
172 '.client-plugin-container');
173
174 this.plugin_ = remoting.ClientPlugin.factory.createPlugin(
175 pluginContainer, this.requiredCapabilities_);
176
177 var that = this;
178 this.host_.options.load().then(function(){
179 that.plugin_.initialize(that.onPluginInitialized_.bind(that));
180 });
181 };
182
183 /**
184 * @param {boolean} initialized
185 * @private
186 */
187 remoting.SessionConnectorImpl.prototype.onPluginInitialized_ = function(
188 initialized) {
189 if (!initialized) {
190 console.error('ERROR: remoting plugin not loaded');
191 this.pluginError_(new remoting.Error(remoting.Error.Tag.MISSING_PLUGIN));
192 return;
193 }
194
195 if (!this.plugin_.isSupportedVersion()) {
196 console.error('ERROR: bad plugin version');
197 this.pluginError_(new remoting.Error(
198 remoting.Error.Tag.BAD_PLUGIN_VERSION));
199 return;
200 }
201
202 this.clientSession_ = new remoting.ClientSession(
203 this.plugin_, this.host_, this.signalStrategy_);
204
205 this.clientSession_.logHostOfflineErrors(this.logHostOfflineErrors_);
206 this.eventHook_ = new base.EventHook(
207 this.clientSession_, 'stateChanged', this.onStateChange_.bind(this));
208 this.plugin_.connect(
209 this.host_, this.signalStrategy_.getJid(), this.credentialsProvider_);
210 };
211
212 /**
213 * @param {!remoting.Error} error
214 * @private
215 */
216 remoting.SessionConnectorImpl.prototype.pluginError_ = function(error) {
217 this.signalStrategy_.setIncomingStanzaCallback(null);
218 this.closeSession_();
219 };
220
221 /**
222 * Handle a change in the state of the client session.
223 *
224 * @param {remoting.ClientSession.StateEvent=} event
225 * @return {void} Nothing.
226 * @private
227 */
228 remoting.SessionConnectorImpl.prototype.onStateChange_ = function(event) {
229 switch (event.current) {
230 case remoting.ClientSession.State.CONNECTED:
231 var connectionInfo = new remoting.ConnectionInfo(
232 this.host_, this.credentialsProvider_, this.clientSession_,
233 this.plugin_);
234 this.handler_.onConnected(connectionInfo);
235 break;
236
237 case remoting.ClientSession.State.CONNECTING:
238 remoting.identity.getEmail().then(function(/** string */ email) {
239 console.log('Connecting as ' + email);
240 });
241 break;
242
243 case remoting.ClientSession.State.AUTHENTICATED:
244 console.log('Connection authenticated');
245 break;
246
247 case remoting.ClientSession.State.INITIALIZING:
248 console.log('Initializing connection');
249 break;
250
251 case remoting.ClientSession.State.CLOSED:
252 this.handler_.onDisconnected();
253 break;
254
255 case remoting.ClientSession.State.FAILED:
256 var error = this.clientSession_.getError();
257 console.error('Client plugin reported connection failed: ' +
258 error.toString());
259 this.handler_.onConnectionFailed(error || remoting.Error.unexpected());
260 break;
261
262 default:
263 console.error('Unexpected client plugin state: ' + event.current);
264 // This should only happen if the web-app and client plugin get out of
265 // sync, and even then the version check should ensure compatibility.
266 this.onError_(new remoting.Error(remoting.Error.Tag.MISSING_PLUGIN));
267 }
268
269 if (this.clientSession_.isFinished()) {
270 this.closeSession_();
271 }
272 };
273
274 /**
275 * @constructor
276 * @implements {remoting.SessionConnectorFactory}
277 */
278 remoting.DefaultSessionConnectorFactory = function() {};
279
280 /**
281 * @param {HTMLElement} clientContainer Container element for the client view.
282 * @param {Array<string>} requiredCapabilities Connector capabilities
283 * required by this application.
284 * @param {remoting.ClientSession.EventHandler} handler
285 * @return {remoting.SessionConnector}
286 */
287 remoting.DefaultSessionConnectorFactory.prototype.createConnector =
288 function(clientContainer, requiredCapabilities, handler) {
289 return new remoting.SessionConnectorImpl(clientContainer,
290 requiredCapabilities, handler);
291 };
OLDNEW
« no previous file with comments | « remoting/webapp/crd/js/session_connector.js ('k') | remoting/webapp/files.gni » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698