| Index: chrome/browser/signin/oauth2_token_service_unittest.cc
|
| diff --git a/chrome/browser/signin/oauth2_token_service_unittest.cc b/chrome/browser/signin/oauth2_token_service_unittest.cc
|
| index 730c30365c6d8d4a32e7501e22b1c7e89ad6e326..2aed156553ed48c23a64d549d2033371ea51ff78 100644
|
| --- a/chrome/browser/signin/oauth2_token_service_unittest.cc
|
| +++ b/chrome/browser/signin/oauth2_token_service_unittest.cc
|
| @@ -29,18 +29,21 @@ class RetryingTestingOAuth2TokenServiceConsumer
|
| : public TestingOAuth2TokenServiceConsumer {
|
| public:
|
| RetryingTestingOAuth2TokenServiceConsumer(
|
| - OAuth2TokenService* oauth2_service)
|
| - : oauth2_service_(oauth2_service) {}
|
| + OAuth2TokenService* oauth2_service,
|
| + const std::string& account_id)
|
| + : oauth2_service_(oauth2_service),
|
| + account_id_(account_id) {}
|
| virtual ~RetryingTestingOAuth2TokenServiceConsumer() {}
|
|
|
| virtual void OnGetTokenFailure(const OAuth2TokenService::Request* request,
|
| const GoogleServiceAuthError& error) OVERRIDE {
|
| TestingOAuth2TokenServiceConsumer::OnGetTokenFailure(request, error);
|
| request_.reset(oauth2_service_->StartRequest(
|
| - std::set<std::string>(), this).release());
|
| + account_id_, OAuth2TokenService::ScopeSet(), this).release());
|
| }
|
|
|
| OAuth2TokenService* oauth2_service_;
|
| + std::string account_id_;
|
| scoped_ptr<OAuth2TokenService::Request> request_;
|
| };
|
|
|
| @@ -62,7 +65,10 @@ class TestOAuth2TokenService : public OAuth2TokenService {
|
| }
|
|
|
| protected:
|
| - virtual std::string GetRefreshToken() OVERRIDE { return refresh_token_; }
|
| + virtual std::string GetRefreshToken(const std::string& account_id) OVERRIDE {
|
| + // account_id explicitly ignored.
|
| + return refresh_token_;
|
| + }
|
|
|
| private:
|
| // OAuth2TokenService implementation.
|
| @@ -87,12 +93,14 @@ class OAuth2TokenServiceTest : public TokenServiceTestHarness {
|
| protected:
|
| net::TestURLFetcherFactory factory_;
|
| scoped_ptr<TestOAuth2TokenService> oauth2_service_;
|
| + std::string account_id_;
|
| TestingOAuth2TokenServiceConsumer consumer_;
|
| };
|
|
|
| TEST_F(OAuth2TokenServiceTest, NoOAuth2RefreshToken) {
|
| scoped_ptr<OAuth2TokenService::Request> request(
|
| - oauth2_service_->StartRequest(std::set<std::string>(), &consumer_));
|
| + oauth2_service_->StartRequest(account_id_, OAuth2TokenService::ScopeSet(),
|
| + &consumer_));
|
| base::RunLoop().RunUntilIdle();
|
|
|
| EXPECT_EQ(0, consumer_.number_of_successful_tokens_);
|
| @@ -102,7 +110,8 @@ TEST_F(OAuth2TokenServiceTest, NoOAuth2RefreshToken) {
|
| TEST_F(OAuth2TokenServiceTest, FailureShouldNotRetry) {
|
| oauth2_service_->set_refresh_token("refreshToken");
|
| scoped_ptr<OAuth2TokenService::Request> request(
|
| - oauth2_service_->StartRequest(std::set<std::string>(), &consumer_));
|
| + oauth2_service_->StartRequest(account_id_, OAuth2TokenService::ScopeSet(),
|
| + &consumer_));
|
| base::RunLoop().RunUntilIdle();
|
|
|
| EXPECT_EQ(0, consumer_.number_of_successful_tokens_);
|
| @@ -120,7 +129,8 @@ TEST_F(OAuth2TokenServiceTest, FailureShouldNotRetry) {
|
| TEST_F(OAuth2TokenServiceTest, SuccessWithoutCaching) {
|
| oauth2_service_->set_refresh_token("refreshToken");
|
| scoped_ptr<OAuth2TokenService::Request> request(
|
| - oauth2_service_->StartRequest(std::set<std::string>(), &consumer_));
|
| + oauth2_service_->StartRequest(account_id_, OAuth2TokenService::ScopeSet(),
|
| + &consumer_));
|
| base::RunLoop().RunUntilIdle();
|
|
|
| EXPECT_EQ(0, consumer_.number_of_successful_tokens_);
|
| @@ -136,20 +146,20 @@ TEST_F(OAuth2TokenServiceTest, SuccessWithoutCaching) {
|
| }
|
|
|
| TEST_F(OAuth2TokenServiceTest, SuccessWithCaching) {
|
| - std::set<std::string> scopes1;
|
| + OAuth2TokenService::ScopeSet scopes1;
|
| scopes1.insert("s1");
|
| scopes1.insert("s2");
|
| - std::set<std::string> scopes1_same;
|
| + OAuth2TokenService::ScopeSet scopes1_same;
|
| scopes1_same.insert("s2");
|
| scopes1_same.insert("s1");
|
| - std::set<std::string> scopes2;
|
| + OAuth2TokenService::ScopeSet scopes2;
|
| scopes2.insert("s3");
|
|
|
| oauth2_service_->set_refresh_token("refreshToken");
|
|
|
| // First request.
|
| scoped_ptr<OAuth2TokenService::Request> request(oauth2_service_->StartRequest(
|
| - scopes1, &consumer_));
|
| + account_id_, scopes1, &consumer_));
|
| base::RunLoop().RunUntilIdle();
|
|
|
| EXPECT_EQ(0, consumer_.number_of_successful_tokens_);
|
| @@ -166,7 +176,7 @@ TEST_F(OAuth2TokenServiceTest, SuccessWithCaching) {
|
| // Second request to the same set of scopes, should return the same token
|
| // without needing a network request.
|
| scoped_ptr<OAuth2TokenService::Request> request2(
|
| - oauth2_service_->StartRequest(scopes1_same, &consumer_));
|
| + oauth2_service_->StartRequest(account_id_, scopes1_same, &consumer_));
|
| base::RunLoop().RunUntilIdle();
|
|
|
| // No new network fetcher.
|
| @@ -177,7 +187,7 @@ TEST_F(OAuth2TokenServiceTest, SuccessWithCaching) {
|
|
|
| // Third request to a new set of scopes, should return another token.
|
| scoped_ptr<OAuth2TokenService::Request> request3(
|
| - oauth2_service_->StartRequest(scopes2, &consumer_));
|
| + oauth2_service_->StartRequest(account_id_, scopes2, &consumer_));
|
| base::RunLoop().RunUntilIdle();
|
| EXPECT_EQ(2, consumer_.number_of_successful_tokens_);
|
| EXPECT_EQ(0, consumer_.number_of_errors_);
|
| @@ -196,7 +206,7 @@ TEST_F(OAuth2TokenServiceTest, SuccessAndExpirationAndFailure) {
|
|
|
| // First request.
|
| scoped_ptr<OAuth2TokenService::Request> request(oauth2_service_->StartRequest(
|
| - std::set<std::string>(), &consumer_));
|
| + account_id_, OAuth2TokenService::ScopeSet(), &consumer_));
|
| base::RunLoop().RunUntilIdle();
|
| EXPECT_EQ(0, consumer_.number_of_successful_tokens_);
|
| EXPECT_EQ(0, consumer_.number_of_errors_);
|
| @@ -211,7 +221,8 @@ TEST_F(OAuth2TokenServiceTest, SuccessAndExpirationAndFailure) {
|
|
|
| // Second request must try to access the network as the token has expired.
|
| scoped_ptr<OAuth2TokenService::Request> request2(
|
| - oauth2_service_->StartRequest(std::set<std::string>(), &consumer_));
|
| + oauth2_service_->StartRequest(account_id_, OAuth2TokenService::ScopeSet(),
|
| + &consumer_));
|
| base::RunLoop().RunUntilIdle();
|
| EXPECT_EQ(1, consumer_.number_of_successful_tokens_);
|
| EXPECT_EQ(0, consumer_.number_of_errors_);
|
| @@ -231,7 +242,7 @@ TEST_F(OAuth2TokenServiceTest, SuccessAndExpirationAndSuccess) {
|
|
|
| // First request.
|
| scoped_ptr<OAuth2TokenService::Request> request(oauth2_service_->StartRequest(
|
| - std::set<std::string>(), &consumer_));
|
| + account_id_, OAuth2TokenService::ScopeSet(), &consumer_));
|
| base::RunLoop().RunUntilIdle();
|
| EXPECT_EQ(0, consumer_.number_of_successful_tokens_);
|
| EXPECT_EQ(0, consumer_.number_of_errors_);
|
| @@ -246,7 +257,8 @@ TEST_F(OAuth2TokenServiceTest, SuccessAndExpirationAndSuccess) {
|
|
|
| // Second request must try to access the network as the token has expired.
|
| scoped_ptr<OAuth2TokenService::Request> request2(
|
| - oauth2_service_->StartRequest(std::set<std::string>(), &consumer_));
|
| + oauth2_service_->StartRequest(account_id_, OAuth2TokenService::ScopeSet(),
|
| + &consumer_));
|
| base::RunLoop().RunUntilIdle();
|
| EXPECT_EQ(1, consumer_.number_of_successful_tokens_);
|
| EXPECT_EQ(0, consumer_.number_of_errors_);
|
| @@ -265,7 +277,7 @@ TEST_F(OAuth2TokenServiceTest, RequestDeletedBeforeCompletion) {
|
| oauth2_service_->set_refresh_token("refreshToken");
|
|
|
| scoped_ptr<OAuth2TokenService::Request> request(oauth2_service_->StartRequest(
|
| - std::set<std::string>(), &consumer_));
|
| + account_id_, OAuth2TokenService::ScopeSet(), &consumer_));
|
| base::RunLoop().RunUntilIdle();
|
| EXPECT_EQ(0, consumer_.number_of_successful_tokens_);
|
| EXPECT_EQ(0, consumer_.number_of_errors_);
|
| @@ -285,7 +297,7 @@ TEST_F(OAuth2TokenServiceTest, RequestDeletedAfterCompletion) {
|
| oauth2_service_->set_refresh_token("refreshToken");
|
|
|
| scoped_ptr<OAuth2TokenService::Request> request(oauth2_service_->StartRequest(
|
| - std::set<std::string>(), &consumer_));
|
| + account_id_, OAuth2TokenService::ScopeSet(), &consumer_));
|
| base::RunLoop().RunUntilIdle();
|
| net::TestURLFetcher* fetcher = factory_.GetFetcherByID(0);
|
| fetcher->set_response_code(net::HTTP_OK);
|
| @@ -306,10 +318,11 @@ TEST_F(OAuth2TokenServiceTest, MultipleRequestsForTheSameScopesWithOneDeleted) {
|
| oauth2_service_->set_refresh_token("refreshToken");
|
|
|
| scoped_ptr<OAuth2TokenService::Request> request(oauth2_service_->StartRequest(
|
| - std::set<std::string>(), &consumer_));
|
| + account_id_, OAuth2TokenService::ScopeSet(), &consumer_));
|
| base::RunLoop().RunUntilIdle();
|
| scoped_ptr<OAuth2TokenService::Request> request2(
|
| - oauth2_service_->StartRequest(std::set<std::string>(), &consumer_));
|
| + oauth2_service_->StartRequest(account_id_, OAuth2TokenService::ScopeSet(),
|
| + &consumer_));
|
| base::RunLoop().RunUntilIdle();
|
|
|
| request.reset();
|
| @@ -326,7 +339,7 @@ TEST_F(OAuth2TokenServiceTest, ClearedRefreshTokenFailsSubsequentRequests) {
|
| // We have a valid refresh token; the first request is successful.
|
| oauth2_service_->set_refresh_token("refreshToken");
|
| scoped_ptr<OAuth2TokenService::Request> request(oauth2_service_->StartRequest(
|
| - std::set<std::string>(), &consumer_));
|
| + account_id_, OAuth2TokenService::ScopeSet(), &consumer_));
|
| base::RunLoop().RunUntilIdle();
|
| net::TestURLFetcher* fetcher = factory_.GetFetcherByID(0);
|
| fetcher->set_response_code(net::HTTP_OK);
|
| @@ -338,7 +351,8 @@ TEST_F(OAuth2TokenServiceTest, ClearedRefreshTokenFailsSubsequentRequests) {
|
|
|
| // The refresh token is no longer available; subsequent requests fail.
|
| oauth2_service_->set_refresh_token("");
|
| - request = oauth2_service_->StartRequest(std::set<std::string>(), &consumer_);
|
| + request = oauth2_service_->StartRequest(account_id_,
|
| + OAuth2TokenService::ScopeSet(), &consumer_);
|
| base::RunLoop().RunUntilIdle();
|
| EXPECT_EQ(fetcher, factory_.GetFetcherByID(0));
|
| EXPECT_EQ(1, consumer_.number_of_successful_tokens_);
|
| @@ -348,12 +362,12 @@ TEST_F(OAuth2TokenServiceTest, ClearedRefreshTokenFailsSubsequentRequests) {
|
| TEST_F(OAuth2TokenServiceTest,
|
| ChangedRefreshTokenDoesNotAffectInFlightRequests) {
|
| oauth2_service_->set_refresh_token("first refreshToken");
|
| - std::set<std::string> scopes;
|
| + OAuth2TokenService::ScopeSet scopes;
|
| scopes.insert("s1");
|
| scopes.insert("s2");
|
|
|
| scoped_ptr<OAuth2TokenService::Request> request(oauth2_service_->StartRequest(
|
| - scopes, &consumer_));
|
| + account_id_, scopes, &consumer_));
|
| base::RunLoop().RunUntilIdle();
|
| net::TestURLFetcher* fetcher1 = factory_.GetFetcherByID(0);
|
|
|
| @@ -364,7 +378,7 @@ TEST_F(OAuth2TokenServiceTest,
|
| // while the 1st request is in flight is successful.
|
| TestingOAuth2TokenServiceConsumer consumer2;
|
| scoped_ptr<OAuth2TokenService::Request> request2(
|
| - oauth2_service_->StartRequest(scopes, &consumer2));
|
| + oauth2_service_->StartRequest(account_id_, scopes, &consumer2));
|
| base::RunLoop().RunUntilIdle();
|
|
|
| net::TestURLFetcher* fetcher2 = factory_.GetFetcherByID(0);
|
| @@ -386,7 +400,7 @@ TEST_F(OAuth2TokenServiceTest,
|
| TEST_F(OAuth2TokenServiceTest, ServiceShutDownBeforeFetchComplete) {
|
| oauth2_service_->set_refresh_token("refreshToken");
|
| scoped_ptr<OAuth2TokenService::Request> request(oauth2_service_->StartRequest(
|
| - std::set<std::string>(), &consumer_));
|
| + account_id_, OAuth2TokenService::ScopeSet(), &consumer_));
|
| base::RunLoop().RunUntilIdle();
|
| EXPECT_EQ(0, consumer_.number_of_successful_tokens_);
|
| EXPECT_EQ(0, consumer_.number_of_errors_);
|
| @@ -400,9 +414,10 @@ TEST_F(OAuth2TokenServiceTest, ServiceShutDownBeforeFetchComplete) {
|
|
|
| TEST_F(OAuth2TokenServiceTest, RetryingConsumer) {
|
| oauth2_service_->set_refresh_token("refreshToken");
|
| - RetryingTestingOAuth2TokenServiceConsumer consumer(oauth2_service_.get());
|
| + RetryingTestingOAuth2TokenServiceConsumer consumer(oauth2_service_.get(),
|
| + account_id_);
|
| scoped_ptr<OAuth2TokenService::Request> request(oauth2_service_->StartRequest(
|
| - std::set<std::string>(), &consumer));
|
| + account_id_, OAuth2TokenService::ScopeSet(), &consumer));
|
| base::RunLoop().RunUntilIdle();
|
| EXPECT_EQ(0, consumer.number_of_successful_tokens_);
|
| EXPECT_EQ(0, consumer.number_of_errors_);
|
| @@ -425,12 +440,12 @@ TEST_F(OAuth2TokenServiceTest, RetryingConsumer) {
|
| }
|
|
|
| TEST_F(OAuth2TokenServiceTest, InvalidateToken) {
|
| - std::set<std::string> scopes;
|
| + OAuth2TokenService::ScopeSet scopes;
|
| oauth2_service_->set_refresh_token("refreshToken");
|
|
|
| // First request.
|
| scoped_ptr<OAuth2TokenService::Request> request(
|
| - oauth2_service_->StartRequest(scopes, &consumer_));
|
| + oauth2_service_->StartRequest(account_id_, scopes, &consumer_));
|
| base::RunLoop().RunUntilIdle();
|
|
|
| EXPECT_EQ(0, consumer_.number_of_successful_tokens_);
|
| @@ -447,7 +462,7 @@ TEST_F(OAuth2TokenServiceTest, InvalidateToken) {
|
| // Second request, should return the same token without needing a network
|
| // request.
|
| scoped_ptr<OAuth2TokenService::Request> request2(
|
| - oauth2_service_->StartRequest(scopes, &consumer_));
|
| + oauth2_service_->StartRequest(account_id_, scopes, &consumer_));
|
| base::RunLoop().RunUntilIdle();
|
|
|
| // No new network fetcher.
|
| @@ -459,7 +474,7 @@ TEST_F(OAuth2TokenServiceTest, InvalidateToken) {
|
| // Invalidating the token should return a new token on the next request.
|
| oauth2_service_->InvalidateToken(scopes, consumer_.last_token_);
|
| scoped_ptr<OAuth2TokenService::Request> request3(
|
| - oauth2_service_->StartRequest(scopes, &consumer_));
|
| + oauth2_service_->StartRequest(account_id_, scopes, &consumer_));
|
| base::RunLoop().RunUntilIdle();
|
| EXPECT_EQ(2, consumer_.number_of_successful_tokens_);
|
| EXPECT_EQ(0, consumer_.number_of_errors_);
|
| @@ -476,11 +491,13 @@ TEST_F(OAuth2TokenServiceTest, InvalidateToken) {
|
| TEST_F(OAuth2TokenServiceTest, CancelAllRequests) {
|
| oauth2_service_->set_refresh_token("refreshToken");
|
| scoped_ptr<OAuth2TokenService::Request> request(
|
| - oauth2_service_->StartRequest(std::set<std::string>(), &consumer_));
|
| + oauth2_service_->StartRequest(account_id_, OAuth2TokenService::ScopeSet(),
|
| + &consumer_));
|
|
|
| oauth2_service_->set_refresh_token("refreshToken2");
|
| scoped_ptr<OAuth2TokenService::Request> request2(
|
| - oauth2_service_->StartRequest(std::set<std::string>(), &consumer_));
|
| + oauth2_service_->StartRequest(account_id_, OAuth2TokenService::ScopeSet(),
|
| + &consumer_));
|
|
|
| base::RunLoop().RunUntilIdle();
|
| EXPECT_EQ(0, consumer_.number_of_successful_tokens_);
|
| @@ -493,21 +510,22 @@ TEST_F(OAuth2TokenServiceTest, CancelAllRequests) {
|
| }
|
|
|
| TEST_F(OAuth2TokenServiceTest, CancelRequestsForToken) {
|
| - std::set<std::string> scope_set_1;
|
| + OAuth2TokenService::ScopeSet scope_set_1;
|
| scope_set_1.insert("scope1");
|
| scope_set_1.insert("scope2");
|
| - std::set<std::string> scope_set_2(scope_set_1.begin(), scope_set_1.end());
|
| + OAuth2TokenService::ScopeSet scope_set_2(scope_set_1.begin(),
|
| + scope_set_1.end());
|
| scope_set_2.insert("scope3");
|
|
|
| oauth2_service_->set_refresh_token("refreshToken");
|
| scoped_ptr<OAuth2TokenService::Request> request1(
|
| - oauth2_service_->StartRequest(scope_set_1, &consumer_));
|
| + oauth2_service_->StartRequest(account_id_, scope_set_1, &consumer_));
|
| scoped_ptr<OAuth2TokenService::Request> request2(
|
| - oauth2_service_->StartRequest(scope_set_2, &consumer_));
|
| + oauth2_service_->StartRequest(account_id_, scope_set_2, &consumer_));
|
|
|
| oauth2_service_->set_refresh_token("refreshToken2");
|
| scoped_ptr<OAuth2TokenService::Request> request3(
|
| - oauth2_service_->StartRequest(scope_set_1, &consumer_));
|
| + oauth2_service_->StartRequest(account_id_, scope_set_1, &consumer_));
|
|
|
| base::RunLoop().RunUntilIdle();
|
| EXPECT_EQ(0, consumer_.number_of_successful_tokens_);
|
|
|