Home | History | Annotate | Download | only in webapp 
      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  * @param {function(remoting.SignalStrategy.State):void} onStateChangedCallback
     15  *   Callback to call on state change.
     16  * @constructor
     17  * @implements {remoting.SignalStrategy}
     18  */
     19 remoting.WcsAdapter =
     20     function(onStateChangedCallback) {
     21   /** @private */
     22   this.onStateChangedCallback_ = onStateChangedCallback;
     23   /** @type {?function(Element):void} @private */
     24   this.onIncomingStanzaCallback_ = null;
     25   /** @private */
     26   this.state_ = remoting.SignalStrategy.State.NOT_CONNECTED;
     27   /** @private */
     28   this.jid_ = '';
     29   /** @private */
     30   this.error_ = remoting.Error.NONE;
     31 }
     32 
     33 /**
     34  * @param {?function(Element):void} onIncomingStanzaCallback Callback to call on
     35  *     incoming messages.
     36  */
     37 remoting.WcsAdapter.prototype.setIncomingStanzaCallback =
     38     function(onIncomingStanzaCallback) {
     39   this.onIncomingStanzaCallback_ = onIncomingStanzaCallback;
     40 }
     41 
     42 remoting.WcsAdapter.prototype.connect = function(server, authToken) {
     43   remoting.wcsSandbox.setOnIq(this.onIncomingStanza_.bind(this));
     44 
     45   remoting.wcsSandbox.connect(this.onWcsConnected_.bind(this),
     46                               this.onError_.bind(this));
     47 }
     48 
     49 /** @return {remoting.SignalStrategy.State} Current state */
     50 remoting.WcsAdapter.prototype.getState = function() {
     51   return this.state_;
     52 }
     53 
     54 /** @return {remoting.Error} Error when in FAILED state. */
     55 remoting.WcsAdapter.prototype.getError = function() {
     56   return this.error_;
     57 }
     58 
     59 /** @return {string} Current JID when in CONNECTED state. */
     60 remoting.WcsAdapter.prototype.getJid = function() {
     61   return this.jid_;
     62 }
     63 
     64 remoting.WcsAdapter.prototype.dispose = function() {
     65   this.setState_(remoting.SignalStrategy.State.CLOSED);
     66   remoting.wcsSandbox.setOnIq(null);
     67 }
     68 
     69 /** @param {string} message */
     70 remoting.WcsAdapter.prototype.sendMessage = function(message) {
     71   // Extract the session id, so we can close the session later.
     72   // HACK: Add 'x' prefix to the IDs of the outgoing messages to make sure that
     73   // stanza IDs used by host and client do not match. This is necessary to
     74   // workaround bug in the signaling endpoint used by chromoting.
     75   // TODO(sergeyu): Remove this hack once the server-side bug is fixed.
     76   var parser = new DOMParser();
     77   var iqNode = parser.parseFromString(message, 'text/xml').firstChild;
     78   var type = iqNode.getAttribute('type');
     79   if (type == 'set') {
     80     var id = iqNode.getAttribute('id');
     81     iqNode.setAttribute('id', 'x' + id);
     82     message = (new XMLSerializer()).serializeToString(iqNode);
     83   }
     84 
     85   // Send the stanza.
     86   remoting.wcsSandbox.sendIq(message);
     87 }
     88 
     89 /** @param {string} jid */
     90 remoting.WcsAdapter.prototype.onWcsConnected_ = function(jid) {
     91   this.jid_ = jid;
     92   this.setState_(remoting.SignalStrategy.State.CONNECTED);
     93 }
     94 
     95 /** @param {string} stanza */
     96 remoting.WcsAdapter.prototype.onIncomingStanza_ = function(stanza) {
     97   var parser = new DOMParser();
     98   var parsed = parser.parseFromString(stanza, 'text/xml').firstChild;
     99 
    100   // HACK: Remove 'x' prefix added to the id in sendMessage().
    101   try {
    102     var type = parsed.getAttribute('type');
    103     var id = parsed.getAttribute('id');
    104     if (type != 'set' && id.charAt(0) == 'x') {
    105       parsed.setAttribute('id', id.substr(1));
    106     }
    107   } catch (err) {
    108     // Pass message as is when it is malformed.
    109   }
    110 
    111   if (this.onIncomingStanzaCallback_) {
    112     this.onIncomingStanzaCallback_(parsed);
    113   }
    114 }
    115 
    116 /** @param {remoting.Error} error */
    117 remoting.WcsAdapter.prototype.onError_ = function(error) {
    118   this.error_ = error;
    119   this.setState_(remoting.SignalStrategy.State.FAILED);
    120 }
    121 
    122 /**
    123  * @param {remoting.SignalStrategy.State} newState
    124  * @private
    125  */
    126 remoting.WcsAdapter.prototype.setState_ = function(newState) {
    127   if (this.state_ != newState) {
    128     this.state_ = newState;
    129     this.onStateChangedCallback_(this.state_);
    130   }
    131 };
    132