@@ -13,25 +13,22 @@ let storage = new Storage.S3(config);
1313
1414// Returns a Promise object which resolves to a stream.
1515function uploadByURL ( url , bucket , fileName ) {
16- return storage . putObject ( {
17-
18- } ) . promise ( ) ;
19-
20- let file = bucket . file ( fileName ) ;
16+ //let file = bucket.file(fileName);
2117 return new Promise ( ( resolve , reject ) => {
2218 request ( url )
2319 . on ( 'response' , ( response ) => { response . pause ( ) ; resolve ( response ) ; } )
2420 . on ( 'error' , ( reject ) ) ;
25- //.on('finish', ());
26- } ) . then ( ( response ) => { return response . pipe ( file . createWriteStream ( { gzip : true } ) ) ; } ) // TODO: Restructure.
21+ } ) . then ( ( response ) => {
22+ return storage . putObject ( { Bucket :bucket , Key :fileName , Body :response } )
23+ . promise ( ) ;
24+ } )
2725 . catch ( ( error ) => { return { error } ; } ) ; // TODO: Add more detailed error handling. - statusCode etc.
2826}
29- // TODO: file.createResumableUpload
3027
3128exports . upload = function ( url ) {
3229 return uploadByURL ( url , storage . bucket ( config . bucket_name ) , path . basename ( url ) ) ;
3330} ;
34-
31+ /*
3532function createTextFile(bucketName, itemName, fileText) {
3633 console.log(`Creating new item: ${itemName}`);
3734 return cos.putObject({
@@ -46,6 +43,7 @@ function createTextFile(bucketName, itemName, fileText) {
4643 console.error(`ERROR: ${e.code} - ${e.message}\n`);
4744 });
4845}
46+ */
4947
5048/**
5149 *
0 commit comments