Requiem for client_screen.js

remoting/webapp/base/js/application.js

 // Copyright 2014 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 /**
  * @fileoverview
  * Interface abstracting the Application functionality.
  */
 
 'use strict';
 
 /** @suppress {duplicate} */
 var remoting = remoting || {};
 
 /**
+ * @type {remoting.ClientSession} The client session object, set once the
+ *     connector has invoked its onOk callback.
+ * TODO(garykac): Make clientSession a member var of Application.
+ */
+remoting.clientSession = null;
+
+/**
+ * @type {remoting.DesktopConnectedView} The client session view object, set
+ *     once the connector has invoked its onOk callback.
+ */
+remoting.desktopConnectedView = null;
+
+/**
  * @param {Array<string>} app_capabilities Array of application capabilities.
  * @constructor
  */
 remoting.Application = function(app_capabilities) {
   /**
    * @type {remoting.Application.Delegate}
    * @private
    */
   this.delegate_ = null;
 
   /**
    * @type {Array<string>}
    * @private
    */
   this.app_capabilities_ = [
     remoting.ClientSession.Capability.SEND_INITIAL_RESOLUTION,
     remoting.ClientSession.Capability.RATE_LIMIT_RESIZE_REQUESTS,
     remoting.ClientSession.Capability.VIDEO_RECORDER
   ];
   // Append the app-specific capabilities.
   this.app_capabilities_.push.apply(this.app_capabilities_, app_capabilities);
 
   /**
    * @type {remoting.SessionConnector}
    * @private
    */
   this.session_connector_ = null;
+
+  /** @private {base.Disposable} */
+  this.sessionConnectedHooks_ = null;
 };
 
 /**
  * @param {remoting.Application.Delegate} appDelegate The delegate that
  *    contains the app-specific functionality.
  */
 remoting.Application.prototype.setDelegate = function(appDelegate) {
   this.delegate_ = appDelegate;
 };
 
@@ skipping 33 matching lines @@
   remoting.SessionConnector.factory =
       new remoting.DefaultSessionConnectorFactory();
 
   // TODO(garykac): This should be owned properly rather than living in the
   // global 'remoting' namespace.
   remoting.settings = new remoting.Settings();
 
   this.delegate_.init(this.getSessionConnector());
 };
 
+/** Disconnect the remoting client. */
+remoting.Application.prototype.disconnect = function() {
+  if (remoting.clientSession) {
+    remoting.clientSession.disconnect(remoting.Error.NONE);
+    console.log('Disconnected.');
+  }
+};
+
 /**
  * Called when a new session has been connected.
  *
  * @param {remoting.ClientSession} clientSession
  * @return {void} Nothing.
  */
 remoting.Application.prototype.onConnected = function(clientSession) {
-  // TODO(garykac): Make clientSession a member var of Application.
   remoting.clientSession = clientSession;
-  remoting.clientSession.addEventListener('stateChanged', onClientStateChange_);
-
+  this.sessionConnectedHooks_ = new base.Disposables(
+    new base.EventHook(
+      clientSession, 'stateChanged', this.onClientStateChange_.bind(this)),
+    new base.RepeatingTimer(this.updateStatistics_.bind(this), 1000)
+  );
   remoting.clipboard.startSession();
-  updateStatistics_();
 
   this.delegate_.handleConnected(clientSession);
 };
 
 /**
  * Called when the current session has been disconnected.
  *
  * @return {void} Nothing.
  */
 remoting.Application.prototype.onDisconnected = function() {
@@ skipping 66 matching lines @@
         this.onConnected.bind(this),
         this.onError.bind(this),
         this.onExtensionMessage.bind(this),
         this.onConnectionFailed.bind(this),
         this.getRequiredCapabilities_(),
         this.delegate_.getDefaultRemapKeys());
   }
   return this.session_connector_;
 };
 
+/**
+ * Callback function called when the state of the client plugin changes. The
+ * current and previous states are available via the |state| member variable.
+ *
+ * @param {remoting.ClientSession.StateEvent=} state
+ * @private
+ */
+remoting.Application.prototype.onClientStateChange_ = function(state) {
+  switch (state.current) {
+    case remoting.ClientSession.State.CLOSED:
+      console.log('Connection closed by host');
+      this.onDisconnected();
+      break;
+    case remoting.ClientSession.State.FAILED:
+      var error = remoting.clientSession.getError();
+      console.error('Client plugin reported connection failed: ' + error);
+      if (error === null) {
+        error = remoting.Error.UNEXPECTED;
+      }
+      this.onError(error);
+      break;
+
+    default:
+      console.error('Unexpected client plugin state: ' + state.current);
+      // This should only happen if the web-app and client plugin get out of
+      // sync, so MISSING_PLUGIN is a suitable error.
+      this.onError(remoting.Error.MISSING_PLUGIN);
+      break;
+  }
+
+  base.dispose(this.sessionConnectedHooks_);
+  this.sessionConnectedHooks_= null;
+  remoting.clientSession.dispose();
+  remoting.clientSession = null;
+};
+
+/** @private */
+remoting.Application.prototype.updateStatistics_ = function() {
+  var perfstats = remoting.clientSession.getPerfStats();
+  remoting.stats.update(perfstats);
+  remoting.clientSession.logStatistics(perfstats);
+};
 
 /**
  * @interface
  */
 remoting.Application.Delegate = function() {};
 
 /**
  * Initialize the application and register all event handlers. After this
  * is called, the app is running and waiting for user events.
  *
@@ skipping 61 matching lines @@
  * Called when an error needs to be displayed to the user.
  *
  * @param {remoting.Error} errorTag The error to be localized and displayed.
  * @return {void} Nothing.
  */
 remoting.Application.Delegate.prototype.handleError = function(errorTag) {};
 
 
 /** @type {remoting.Application} */
 remoting.app = null;