-
Notifications
You must be signed in to change notification settings - Fork 1
/
files.js
43 lines (39 loc) · 1.54 KB
/
files.js
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
const fs = require('fs');
const path = require('path');
const assert = require('assert');
const FormData = require('form-data');
const axios = require('axios');
module.exports = (call) => ({
upload: async (filepath, title_ = null, filename_ = null) => {
// prepare
const basename = path.basename(filepath);
const title = title_ === null ? basename : title_;
const filename = filename_ === null ? basename : filename_;
const stat = fs.statSync(filepath);
// get upload information
const getUploadUrlResponse = await call('files.getUploadURL', { filename, length: stat.size });
assert(getUploadUrlResponse.ok === true, getUploadUrlResponse);
// upload
const formData = new FormData();
formData.append('file', fs.createReadStream(filepath));
const requestParams = {
method: 'post',
url: getUploadUrlResponse.upload_url,
data: formData,
headers: {
// eslint-disable-next-line no-underscore-dangle
'Content-Type': `multipart/form-data; boundary=${formData._boundary}`,
...formData.getHeaders()
}
};
const { data } = await axios(requestParams);
assert(data === `OK - ${stat.size}`);
// complete upload
const completeUploadResponse = await call('files.completeUpload', {
files: JSON.stringify([{ id: getUploadUrlResponse.file, title }])
});
assert(completeUploadResponse.ok === true, completeUploadResponse);
assert(completeUploadResponse.files.length === 1, completeUploadResponse);
return completeUploadResponse.files[0].id;
}
});