| OLD | NEW |
| 1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2013 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 "google_apis/gaia/fake_gaia.h" | 5 #include "google_apis/gaia/fake_gaia.h" |
| 6 | 6 |
| 7 #include <vector> | 7 #include <vector> |
| 8 | 8 |
| 9 #include "base/base_paths.h" | 9 #include "base/base_paths.h" |
| 10 #include "base/bind.h" | 10 #include "base/bind.h" |
| (...skipping 118 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 129 : expires_in(3600) {} | 129 : expires_in(3600) {} |
| 130 | 130 |
| 131 FakeGaia::AccessTokenInfo::~AccessTokenInfo() {} | 131 FakeGaia::AccessTokenInfo::~AccessTokenInfo() {} |
| 132 | 132 |
| 133 FakeGaia::MergeSessionParams::MergeSessionParams() { | 133 FakeGaia::MergeSessionParams::MergeSessionParams() { |
| 134 } | 134 } |
| 135 | 135 |
| 136 FakeGaia::MergeSessionParams::~MergeSessionParams() { | 136 FakeGaia::MergeSessionParams::~MergeSessionParams() { |
| 137 } | 137 } |
| 138 | 138 |
| 139 void FakeGaia::MergeSessionParams::Update(const MergeSessionParams& update) { |
| 140 // This lambda uses a pointer to data member to merge attributes. |
| 141 auto maybe_update_field = |
| 142 [this, &update](std::string MergeSessionParams::* field_ptr) { |
| 143 if (!(update.*field_ptr).empty()) |
| 144 this->*field_ptr = update.*field_ptr; |
| 145 }; |
| 146 |
| 147 maybe_update_field(&MergeSessionParams::auth_sid_cookie); |
| 148 maybe_update_field(&MergeSessionParams::auth_lsid_cookie); |
| 149 maybe_update_field(&MergeSessionParams::auth_code); |
| 150 maybe_update_field(&MergeSessionParams::refresh_token); |
| 151 maybe_update_field(&MergeSessionParams::access_token); |
| 152 maybe_update_field(&MergeSessionParams::gaia_uber_token); |
| 153 maybe_update_field(&MergeSessionParams::session_sid_cookie); |
| 154 maybe_update_field(&MergeSessionParams::session_lsid_cookie); |
| 155 maybe_update_field(&MergeSessionParams::email); |
| 156 } |
| 157 |
| 139 FakeGaia::FakeGaia() : issue_oauth_code_cookie_(false) { | 158 FakeGaia::FakeGaia() : issue_oauth_code_cookie_(false) { |
| 140 base::FilePath source_root_dir; | 159 base::FilePath source_root_dir; |
| 141 PathService::Get(base::DIR_SOURCE_ROOT, &source_root_dir); | 160 PathService::Get(base::DIR_SOURCE_ROOT, &source_root_dir); |
| 142 CHECK(base::ReadFileToString( | 161 CHECK(base::ReadFileToString( |
| 143 source_root_dir.Append(base::FilePath(kServiceLogin)), | 162 source_root_dir.Append(base::FilePath(kServiceLogin)), |
| 144 &service_login_response_)); | 163 &service_login_response_)); |
| 145 CHECK(base::ReadFileToString( | 164 CHECK(base::ReadFileToString( |
| 146 source_root_dir.Append(base::FilePath(kEmbeddedSetupChromeos)), | 165 source_root_dir.Append(base::FilePath(kEmbeddedSetupChromeos)), |
| 147 &embedded_setup_chromeos_response_)); | 166 &embedded_setup_chromeos_response_)); |
| 148 } | 167 } |
| (...skipping 15 matching lines...) Expand all Loading... |
| 164 params.session_lsid_cookie = kTestSessionLSIDCookie; | 183 params.session_lsid_cookie = kTestSessionLSIDCookie; |
| 165 params.email = email; | 184 params.email = email; |
| 166 SetMergeSessionParams(params); | 185 SetMergeSessionParams(params); |
| 167 } | 186 } |
| 168 | 187 |
| 169 void FakeGaia::SetMergeSessionParams( | 188 void FakeGaia::SetMergeSessionParams( |
| 170 const MergeSessionParams& params) { | 189 const MergeSessionParams& params) { |
| 171 merge_session_params_ = params; | 190 merge_session_params_ = params; |
| 172 } | 191 } |
| 173 | 192 |
| 193 void FakeGaia::UpdateMergeSessionParams(const MergeSessionParams& params) { |
| 194 merge_session_params_.Update(params); |
| 195 } |
| 196 |
| 174 void FakeGaia::MapEmailToGaiaId(const std::string& email, | 197 void FakeGaia::MapEmailToGaiaId(const std::string& email, |
| 175 const std::string& gaia_id) { | 198 const std::string& gaia_id) { |
| 176 DCHECK(!email.empty()); | 199 DCHECK(!email.empty()); |
| 177 DCHECK(!gaia_id.empty()); | 200 DCHECK(!gaia_id.empty()); |
| 178 email_to_gaia_id_map_[email] = gaia_id; | 201 email_to_gaia_id_map_[email] = gaia_id; |
| 179 } | 202 } |
| 180 | 203 |
| 181 std::string FakeGaia::GetGaiaIdOfEmail(const std::string& email) const { | 204 std::string FakeGaia::GetGaiaIdOfEmail(const std::string& email) const { |
| 182 DCHECK(!email.empty()); | 205 DCHECK(!email.empty()); |
| 183 auto it = email_to_gaia_id_map_.find(email); | 206 const auto it = email_to_gaia_id_map_.find(email); |
| 184 return it == email_to_gaia_id_map_.end() ? std::string(kDefaultGaiaId) : | 207 return it == email_to_gaia_id_map_.end() ? std::string(kDefaultGaiaId) : |
| 185 it->second; | 208 it->second; |
| 186 } | 209 } |
| 187 | 210 |
| 188 void FakeGaia::AddGoogleAccountsSigninHeader( | 211 void FakeGaia::AddGoogleAccountsSigninHeader( |
| 189 net::test_server::BasicHttpResponse* http_response, | 212 net::test_server::BasicHttpResponse* http_response, |
| 190 const std::string& email) const { | 213 const std::string& email) const { |
| 191 DCHECK(!email.empty()); | 214 DCHECK(!email.empty()); |
| 192 http_response->AddCustomHeader("google-accounts-signin", | 215 http_response->AddCustomHeader("google-accounts-signin", |
| 193 base::StringPrintf( | 216 base::StringPrintf( |
| (...skipping 105 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 299 // static | 322 // static |
| 300 bool FakeGaia::GetQueryParameter(const std::string& query, | 323 bool FakeGaia::GetQueryParameter(const std::string& query, |
| 301 const std::string& key, | 324 const std::string& key, |
| 302 std::string* value) { | 325 std::string* value) { |
| 303 // Name and scheme actually don't matter, but are required to get a valid URL | 326 // Name and scheme actually don't matter, but are required to get a valid URL |
| 304 // for parsing. | 327 // for parsing. |
| 305 GURL query_url("http://localhost?" + query); | 328 GURL query_url("http://localhost?" + query); |
| 306 return net::GetValueForKeyInQuery(query_url, key, value); | 329 return net::GetValueForKeyInQuery(query_url, key, value); |
| 307 } | 330 } |
| 308 | 331 |
| 332 std::string FakeGaia::GetDeviceIdByRefreshToken( |
| 333 const std::string& refresh_token) const { |
| 334 auto it = refresh_token_to_device_id_map_.find(refresh_token); |
| 335 return it != refresh_token_to_device_id_map_.end() ? it->second |
| 336 : std::string(); |
| 337 } |
| 338 |
| 339 void FakeGaia::SetRefreshTokenToDeviceIdMap( |
| 340 const RefreshTokenToDeviceIdMap& refresh_token_to_device_id_map) { |
| 341 refresh_token_to_device_id_map_ = refresh_token_to_device_id_map; |
| 342 } |
| 343 |
| 309 void FakeGaia::HandleMergeSession(const HttpRequest& request, | 344 void FakeGaia::HandleMergeSession(const HttpRequest& request, |
| 310 BasicHttpResponse* http_response) { | 345 BasicHttpResponse* http_response) { |
| 311 http_response->set_code(net::HTTP_UNAUTHORIZED); | 346 http_response->set_code(net::HTTP_UNAUTHORIZED); |
| 312 if (merge_session_params_.session_sid_cookie.empty() || | 347 if (merge_session_params_.session_sid_cookie.empty() || |
| 313 merge_session_params_.session_lsid_cookie.empty()) { | 348 merge_session_params_.session_lsid_cookie.empty()) { |
| 314 http_response->set_code(net::HTTP_BAD_REQUEST); | 349 http_response->set_code(net::HTTP_BAD_REQUEST); |
| 315 return; | 350 return; |
| 316 } | 351 } |
| 317 | 352 |
| 318 std::string uber_token; | 353 std::string uber_token; |
| (...skipping 276 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 595 | 630 |
| 596 if (grant_type == "authorization_code") { | 631 if (grant_type == "authorization_code") { |
| 597 std::string auth_code; | 632 std::string auth_code; |
| 598 if (!GetQueryParameter(request.content, "code", &auth_code) || | 633 if (!GetQueryParameter(request.content, "code", &auth_code) || |
| 599 auth_code != merge_session_params_.auth_code) { | 634 auth_code != merge_session_params_.auth_code) { |
| 600 http_response->set_code(net::HTTP_BAD_REQUEST); | 635 http_response->set_code(net::HTTP_BAD_REQUEST); |
| 601 LOG(ERROR) << "No 'code' param in /o/oauth2/token"; | 636 LOG(ERROR) << "No 'code' param in /o/oauth2/token"; |
| 602 return; | 637 return; |
| 603 } | 638 } |
| 604 | 639 |
| 640 std::string device_id; |
| 641 if (GetQueryParameter(request.content, "device_id", &device_id)) { |
| 642 std::string device_type; |
| 643 if (!GetQueryParameter(request.content, "device_type", &device_type)) { |
| 644 http_response->set_code(net::HTTP_BAD_REQUEST); |
| 645 LOG(ERROR) << "'device_type' should be set if 'device_id' is set."; |
| 646 return; |
| 647 } |
| 648 if (device_type != "chrome") { |
| 649 http_response->set_code(net::HTTP_BAD_REQUEST); |
| 650 LOG(ERROR) << "'device_type' is not 'chrome'."; |
| 651 return; |
| 652 } |
| 653 } |
| 654 |
| 605 base::DictionaryValue response_dict; | 655 base::DictionaryValue response_dict; |
| 606 response_dict.SetString("refresh_token", | 656 response_dict.SetString("refresh_token", |
| 607 merge_session_params_.refresh_token); | 657 merge_session_params_.refresh_token); |
| 658 if (!device_id.empty()) |
| 659 refresh_token_to_device_id_map_[merge_session_params_.refresh_token] = |
| 660 device_id; |
| 608 response_dict.SetString("access_token", | 661 response_dict.SetString("access_token", |
| 609 merge_session_params_.access_token); | 662 merge_session_params_.access_token); |
| 610 response_dict.SetInteger("expires_in", 3600); | 663 response_dict.SetInteger("expires_in", 3600); |
| 611 FormatJSONResponse(response_dict, http_response); | 664 FormatJSONResponse(response_dict, http_response); |
| 612 return; | 665 return; |
| 613 } | 666 } |
| 614 | 667 |
| 615 std::string scope; | 668 std::string scope; |
| 616 GetQueryParameter(request.content, "scope", &scope); | 669 GetQueryParameter(request.content, "scope", &scope); |
| 617 | 670 |
| (...skipping 94 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 712 if (token_info) { | 765 if (token_info) { |
| 713 base::DictionaryValue response_dict; | 766 base::DictionaryValue response_dict; |
| 714 response_dict.SetString("id", GetGaiaIdOfEmail(token_info->email)); | 767 response_dict.SetString("id", GetGaiaIdOfEmail(token_info->email)); |
| 715 response_dict.SetString("email", token_info->email); | 768 response_dict.SetString("email", token_info->email); |
| 716 response_dict.SetString("verified_email", token_info->email); | 769 response_dict.SetString("verified_email", token_info->email); |
| 717 FormatJSONResponse(response_dict, http_response); | 770 FormatJSONResponse(response_dict, http_response); |
| 718 } else { | 771 } else { |
| 719 http_response->set_code(net::HTTP_BAD_REQUEST); | 772 http_response->set_code(net::HTTP_BAD_REQUEST); |
| 720 } | 773 } |
| 721 } | 774 } |
| OLD | NEW |