mirror of
https://github.com/Alfresco/alfresco-ng2-components.git
synced 2025-07-24 17:32:15 +00:00
improve retry
This commit is contained in:
@@ -21,18 +21,21 @@ replaceHrefInIndex = (folder) => {
|
||||
});
|
||||
}
|
||||
|
||||
unzipRetry = (tentativeNumber, outputFolder) => {
|
||||
unzipRetry = (tentativeNumber, outputFolder, url) => {
|
||||
var file = fs.createWriteStream('demo.zip');
|
||||
http.get(`http://${url}`, (response) => {
|
||||
response.pipe(file);
|
||||
file.on('finish', async () => {
|
||||
|
||||
console.log('Unzip Demo ' + path.join(__dirname, '../demo.zip'));
|
||||
setTimeout(() => {
|
||||
fs.createReadStream(path.join(__dirname, '../demo.zip'))
|
||||
.pipe(unzip.Extract({path: path.join(__dirname, '../demo-shell')}))
|
||||
.on('error', () => {
|
||||
if (tentativeNumber <= 4) {
|
||||
|
||||
setTimeout(() => {
|
||||
unzipRetry(tentativeNumber++, outputFolder);
|
||||
}, 10000);
|
||||
if (tentativeNumber <= 4) {
|
||||
tentativeNumber++;
|
||||
unzipRetry(tentativeNumber, outputFolder);
|
||||
}
|
||||
})
|
||||
.on('finish', () => {
|
||||
@@ -52,6 +55,9 @@ unzipRetry = (tentativeNumber, outputFolder) => {
|
||||
|
||||
})
|
||||
}, 10000);
|
||||
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
async function main() {
|
||||
@@ -88,13 +94,7 @@ async function main() {
|
||||
|
||||
let outputFolder = program.baseHref ? program.baseHref : 'dist';
|
||||
|
||||
var file = fs.createWriteStream('demo.zip');
|
||||
http.get(`http://${url}`, (response) => {
|
||||
response.pipe(file);
|
||||
file.on('finish', async () => {
|
||||
unzipRetry(1, outputFolder);
|
||||
});
|
||||
});
|
||||
unzipRetry(0, outputFolder, url);
|
||||
}
|
||||
|
||||
main();
|
||||
|
@@ -11,14 +11,14 @@ var exec = require('child_process').exec;
|
||||
|
||||
var alfrescoJsApi;
|
||||
|
||||
unzipRetry = (tentativeNumber, pacakge, outputFolder) => {
|
||||
unzipRetry = (url, outputFolder, pacakge, tentativeNumber) => {
|
||||
console.log(`Unzip ${pacakge}` + path.join(__dirname, `../${pacakge}.zip`));
|
||||
fs.createReadStream(path.join(__dirname, `../${pacakge}.zip`))
|
||||
.pipe(unzip.Extract({path: path.join(__dirname, `../${outputFolder}/@alfresco/`)}))
|
||||
.on('error', () => {
|
||||
if (tentativeNumber <= 4) {
|
||||
setTimeout(() => {
|
||||
unzipRetry(tentativeNumber++, pacakge, outputFolder);
|
||||
downloadZip(tentativeNumber, url, outputFolder, pacakge);
|
||||
}, 10000);
|
||||
}
|
||||
})
|
||||
@@ -35,15 +35,20 @@ unzipRetry = (tentativeNumber, pacakge, outputFolder) => {
|
||||
})
|
||||
}
|
||||
|
||||
downloadZip = async (url, outputFolder, pacakge) => {
|
||||
downloadZip = async (url, outputFolder, pacakge, tentativeNumber) => {
|
||||
if (!tentativeNumber) {
|
||||
tentativeNumber = 0;
|
||||
}
|
||||
|
||||
tentativeNumber++;
|
||||
|
||||
console.log(`Download ${pacakge} in OutputFolder ${outputFolder}`)
|
||||
|
||||
console.log(`Download ${pacakge}`)
|
||||
console.log(`OutputFolder ${outputFolder}`)
|
||||
var file = fs.createWriteStream(`${pacakge}.zip`);
|
||||
return await http.get(`http://${url}`, (response) => {
|
||||
response.pipe(file);
|
||||
file.on('finish', async () => {
|
||||
unzipRetry(1, pacakge, outputFolder);
|
||||
unzipRetry(url, outputFolder, pacakge, tentativeNumber);
|
||||
});
|
||||
});
|
||||
}
|
||||
|
Reference in New Issue
Block a user