function uploadVideoAssets()

in lambda-functions/deploy-function/index.js [56:121]


function uploadVideoAssets(event) {
 console.log("In uploadVideoAssets :%s", SourceVideoAssetsPrefix);

 let videoUrls = [];

 var lineReader = readline.createInterface({
   input: S3.getObject({ Bucket: SourceFileBucket, Key: SourceVideoAssetsPrefix+'/video-manifest.txt'}).createReadStream()
 });

 lineReader.on('line', function (line) {
   // console.log('Line from file:', line);
   let destKey = line.replace(SourceVideoAssetsPrefix,'');
  // console.log("Destination key ",destKey);

        var params = {
          Bucket: SourceBucket,
          CopySource: SourceFileBucket + '/' + line,
          Key: VideoAssetsPrefix + destKey
        };
        S3.copyObject(params, function(err, data) {
           if (err) console.log(err, err.stack); // an error occurred
           else{
             // console.log(data);
           }               // successful response

         });
 })
 .on('close', function() {
   console.log("Done uploading video assets");
   // return new Promise((resolve, reject) => { // (*)
   //     resolve('Done uploading video assets');
   //    });
 });
 //
 // return .promise()
 //  .then(data => {
 //    console.log("Data ",data.Body);
 //
 //   });

 // return S3.listObjects({ Bucket: SourceFileBucket, Prefix: SourceVideoAssetsPrefix }).promise()
 //  .then(data => {
 //    // console.log("Data :",data);
 //    data.Contents.forEach(function(asset){
 //      // console.log("Key :%s",asset.Key);
 //      let destKey = asset.Key.replace(SourceVideoAssetsPrefix,'');
 //      // console.log("Destination key ",destKey);
 //
 //      var params = {
 //        Bucket: SourceBucket,
 //        CopySource: SourceFileBucket + '/' + asset.Key,
 //        Key: VideoAssetsPrefix + destKey
 //      };
 //      S3.copyObject(params, function(err, data) {
 //         if (err) console.log(err, err.stack); // an error occurred
 //         else{
 //           console.log(data);
 //         }               // successful response
 //
 //       });
 //    });
 //    return new Promise((resolve, reject) => { // (*)
 //     resolve('Done uploading video assets');
 //    });
 //   });
}