/** * Minified by jsDelivr using Terser v5.39.0. * Original file: /npm/pkgcloud-container-copy@0.5.5/pkgcloudContainerCopy.js * * Do NOT use SRI with dynamically generated files! More information: https://www.jsdelivr.com/using-sri-with-dynamic-files */ var pkgcloud=require("pkgcloud"),AWS=require("aws-sdk"),path=require("path"),fs=require("fs"),when=require("when"),nodefn=require("when/node"),md5=require("MD5"),stream=require("stream"),mkdirp=require("mkdirp"),url=require("url"),mime=require("mime-types"),pcc={copyContainer:function(e,n){var t=0,r=[];return when.unfold((function(){return t>=5?when.reject("transfer not completed, files on destination do not match the source"):pcc._copyContainer(e,n,t++).then((function(e){return when.filter((function(e){return null!==e}),e)})).then((function(e){return r=r.concat(e),when.resolve([null,0===e.length])}))}),(function(e){return e}),(function(){})).then((function(){var e=r.map((function(e){return e.name}));return r.filter((function(n,t){return e.lastIndexOf(n.name)===t}))}))},_copyContainer:function(e,n,t){var r=pcc.getFileList(e).catch((function(e){console.log("source error:",e)})),i=pcc.getFileList(n).catch((function(e){console.log("destination error:",e)}));return when.join(r,i).then((function(r){var i=pcc.getTransferPlan(r[0],r[1]),o=[];i.created.forEach((function(r){r.isDir?o.push({file:r,action:function(e){return pcc.createDir(n,e).then((function(e){return e&&process.stdout.write("created: "+e.name+path.sep+(t>0?" retry "+t:"")+"\n"),e}))}}):o.push({file:r,action:function(r){return pcc.transferFile(e,n,r).then((function(e){return e&&process.stdout.write("created: "+e.name+" "+e.size+(t>0?" retry "+t:"")+"\n"),e}))}})})),i.modified.forEach((function(r){o.push({file:r,action:function(r){return pcc.transferFile(e,n,r).then((function(e){return e&&process.stdout.write("modified: "+e.name+" "+e.size+(t>0?" retry "+t:"")+"\n"),e}))}})})),i.touched.forEach((function(e){})),i.deleted.reverse().forEach((function(e){e.isDir?o.push({file:e,action:function(e){return pcc.deleteDir(n,e).then((function(e){return e&&process.stdout.write("deleted: "+e.name+path.sep+(t>0?" retry "+t:"")+"\n"),e}))}}):o.push({file:e,action:function(e){return pcc.deleteFile(n,e).then((function(e){return e&&process.stdout.write("deleted: "+e.name+(t>0?" retry "+t:"")+"\n"),e}))}})}));var c=pcc.getHostname(e),a=pcc.getHostname(n);return null!==c&&c===a?when.reduce(o,(function(e,n){return n.action(n.file).then((function(n){return e.push(n),e}))}),[]):when.all(when.map(o,(function(e){return e.action(e.file)})))})).catch((function(e){console.log("error:",e)}))},transferFile:function(e,n,t){return when.promise((function(r,i){var o=pcc.getDestinationStream(n,t),c=pcc.getSourceStream(e,t);c.pipe(o),o.on("finish",(function(){r(t)})),o.on("success",(function(){r(t)})),o.on("error",(function(e){console.log("destination error:",t.name),i(e)})),c.on("error",(function(e){console.log("source error:",t.name),i(e)}))}))},createCloudContainerSpecifer:function(e,n,t){void 0===n&&(n=e.container,t=e.namePrefix,e=e.client),void 0===t&&(t="");var r={client:"aws-sdk"===e.provider?new AWS.S3({region:e.region,params:{Bucket:n,EncodingType:"url",Prefix:t}}):"rackspace"===e.provider||"amazon"===e.provider||void 0===e.download?pkgcloud.storage.createClient(e):e,container:n,namePrefix:t,delete:{enabled:!e.delete||void 0===e.delete.enabled||e.delete.enabled}};return e.meta&&(r.meta=e.meta),r},getSourceStream:function(e,n){if("string"==typeof e)return fs.createReadStream(path.resolve(e,n.name));if(e.client instanceof AWS.S3)return e.client.getObject({Key:e.namePrefix+n.name}).createReadStream();var t=e.client,r=e.container;return t.download({container:r,remote:n.name},(function(e){e&&console.log("source callback error:",e)}))},getDestinationStream:function(e,n){var t=new stream.PassThrough;if("string"==typeof e){var r=path.resolve(e,n.name);return nodefn.lift(mkdirp)(path.dirname(r)).then((function(){t.pipe(fs.createWriteStream(r))})),t}if(e.client instanceof AWS.S3){var i={};if(e.meta){var o={"Cache-Control":"CacheControl","Content-Encoding":"ContentEncoding"},c=e.meta;if(c.path&&c.default)for(var a in c.default)c.default.hasOwnProperty(a)&&(o[a]?i[o[a]]=c.default[a]:i[a]=c.default[a]);if(c.path&&c.path[n.name])for(var a in c.path[n.name])c.path[n.name].hasOwnProperty(a)&&(o[a]?i[o[a]]=c.path[n.name][a]:i[a]=c.path[n.name][a])}return i.Key=e.namePrefix+n.name,i.Body=t,i.ContentLength=n.size,i.ContentType=mime.lookup(n.name)||"application/octet-stream",e.client.putObject(i,(function(e){e&&console.log("destination callback error:",e)})),t}var u=e.client,l=e.container,s=u.upload({container:l,remote:n.name},(function(e){e&&console.log("destination callback error:",e)}));return t.pipe(s),t},createDir:function(e,n){return"string"==typeof e?nodefn.lift(mkdirp)(path.resolve(e,n.name)).then((function(){return n})):(e.client,AWS.S3,when.resolve(n))},deleteDir:function(e,n){if("string"==typeof e){var t=0;return when.unfold((function(){return++t>20?when.reject("directory not empty "+n.name):nodefn.lift(fs.readdir).bind(fs)(path.resolve(e,n.name)).then((function(t){return t.length?when.resolve([null,!1]).delay(100):nodefn.lift(fs.rmdir).bind(fs)(path.resolve(e,n.name))})).catch((function(e){return"ENOENT"!==e.code?when.reject(e):[null,!0]})).then((function(){return[null,!0]}))}),(function(e){return e}),(function(){})).then((function(){return n}))}return e.delete.enabled?(e.client,AWS.S3,when.resolve(n)):when.resolve(null)},deleteFile:function(e,n){if("string"==typeof e)return nodefn.lift(fs.unlink).bind(fs)(path.resolve(e,n.name)).then((function(){return n}));if(!e.delete.enabled)return when.resolve(null);if(e.client instanceof AWS.S3)return nodefn.lift(e.client.deleteObject).bind(e.client)({Key:e.namePrefix+n.name}).then((function(){return n}));var t=e.client,r=e.container;return nodefn.lift(t.removeFile).bind(t)(r,n.name).then((function(){return n}))},getHostname:function(e){return"string"==typeof e?null:e.client instanceof AWS.S3?e.client.endpoint.hostname:e.client&&e.client._serviceUrl?url.parse(e.client._serviceUrl).hostname:null},sort:function(e,n){return e.name===n.name?0:e.name>n.name?1:-1},getTransferPlan:function(e,n){var t={created:[],modified:[],touched:[],deleted:[],unchanged:[]};e=e.sort(pcc.sort),n=n.sort(pcc.sort);for(var r=0,i=0;r