OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "sync/internal_api/public/attachments/attachment_downloader_impl.h" | 5 #include "sync/internal_api/public/attachments/attachment_downloader_impl.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/memory/weak_ptr.h" | 8 #include "base/memory/weak_ptr.h" |
9 #include "base/message_loop/message_loop.h" | 9 #include "base/message_loop/message_loop.h" |
10 #include "base/run_loop.h" | 10 #include "base/run_loop.h" |
(...skipping 16 matching lines...) Expand all Loading... |
27 const char kAttachmentServerUrl[] = "http://attachments.com/"; | 27 const char kAttachmentServerUrl[] = "http://attachments.com/"; |
28 const char kAttachmentContent[] = "attachment.content"; | 28 const char kAttachmentContent[] = "attachment.content"; |
29 | 29 |
30 // MockOAuth2TokenService remembers last request for access token and verifies | 30 // MockOAuth2TokenService remembers last request for access token and verifies |
31 // that only one request is active at a time. | 31 // that only one request is active at a time. |
32 // Call RespondToAccessTokenRequest to respond to it. | 32 // Call RespondToAccessTokenRequest to respond to it. |
33 class MockOAuth2TokenService : public FakeOAuth2TokenService { | 33 class MockOAuth2TokenService : public FakeOAuth2TokenService { |
34 public: | 34 public: |
35 MockOAuth2TokenService() : num_invalidate_token_(0) {} | 35 MockOAuth2TokenService() : num_invalidate_token_(0) {} |
36 | 36 |
37 virtual ~MockOAuth2TokenService() {} | 37 ~MockOAuth2TokenService() override {} |
38 | 38 |
39 void RespondToAccessTokenRequest(GoogleServiceAuthError error); | 39 void RespondToAccessTokenRequest(GoogleServiceAuthError error); |
40 | 40 |
41 int num_invalidate_token() const { return num_invalidate_token_; } | 41 int num_invalidate_token() const { return num_invalidate_token_; } |
42 | 42 |
43 protected: | 43 protected: |
44 virtual void FetchOAuth2Token(RequestImpl* request, | 44 void FetchOAuth2Token(RequestImpl* request, |
45 const std::string& account_id, | 45 const std::string& account_id, |
46 net::URLRequestContextGetter* getter, | 46 net::URLRequestContextGetter* getter, |
47 const std::string& client_id, | 47 const std::string& client_id, |
48 const std::string& client_secret, | 48 const std::string& client_secret, |
49 const ScopeSet& scopes) override; | 49 const ScopeSet& scopes) override; |
50 | 50 |
51 virtual void InvalidateOAuth2Token(const std::string& account_id, | 51 void InvalidateOAuth2Token(const std::string& account_id, |
52 const std::string& client_id, | 52 const std::string& client_id, |
53 const ScopeSet& scopes, | 53 const ScopeSet& scopes, |
54 const std::string& access_token) override; | 54 const std::string& access_token) override; |
55 | 55 |
56 private: | 56 private: |
57 base::WeakPtr<RequestImpl> last_request_; | 57 base::WeakPtr<RequestImpl> last_request_; |
58 int num_invalidate_token_; | 58 int num_invalidate_token_; |
59 }; | 59 }; |
60 | 60 |
61 void MockOAuth2TokenService::RespondToAccessTokenRequest( | 61 void MockOAuth2TokenService::RespondToAccessTokenRequest( |
62 GoogleServiceAuthError error) { | 62 GoogleServiceAuthError error) { |
63 EXPECT_TRUE(last_request_ != NULL); | 63 EXPECT_TRUE(last_request_ != NULL); |
64 std::string access_token; | 64 std::string access_token; |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
96 ++num_invalidate_token_; | 96 ++num_invalidate_token_; |
97 } | 97 } |
98 | 98 |
99 class TokenServiceProvider | 99 class TokenServiceProvider |
100 : public OAuth2TokenServiceRequest::TokenServiceProvider, | 100 : public OAuth2TokenServiceRequest::TokenServiceProvider, |
101 base::NonThreadSafe { | 101 base::NonThreadSafe { |
102 public: | 102 public: |
103 TokenServiceProvider(OAuth2TokenService* token_service); | 103 TokenServiceProvider(OAuth2TokenService* token_service); |
104 | 104 |
105 // OAuth2TokenService::TokenServiceProvider implementation. | 105 // OAuth2TokenService::TokenServiceProvider implementation. |
106 virtual scoped_refptr<base::SingleThreadTaskRunner> | 106 scoped_refptr<base::SingleThreadTaskRunner> GetTokenServiceTaskRunner() |
107 GetTokenServiceTaskRunner() override; | 107 override; |
108 virtual OAuth2TokenService* GetTokenService() override; | 108 OAuth2TokenService* GetTokenService() override; |
109 | 109 |
110 private: | 110 private: |
111 virtual ~TokenServiceProvider(); | 111 ~TokenServiceProvider() override; |
112 | 112 |
113 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; | 113 scoped_refptr<base::SingleThreadTaskRunner> task_runner_; |
114 OAuth2TokenService* token_service_; | 114 OAuth2TokenService* token_service_; |
115 }; | 115 }; |
116 | 116 |
117 TokenServiceProvider::TokenServiceProvider(OAuth2TokenService* token_service) | 117 TokenServiceProvider::TokenServiceProvider(OAuth2TokenService* token_service) |
118 : task_runner_(base::ThreadTaskRunnerHandle::Get()), | 118 : task_runner_(base::ThreadTaskRunnerHandle::Get()), |
119 token_service_(token_service) { | 119 token_service_(token_service) { |
120 DCHECK(token_service_); | 120 DCHECK(token_service_); |
121 } | 121 } |
(...skipping 341 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
463 raw += "X-Goog-Hash: md5=rL0Y20zC+Fzt72VPzMSk2A==\n"; | 463 raw += "X-Goog-Hash: md5=rL0Y20zC+Fzt72VPzMSk2A==\n"; |
464 raw += "\n"; | 464 raw += "\n"; |
465 std::replace(raw.begin(), raw.end(), '\n', '\0'); | 465 std::replace(raw.begin(), raw.end(), '\n', '\0'); |
466 scoped_refptr<net::HttpResponseHeaders> headers( | 466 scoped_refptr<net::HttpResponseHeaders> headers( |
467 new net::HttpResponseHeaders(raw)); | 467 new net::HttpResponseHeaders(raw)); |
468 std::string extracted; | 468 std::string extracted; |
469 ASSERT_FALSE(AttachmentDownloaderImpl::ExtractCrc32c(*headers, &extracted)); | 469 ASSERT_FALSE(AttachmentDownloaderImpl::ExtractCrc32c(*headers, &extracted)); |
470 } | 470 } |
471 | 471 |
472 } // namespace syncer | 472 } // namespace syncer |
OLD | NEW |