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
|
using Spit;
internal class Publishing.YouTube.UploadTransaction : Publishing.RESTSupport.GooglePublisher.AuthenticatedTransaction {
private PublishingParameters parameters;
private Publishing.RESTSupport.GoogleSession session;
private Spit.Publishing.Publishable publishable;
public UploadTransaction(Publishing.RESTSupport.GoogleSession session,
PublishingParameters parameters, Spit.Publishing.Publishable publishable) {
base(session, "https://www.googleapis.com/upload/youtube/v3/videos",
Publishing.RESTSupport.HttpMethod.POST);
assert(session.is_authenticated());
this.session = session;
this.parameters = parameters;
this.publishable = publishable;
}
public override async void execute_async() throws Spit.Publishing.PublishingError {
// Collect parameters
var slug = publishable.get_param_string(Spit.Publishing.Publishable.PARAM_STRING_BASENAME);
// Set title to publishing name, but if that's empty default to filename.
string title = publishable.get_publishing_name();
if (title == "") {
title = publishable.get_param_string(Spit.Publishing.Publishable.PARAM_STRING_BASENAME);
}
var builder = new Json.Builder();
builder.begin_object();
builder.set_member_name("snippet");
builder.begin_object();
builder.set_member_name("description");
builder.add_string_value(slug);
builder.set_member_name("title");
builder.add_string_value(title);
builder.end_object();
builder.set_member_name("status");
builder.begin_object();
builder.set_member_name("privacyStatus");
builder.add_string_value(parameters.get_privacy().to_string());
builder.end_object();
builder.end_object();
var meta_data = Json.to_string (builder.get_root(), false);
debug ("Parameters: %s", meta_data);
var message_parts = new Soup.Multipart("multipart/related");
var headers = new Soup.MessageHeaders(Soup.MessageHeadersType.MULTIPART);
var encoding = new GLib.HashTable<string, string>(str_hash, str_equal);
encoding.insert("encoding", "UTF-8");
headers.set_content_type ("application/json", encoding);
message_parts.append_part (headers, new Bytes (meta_data.data));
headers = new Soup.MessageHeaders(Soup.MessageHeadersType.MULTIPART);
headers.set_content_type ("application/octet-stream", null);
headers.append("Content-Transfer-Encoding", "binary");
MappedFile? mapped_file = null;
try {
mapped_file = new MappedFile(publishable.get_serialized_file().get_path(), false);
} catch (Error e) {
throw new Spit.Publishing.PublishingError.LOCAL_FILE_ERROR(
_("A temporary file needed for publishing is unavailable"));
}
message_parts.append_part (headers, mapped_file.get_bytes());
var outbound_message = new Soup.Message.from_multipart (get_endpoint_url() + "?part=" + GLib.Uri.escape_string ("snippet,status"), message_parts);
outbound_message.get_request_headers().append("Authorization", "Bearer " +
session.get_access_token());
set_message(outbound_message, mapped_file.get_length() + meta_data.length);
set_is_executed(true);
yield send_async();
}
}
|
