1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
|
// 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 CHROME_BROWSER_GOOGLE_APIS_DRIVE_UPLOADER_H_
#define CHROME_BROWSER_GOOGLE_APIS_DRIVE_UPLOADER_H_
#include <string>
#include "base/basictypes.h"
#include "base/callback_forward.h"
#include "base/memory/weak_ptr.h"
#include "base/threading/sequenced_worker_pool.h"
#include "chrome/browser/google_apis/drive_upload_error.h"
#include "chrome/browser/google_apis/gdata_errorcode.h"
#include "chrome/browser/google_apis/gdata_wapi_parser.h"
class FilePath;
class GURL;
namespace google_apis {
class DriveServiceInterface;
struct ResumeUploadResponse;
// Callback to be invoked once the upload has completed.
typedef base::Callback<void(DriveUploadError error,
const FilePath& drive_path,
const FilePath& file_path,
scoped_ptr<ResourceEntry> resource_entry)>
UploadCompletionCallback;
class DriveUploaderInterface {
public:
virtual ~DriveUploaderInterface() {}
// Uploads a new file to a directory specified by |upload_location|.
// Returns the upload_id.
//
// upload_location:
// the "resumable-create-media" URL of the destination directory.
//
// drive_file_path:
// The destination path like "drive/foo/bar.txt".
//
// local_file_path:
// The path to the local file to be uploaded.
//
// title:
// The title (file name) of the file to be uploaded.
//
// content_type:
// The content type of the file to be uploaded.
//
// callback:
// Called when an upload is done regardless of it was successful or not.
// Must not be null.
virtual void UploadNewFile(const GURL& upload_location,
const FilePath& drive_file_path,
const FilePath& local_file_path,
const std::string& title,
const std::string& content_type,
const UploadCompletionCallback& callback) = 0;
// Uploads an existing file (a file that already exists on Drive).
//
// See comments at UploadNewFile() about common parameters.
//
// etag:
// Expected ETag for the destination file. If it does not match, the upload
// fails with UPLOAD_ERROR_CONFLICT.
// If |etag| is empty, the test is skipped.
virtual void UploadExistingFile(const GURL& upload_location,
const FilePath& drive_file_path,
const FilePath& local_file_path,
const std::string& content_type,
const std::string& etag,
const UploadCompletionCallback& callback) = 0;
};
class DriveUploader : public DriveUploaderInterface {
public:
explicit DriveUploader(DriveServiceInterface* drive_service);
virtual ~DriveUploader();
// DriveUploaderInterface overrides.
virtual void UploadNewFile(const GURL& upload_location,
const FilePath& drive_file_path,
const FilePath& local_file_path,
const std::string& title,
const std::string& content_type,
const UploadCompletionCallback& callback) OVERRIDE;
virtual void UploadExistingFile(
const GURL& upload_location,
const FilePath& drive_file_path,
const FilePath& local_file_path,
const std::string& content_type,
const std::string& etag,
const UploadCompletionCallback& callback) OVERRIDE;
private:
struct UploadFileInfo;
// Starts uploading a file with |upload_file_info|.
void StartUploadFile(scoped_ptr<UploadFileInfo> upload_file_info);
// net::FileStream::Open completion callback. The result of the file open
// operation is passed as |result|, and the size is stored in |file_size|.
void OpenCompletionCallback(scoped_ptr<UploadFileInfo> upload_file_info,
int64 file_size);
// DriveService callback for InitiateUpload.
void OnUploadLocationReceived(scoped_ptr<UploadFileInfo> upload_file_info,
GDataErrorCode code,
const GURL& upload_location);
// Uploads the next chunk of data from the file.
void UploadNextChunk(scoped_ptr<UploadFileInfo> upload_file_info);
// net::FileStream::Read completion callback.
void ReadCompletionCallback(scoped_ptr<UploadFileInfo> upload_file_info,
int bytes_to_read,
int bytes_read);
// Calls DriveService's ResumeUpload with the current upload info.
void ResumeUpload(scoped_ptr<UploadFileInfo> upload_file_info,
int bytes_to_send);
// DriveService callback for ResumeUpload.
void OnResumeUploadResponseReceived(
scoped_ptr<UploadFileInfo> upload_file_info,
const ResumeUploadResponse& response,
scoped_ptr<ResourceEntry> entry);
// Handle failed uploads.
void UploadFailed(scoped_ptr<UploadFileInfo> upload_file_info,
DriveUploadError error);
// Pointers to DriveServiceInterface object owned by DriveSystemService.
// The lifetime of this object is guaranteed to exceed that of the
// DriveUploader instance.
DriveServiceInterface* drive_service_;
// TaskRunner for opening, reading, and closing files.
scoped_refptr<base::SequencedTaskRunner> blocking_task_runner_;
// 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<DriveUploader> weak_ptr_factory_;
DISALLOW_COPY_AND_ASSIGN(DriveUploader);
};
} // namespace google_apis
#endif // CHROME_BROWSER_GOOGLE_APIS_DRIVE_UPLOADER_H_
|
