diff --git a/init.js b/init.js index d2b2555..24ff137 100644 --- a/init.js +++ b/init.js @@ -4,20 +4,23 @@ 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) 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 } } +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)) }