From 9fccd886ee2e00eae8177c63906705053e97cd90 Mon Sep 17 00:00:00 2001 From: Michelle Tilley Date: Fri, 3 Jun 2016 23:40:59 -0700 Subject: [PATCH 1/2] Fix extension check --- init.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/init.js b/init.js index d2b2555..e451562 100644 --- a/init.js +++ b/init.js @@ -10,7 +10,7 @@ s3.setKey(AWS_KEY) const BUCKET = 'my-s3-bucket' function extract(filename, buffer){ - if(path.extname(filename) === 'zip'){ + if(path.extname(filename) === '.zip'){ return unzip(buffer) }else{ return bytes From 7d1ab14d4ff7596010e1d28ceea110bcfbcf60cc Mon Sep 17 00:00:00 2001 From: Michelle Tilley Date: Fri, 3 Jun 2016 23:42:21 -0700 Subject: [PATCH 2/2] Streaming API --- init.js | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/init.js b/init.js index e451562..24ff137 100644 --- a/init.js +++ b/init.js @@ -4,6 +4,8 @@ import fs from 'fs' import {s3} from 'aws' import {unzip} from 'zip' +import createExtractor from './create-extractor' + const AWS_KEY = 'abcdefg0123456789' s3.setKey(AWS_KEY) @@ -17,7 +19,8 @@ function extract(filename, buffer){ } } +const extractor = createExtractor(extract) + function upload (filename, targetName) { - const bytes = extract(filenane, fs.readFileSync(filename)) - s3.putObject(BUCKET, filename, targetName) + fs.createReadStream(filename).pipe(extractor).pipe(s3.createWriteStream(BUCKET, targetName)) }