OLD | NEW |
| (Empty) |
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 | |
3 // found in the LICENSE file. | |
4 | |
5 #include "chrome/browser/interests/interests_fetcher.h" | |
6 | |
7 #include "base/bind.h" | |
8 #include "base/bind_helpers.h" | |
9 #include "base/command_line.h" | |
10 #include "base/memory/ref_counted.h" | |
11 #include "base/message_loop/message_loop.h" | |
12 #include "base/threading/thread_task_runner_handle.h" | |
13 #include "chrome/common/chrome_switches.h" | |
14 #include "components/signin/core/browser/fake_profile_oauth2_token_service.h" | |
15 #include "net/base/net_errors.h" | |
16 #include "net/http/http_status_code.h" | |
17 #include "net/url_request/test_url_fetcher_factory.h" | |
18 #include "net/url_request/url_request_status.h" | |
19 #include "net/url_request/url_request_test_util.h" | |
20 #include "testing/gmock/include/gmock/gmock-generated-function-mockers.h" | |
21 #include "testing/gmock/include/gmock/gmock-matchers.h" | |
22 #include "testing/gmock/include/gmock/gmock-more-matchers.h" | |
23 #include "testing/gmock/include/gmock/gmock-spec-builders.h" | |
24 #include "testing/gtest/include/gtest/gtest.h" | |
25 | |
26 using testing::IsEmpty; | |
27 using testing::Not; | |
28 | |
29 namespace { | |
30 | |
31 const int kInterestsFetcherURLFetcherID = 0; | |
32 const char kInterestsURL[] = "http://www.fake.com"; | |
33 const char kEmptyResponse[] = | |
34 "{\n" | |
35 " \"interests\": []\n" | |
36 "}\n"; | |
37 const char kSuccessfulResponse[] = | |
38 "{\n" | |
39 " \"interests\": [\n" | |
40 " {\n" | |
41 " \"name\": \"Google\",\n" | |
42 " \"imageUrl\": \"https://fake.com/fake.png\",\n" | |
43 " \"relevance\": 0.9\n" | |
44 " },\n" | |
45 " {\n" | |
46 " \"name\": \"Google Chrome\",\n" | |
47 " \"imageUrl\": \"https://fake.com/fake.png\",\n" | |
48 " \"relevance\": 0.98\n" | |
49 " }\n" | |
50 " ]\n" | |
51 "}\n"; | |
52 const char kAccountId[] = "account@gmail.com"; | |
53 | |
54 std::vector<InterestsFetcher::Interest> GetExpectedEmptyResponse() { | |
55 return std::vector<InterestsFetcher::Interest>(); | |
56 } | |
57 | |
58 std::vector<InterestsFetcher::Interest> GetExpectedSuccessfulResponse() { | |
59 std::vector<InterestsFetcher::Interest> res; | |
60 res.push_back(InterestsFetcher::Interest{ | |
61 "Google", GURL("https://fake.com/fake.png"), 0.9}); | |
62 res.push_back(InterestsFetcher::Interest{ | |
63 "Google Chrome", GURL("https://fake.com/fake.png"), 0.98}); | |
64 return res; | |
65 } | |
66 } // namespace | |
67 | |
68 class InterestsFetcherTest : public testing::Test { | |
69 public: | |
70 InterestsFetcherTest() | |
71 : request_context_(new net::TestURLRequestContextGetter( | |
72 base::ThreadTaskRunnerHandle::Get())), | |
73 url_fetcher_factory_(new net::TestURLFetcherFactory()) { | |
74 token_service_.UpdateCredentials(kAccountId, "refresh_token"); | |
75 | |
76 base::CommandLine* command_line = base::CommandLine::ForCurrentProcess(); | |
77 | |
78 command_line->AppendSwitchASCII(switches::kInterestsURL, kInterestsURL); | |
79 } | |
80 | |
81 MOCK_METHOD0(OnSuccessfulResponse, void()); | |
82 MOCK_METHOD0(OnEmptyResponse, void()); | |
83 MOCK_METHOD0(OnFailedResponse, void()); | |
84 | |
85 void OnReceivedInterests( | |
86 std::unique_ptr<std::vector<InterestsFetcher::Interest>> interests) { | |
87 if (!interests) { | |
88 OnFailedResponse(); | |
89 return; | |
90 } | |
91 | |
92 if (*interests == GetExpectedEmptyResponse()) | |
93 OnEmptyResponse(); | |
94 else if (*interests == GetExpectedSuccessfulResponse()) | |
95 OnSuccessfulResponse(); | |
96 else | |
97 FAIL() << "Unexpected interests response."; | |
98 } | |
99 | |
100 protected: | |
101 void RequestInterests() { | |
102 request_.reset(new InterestsFetcher(&token_service_, | |
103 kAccountId, | |
104 request_context_.get())); | |
105 | |
106 request_->FetchInterests(base::Bind( | |
107 &InterestsFetcherTest::OnReceivedInterests, base::Unretained(this))); | |
108 } | |
109 | |
110 net::TestURLFetcher* GetURLFetcher() { | |
111 net::TestURLFetcher* url_fetcher = | |
112 url_fetcher_factory_->GetFetcherByID(kInterestsFetcherURLFetcherID); | |
113 EXPECT_TRUE(url_fetcher); | |
114 return url_fetcher; | |
115 } | |
116 | |
117 void IssueAccessTokenErrors() { | |
118 token_service_.IssueErrorForAllPendingRequestsForAccount( | |
119 kAccountId, GoogleServiceAuthError::FromServiceError("Error!")); | |
120 } | |
121 | |
122 void IssueAccessTokens() { | |
123 token_service_.IssueAllTokensForAccount( | |
124 kAccountId, "access_token", | |
125 base::Time::Now() + base::TimeDelta::FromHours(1)); | |
126 } | |
127 | |
128 void SendResponse(net::Error error, | |
129 int response_code, | |
130 const std::string& response) { | |
131 net::TestURLFetcher* url_fetcher = GetURLFetcher(); | |
132 url_fetcher->set_status(net::URLRequestStatus::FromError(error)); | |
133 url_fetcher->set_response_code(response_code); | |
134 url_fetcher->SetResponseString(response); | |
135 url_fetcher->delegate()->OnURLFetchComplete(url_fetcher); | |
136 } | |
137 | |
138 void SendValidResponse(const std::string& response) { | |
139 SendResponse(net::OK, net::HTTP_OK, response); | |
140 } | |
141 | |
142 void SendFailedResponse() { | |
143 SendResponse(net::ERR_ABORTED, 0, std::string()); | |
144 } | |
145 | |
146 void SendAuthorizationError() { | |
147 SendResponse(net::OK, net::HTTP_UNAUTHORIZED, std::string()); | |
148 } | |
149 | |
150 base::MessageLoop message_loop_; | |
151 FakeProfileOAuth2TokenService token_service_; | |
152 scoped_refptr<net::TestURLRequestContextGetter> request_context_; | |
153 std::unique_ptr<net::TestURLFetcherFactory> url_fetcher_factory_; | |
154 std::unique_ptr<InterestsFetcher> request_; | |
155 }; | |
156 | |
157 TEST_F(InterestsFetcherTest, EmptyResponse) { | |
158 RequestInterests(); | |
159 EXPECT_CALL(*this, OnEmptyResponse()); | |
160 IssueAccessTokens(); | |
161 SendValidResponse(kEmptyResponse); | |
162 } | |
163 | |
164 TEST_F(InterestsFetcherTest, SuccessfullResponse) { | |
165 RequestInterests(); | |
166 EXPECT_CALL(*this, OnSuccessfulResponse()); | |
167 IssueAccessTokens(); | |
168 SendValidResponse(kSuccessfulResponse); | |
169 } | |
170 | |
171 TEST_F(InterestsFetcherTest, FailedResponse) { | |
172 RequestInterests(); | |
173 EXPECT_CALL(*this, OnFailedResponse()); | |
174 IssueAccessTokens(); | |
175 SendFailedResponse(); | |
176 } | |
177 | |
178 TEST_F(InterestsFetcherTest, FailedOAuthRequest) { | |
179 RequestInterests(); | |
180 EXPECT_CALL(*this, OnFailedResponse()); | |
181 IssueAccessTokenErrors(); | |
182 } | |
183 | |
184 TEST_F(InterestsFetcherTest, RetryOnAuthorizationError) { | |
185 RequestInterests(); | |
186 | |
187 EXPECT_CALL(*this, OnEmptyResponse()).Times(0); | |
188 IssueAccessTokens(); | |
189 SendAuthorizationError(); | |
190 | |
191 EXPECT_CALL(*this, OnEmptyResponse()); | |
192 IssueAccessTokens(); | |
193 SendValidResponse(kEmptyResponse); | |
194 } | |
195 | |
196 TEST_F(InterestsFetcherTest, RetryOnlyOnceOnAuthorizationError) { | |
197 RequestInterests(); | |
198 | |
199 EXPECT_CALL(*this, OnEmptyResponse()).Times(0); | |
200 IssueAccessTokens(); | |
201 SendAuthorizationError(); | |
202 | |
203 EXPECT_CALL(*this, OnFailedResponse()); | |
204 IssueAccessTokens(); | |
205 SendAuthorizationError(); | |
206 } | |
OLD | NEW |