lbry-desktop/lbrytv/setup/publish.js

91 lines
2.7 KiB
JavaScript
Raw Normal View History

2019-02-22 06:01:59 +01:00
// @flow
/*
https://api.lbry.tv/api/v1/proxy currently expects publish to consist
of a multipart/form-data POST request with:
- 'file' binary
- 'json_payload' collection of publish params to be passed to the server's sdk.
*/
2019-11-07 20:39:22 +01:00
import { X_LBRY_AUTH_TOKEN } from '../../ui/constants/token';
import { doUpdateUploadProgress } from 'lbryinc';
2019-11-04 16:16:56 +01:00
import { apiCall } from 'lbry-redux';
2019-02-22 06:01:59 +01:00
// A modified version of Lbry.apiCall that allows
// to perform calling methods at arbitrary urls
// and pass form file fields
2019-09-30 22:11:45 +02:00
export default function apiPublishCallViaWeb(
2019-02-22 06:01:59 +01:00
connectionString: string,
2019-09-30 22:11:45 +02:00
token: string,
2019-02-22 06:01:59 +01:00
method: string,
params: { file_path: string },
resolve: Function,
reject: Function
) {
2019-11-04 16:16:56 +01:00
const { file_path: filePath } = params;
if (!filePath) {
return apiCall(method, params, resolve, reject);
}
2019-02-22 06:01:59 +01:00
const counter = new Date().getTime();
2019-11-04 16:16:56 +01:00
const fileField = filePath;
2019-02-22 06:01:59 +01:00
// Putting a dummy value here, the server is going to process the POSTed file
// and set the file_path itself
params.file_path = '__POST_FILE__';
2019-11-04 16:16:56 +01:00
2019-02-22 06:01:59 +01:00
const jsonPayload = JSON.stringify({
jsonrpc: '2.0',
method,
params,
id: counter,
});
const body = new FormData();
body.append('file', fileField);
body.append('json_payload', jsonPayload);
function makeRequest(connectionString, method, token, body, params) {
return new Promise((resolve, reject) => {
let xhr = new XMLHttpRequest();
xhr.open(method, connectionString);
xhr.setRequestHeader(X_LBRY_AUTH_TOKEN, token);
xhr.responseType = 'json';
xhr.upload.onprogress = e => {
let percentComplete = Math.ceil((e.loaded / e.total) * 100);
window.store.dispatch(doUpdateUploadProgress(percentComplete, params, xhr));
};
xhr.onload = () => {
window.store.dispatch(doUpdateUploadProgress(undefined, params));
resolve(xhr);
};
xhr.onerror = () => {
window.store.dispatch(doUpdateUploadProgress(undefined, params));
reject(new Error(__('There was a problem with your upload')));
};
xhr.onabort = () => {
window.store.dispatch(doUpdateUploadProgress(undefined, params));
};
xhr.send(body);
});
}
return makeRequest(connectionString, 'POST', token, body, params)
.then(xhr => {
let error;
if (xhr) {
if (xhr.response && xhr.status >= 200 && xhr.status < 300) {
return resolve(xhr.response.result);
} else if (xhr.statusText) {
error = new Error(xhr.statusText);
} else {
error = new Error(__('Upload likely timed out. Try a smaller file while we work on this.'));
}
}
2019-02-22 06:01:59 +01:00
if (error) {
return Promise.reject(error);
2019-02-22 06:01:59 +01:00
}
})
.catch(reject);
}