Files.app: Implement sending batch requests.

google_apis/drive/drive_api_requests.h

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #ifndef GOOGLE_APIS_DRIVE_DRIVE_API_REQUESTS_H_
 #define GOOGLE_APIS_DRIVE_DRIVE_API_REQUESTS_H_
 
 #include <string>
 #include <vector>
 
@@ skipping 1079 matching lines @@
   PermissionType type_;
   PermissionRole role_;
   std::string value_;
 
   DISALLOW_COPY_AND_ASSIGN(PermissionsInsertRequest);
 };
 
 //========================== BatchUploadRequest ==========================
 
 struct BatchUploadChildEntry {
-  explicit BatchUploadChildEntry(UrlFetchRequestBase* request)
+  BatchUploadChildEntry() : request(NULL), prepared(false) {}
+  explicit BatchUploadChildEntry(BatchableRequestBase* request)
       : request(request), prepared(false) {}
-  UrlFetchRequestBase* request;
+  BatchableRequestBase* request;
   bool prepared;
 };
 
 class BatchUploadRequest : public UrlFetchRequestBase {
  public:
   BatchUploadRequest(RequestSender* sender,
                      const DriveApiUrlGenerator& url_generator);
   ~BatchUploadRequest() override;
 
   // Adds request to the batch request.
-  void AddRequest(UrlFetchRequestBase* request);
+  void AddRequest(BatchableRequestBase* request);
 
   // Completes building batch upload request, and starts to send the request to
   // server.
   void Commit();
 
   // Obtains weak pointer of this.
   base::WeakPtr<BatchUploadRequest> GetWeakPtrAsBatchUploadRequest();
 
+  // Set boundary. Only tests can use this method.
+  void SetBoundaryForTesting(const std::string& boundary);
+
   // Obtains reference to RequestSender that owns the request.
   RequestSender* sender() const { return sender_; }
+
+  // Obtains URLGenerator.
   DriveApiUrlGenerator url_generator() const { return url_generator_; }

[kinaba, 2015/04/13 08:25:27]

const DriveApiUrlGenerator& ?

[hirono, 2015/04/13 09:16:10]

Done.

 
-  // Returns URL of this request.
+  // UrlFetchRequestBase overrides.
+  void Prepare(const PrepareCallback& callback) override;
+  void Cancel() override;
   GURL GetURL() const override;
-
+  net::URLFetcher::RequestType GetRequestType() const override;
+  std::vector<std::string> GetExtraRequestHeaders() const override;
+  bool GetContentData(
+      std::string* upload_content_type,
+      std::string* upload_content) override;
   void ProcessURLFetchResults(const net::URLFetcher* source) override;
   void RunCallbackOnPrematureFailure(DriveApiErrorCode code) override;
 
  private:
+  typedef void* RequestID;
+  // Called after child requests' |Prepare| method.
+  void OnChildRequestPrepared(RequestID request_id, DriveApiErrorCode result);
+
+  // Complete |Prepare| if possible.
+  void MayCompletePrepare();
+
+  // Process result for each child.
+  void ProcessURLFetchResultsForChild(RequestID id, const std::string& body);
+
   RequestSender* const sender_;
   const DriveApiUrlGenerator url_generator_;
-  std::vector<BatchUploadChildEntry> child_requests_;
+  std::map<RequestID, BatchUploadChildEntry> child_requests_;
+
+  PrepareCallback prepare_callback_;
+  bool committed_;
+
+  // Boundary of multipart body.
+  std::string boundary_;
+
+  // Multipart of child requests.
+  ContentTypeAndData upload_content_;
 
   // Note: This should remain the last member so it'll be destroyed and
   // invalidate its weak pointers before any other members are destroyed.
   base::WeakPtrFactory<BatchUploadRequest> weak_ptr_factory_;
 
   DISALLOW_COPY_AND_ASSIGN(BatchUploadRequest);
 };
 
 }  // namespace drive
 }  // namespace google_apis
 
 #endif  // GOOGLE_APIS_DRIVE_DRIVE_API_REQUESTS_H_