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} */
8var 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 */
19remoting.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 */
37remoting.WcsAdapter.prototype.setIncomingStanzaCallback =
38    function(onIncomingStanzaCallback) {
39  this.onIncomingStanzaCallback_ = onIncomingStanzaCallback;
40}
41
42remoting.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 */
50remoting.WcsAdapter.prototype.getState = function() {
51  return this.state_;
52}
53
54/** @return {remoting.Error} Error when in FAILED state. */
55remoting.WcsAdapter.prototype.getError = function() {
56  return this.error_;
57}
58
59/** @return {string} Current JID when in CONNECTED state. */
60remoting.WcsAdapter.prototype.getJid = function() {
61  return this.jid_;
62}
63
64remoting.WcsAdapter.prototype.dispose = function() {
65  this.setState_(remoting.SignalStrategy.State.CLOSED);
66  remoting.wcsSandbox.setOnIq(null);
67}
68
69/** @param {string} message */
70remoting.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 */
90remoting.WcsAdapter.prototype.onWcsConnected_ = function(jid) {
91  this.jid_ = jid;
92  this.setState_(remoting.SignalStrategy.State.CONNECTED);
93}
94
95/** @param {string} stanza */
96remoting.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 */
117remoting.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 */
126remoting.WcsAdapter.prototype.setState_ = function(newState) {
127  if (this.state_ != newState) {
128    this.state_ = newState;
129    this.onStateChangedCallback_(this.state_);
130  }
131};
132