| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 // |
| 5 // This file provides base classes used to implement operations for Google APIs. |
| 4 | 6 |
| 5 #ifndef CHROME_BROWSER_GOOGLE_APIS_BASE_OPERATIONS_H_ | 7 #ifndef CHROME_BROWSER_GOOGLE_APIS_BASE_OPERATIONS_H_ |
| 6 #define CHROME_BROWSER_GOOGLE_APIS_BASE_OPERATIONS_H_ | 8 #define CHROME_BROWSER_GOOGLE_APIS_BASE_OPERATIONS_H_ |
| 7 | 9 |
| 8 #include <string> | 10 #include <string> |
| 9 #include <vector> | 11 #include <vector> |
| 10 | 12 |
| 11 #include "base/callback.h" | 13 #include "base/callback.h" |
| 12 #include "base/memory/weak_ptr.h" | 14 #include "base/memory/weak_ptr.h" |
| 13 #include "chrome/browser/google_apis/gdata_errorcode.h" | 15 #include "chrome/browser/google_apis/gdata_errorcode.h" |
| 14 #include "chrome/browser/google_apis/operation_registry.h" | 16 #include "chrome/browser/google_apis/operation_registry.h" |
| 15 #include "google_apis/gaia/oauth2_access_token_consumer.h" | 17 #include "google_apis/gaia/oauth2_access_token_consumer.h" |
| 16 #include "googleurl/src/gurl.h" | 18 #include "googleurl/src/gurl.h" |
| 17 #include "net/url_request/url_fetcher.h" | 19 #include "net/url_request/url_fetcher.h" |
| 18 #include "net/url_request/url_fetcher_delegate.h" | 20 #include "net/url_request/url_fetcher_delegate.h" |
| 19 | 21 |
| 20 class OAuth2AccessTokenFetcher; | 22 class OAuth2AccessTokenFetcher; |
| 21 | 23 |
| 22 namespace base { | 24 namespace base { |
| 23 class Value; | 25 class Value; |
| 24 } // namespace base | 26 } // namespace base |
| 25 | 27 |
| 26 namespace google_apis { | 28 namespace google_apis { |
| 27 | 29 |
| 28 //======================= AuthenticatedOperationInterface ====================== | 30 //======================= AuthenticatedOperationInterface ====================== |
| 29 | 31 |
| 30 // An interface for implementing an operation used by DriveServiceInterface. | 32 // An interface class for implementing an operation which requires OAuth2 |
| 33 // authentication. |
| 31 class AuthenticatedOperationInterface { | 34 class AuthenticatedOperationInterface { |
| 32 public: | 35 public: |
| 33 // Callback to DriveServiceInterface upon for re-authentication. | 36 // Callback to DriveServiceInterface upon for re-authentication. |
| 34 typedef base::Callback<void(AuthenticatedOperationInterface* operation)> | 37 typedef base::Callback<void(AuthenticatedOperationInterface* operation)> |
| 35 ReAuthenticateCallback; | 38 ReAuthenticateCallback; |
| 36 | 39 |
| 37 virtual ~AuthenticatedOperationInterface() {} | 40 virtual ~AuthenticatedOperationInterface() {} |
| 38 | 41 |
| 39 // Starts the actual operation after obtaining an authentication token | 42 // Starts the actual operation after obtaining an authentication token |
| 40 // |auth_token|. User-Agent header will be set to |custom_user_agent| if | 43 // |auth_token|. User-Agent header will be set to |custom_user_agent| if |
| 41 // the value is not empty. | 44 // the value is not empty. |
| 42 virtual void Start(const std::string& auth_token, | 45 virtual void Start(const std::string& auth_token, |
| 43 const std::string& custom_user_agent) = 0; | 46 const std::string& custom_user_agent) = 0; |
| 44 | 47 |
| 45 // Invoked when the authentication failed with an error code |code|. | 48 // Invoked when the authentication failed with an error code |code|. |
| 46 virtual void OnAuthFailed(GDataErrorCode code) = 0; | 49 virtual void OnAuthFailed(GDataErrorCode code) = 0; |
| 47 | 50 |
| 48 // Sets the callback to DriveServiceInterface when the operation restarts due | 51 // Sets the callback to DriveServiceInterface when the operation restarts due |
| 49 // to an authentication failure. | 52 // to an authentication failure. |
| 53 // This function should be called before Start(). |
| 54 // TODO(satorux): Make it a parameter of Start(). crbug.com/163535. |
| 50 virtual void SetReAuthenticateCallback( | 55 virtual void SetReAuthenticateCallback( |
| 51 const ReAuthenticateCallback& callback) = 0; | 56 const ReAuthenticateCallback& callback) = 0; |
| 52 | 57 |
| 53 // Gets a weak pointer to this operation object. Since operations may be | 58 // Gets a weak pointer to this operation object. Since operations may be |
| 54 // deleted when it is canceled by user action, for posting asynchronous tasks | 59 // deleted when it is canceled by user action, for posting asynchronous tasks |
| 55 // on the authentication operation object, weak pointers have to be used. | 60 // on the authentication operation object, weak pointers have to be used. |
| 56 // TODO(kinaba): crbug.com/134814 use more clean life time management than | 61 // TODO(kinaba): crbug.com/134814 use more clean life time management than |
| 57 // using weak pointers, while deprecating OperationRegistry. | 62 // using weak pointers, while deprecating OperationRegistry. |
| 58 virtual base::WeakPtr<AuthenticatedOperationInterface> GetWeakPtr() = 0; | 63 virtual base::WeakPtr<AuthenticatedOperationInterface> GetWeakPtr() = 0; |
| 59 }; | 64 }; |
| 60 | 65 |
| 61 //============================ UrlFetchOperationBase =========================== | 66 //============================ UrlFetchOperationBase =========================== |
| 62 | 67 |
| 63 // Callback type for getting the content from URLFetcher::GetResponseAsString(). | 68 // Callback type for getting the content from URLFetcher::GetResponseAsString(). |
| 64 typedef base::Callback<void( | 69 typedef base::Callback<void( |
| 65 GDataErrorCode error, | 70 GDataErrorCode error, |
| 66 scoped_ptr<std::string> content)> GetContentCallback; | 71 scoped_ptr<std::string> content)> GetContentCallback; |
| 67 | 72 |
| 68 // Base class for operations that are fetching URLs. | 73 // Base class for operations that are fetching URLs. |
| 69 class UrlFetchOperationBase : public AuthenticatedOperationInterface, | 74 class UrlFetchOperationBase : public AuthenticatedOperationInterface, |
| 70 public OperationRegistry::Operation, | 75 public OperationRegistry::Operation, |
| 71 public net::URLFetcherDelegate { | 76 public net::URLFetcherDelegate { |
| 72 public: | 77 public: |
| 73 // Overridden from AuthenticatedOperationInterface. | 78 // AuthenticatedOperationInterface overrides. |
| 74 virtual void Start(const std::string& auth_token, | 79 virtual void Start(const std::string& auth_token, |
| 75 const std::string& custom_user_agent) OVERRIDE; | 80 const std::string& custom_user_agent) OVERRIDE; |
| 76 | |
| 77 // Overridden from AuthenticatedOperationInterface. | |
| 78 virtual void SetReAuthenticateCallback( | 81 virtual void SetReAuthenticateCallback( |
| 79 const ReAuthenticateCallback& callback) OVERRIDE; | 82 const ReAuthenticateCallback& callback) OVERRIDE; |
| 80 | |
| 81 // Overridden from AuthenticatedOperationInterface. | |
| 82 virtual base::WeakPtr<AuthenticatedOperationInterface> GetWeakPtr() OVERRIDE; | 83 virtual base::WeakPtr<AuthenticatedOperationInterface> GetWeakPtr() OVERRIDE; |
| 83 | 84 |
| 84 protected: | 85 protected: |
| 85 explicit UrlFetchOperationBase(OperationRegistry* registry); | 86 explicit UrlFetchOperationBase(OperationRegistry* registry); |
| 87 // Use this constructor when you need to implement operations that take a |
| 88 // drive file path (ex. for downloading and uploading). |
| 89 // TODO(satorux): Remove the drive file path hack. crbug.com/163296 |
| 86 UrlFetchOperationBase(OperationRegistry* registry, | 90 UrlFetchOperationBase(OperationRegistry* registry, |
| 87 OperationType type, | 91 OperationType type, |
| 88 const FilePath& path); | 92 const FilePath& drive_file_path); |
| 89 virtual ~UrlFetchOperationBase(); | 93 virtual ~UrlFetchOperationBase(); |
| 90 | 94 |
| 91 // Gets URL for the request. | 95 // Gets URL for the request. |
| 92 virtual GURL GetURL() const = 0; | 96 virtual GURL GetURL() const = 0; |
| 97 |
| 93 // Returns the request type. A derived class should override this method | 98 // Returns the request type. A derived class should override this method |
| 94 // for a request type other than HTTP GET. | 99 // for a request type other than HTTP GET. |
| 95 virtual net::URLFetcher::RequestType GetRequestType() const; | 100 virtual net::URLFetcher::RequestType GetRequestType() const; |
| 101 |
| 96 // Returns the extra HTTP headers for the request. A derived class should | 102 // Returns the extra HTTP headers for the request. A derived class should |
| 97 // override this method to specify any extra headers needed for the request. | 103 // override this method to specify any extra headers needed for the request. |
| 98 virtual std::vector<std::string> GetExtraRequestHeaders() const; | 104 virtual std::vector<std::string> GetExtraRequestHeaders() const; |
| 105 |
| 99 // Used by a derived class to add any content data to the request. | 106 // Used by a derived class to add any content data to the request. |
| 100 // Returns true if |upload_content_type| and |upload_content| are updated | 107 // Returns true if |upload_content_type| and |upload_content| are updated |
| 101 // with the content type and data for the request. | 108 // with the content type and data for the request. |
| 102 virtual bool GetContentData(std::string* upload_content_type, | 109 virtual bool GetContentData(std::string* upload_content_type, |
| 103 std::string* upload_content); | 110 std::string* upload_content); |
| 104 | 111 |
| 105 // Invoked by OnURLFetchComplete when the operation completes without an | 112 // Invoked by OnURLFetchComplete when the operation completes without an |
| 106 // authentication error. Must be implemented by a derived class. | 113 // authentication error. Must be implemented by a derived class. |
| 107 virtual void ProcessURLFetchResults(const net::URLFetcher* source) = 0; | 114 virtual void ProcessURLFetchResults(const net::URLFetcher* source) = 0; |
| 108 | 115 |
| 109 // Invoked when it needs to notify the status. Chunked operations that | 116 // Invoked when it needs to notify the status. Chunked operations that |
| 110 // constructs a logically single operation from multiple physical operations | 117 // constructs a logically single operation from multiple physical operations |
| 111 // should notify resume/suspend instead of start/finish. | 118 // should notify resume/suspend instead of start/finish. |
| 112 virtual void NotifyStartToOperationRegistry(); | 119 virtual void NotifyStartToOperationRegistry(); |
| 113 virtual void NotifySuccessToOperationRegistry(); | 120 virtual void NotifySuccessToOperationRegistry(); |
| 114 | 121 |
| 115 // Invoked by this base class upon an authentication error or cancel by | 122 // Invoked by this base class upon an authentication error or cancel by |
| 116 // an user operation. Must be implemented by a derived class. | 123 // an user operation. Must be implemented by a derived class. |
| 117 virtual void RunCallbackOnPrematureFailure(GDataErrorCode code) = 0; | 124 virtual void RunCallbackOnPrematureFailure(GDataErrorCode code) = 0; |
| 118 | 125 |
| 119 // Implement OperationRegistry::Operation | |
| 120 virtual void DoCancel() OVERRIDE; | |
| 121 | |
| 122 // Overridden from URLFetcherDelegate. | |
| 123 virtual void OnURLFetchComplete(const net::URLFetcher* source) OVERRIDE; | |
| 124 | |
| 125 // Overridden from AuthenticatedOperationInterface. | |
| 126 virtual void OnAuthFailed(GDataErrorCode code) OVERRIDE; | |
| 127 | |
| 128 // Invoked when ProcessURLFetchResults() is completed. | 126 // Invoked when ProcessURLFetchResults() is completed. |
| 129 void OnProcessURLFetchResultsComplete(bool result); | 127 void OnProcessURLFetchResultsComplete(bool result); |
| 130 | 128 |
| 131 // Returns an appropriate GDataErrorCode based on the HTTP response code and | 129 // Returns an appropriate GDataErrorCode based on the HTTP response code and |
| 132 // the status of the URLFetcher. | 130 // the status of the URLFetcher. |
| 133 GDataErrorCode GetErrorCode(const net::URLFetcher* source) const; | 131 static GDataErrorCode GetErrorCode(const net::URLFetcher* source); |
| 134 | 132 |
| 135 std::string GetResponseHeadersAsString( | 133 // The following members are used by DownloadFileOperation. |
| 136 const net::URLFetcher* url_fetcher); | 134 // TODO(satorux): Make them private. |
| 135 bool save_temp_file_; |
| 136 FilePath output_file_path_; |
| 137 |
| 138 private: |
| 139 // OperationRegistry::Operation overrides. |
| 140 virtual void DoCancel() OVERRIDE; |
| 141 |
| 142 // URLFetcherDelegate overrides. |
| 143 virtual void OnURLFetchComplete(const net::URLFetcher* source) OVERRIDE; |
| 144 |
| 145 // AuthenticatedOperationInterface overrides. |
| 146 virtual void OnAuthFailed(GDataErrorCode code) OVERRIDE; |
| 137 | 147 |
| 138 ReAuthenticateCallback re_authenticate_callback_; | 148 ReAuthenticateCallback re_authenticate_callback_; |
| 139 int re_authenticate_count_; | 149 int re_authenticate_count_; |
| 140 bool save_temp_file_; | |
| 141 FilePath output_file_path_; | |
| 142 scoped_ptr<net::URLFetcher> url_fetcher_; | 150 scoped_ptr<net::URLFetcher> url_fetcher_; |
| 143 bool started_; | 151 bool started_; |
| 144 | 152 |
| 145 // WeakPtrFactory bound to the UI thread. | 153 // WeakPtrFactory bound to the UI thread. |
| 146 // Note: This should remain the last member so it'll be destroyed and | 154 // Note: This should remain the last member so it'll be destroyed and |
| 147 // invalidate its weak pointers before any other members are destroyed. | 155 // invalidate its weak pointers before any other members are destroyed. |
| 148 base::WeakPtrFactory<UrlFetchOperationBase> weak_ptr_factory_; | 156 base::WeakPtrFactory<UrlFetchOperationBase> weak_ptr_factory_; |
| 149 }; | 157 }; |
| 150 | 158 |
| 151 //============================ EntryActionOperation ============================ | 159 //============================ EntryActionOperation ============================ |
| 152 | 160 |
| 153 // Callback type for Delete/Move DocumentServiceInterface calls. | 161 // Callback type for Delete/Move DocumentServiceInterface calls. |
| 154 typedef base::Callback<void(GDataErrorCode error)> EntryActionCallback; | 162 typedef base::Callback<void(GDataErrorCode error)> EntryActionCallback; |
| 155 | 163 |
| 156 // This class performs a simple action over a given entry (document/file). | 164 // This class performs a simple action over a given entry (document/file). |
| 157 // It is meant to be used for operations that return no JSON blobs. | 165 // It is meant to be used for operations that return no JSON blobs. |
| 158 class EntryActionOperation : public UrlFetchOperationBase { | 166 class EntryActionOperation : public UrlFetchOperationBase { |
| 159 public: | 167 public: |
| 160 EntryActionOperation(OperationRegistry* registry, | 168 EntryActionOperation(OperationRegistry* registry, |
| 161 const EntryActionCallback& callback); | 169 const EntryActionCallback& callback); |
| 162 virtual ~EntryActionOperation(); | 170 virtual ~EntryActionOperation(); |
| 163 | 171 |
| 164 protected: | 172 protected: |
| 165 // Overridden from UrlFetchOperationBase. | 173 // Overridden from UrlFetchOperationBase. |
| 166 virtual void ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE; | 174 virtual void ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE; |
| 167 virtual void RunCallbackOnPrematureFailure(GDataErrorCode code) OVERRIDE; | 175 virtual void RunCallbackOnPrematureFailure(GDataErrorCode code) OVERRIDE; |
| 168 | 176 |
| 169 private: | 177 private: |
| 170 EntryActionCallback callback_; | 178 const EntryActionCallback callback_; |
| 171 | 179 |
| 172 DISALLOW_COPY_AND_ASSIGN(EntryActionOperation); | 180 DISALLOW_COPY_AND_ASSIGN(EntryActionOperation); |
| 173 }; | 181 }; |
| 174 | 182 |
| 175 //============================== GetDataOperation ============================== | 183 //============================== GetDataOperation ============================== |
| 176 | 184 |
| 177 // Callback type for DocumentServiceInterface::GetDocuments. | 185 // Callback type for DocumentServiceInterface::GetDocuments. |
| 178 // Note: feed_data argument should be passed using base::Passed(&feed_data), not | 186 // Note: feed_data argument should be passed using base::Passed(&feed_data), not |
| 179 // feed_data.Pass(). | 187 // feed_data.Pass(). |
| 180 typedef base::Callback<void(GDataErrorCode error, | 188 typedef base::Callback<void(GDataErrorCode error, |
| 181 scoped_ptr<base::Value> feed_data)> GetDataCallback; | 189 scoped_ptr<base::Value> feed_data)> GetDataCallback; |
| 182 | 190 |
| 183 // This class performs the operation for fetching and parsing JSON data content. | 191 // This class performs the operation for fetching and converting the fetched |
| 192 // content into a base::Value. |
| 184 class GetDataOperation : public UrlFetchOperationBase { | 193 class GetDataOperation : public UrlFetchOperationBase { |
| 185 public: | 194 public: |
| 186 GetDataOperation(OperationRegistry* registry, | 195 GetDataOperation(OperationRegistry* registry, |
| 187 const GetDataCallback& callback); | 196 const GetDataCallback& callback); |
| 188 virtual ~GetDataOperation(); | 197 virtual ~GetDataOperation(); |
| 189 | 198 |
| 190 // Parse GData JSON response. | 199 // Parses JSON response. A derived class should override this function if |
| 200 // the input data is not JSON (ex. XML). |
| 191 virtual void ParseResponse(GDataErrorCode fetch_error_code, | 201 virtual void ParseResponse(GDataErrorCode fetch_error_code, |
| 192 const std::string& data); | 202 const std::string& data); |
| 193 | 203 |
| 194 protected: | 204 // UrlFetchOperationBase overrides. |
| 195 // Overridden from UrlFetchOperationBase. | |
| 196 virtual void ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE; | 205 virtual void ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE; |
| 197 virtual void RunCallbackOnPrematureFailure( | 206 |
| 198 GDataErrorCode fetch_error_code) OVERRIDE; | 207 // Runs |callback_| with the given parameters, if |callback_| is not null. |
| 208 // TODO(satorux): Remove this by making |callback_| mandatory. |
| 199 void RunCallback(GDataErrorCode fetch_error_code, | 209 void RunCallback(GDataErrorCode fetch_error_code, |
| 200 scoped_ptr<base::Value> value); | 210 scoped_ptr<base::Value> value); |
| 201 | 211 |
| 202 private: | 212 private: |
| 213 // UrlFetchOperationBase overrides. |
| 214 virtual void RunCallbackOnPrematureFailure( |
| 215 GDataErrorCode fetch_error_code) OVERRIDE; |
| 216 |
| 203 // Called when ParseJsonOnBlockingPool() is completed. | 217 // Called when ParseJsonOnBlockingPool() is completed. |
| 204 void OnDataParsed(google_apis::GDataErrorCode fetch_error_code, | 218 void OnDataParsed(google_apis::GDataErrorCode fetch_error_code, |
| 205 scoped_ptr<base::Value> value); | 219 scoped_ptr<base::Value> value); |
| 206 | 220 |
| 207 GetDataCallback callback_; | 221 const GetDataCallback callback_; |
| 208 | 222 |
| 209 // Note: This should remain the last member so it'll be destroyed and | 223 // Note: This should remain the last member so it'll be destroyed and |
| 210 // invalidate its weak pointers before any other members are destroyed. | 224 // invalidate its weak pointers before any other members are destroyed. |
| 211 base::WeakPtrFactory<GetDataOperation> weak_ptr_factory_; | 225 base::WeakPtrFactory<GetDataOperation> weak_ptr_factory_; |
| 212 DISALLOW_COPY_AND_ASSIGN(GetDataOperation); | 226 DISALLOW_COPY_AND_ASSIGN(GetDataOperation); |
| 213 }; | 227 }; |
| 214 | 228 |
| 215 } // namespace google_apis | 229 } // namespace google_apis |
| 216 | 230 |
| 217 #endif // CHROME_BROWSER_GOOGLE_APIS_BASE_OPERATIONS_H_ | 231 #endif // CHROME_BROWSER_GOOGLE_APIS_BASE_OPERATIONS_H_ |
| OLD | NEW |