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');
// });
// });
}