-
Notifications
You must be signed in to change notification settings - Fork 236
/
convert.js
25 lines (24 loc) · 624 Bytes
/
convert.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
/*global require, module */
var aws = require('aws-sdk');
module.exports = function convert(bucket, fileKey, callback) {
'use strict';
var s3 = new aws.S3(),
Transform = require('stream').Transform,
uppercase = new Transform({decodeStrings: false}),
stream;
uppercase._transform = function (chunk, encoding, done) {
done(null, chunk.toUpperCase());
};
stream = s3.getObject({
Bucket: bucket,
Key: fileKey
}).createReadStream();
stream.setEncoding('utf8');
stream.pipe(uppercase);
s3.upload({
Bucket: bucket,
Key: fileKey.replace(/^in/, 'out'),
Body: uppercase,
ACL: 'private'
}, callback);
};