actions/curl
1
0
Fork 0
mirror of https://git.mirrors.martin98.com/https://github.com/cyberman54/curl synced 2026-04-29 20:28:06 +08:00
Code Issues Packages Projects Releases Wiki Activity

test

Browse Source
This commit is contained in:
Wathanyu Phromma
2020-05-29 20:49:58 +07:00
parent d2e57873b6
commit 78fadbd8b4
3 changed files with 45 additions and 59 deletions
Download Patch File Download Diff File Expand all files Collapse all files

78
dist/util.js vendored
View File

@@ -64,50 +64,40 @@ exports.buildOutput = function (res) {
"headers": res.headers
});
};
exports.sendRequestWithRetry = function (config) { return __awaiter(void 0, void 0, void 0, function () {
var exit, countRetry, retryArr, numberOfRetry, backoff, err_1;
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
exit = false;
countRetry = 0;
retryArr = core.getInput('retry').split('/');
numberOfRetry = Number(retryArr[0]);
backoff = Number(retryArr[1]);
core.info("retry: " + countRetry);
_a.label = 1;
case 1:
_a.trys.push([1, 2, , 6]);
axios_1.default(config)
.then(function (res) {
exit = true;
output_1.default(res);
})
.catch(function (err) {
throw new Error(err);
});
return [3 /*break*/, 6];
case 2:
err_1 = _a.sent();
countRetry += 1;
core.info("retry: " + countRetry);
if (!(countRetry <= numberOfRetry)) return [3 /*break*/, 4];
return [4 /*yield*/, sleep(backoff * 1000)];
case 3:
_a.sent();
return [3 /*break*/, 5];
case 4:
exit = true;
core.setFailed(err_1);
_a.label = 5;
case 5: return [3 /*break*/, 6];
case 6:
if (!exit) return [3 /*break*/, 1];
_a.label = 7;
case 7: return [2 /*return*/];
}
});
}); };
exports.sendRequestWithRetry = function (config) {
var exit = false;
var countRetry = 0;
var retryArr = core.getInput('retry').split('/');
var numberOfRetry = Number(retryArr[0]);
var backoff = Number(retryArr[1]);
core.info("retry: " + countRetry);
do {
axios_1.default(config)
.then(function (res) {
exit = true;
output_1.default(res);
})
.catch(function (err) { return __awaiter(void 0, void 0, void 0, function () {
return __generator(this, function (_a) {
switch (_a.label) {
case 0:
countRetry += 1;
core.info("retry: " + countRetry);
if (!(countRetry <= numberOfRetry)) return [3 /*break*/, 2];
return [4 /*yield*/, sleep(backoff * 1000)];
case 1:
_a.sent();
return [3 /*break*/, 3];
case 2:
exit = true;
core.setFailed(err);
_a.label = 3;
case 3: return [2 /*return*/];
}
});
}); });
} while (!exit);
};
function sleep(ms) {
return new Promise(function (resolve) { return setTimeout(resolve, ms); });
}