[Webapp Refactor] Implements remoting.Activity.

remoting/webapp/crd/js/me2me_connect_flow.js

 // Copyright 2015 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.
 
 /** @suppress {duplicate} */
 var remoting = remoting || {};
 
 (function() {
 
 'use strict';
 
 /**
  * @param {remoting.SessionConnector} sessionConnector
  * @param {remoting.Host} host
  *
  * @constructor
+ * @implements {remoting.ConnectFlow}
  */
 remoting.Me2MeConnectFlow = function(sessionConnector, host) {
   /** @private */
   this.host_ = host;
   /** @private */
   this.connector_ = sessionConnector;
+  /** @private */
+  this.pinDialog_ =
+      new remoting.PinDialog(document.getElementById('pin-dialog'), host);
+  /** @private */
+  this.hostUpdateDialog_ = new remoting.HostNeedsUpdateDialog(
+      document.getElementById('host-needs-update-dialog'), this.host_);
+  /** @private */
+  this.retryOnHostOffline_ = true;
 };
 
+remoting.Me2MeConnectFlow.prototype.dispose = function() {};
+
 remoting.Me2MeConnectFlow.prototype.start = function() {
   var webappVersion = chrome.runtime.getManifest().version;
-  var needsUpdateDialog = new remoting.HostNeedsUpdateDialog(
-      document.getElementById('host-needs-update-dialog'), this.host_);
   var that = this;
 
-  needsUpdateDialog.showIfNecessary(webappVersion).then(function() {
+  this.hostUpdateDialog_.showIfNecessary(webappVersion).then(function() {
     return that.host_.options.load();
   }).then(function() {
     that.connect_();
   }).catch(function(/** remoting.Error */ error) {
     if (error.hasTag(remoting.Error.Tag.CANCELLED)) {
       remoting.setMode(remoting.AppMode.HOME);
     }
   });
 };
 
 /** @private */
 remoting.Me2MeConnectFlow.prototype.connect_ = function() {
   remoting.setMode(remoting.AppMode.CLIENT_CONNECTING);
   var host = this.host_;
 
   /**
    * @param {string} tokenUrl Token-issue URL received from the host.
    * @param {string} hostPublicKey Host public key (DER and Base64 encoded).
    * @param {string} scope OAuth scope to request the token for.
    * @param {function(string, string):void} onThirdPartyTokenFetched Callback.
    */
   var fetchThirdPartyToken = function(
       tokenUrl, hostPublicKey, scope, onThirdPartyTokenFetched) {
     var thirdPartyTokenFetcher = new remoting.ThirdPartyTokenFetcher(
         tokenUrl, hostPublicKey, scope, host.tokenUrlPatterns,
         onThirdPartyTokenFetched);
     thirdPartyTokenFetcher.fetchToken();
   };
 
+  var that = this;
   /**
    * @param {boolean} supportsPairing
    * @param {function(string):void} onPinFetched
    */
   var requestPin = function(supportsPairing, onPinFetched) {
-    var pinDialog =
-        new remoting.PinDialog(document.getElementById('pin-dialog'), host);
-    pinDialog.show(supportsPairing).then(function(/** string */ pin) {
+    that.pinDialog_.show(supportsPairing).then(function(/** string */ pin) {
       remoting.setMode(remoting.AppMode.CLIENT_CONNECTING);
       onPinFetched(pin);
-      /** @type {boolean} */
-      remoting.pairingRequested = pinDialog.pairingRequested();
     }).catch(function(/** remoting.Error */ error) {
       base.debug.assert(error.hasTag(remoting.Error.Tag.CANCELLED));
       remoting.setMode(remoting.AppMode.HOME);
     });
   };
 
   var pairingInfo = host.options.pairingInfo;
   this.connector_.connectMe2Me(host, requestPin, fetchThirdPartyToken,
                                pairingInfo.clientId, pairingInfo.sharedSecret);
 };
 
+/**
+ * @param {!remoting.Error} error
+ */
+remoting.Me2MeConnectFlow.prototype.onConnectionFailed = function(error) {
+  var that = this;
+  var onHostListRefresh = function(/** boolean */ success) {
+    if (success) {
+      that.connector_.retryConnectMe2Me(that.host_);
+      return;
+    }
+    that.onError(error);
+  };
+
+  if (error.hasTag(remoting.Error.Tag.HOST_IS_OFFLINE) &&
+      this.retryOnHostOffline_) {
+    this.retryOnHostOffline_ = false;
+
+    // The plugin will be re-created when the host finished refreshing
+    remoting.hostList.refresh(onHostListRefresh);
+  } else {
+    this.onError(error);
+  }
+};
+
+/**
+ * @param {!remoting.ConnectionInfo} connectionInfo
+ */
+remoting.Me2MeConnectFlow.prototype.onConnected = function(connectionInfo) {
+  // Reset the refresh flag so that the next connection will retry if needed.
+  this.retryOnHostOffline_ = true;
+
+  if (remoting.app.hasCapability(remoting.ClientSession.Capability.CAST)) {
+    this.connector_.registerProtocolExtension(
+        new remoting.CastExtensionHandler());
+  }
+  this.connector_.registerProtocolExtension(new remoting.GnubbyAuthHandler());
+  this.pinDialog_.requestPairingIfNecessary(connectionInfo.plugin(),
+                                            this.connector_);
+};
+
+remoting.Me2MeConnectFlow.prototype.onDisconnected = function() {
+  remoting.setMode(remoting.AppMode.CLIENT_SESSION_FINISHED_ME2ME);
+};
+
+/**
+ * @param {!remoting.Error} error
+ */
+remoting.Me2MeConnectFlow.prototype.onError = function(error) {
+  this.retryOnHostOffline_ = true;
+  var errorDiv = document.getElementById('connect-error-message');
+  l10n.localizeElementFromTag(errorDiv, error.getTag());
+  remoting.setMode(remoting.AppMode.CLIENT_CONNECT_FAILED_IT2ME);
+};
 
 /**
  * @param {HTMLElement} rootElement
  * @param {remoting.Host} host
  * @constructor
  */
 remoting.HostNeedsUpdateDialog = function(rootElement, host) {
   /** @private */
   this.host_ = host;
   /** @private */
@@ skipping 88 matching lines @@
 remoting.PinDialog.prototype.show = function(supportsPairing) {
   // Reset the UI.
   this.pairingCheckbox_.checked = false;
   this.rootElement_.querySelector('.pairing-section').hidden = !supportsPairing;
   var message = this.rootElement_.querySelector('.pin-message');
   l10n.localizeElement(message, this.host_.hostName);
   this.pinInput_.value = '';
   return this.dialog_.show();
 };
 
-/** @return {boolean} */
-remoting.PinDialog.prototype.pairingRequested = function() {
-  return this.pairingCheckbox_.checked;
+/**
+ * @param {remoting.ClientPlugin} plugin
+ * @param {remoting.SessionConnector} connector
+ */
+remoting.PinDialog.prototype.requestPairingIfNecessary =
+    function(plugin, connector) {
+  if (this.pairingCheckbox_.checked) {
+    var that = this;
+    /**
+     * @param {string} clientId
+     * @param {string} sharedSecret
+     */
+    var onPairingComplete = function(clientId, sharedSecret) {
+      that.host_.options.pairingInfo.clientId = clientId;
+      that.host_.options.pairingInfo.sharedSecret = sharedSecret;
+      that.host_.options.save();
+      connector.updatePairingInfo(clientId, sharedSecret);
+    };
+
+    // Use the platform name as a proxy for the local computer name.
+    // TODO(jamiewalch): Use a descriptive name for the local computer, for
+    // example, its Chrome Sync name.
+    var clientName = '';
+    if (remoting.platformIsMac()) {
+      clientName = 'Mac';
+    } else if (remoting.platformIsWindows()) {
+      clientName = 'Windows';
+    } else if (remoting.platformIsChromeOS()) {
+      clientName = 'ChromeOS';
+    } else if (remoting.platformIsLinux()) {
+      clientName = 'Linux';
+    } else {
+      console.log('Unrecognized client platform. Using navigator.platform.');
+      clientName = navigator.platform;
+    }
+    plugin.requestPairing(clientName, onPairingComplete);
+  }
 };
 
 })();