OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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/gcd_state_updater.h" | 5 #include "remoting/host/gcd_state_updater.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <utility> |
8 #include <vector> | 9 #include <vector> |
9 | 10 |
10 #include "base/strings/stringize_macros.h" | 11 #include "base/strings/stringize_macros.h" |
11 #include "base/test/simple_test_clock.h" | 12 #include "base/test/simple_test_clock.h" |
12 #include "base/test/test_mock_time_task_runner.h" | 13 #include "base/test/test_mock_time_task_runner.h" |
13 #include "base/thread_task_runner_handle.h" | 14 #include "base/thread_task_runner_handle.h" |
14 #include "net/url_request/test_url_fetcher_factory.h" | 15 #include "net/url_request/test_url_fetcher_factory.h" |
15 #include "remoting/base/constants.h" | 16 #include "remoting/base/constants.h" |
16 #include "remoting/host/fake_oauth_token_getter.h" | 17 #include "remoting/host/fake_oauth_token_getter.h" |
17 #include "remoting/host/gcd_rest_client.h" | 18 #include "remoting/host/gcd_rest_client.h" |
(...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
55 scoped_ptr<GcdRestClient> rest_client_; | 56 scoped_ptr<GcdRestClient> rest_client_; |
56 FakeSignalStrategy signal_strategy_; | 57 FakeSignalStrategy signal_strategy_; |
57 int on_success_count_ = 0; | 58 int on_success_count_ = 0; |
58 int on_host_id_error_count_ = 0; | 59 int on_host_id_error_count_ = 0; |
59 }; | 60 }; |
60 | 61 |
61 TEST_F(GcdStateUpdaterTest, Success) { | 62 TEST_F(GcdStateUpdaterTest, Success) { |
62 scoped_ptr<GcdStateUpdater> updater(new GcdStateUpdater( | 63 scoped_ptr<GcdStateUpdater> updater(new GcdStateUpdater( |
63 base::Bind(&GcdStateUpdaterTest::OnSuccess, base::Unretained(this)), | 64 base::Bind(&GcdStateUpdaterTest::OnSuccess, base::Unretained(this)), |
64 base::Bind(&GcdStateUpdaterTest::OnHostIdError, base::Unretained(this)), | 65 base::Bind(&GcdStateUpdaterTest::OnHostIdError, base::Unretained(this)), |
65 &signal_strategy_, rest_client_.Pass())); | 66 &signal_strategy_, std::move(rest_client_))); |
66 | 67 |
67 signal_strategy_.Connect(); | 68 signal_strategy_.Connect(); |
68 task_runner_->RunUntilIdle(); | 69 task_runner_->RunUntilIdle(); |
69 net::TestURLFetcher* fetcher = url_fetcher_factory_.GetFetcherByID(0); | 70 net::TestURLFetcher* fetcher = url_fetcher_factory_.GetFetcherByID(0); |
70 ASSERT_TRUE(fetcher); | 71 ASSERT_TRUE(fetcher); |
71 EXPECT_EQ("{\"patches\":[{\"patch\":{" | 72 EXPECT_EQ("{\"patches\":[{\"patch\":{" |
72 "\"base\":{\"_hostVersion\":\"" STRINGIZE(VERSION) "\"," | 73 "\"base\":{\"_hostVersion\":\"" STRINGIZE(VERSION) "\"," |
73 "\"_jabberId\":\"local_jid\"}}," | 74 "\"_jabberId\":\"local_jid\"}}," |
74 "\"timeMs\":0.0}],\"requestTimeMs\":0.0}", | 75 "\"timeMs\":0.0}],\"requestTimeMs\":0.0}", |
75 fetcher->upload_data()); | 76 fetcher->upload_data()); |
76 fetcher->set_response_code(200); | 77 fetcher->set_response_code(200); |
77 fetcher->delegate()->OnURLFetchComplete(fetcher); | 78 fetcher->delegate()->OnURLFetchComplete(fetcher); |
78 EXPECT_EQ(1, on_success_count_); | 79 EXPECT_EQ(1, on_success_count_); |
79 | 80 |
80 updater.reset(); | 81 updater.reset(); |
81 | 82 |
82 EXPECT_EQ(0, on_host_id_error_count_); | 83 EXPECT_EQ(0, on_host_id_error_count_); |
83 } | 84 } |
84 | 85 |
85 TEST_F(GcdStateUpdaterTest, QueuedRequests) { | 86 TEST_F(GcdStateUpdaterTest, QueuedRequests) { |
86 scoped_ptr<GcdStateUpdater> updater(new GcdStateUpdater( | 87 scoped_ptr<GcdStateUpdater> updater(new GcdStateUpdater( |
87 base::Bind(&GcdStateUpdaterTest::OnSuccess, base::Unretained(this)), | 88 base::Bind(&GcdStateUpdaterTest::OnSuccess, base::Unretained(this)), |
88 base::Bind(&GcdStateUpdaterTest::OnHostIdError, base::Unretained(this)), | 89 base::Bind(&GcdStateUpdaterTest::OnHostIdError, base::Unretained(this)), |
89 &signal_strategy_, rest_client_.Pass())); | 90 &signal_strategy_, std::move(rest_client_))); |
90 | 91 |
91 // Connect, then re-connect with a different JID while the status | 92 // Connect, then re-connect with a different JID while the status |
92 // update for the first connection is pending. | 93 // update for the first connection is pending. |
93 signal_strategy_.Connect(); | 94 signal_strategy_.Connect(); |
94 task_runner_->RunUntilIdle(); | 95 task_runner_->RunUntilIdle(); |
95 signal_strategy_.Disconnect(); | 96 signal_strategy_.Disconnect(); |
96 task_runner_->RunUntilIdle(); | 97 task_runner_->RunUntilIdle(); |
97 signal_strategy_.SetLocalJid("local_jid2"); | 98 signal_strategy_.SetLocalJid("local_jid2"); |
98 signal_strategy_.Connect(); | 99 signal_strategy_.Connect(); |
99 task_runner_->RunUntilIdle(); | 100 task_runner_->RunUntilIdle(); |
(...skipping 23 matching lines...) Expand all Loading... |
123 | 124 |
124 updater.reset(); | 125 updater.reset(); |
125 | 126 |
126 EXPECT_EQ(0, on_host_id_error_count_); | 127 EXPECT_EQ(0, on_host_id_error_count_); |
127 } | 128 } |
128 | 129 |
129 TEST_F(GcdStateUpdaterTest, Retry) { | 130 TEST_F(GcdStateUpdaterTest, Retry) { |
130 scoped_ptr<GcdStateUpdater> updater(new GcdStateUpdater( | 131 scoped_ptr<GcdStateUpdater> updater(new GcdStateUpdater( |
131 base::Bind(&GcdStateUpdaterTest::OnSuccess, base::Unretained(this)), | 132 base::Bind(&GcdStateUpdaterTest::OnSuccess, base::Unretained(this)), |
132 base::Bind(&GcdStateUpdaterTest::OnHostIdError, base::Unretained(this)), | 133 base::Bind(&GcdStateUpdaterTest::OnHostIdError, base::Unretained(this)), |
133 &signal_strategy_, rest_client_.Pass())); | 134 &signal_strategy_, std::move(rest_client_))); |
134 | 135 |
135 signal_strategy_.Connect(); | 136 signal_strategy_.Connect(); |
136 task_runner_->RunUntilIdle(); | 137 task_runner_->RunUntilIdle(); |
137 net::TestURLFetcher* fetcher = url_fetcher_factory_.GetFetcherByID(0); | 138 net::TestURLFetcher* fetcher = url_fetcher_factory_.GetFetcherByID(0); |
138 ASSERT_TRUE(fetcher); | 139 ASSERT_TRUE(fetcher); |
139 fetcher->set_response_code(0); | 140 fetcher->set_response_code(0); |
140 fetcher->delegate()->OnURLFetchComplete(fetcher); | 141 fetcher->delegate()->OnURLFetchComplete(fetcher); |
141 task_runner_->FastForwardBy(base::TimeDelta::FromSeconds(1)); | 142 task_runner_->FastForwardBy(base::TimeDelta::FromSeconds(1)); |
142 EXPECT_EQ(1.0, clock_->Now().ToDoubleT()); | 143 EXPECT_EQ(1.0, clock_->Now().ToDoubleT()); |
143 fetcher = url_fetcher_factory_.GetFetcherByID(0); | 144 fetcher = url_fetcher_factory_.GetFetcherByID(0); |
144 ASSERT_TRUE(fetcher); | 145 ASSERT_TRUE(fetcher); |
145 fetcher->set_response_code(200); | 146 fetcher->set_response_code(200); |
146 fetcher->delegate()->OnURLFetchComplete(fetcher); | 147 fetcher->delegate()->OnURLFetchComplete(fetcher); |
147 EXPECT_EQ(1, on_success_count_); | 148 EXPECT_EQ(1, on_success_count_); |
148 | 149 |
149 updater.reset(); | 150 updater.reset(); |
150 | 151 |
151 EXPECT_EQ(0, on_host_id_error_count_); | 152 EXPECT_EQ(0, on_host_id_error_count_); |
152 } | 153 } |
153 | 154 |
154 TEST_F(GcdStateUpdaterTest, UnknownHost) { | 155 TEST_F(GcdStateUpdaterTest, UnknownHost) { |
155 scoped_ptr<GcdStateUpdater> updater(new GcdStateUpdater( | 156 scoped_ptr<GcdStateUpdater> updater(new GcdStateUpdater( |
156 base::Bind(&GcdStateUpdaterTest::OnSuccess, base::Unretained(this)), | 157 base::Bind(&GcdStateUpdaterTest::OnSuccess, base::Unretained(this)), |
157 base::Bind(&GcdStateUpdaterTest::OnHostIdError, base::Unretained(this)), | 158 base::Bind(&GcdStateUpdaterTest::OnHostIdError, base::Unretained(this)), |
158 &signal_strategy_, rest_client_.Pass())); | 159 &signal_strategy_, std::move(rest_client_))); |
159 | 160 |
160 signal_strategy_.Connect(); | 161 signal_strategy_.Connect(); |
161 task_runner_->RunUntilIdle(); | 162 task_runner_->RunUntilIdle(); |
162 net::TestURLFetcher* fetcher = url_fetcher_factory_.GetFetcherByID(0); | 163 net::TestURLFetcher* fetcher = url_fetcher_factory_.GetFetcherByID(0); |
163 ASSERT_TRUE(fetcher); | 164 ASSERT_TRUE(fetcher); |
164 fetcher->set_response_code(404); | 165 fetcher->set_response_code(404); |
165 fetcher->delegate()->OnURLFetchComplete(fetcher); | 166 fetcher->delegate()->OnURLFetchComplete(fetcher); |
166 EXPECT_EQ(0, on_success_count_); | 167 EXPECT_EQ(0, on_success_count_); |
167 EXPECT_EQ(1, on_host_id_error_count_); | 168 EXPECT_EQ(1, on_host_id_error_count_); |
168 } | 169 } |
169 | 170 |
170 } // namespace remoting | 171 } // namespace remoting |
OLD | NEW |