Use XMPP in V2 webapp

remoting/webapp/wcs_adapter.js

Index: remoting/webapp/wcs_adapter.js
diff --git a/remoting/webapp/wcs_adapter.js b/remoting/webapp/wcs_adapter.js
new file mode 100644
index 0000000000000000000000000000000000000000..9ac7cc4836d8eeb9ce51890647aca74f10f4fe24
--- /dev/null
+++ b/remoting/webapp/wcs_adapter.js
@@ -0,0 +1,131 @@
+// 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.
+
+'use strict';
+
+/** @suppress {duplicate} */
+var remoting = remoting || {};
+
+/**
+ * WCS-based SignalStrategy implementation. Used instead of XMPPConnection
+ * when XMPP cannot be used (e.g. in V1 app).
+ *
+ * @param {function(remoting.SignalStrategy.State):void} onStateChangedCallback
+ *   Callback to call on state change.
+ * @constructor
+ * @implements {remoting.SignalStrategy}
+ */
+remoting.WcsAdapter =
+    function(onStateChangedCallback) {
+  /** @private */
+  this.onStateChangedCallback_ = onStateChangedCallback;
+  /** @type {?function(Element):void} @private */
+  this.onIncomingStanzaCallback_ = null;
+  /** @private */
+  this.state_ = remoting.SignalStrategy.State.NOT_CONNECTED;
+  /** @private */
+  this.jid_ = '';
+  /** @private */
+  this.error_ = remoting.Error.NONE;
+}
+
+/**
+ * @param {?function(Element):void} onIncomingStanzaCallback Callback to call on
+ *     incoming messages.
+ */
+remoting.WcsAdapter.prototype.setIncomingStanzaCallback =
+    function(onIncomingStanzaCallback) {
+  this.onIncomingStanzaCallback_ = onIncomingStanzaCallback;
+}
+
+remoting.WcsAdapter.prototype.connect = function(server, authToken) {
+  remoting.wcsSandbox.setOnIq(this.onIncomingStanza_.bind(this));
+
+  remoting.wcsSandbox.connect(this.onWcsConnected_.bind(this),
+                              this.onError_.bind(this));
+}
+
+/** @return {remoting.SignalStrategy.State} Current state */
+remoting.WcsAdapter.prototype.getState = function() {
+  return this.state_;
+}
+
+/** @return {remoting.Error} Error when in FAILED state. */
+remoting.WcsAdapter.prototype.getError = function() {
+  return this.error_;
+}
+
+/** @return {string} Current JID when in CONNECTED state. */
+remoting.WcsAdapter.prototype.getJid = function() {
+  return this.jid_;
+}
+
+remoting.WcsAdapter.prototype.dispose = function() {
+  this.setState_(remoting.SignalStrategy.State.CLOSED);
+  remoting.wcsSandbox.setOnIq(null);
+}
+
+/** @param {string} message */
+remoting.WcsAdapter.prototype.sendMessage = function(message) {
+  // Extract the session id, so we can close the session later.
+  // HACK: Add 'x' prefix to the IDs of the outgoing messages to make sure that
+  // stanza IDs used by host and client do not match. This is necessary to
+  // workaround bug in the signaling endpoint used by chromoting.
+  // TODO(sergeyu): Remove this hack once the server-side bug is fixed.
+  var parser = new DOMParser();
+  var iqNode = parser.parseFromString(message, 'text/xml').firstChild;
+  var type = iqNode.getAttribute('type');
+  if (type == 'set') {
+    var id = iqNode.getAttribute('id');
+    iqNode.setAttribute('id', 'x' + id);
+    message = (new XMLSerializer()).serializeToString(iqNode);
+  }
+
+  // Send the stanza.
+  remoting.wcsSandbox.sendIq(message);
+}
+
+/** @param {string} jid */
+remoting.WcsAdapter.prototype.onWcsConnected_ = function(jid) {
+  this.jid_ = jid;
+  this.setState_(remoting.SignalStrategy.State.CONNECTED);
+}
+
+/** @param {string} stanza */
+remoting.WcsAdapter.prototype.onIncomingStanza_ = function(stanza) {
+  var parser = new DOMParser();
+  var parsed = parser.parseFromString(stanza, 'text/xml').firstChild;
+
+  // HACK: Remove 'x' prefix added to the id in sendMessage().
+  try {
+    var type = parsed.getAttribute('type');
+    var id = parsed.getAttribute('id');
+    if (type != 'set' && id.charAt(0) == 'x') {
+      parsed.setAttribute('id', id.substr(1));
+    }
+  } catch (err) {
+    // Pass message as is when it is malformed.
+  }
+
+  if (this.onIncomingStanzaCallback_) {
+    this.onIncomingStanzaCallback_(parsed);
+  }
+}
+
+/** @param {remoting.Error} error */
+remoting.WcsAdapter.prototype.onError_ = function(error) {
+  this.error_ = error;
+  this.setState_(remoting.SignalStrategy.State.FAILED);
+}
+
+/**
+ * @param {remoting.SignalStrategy.State} newState
+ * @private
+ */
+remoting.WcsAdapter.prototype.setState_ = function(newState) {
+  if (this.state_ != newState) {
+    this.state_ = newState;
+    this.onStateChangedCallback_(this.state_);
+  }
+};