remoting/webapp/crd/js/wcs_adapter.js

   1 // Copyright 2014 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 'use strict';
   6
   7 /** @suppress {duplicate} */
   8 var remoting = remoting || {};
   9
  10 /**
  11  * WCS-based SignalStrategy implementation. Used instead of XMPPConnection
  12  * when XMPP cannot be used (e.g. in V1 app).
  13  *
  14  * @constructor
  15  * @implements {remoting.SignalStrategy}
  16  */
  17 remoting.WcsAdapter = function() {
  18   /** @type {?function(remoting.SignalStrategy.State):void} @private */
  19   this.onStateChangedCallback_ = null;
  20   /** @type {?function(Element):void} @private */
  21   this.onIncomingStanzaCallback_ = null;
  22   /** @private */
  23   this.state_ = remoting.SignalStrategy.State.NOT_CONNECTED;
  24   /** @private */
  25   this.jid_ = '';
  26   /** @private */
  27   this.error_ = remoting.Error.NONE;
  28 };
  29
  30 /**
  31  * @param {function(remoting.SignalStrategy.State):void} onStateChangedCallback
  32  */
  33 remoting.WcsAdapter.prototype.setStateChangedCallback = function(
  34     onStateChangedCallback) {
  35   this.onStateChangedCallback_ = onStateChangedCallback;
  36 };
  37
  38 /**
  39  * @param {?function(Element):void} onIncomingStanzaCallback Callback to call on
  40  *     incoming messages.
  41  */
  42 remoting.WcsAdapter.prototype.setIncomingStanzaCallback =
  43     function(onIncomingStanzaCallback) {
  44   this.onIncomingStanzaCallback_ = onIncomingStanzaCallback;
  45 };
  46
  47 /**
  48  * @param {string} server
  49  * @param {string} username
  50  * @param {string} authToken
  51  */
  52 remoting.WcsAdapter.prototype.connect = function(server, username, authToken) {
  53   base.debug.assert(this.onStateChangedCallback_ != null);
  54
  55   remoting.wcsSandbox.setOnIq(this.onIncomingStanza_.bind(this));
  56   remoting.wcsSandbox.connect(this.onWcsConnected_.bind(this),
  57                               this.onError_.bind(this));
  58 };
  59
  60 /** @return {remoting.SignalStrategy.State} Current state */
  61 remoting.WcsAdapter.prototype.getState = function() {
  62   return this.state_;
  63 };
  64
  65 /** @return {remoting.Error} Error when in FAILED state. */
  66 remoting.WcsAdapter.prototype.getError = function() {
  67   return this.error_;
  68 };
  69
  70 /** @return {string} Current JID when in CONNECTED state. */
  71 remoting.WcsAdapter.prototype.getJid = function() {
  72   return this.jid_;
  73 };
  74
  75 /** @return {remoting.SignalStrategy.Type} The signal strategy type. */
  76 remoting.WcsAdapter.prototype.getType = function() {
  77   return remoting.SignalStrategy.Type.WCS;
  78 };
  79
  80 remoting.WcsAdapter.prototype.dispose = function() {
  81   this.setState_(remoting.SignalStrategy.State.CLOSED);
  82   remoting.wcsSandbox.setOnIq(null);
  83 };
  84
  85 /** @param {string} message */
  86 remoting.WcsAdapter.prototype.sendMessage = function(message) {
  87   // Extract the session id, so we can close the session later.
  88   // HACK: Add 'x' prefix to the IDs of the outgoing messages to make sure that
  89   // stanza IDs used by host and client do not match. This is necessary to
  90   // workaround bug in the signaling endpoint used by chromoting.
  91   // TODO(sergeyu): Remove this hack once the server-side bug is fixed.
  92   var parser = new DOMParser();
  93   var iqNode = parser.parseFromString(message, 'text/xml').firstChild;
  94   var type = iqNode.getAttribute('type');
  95   if (type == 'set') {
  96     var id = iqNode.getAttribute('id');
  97     iqNode.setAttribute('id', 'x' + id);
  98     message = (new XMLSerializer()).serializeToString(iqNode);
  99   }
 100
 101   // Send the stanza.
 102   remoting.wcsSandbox.sendIq(message);
 103 };
 104
 105 /**
 106  * @param {remoting.LogToServer} logToServer The LogToServer instance for the
 107  *     connection.
 108  */
 109 remoting.WcsAdapter.prototype.sendConnectionSetupResults =
 110     function(logToServer) {
 111 };
 112
 113 /** @param {string} jid */
 114 remoting.WcsAdapter.prototype.onWcsConnected_ = function(jid) {
 115   this.jid_ = jid;
 116   this.setState_(remoting.SignalStrategy.State.CONNECTED);
 117 };
 118
 119 /** @param {string} stanza */
 120 remoting.WcsAdapter.prototype.onIncomingStanza_ = function(stanza) {
 121   var parser = new DOMParser();
 122   var parsed = parser.parseFromString(stanza, 'text/xml').firstChild;
 123
 124   // HACK: Remove 'x' prefix added to the id in sendMessage().
 125   try {
 126     var type = parsed.getAttribute('type');
 127     var id = parsed.getAttribute('id');
 128     if (type != 'set' && id.charAt(0) == 'x') {
 129       parsed.setAttribute('id', id.substr(1));
 130     }
 131   } catch (err) {
 132     // Pass message as is when it is malformed.
 133   }
 134
 135   if (this.onIncomingStanzaCallback_) {
 136     this.onIncomingStanzaCallback_(parsed);
 137   }
 138 };
 139
 140 /** @param {remoting.Error} error */
 141 remoting.WcsAdapter.prototype.onError_ = function(error) {
 142   this.error_ = error;
 143   this.setState_(remoting.SignalStrategy.State.FAILED);
 144 };
 145
 146 /**
 147  * @param {remoting.SignalStrategy.State} newState
 148  * @private
 149  */
 150 remoting.WcsAdapter.prototype.setState_ = function(newState) {
 151   if (this.state_ != newState) {
 152     this.state_ = newState;
 153     this.onStateChangedCallback_(this.state_);
 154   }
 155 };