1 // Copyright (c) 2012 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 #include "remoting/jingle_glue/fake_signal_strategy.h"
6
7 #include "base/bind.h"
8 #include "base/location.h"
9 #include "base/logging.h"
10 #include "base/single_thread_task_runner.h"
11 #include "base/stl_util.h"
12 #include "base/strings/string_number_conversions.h"
13 #include "base/thread_task_runner_handle.h"
14 #include "third_party/libjingle/source/talk/xmllite/xmlelement.h"
15 #include "third_party/libjingle/source/talk/xmpp/constants.h"
16
17 namespace remoting {
18
19 // static
Connect(FakeSignalStrategy * peer1,FakeSignalStrategy * peer2)20 void FakeSignalStrategy::Connect(FakeSignalStrategy* peer1,
21 FakeSignalStrategy* peer2) {
22 peer1->peer_ = peer2;
23 peer2->peer_ = peer1;
24 }
25
FakeSignalStrategy(const std::string & jid)26 FakeSignalStrategy::FakeSignalStrategy(const std::string& jid)
27 : jid_(jid),
28 peer_(NULL),
29 last_id_(0),
30 weak_factory_(this) {
31
32 }
33
~FakeSignalStrategy()34 FakeSignalStrategy::~FakeSignalStrategy() {
35 while (!received_messages_.empty()) {
36 delete received_messages_.front();
37 received_messages_.pop_front();
38 }
39 }
40
Connect()41 void FakeSignalStrategy::Connect() {
42 DCHECK(CalledOnValidThread());
43 FOR_EACH_OBSERVER(Listener, listeners_,
44 OnSignalStrategyStateChange(CONNECTED));
45 }
46
Disconnect()47 void FakeSignalStrategy::Disconnect() {
48 DCHECK(CalledOnValidThread());
49 FOR_EACH_OBSERVER(Listener, listeners_,
50 OnSignalStrategyStateChange(DISCONNECTED));
51 }
52
GetState() const53 SignalStrategy::State FakeSignalStrategy::GetState() const {
54 return CONNECTED;
55 }
56
GetError() const57 SignalStrategy::Error FakeSignalStrategy::GetError() const {
58 return OK;
59 }
60
GetLocalJid() const61 std::string FakeSignalStrategy::GetLocalJid() const {
62 DCHECK(CalledOnValidThread());
63 return jid_;
64 }
65
AddListener(Listener * listener)66 void FakeSignalStrategy::AddListener(Listener* listener) {
67 DCHECK(CalledOnValidThread());
68 listeners_.AddObserver(listener);
69 }
70
RemoveListener(Listener * listener)71 void FakeSignalStrategy::RemoveListener(Listener* listener) {
72 DCHECK(CalledOnValidThread());
73 listeners_.RemoveObserver(listener);
74 }
75
SendStanza(scoped_ptr<buzz::XmlElement> stanza)76 bool FakeSignalStrategy::SendStanza(scoped_ptr<buzz::XmlElement> stanza) {
77 DCHECK(CalledOnValidThread());
78
79 stanza->SetAttr(buzz::QN_FROM, jid_);
80
81 if (peer_) {
82 peer_->OnIncomingMessage(stanza.Pass());
83 return true;
84 } else {
85 return false;
86 }
87 }
88
GetNextId()89 std::string FakeSignalStrategy::GetNextId() {
90 ++last_id_;
91 return base::IntToString(last_id_);
92 }
93
OnIncomingMessage(scoped_ptr<buzz::XmlElement> stanza)94 void FakeSignalStrategy::OnIncomingMessage(
95 scoped_ptr<buzz::XmlElement> stanza) {
96 pending_messages_.push(stanza.get());
97 received_messages_.push_back(stanza.release());
98 base::ThreadTaskRunnerHandle::Get()->PostTask(
99 FROM_HERE, base::Bind(&FakeSignalStrategy::DeliverIncomingMessages,
100 weak_factory_.GetWeakPtr()));
101 }
102
DeliverIncomingMessages()103 void FakeSignalStrategy::DeliverIncomingMessages() {
104 while (!pending_messages_.empty()) {
105 buzz::XmlElement* stanza = pending_messages_.front();
106 const std::string& to_field = stanza->Attr(buzz::QN_TO);
107 if (to_field != jid_) {
108 LOG(WARNING) << "Dropping stanza that is addressed to " << to_field
109 << ". Local jid: " << jid_
110 << ". Message content: " << stanza->Str();
111 return;
112 }
113
114 ObserverListBase<Listener>::Iterator it(listeners_);
115 Listener* listener;
116 while ((listener = it.GetNext()) != NULL) {
117 if (listener->OnSignalStrategyIncomingStanza(stanza))
118 break;
119 }
120
121 pending_messages_.pop();
122 }
123 }
124
125 } // namespace remoting
126