| 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 // | 4 // |
| 5 // This file provides base classes used to issue HTTP requests for Google | 5 // This file provides base classes used to issue HTTP requests for Google |
| 6 // APIs. | 6 // APIs. |
| 7 | 7 |
| 8 #ifndef GOOGLE_APIS_DRIVE_BASE_REQUESTS_H_ | 8 #ifndef GOOGLE_APIS_DRIVE_BASE_REQUESTS_H_ |
| 9 #define GOOGLE_APIS_DRIVE_BASE_REQUESTS_H_ | 9 #define GOOGLE_APIS_DRIVE_BASE_REQUESTS_H_ |
| 10 | 10 |
| (...skipping 11 matching lines...) Expand all Loading... |
| 22 #include "url/gurl.h" | 22 #include "url/gurl.h" |
| 23 | 23 |
| 24 namespace base { | 24 namespace base { |
| 25 class Value; | 25 class Value; |
| 26 } // namespace base | 26 } // namespace base |
| 27 | 27 |
| 28 namespace google_apis { | 28 namespace google_apis { |
| 29 | 29 |
| 30 class RequestSender; | 30 class RequestSender; |
| 31 | 31 |
| 32 // Callback used to pass parsed JSON from ParseJson(). If parsing error occurs, | |
| 33 // then the passed argument is null. | |
| 34 typedef base::Callback<void(scoped_ptr<base::Value> value)> ParseJsonCallback; | |
| 35 | |
| 36 // Callback used for DownloadFileRequest and ResumeUploadRequestBase. | 32 // Callback used for DownloadFileRequest and ResumeUploadRequestBase. |
| 37 typedef base::Callback<void(int64 progress, int64 total)> ProgressCallback; | 33 typedef base::Callback<void(int64 progress, int64 total)> ProgressCallback; |
| 38 | 34 |
| 39 // Callback used to get the content from DownloadFileRequest. | 35 // Callback used to get the content from DownloadFileRequest. |
| 40 typedef base::Callback<void( | 36 typedef base::Callback<void( |
| 41 GDataErrorCode error, | 37 GDataErrorCode error, |
| 42 scoped_ptr<std::string> content)> GetContentCallback; | 38 scoped_ptr<std::string> content)> GetContentCallback; |
| 43 | 39 |
| 44 // Parses JSON passed in |json| on |blocking_task_runner|. Runs |callback| on | 40 // Parses JSON passed in |json|. Returns NULL on failure. |
| 45 // the calling thread when finished with either success or failure. | 41 scoped_ptr<base::Value> ParseJson(const std::string& json); |
| 46 // The callback must not be null. | |
| 47 void ParseJson(base::TaskRunner* blocking_task_runner, | |
| 48 const std::string& json, | |
| 49 const ParseJsonCallback& callback); | |
| 50 | 42 |
| 51 //======================= AuthenticatedRequestInterface ====================== | 43 //======================= AuthenticatedRequestInterface ====================== |
| 52 | 44 |
| 53 // An interface class for implementing a request which requires OAuth2 | 45 // An interface class for implementing a request which requires OAuth2 |
| 54 // authentication. | 46 // authentication. |
| 55 class AuthenticatedRequestInterface { | 47 class AuthenticatedRequestInterface { |
| 56 public: | 48 public: |
| 57 // Called when re-authentication is required. See Start() for details. | 49 // Called when re-authentication is required. See Start() for details. |
| 58 typedef base::Callback<void(AuthenticatedRequestInterface* request)> | 50 typedef base::Callback<void(AuthenticatedRequestInterface* request)> |
| 59 ReAuthenticateCallback; | 51 ReAuthenticateCallback; |
| (...skipping 182 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 242 // Overridden from UrlFetchRequestBase. | 234 // Overridden from UrlFetchRequestBase. |
| 243 virtual void ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE; | 235 virtual void ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE; |
| 244 virtual void RunCallbackOnPrematureFailure(GDataErrorCode code) OVERRIDE; | 236 virtual void RunCallbackOnPrematureFailure(GDataErrorCode code) OVERRIDE; |
| 245 | 237 |
| 246 private: | 238 private: |
| 247 const EntryActionCallback callback_; | 239 const EntryActionCallback callback_; |
| 248 | 240 |
| 249 DISALLOW_COPY_AND_ASSIGN(EntryActionRequest); | 241 DISALLOW_COPY_AND_ASSIGN(EntryActionRequest); |
| 250 }; | 242 }; |
| 251 | 243 |
| 252 //============================== GetDataRequest ============================== | |
| 253 | |
| 254 // Callback type for requests that returns JSON data. | |
| 255 typedef base::Callback<void(GDataErrorCode error, | |
| 256 scoped_ptr<base::Value> json_data)> GetDataCallback; | |
| 257 | |
| 258 // This class performs the request for fetching and converting the fetched | |
| 259 // content into a base::Value. | |
| 260 class GetDataRequest : public UrlFetchRequestBase { | |
| 261 public: | |
| 262 // |callback| is called when the request finishes either by success or by | |
| 263 // failure. On success, a JSON Value object is passed. It must not be null. | |
| 264 GetDataRequest(RequestSender* sender, const GetDataCallback& callback); | |
| 265 virtual ~GetDataRequest(); | |
| 266 | |
| 267 protected: | |
| 268 // UrlFetchRequestBase overrides. | |
| 269 virtual void ProcessURLFetchResults(const net::URLFetcher* source) OVERRIDE; | |
| 270 virtual void RunCallbackOnPrematureFailure( | |
| 271 GDataErrorCode fetch_error_code) OVERRIDE; | |
| 272 | |
| 273 private: | |
| 274 // Parses JSON response. | |
| 275 void ParseResponse(GDataErrorCode fetch_error_code, const std::string& data); | |
| 276 | |
| 277 // Called when ParseJsonOnBlockingPool() is completed. | |
| 278 void OnDataParsed(GDataErrorCode fetch_error_code, | |
| 279 scoped_ptr<base::Value> value); | |
| 280 | |
| 281 const GetDataCallback callback_; | |
| 282 | |
| 283 // Note: This should remain the last member so it'll be destroyed and | |
| 284 // invalidate its weak pointers before any other members are destroyed. | |
| 285 base::WeakPtrFactory<GetDataRequest> weak_ptr_factory_; | |
| 286 | |
| 287 DISALLOW_COPY_AND_ASSIGN(GetDataRequest); | |
| 288 }; | |
| 289 | |
| 290 | |
| 291 //=========================== InitiateUploadRequestBase======================= | 244 //=========================== InitiateUploadRequestBase======================= |
| 292 | 245 |
| 293 // Callback type for DriveServiceInterface::InitiateUpload. | 246 // Callback type for DriveServiceInterface::InitiateUpload. |
| 294 typedef base::Callback<void(GDataErrorCode error, | 247 typedef base::Callback<void(GDataErrorCode error, |
| 295 const GURL& upload_url)> InitiateUploadCallback; | 248 const GURL& upload_url)> InitiateUploadCallback; |
| 296 | 249 |
| 297 // This class provides base implementation for performing the request for | 250 // This class provides base implementation for performing the request for |
| 298 // initiating the upload of a file. | 251 // initiating the upload of a file. |
| 299 // |callback| will be called with the obtained upload URL. The URL will be | 252 // |callback| will be called with the obtained upload URL. The URL will be |
| 300 // used with requests for resuming the file uploading. | 253 // used with requests for resuming the file uploading. |
| (...skipping 229 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 530 const ProgressCallback progress_callback_; | 483 const ProgressCallback progress_callback_; |
| 531 const GURL download_url_; | 484 const GURL download_url_; |
| 532 const base::FilePath output_file_path_; | 485 const base::FilePath output_file_path_; |
| 533 | 486 |
| 534 DISALLOW_COPY_AND_ASSIGN(DownloadFileRequestBase); | 487 DISALLOW_COPY_AND_ASSIGN(DownloadFileRequestBase); |
| 535 }; | 488 }; |
| 536 | 489 |
| 537 } // namespace google_apis | 490 } // namespace google_apis |
| 538 | 491 |
| 539 #endif // GOOGLE_APIS_DRIVE_BASE_REQUESTS_H_ | 492 #endif // GOOGLE_APIS_DRIVE_BASE_REQUESTS_H_ |
| OLD | NEW |