OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 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 | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "remoting/host/register_support_host_request.h" | 5 #include "remoting/host/register_support_host_request.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/memory/ref_counted.h" | 8 #include "base/memory/ref_counted.h" |
9 #include "base/message_loop.h" | 9 #include "base/message_loop.h" |
10 #include "base/observer_list.h" | 10 #include "base/observer_list.h" |
11 #include "base/string_number_conversions.h" | 11 #include "base/string_number_conversions.h" |
12 #include "remoting/base/constants.h" | 12 #include "remoting/base/constants.h" |
13 #include "remoting/host/host_key_pair.h" | 13 #include "remoting/base/rsa_key_pair.h" |
| 14 #include "remoting/base/test_rsa_key_pair.h" |
14 #include "remoting/host/in_memory_host_config.h" | 15 #include "remoting/host/in_memory_host_config.h" |
15 #include "remoting/host/test_key_pair.h" | |
16 #include "remoting/jingle_glue/iq_sender.h" | 16 #include "remoting/jingle_glue/iq_sender.h" |
17 #include "remoting/jingle_glue/mock_objects.h" | 17 #include "remoting/jingle_glue/mock_objects.h" |
18 #include "testing/gmock/include/gmock/gmock.h" | 18 #include "testing/gmock/include/gmock/gmock.h" |
19 #include "testing/gtest/include/gtest/gtest.h" | 19 #include "testing/gtest/include/gtest/gtest.h" |
20 #include "third_party/libjingle/source/talk/xmllite/xmlelement.h" | 20 #include "third_party/libjingle/source/talk/xmllite/xmlelement.h" |
21 #include "third_party/libjingle/source/talk/xmpp/constants.h" | 21 #include "third_party/libjingle/source/talk/xmpp/constants.h" |
22 | 22 |
23 using buzz::QName; | 23 using buzz::QName; |
24 using buzz::XmlElement; | 24 using buzz::XmlElement; |
25 | 25 |
(...skipping 25 matching lines...) Expand all Loading... |
51 MOCK_METHOD3(OnResponse, void(bool result, const std::string& support_id, | 51 MOCK_METHOD3(OnResponse, void(bool result, const std::string& support_id, |
52 const base::TimeDelta& lifetime)); | 52 const base::TimeDelta& lifetime)); |
53 }; | 53 }; |
54 | 54 |
55 } // namespace | 55 } // namespace |
56 | 56 |
57 class RegisterSupportHostRequestTest : public testing::Test { | 57 class RegisterSupportHostRequestTest : public testing::Test { |
58 public: | 58 public: |
59 protected: | 59 protected: |
60 virtual void SetUp() { | 60 virtual void SetUp() { |
61 ASSERT_TRUE(key_pair_.LoadFromString(kTestHostKeyPair)); | 61 key_pair_ = RsaKeyPair::FromString(kTestRsaKeyPair); |
| 62 ASSERT_TRUE(key_pair_); |
62 | 63 |
63 EXPECT_CALL(signal_strategy_, AddListener(NotNull())) | 64 EXPECT_CALL(signal_strategy_, AddListener(NotNull())) |
64 .WillRepeatedly(AddListener(&signal_strategy_listeners_)); | 65 .WillRepeatedly(AddListener(&signal_strategy_listeners_)); |
65 EXPECT_CALL(signal_strategy_, RemoveListener(NotNull())) | 66 EXPECT_CALL(signal_strategy_, RemoveListener(NotNull())) |
66 .WillRepeatedly(RemoveListener(&signal_strategy_listeners_)); | 67 .WillRepeatedly(RemoveListener(&signal_strategy_listeners_)); |
67 EXPECT_CALL(signal_strategy_, GetLocalJid()) | 68 EXPECT_CALL(signal_strategy_, GetLocalJid()) |
68 .WillRepeatedly(Return(kTestJid)); | 69 .WillRepeatedly(Return(kTestJid)); |
69 } | 70 } |
70 | 71 |
71 MessageLoop message_loop_; | 72 MessageLoop message_loop_; |
72 MockSignalStrategy signal_strategy_; | 73 MockSignalStrategy signal_strategy_; |
73 ObserverList<SignalStrategy::Listener, true> signal_strategy_listeners_; | 74 ObserverList<SignalStrategy::Listener, true> signal_strategy_listeners_; |
74 HostKeyPair key_pair_; | 75 scoped_refptr<RsaKeyPair> key_pair_; |
75 MockCallback callback_; | 76 MockCallback callback_; |
76 }; | 77 }; |
77 | 78 |
78 TEST_F(RegisterSupportHostRequestTest, Send) { | 79 TEST_F(RegisterSupportHostRequestTest, Send) { |
79 // |iq_request| is freed by RegisterSupportHostRequest. | 80 // |iq_request| is freed by RegisterSupportHostRequest. |
80 int64 start_time = static_cast<int64>(base::Time::Now().ToDoubleT()); | 81 int64 start_time = static_cast<int64>(base::Time::Now().ToDoubleT()); |
81 | 82 |
82 scoped_ptr<RegisterSupportHostRequest> request( | 83 scoped_ptr<RegisterSupportHostRequest> request( |
83 new RegisterSupportHostRequest(&signal_strategy_, &key_pair_, | 84 new RegisterSupportHostRequest(&signal_strategy_, key_pair_, |
84 kTestBotJid, | 85 kTestBotJid, |
85 base::Bind(&MockCallback::OnResponse, | 86 base::Bind(&MockCallback::OnResponse, |
86 base::Unretained(&callback_)))); | 87 base::Unretained(&callback_)))); |
87 | 88 |
88 XmlElement* sent_iq = NULL; | 89 XmlElement* sent_iq = NULL; |
89 EXPECT_CALL(signal_strategy_, GetNextId()) | 90 EXPECT_CALL(signal_strategy_, GetNextId()) |
90 .WillOnce(Return(kStanzaId)); | 91 .WillOnce(Return(kStanzaId)); |
91 EXPECT_CALL(signal_strategy_, SendStanzaPtr(NotNull())) | 92 EXPECT_CALL(signal_strategy_, SendStanzaPtr(NotNull())) |
92 .WillOnce(DoAll(SaveArg<0>(&sent_iq), Return(true))); | 93 .WillOnce(DoAll(SaveArg<0>(&sent_iq), Return(true))); |
93 | 94 |
(...skipping 17 matching lines...) Expand all Loading... |
111 EXPECT_TRUE(stanza->NextNamed(signature_tag) == NULL); | 112 EXPECT_TRUE(stanza->NextNamed(signature_tag) == NULL); |
112 | 113 |
113 std::string time_str = | 114 std::string time_str = |
114 signature->Attr(QName(kChromotingXmlNamespace, "time")); | 115 signature->Attr(QName(kChromotingXmlNamespace, "time")); |
115 int64 time; | 116 int64 time; |
116 EXPECT_TRUE(base::StringToInt64(time_str, &time)); | 117 EXPECT_TRUE(base::StringToInt64(time_str, &time)); |
117 int64 now = static_cast<int64>(base::Time::Now().ToDoubleT()); | 118 int64 now = static_cast<int64>(base::Time::Now().ToDoubleT()); |
118 EXPECT_LE(start_time, time); | 119 EXPECT_LE(start_time, time); |
119 EXPECT_GE(now, time); | 120 EXPECT_GE(now, time); |
120 | 121 |
121 HostKeyPair key_pair; | 122 scoped_refptr<RsaKeyPair> key_pair = RsaKeyPair::FromString(kTestRsaKeyPair); |
122 key_pair.LoadFromString(kTestHostKeyPair); | 123 ASSERT_TRUE(key_pair); |
| 124 |
123 std::string expected_signature = | 125 std::string expected_signature = |
124 key_pair.GetSignature(std::string(kTestJid) + ' ' + time_str); | 126 key_pair->SignMessage(std::string(kTestJid) + ' ' + time_str); |
125 EXPECT_EQ(expected_signature, signature->BodyText()); | 127 EXPECT_EQ(expected_signature, signature->BodyText()); |
126 | 128 |
127 // Generate response and verify that callback is called. | 129 // Generate response and verify that callback is called. |
128 EXPECT_CALL(callback_, OnResponse(true, kSupportId, | 130 EXPECT_CALL(callback_, OnResponse(true, kSupportId, |
129 base::TimeDelta::FromSeconds(300))); | 131 base::TimeDelta::FromSeconds(300))); |
130 | 132 |
131 scoped_ptr<XmlElement> response(new XmlElement(buzz::QN_IQ)); | 133 scoped_ptr<XmlElement> response(new XmlElement(buzz::QN_IQ)); |
132 response->AddAttr(QName("", "from"), kTestBotJid); | 134 response->AddAttr(QName("", "from"), kTestBotJid); |
133 response->AddAttr(QName("", "type"), "result"); | 135 response->AddAttr(QName("", "type"), "result"); |
134 response->AddAttr(QName("", "id"), kStanzaId); | 136 response->AddAttr(QName("", "id"), kStanzaId); |
(...skipping 19 matching lines...) Expand all Loading... |
154 while ((listener = it.GetNext()) != NULL) { | 156 while ((listener = it.GetNext()) != NULL) { |
155 if (listener->OnSignalStrategyIncomingStanza(response.get())) | 157 if (listener->OnSignalStrategyIncomingStanza(response.get())) |
156 consumed++; | 158 consumed++; |
157 } | 159 } |
158 EXPECT_EQ(1, consumed); | 160 EXPECT_EQ(1, consumed); |
159 | 161 |
160 message_loop_.RunUntilIdle(); | 162 message_loop_.RunUntilIdle(); |
161 } | 163 } |
162 | 164 |
163 } // namespace remoting | 165 } // namespace remoting |
OLD | NEW |