2015-07-09 23:01:43 +01:00
|
|
|
import aws from 'aws-sdk';
|
|
|
|
import s3UploadStream from 's3-upload-stream';
|
|
|
|
import debugname from 'debug';
|
|
|
|
const debug = debugname('hostr:s3');
|
|
|
|
|
|
|
|
const s3 = new aws.S3();
|
|
|
|
const s3Stream = s3UploadStream(s3);
|
|
|
|
|
|
|
|
export function get(key) {
|
2015-08-30 18:35:05 +02:00
|
|
|
debug('fetching from s3: %s', 'hostr_files/' + key);
|
|
|
|
return s3.getObject({Bucket: process.env.AWS_BUCKET, Key: 'hostr_files/' + key}).createReadStream();
|
2015-07-09 23:01:43 +01:00
|
|
|
}
|
|
|
|
|
2015-08-23 22:12:32 +01:00
|
|
|
export function upload(key) {
|
2015-08-30 18:35:05 +02:00
|
|
|
debug('sending to s3: %s', 'hostr_files/' + key);
|
|
|
|
return s3Stream.upload({Bucket: process.env.AWS_BUCKET, Key: 'hostr_files/' + key});
|
2015-07-09 23:01:43 +01:00
|
|
|
}
|