| 1 | const fs = require('fs'),
|
| 2 | request = require('request');
|
| 3 |
|
| 4 | const uploadFile = (fileName, s3Url) => {
|
| 5 | var stats = fs.statSync(fileName);
|
| 6 | return new Promise((resolve, reject) => {
|
| 7 | fs.createReadStream(fileName).pipe(
|
| 8 | request
|
| 9 | .put({
|
| 10 | url: s3Url,
|
| 11 | headers: {
|
| 12 | 'Content-Length': stats['size']
|
| 13 | }
|
| 14 | })
|
| 15 | .on('error', e => reject(e))
|
| 16 | .on('end', () => resolve(s3Url))
|
| 17 | );
|
| 18 | });
|
| 19 | };
|
| 20 |
|
| 21 | module.exports = uploadFile;
|