Move ProtocolExtensionManager from SessionConnector into its own class

remoting/webapp/crd/js/client_session.js

 // Copyright (c) 2012 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
  * Class handling creation and teardown of a remoting client session.
  *
  * The ClientSession class controls lifetime of the client plugin
  * object and provides the plugin with the functionality it needs to
@@ skipping 17 matching lines @@
  *
  * @const
  * @type {number}
  */
 remoting.ACCESS_TOKEN_RESEND_INTERVAL_MS = 15 * 60 * 1000;
 
 /**
  * @param {remoting.ClientPlugin} plugin
  * @param {remoting.Host} host The host to connect to.
  * @param {remoting.SignalStrategy} signalStrategy Signal strategy.
- * @param {function(string, string):boolean} onExtensionMessage The handler for
- *     protocol extension messages. Returns true if a message is recognized;
- *     false otherwise.
  *
  * @constructor
  * @extends {base.EventSourceImpl}
  * @implements {base.Disposable}
  * @implements {remoting.ClientPlugin.ConnectionEventHandler}
  */
-remoting.ClientSession = function(plugin, host, signalStrategy,
-                                  onExtensionMessage) {
+remoting.ClientSession = function(plugin, host, signalStrategy) {
   base.inherits(this, base.EventSourceImpl);
 
   /** @private */
   this.state_ = remoting.ClientSession.State.INITIALIZING;
 
   /** @private {!remoting.Error} */
   this.error_ = remoting.Error.none();
 
   /** @private */
   this.host_ = host;
@@ skipping 14 matching lines @@
   remoting.formatIq.setJids(this.signalStrategy_.getJid(), host.jabberId);
 
   /**
    * Allow host-offline error reporting to be suppressed in situations where it
    * would not be useful, for example, when using a cached host JID.
    *
    * @type {boolean} @private
    */
   this.logHostOfflineErrors_ = true;
 
-  /** @private {function(string, string):boolean} */
-  this.onExtensionMessageHandler_ = onExtensionMessage;
-
   /** @private {remoting.ClientPlugin} */
   this.plugin_ = plugin;
   plugin.setConnectionEventHandler(this);
 
   this.defineEvents(Object.keys(remoting.ClientSession.Events));
 };
 
 /** @enum {string} */
 remoting.ClientSession.Events = {
   stateChanged: 'stateChanged', // deprecated.
@@ skipping 409 matching lines @@
     return;
   }
 
   this.capabilities_ = capabilities;
   if (this.hasCapability(remoting.ClientSession.Capability.GOOGLE_DRIVE)) {
     this.sendGoogleDriveAccessToken_();
   }
 };
 
 /**
- * @param {string} type
- * @param {string} data
- */
-remoting.ClientSession.prototype.onExtensionMessage = function(type, data) {
-  this.onExtensionMessageHandler_(type, data);
-};
-
-/**
  * @param {remoting.ClientSession.State} newState The new state for the session.
  * @return {void} Nothing.
  * @private
  */
 remoting.ClientSession.prototype.setState_ = function(newState) {
   var oldState = this.state_;
   this.state_ = newState;
   var state = this.state_;
   if (oldState == remoting.ClientSession.State.CONNECTING ||
       oldState == remoting.ClientSession.State.AUTHENTICATED) {
@@ skipping 95 matching lines @@
     'https://docs.google.com/feeds/',
     'https://www.googleapis.com/auth/drive'
   ];
   remoting.identity.getNewToken(googleDriveScopes).
       then(sendToken).
       catch(remoting.Error.handler(sendError));
   window.setTimeout(this.sendGoogleDriveAccessToken_.bind(this),
                     remoting.ACCESS_TOKEN_RESEND_INTERVAL_MS);
 };