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
|
/* Copyright 2016 Software Freedom Conservancy Inc.
* Copyright 2019 Jens Georg <mail@jensge.org>
*
* This software is licensed under the GNU LGPL (version 2.1 or later).
* See the COPYING file in this distribution.
*/
namespace Publishing.GooglePhotos {
internal class UploadTransaction : Publishing.RESTSupport.GooglePublisher.AuthenticatedTransaction {
private PublishingParameters parameters;
private Publishing.RESTSupport.GoogleSession session;
private Spit.Publishing.Publishable publishable;
private InputStream mapped_file;
public UploadTransaction(Publishing.RESTSupport.GoogleSession session,
PublishingParameters parameters, Spit.Publishing.Publishable publishable) {
base(session, "https://photoslibrary.googleapis.com/v1/uploads",
Publishing.RESTSupport.HttpMethod.POST);
assert(session.is_authenticated());
this.session = session;
this.parameters = parameters;
this.publishable = publishable;
}
public Spit.Publishing.Publishable get_publishable() {
return this.publishable;
}
public override async void execute_async() throws Spit.Publishing.PublishingError {
var basename = publishable.get_param_string(Spit.Publishing.Publishable.PARAM_STRING_BASENAME);
int64 mapped_file_size = -1;
// attempt to map the binary image data from disk into memory
try {
mapped_file = publishable.get_serialized_file().read(null);
var info = ((FileInputStream)mapped_file).query_info("standard::size", null);
mapped_file_size = info.get_size();
} catch (Error e) {
string msg = "Google Photos: couldn't read data from %s: %s".printf(
publishable.get_serialized_file().get_path(), e.message);
warning("%s", msg);
throw new Spit.Publishing.PublishingError.LOCAL_FILE_ERROR(msg);
}
// create a message that can be sent over the wire whose payload is the multipart container
// that we've been building up
var outbound_message = new Soup.Message ("POST", get_endpoint_url());
outbound_message.request_headers.append("Authorization", "Bearer " +
session.get_access_token());
outbound_message.request_headers.append("X-Goog-Upload-File-Name", basename);
outbound_message.request_headers.append("X-Goog-Upload-Protocol", "raw");
outbound_message.request_headers.set_content_type("application/octet-stream", null);
outbound_message.set_request_body(null, mapped_file, (ssize_t)mapped_file_size);
set_message(outbound_message, (ulong)mapped_file_size);
// send the message and get its response
set_is_executed(true);
yield send_async();
}
}
internal class Uploader : Publishing.RESTSupport.BatchUploader {
private PublishingParameters parameters;
public string[] upload_tokens = new string[0];
public string[] titles = new string[0];
public Uploader(Publishing.RESTSupport.GoogleSession session,
Spit.Publishing.Publishable[] publishables, PublishingParameters parameters) {
base(session, publishables);
this.parameters = parameters;
}
protected override Publishing.RESTSupport.Transaction create_transaction(
Spit.Publishing.Publishable publishable) {
var txn = new UploadTransaction((Publishing.RESTSupport.GoogleSession) get_session(),
parameters, get_current_publishable());
txn.completed.connect(this.on_transaction_completed);
return txn;
}
private void on_transaction_completed (Publishing.RESTSupport.Transaction txn) {
txn.completed.disconnect (on_transaction_completed);
this.upload_tokens += txn.get_response();
var title = ((UploadTransaction)txn).get_publishable().get_publishing_name();
var publishable = ((UploadTransaction)txn).get_publishable();
if (title == null || title == "") {
title = publishable.get_param_string(Spit.Publishing.Publishable.PARAM_STRING_BASENAME);
}
this.titles += title;
}
}
}
|
