mirror of
https://git.mirrors.martin98.com/https://github.com/cyberman54/curl
synced 2025-08-22 02:49:07 +08:00
Merge pull request #17 from David-Byrne/retry-post
Retry requests if configured regardless of HTTP Verb
This commit is contained in:
commit
13079d5a27
4
dist/util.js
vendored
4
dist/util.js
vendored
@ -109,7 +109,8 @@ exports.tryToParseJson = function (data) {
|
||||
};
|
||||
exports.sendRequestWithRetry = function (config) { return __awaiter(void 0, void 0, void 0, function () {
|
||||
var client;
|
||||
return __generator(this, function (_a) {
|
||||
var _a;
|
||||
return __generator(this, function (_b) {
|
||||
client = axios_1.default.create();
|
||||
if (requestconf_1.INPUT_RETRIES) {
|
||||
if (isNaN(Number(requestconf_1.INPUT_RETRIES))) {
|
||||
@ -118,6 +119,7 @@ exports.sendRequestWithRetry = function (config) { return __awaiter(void 0, void
|
||||
client.defaults.raxConfig = {
|
||||
instance: client,
|
||||
retry: Number(requestconf_1.INPUT_RETRIES),
|
||||
httpMethodsToRetry: [(_a = config.method) !== null && _a !== void 0 ? _a : ''],
|
||||
onRetryAttempt: function (err) {
|
||||
var cfg = rax.getConfig(err);
|
||||
core.info("Retry attempt #" + (cfg === null || cfg === void 0 ? void 0 : cfg.currentRetryAttempt));
|
||||
|
2
dist/util.js.map
vendored
2
dist/util.js.map
vendored
@ -1 +1 @@
|
||||
{"version":3,"file":"util.js","sourceRoot":"./src/","sources":["util.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,6CAA4D;AAC5D,kDAAsC;AACtC,gDAAiE;AACjE,oDAAiC;AACjC,+CAAmC;AACnC,4CAAgC;AAEnB,QAAA,sBAAsB,GAAG;IACpC,IAAM,mBAAmB,GAAc,0BAAuB;SAC3D,KAAK,CAAC,GAAG,CAAC;SACV,MAAM,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,KAAK,EAAE,EAAR,CAAQ,CAAC;SACvB,GAAG,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,IAAI,EAAE,EAAR,CAAQ,CAAC,CAAC;IACxB,IAAI,MAAM,GAAa,EAAE,CAAC;IAC1B,KAA+B,UAAmB,EAAnB,2CAAmB,EAAnB,iCAAmB,EAAnB,IAAmB,EAAE;QAA/C,IAAI,kBAAkB,4BAAA;QACzB,IAAI,KAAK,CAAC,MAAM,CAAC,kBAAkB,CAAC,CAAC,EAAE;YACrC,MAAM,IAAI,KAAK,CAAC,mBAAiB,kBAAkB,gBAAa,CAAC,CAAC;SACnE;QACD,MAAM,CAAC,IAAI,CAAC,MAAM,CAAC,kBAAkB,CAAC,CAAC,CAAC;KACzC;IACD,OAAO,MAAM,CAAC;AAChB,CAAC,CAAC;AAEW,QAAA,WAAW,GAAG,UAAC,GAAuB;IACjD,OAAO,IAAI,CAAC,SAAS,CAAC;QACpB,WAAW,EAAE,GAAG,CAAC,MAAM;QACvB,IAAI,EAAE,GAAG,CAAC,IAAI;QACd,OAAO,EAAE,GAAG,CAAC,OAAO;KACrB,CAAC,CAAC;AACL,CAAC,CAAC;AAEW,QAAA,cAAc,GAAG,UAAC,IAAY;IACzC,IAAI,MAAM,GAAqB,IAAI,CAAC;IAEpC,6BAA6B;IAC7B,IAAI;QACF,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;QAC1B,OAAO,MAAM,CAAC;KACf;IAAC,WAAM;QACN,aAAa;KACd;IAED,8BAA8B;IAC9B,IAAI;QACF,MAAM,GAAG,IAAI,CAAC,IAAI,CAAC,IAAI,EAAE,EAAE,IAAI,EAAE,IAAI,EAAE,CAAC,CAAC;QACzC,OAAO,MAAM,CAAC;KACf;IAAC,WAAM;QACN,aAAa;KACd;IACD,OAAO,IAAI,CAAC;AACd,CAAC,CAAC;AAEW,QAAA,oBAAoB,GAAG,UAAO,MAA0B;;;QAC7D,MAAM,GAAG,eAAK,CAAC,MAAM,EAAE,CAAC;QAC9B,IAAI,2BAAa,EAAE;YACjB,IAAI,KAAK,CAAC,MAAM,CAAC,2BAAa,CAAC,CAAC,EAAE;gBAChC,MAAM,IAAI,KAAK,CAAC,0BAA0B,CAAC,CAAC;aAC7C;YACD,MAAM,CAAC,QAAQ,CAAC,SAAS,GAAG;gBAC1B,QAAQ,EAAE,MAAM;gBAChB,KAAK,EAAE,MAAM,CAAC,2BAAa,CAAC;gBAC5B,cAAc,EAAE,UAAC,GAAG;oBAClB,IAAM,GAAG,GAAG,GAAG,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC;oBAC/B,IAAI,CAAC,IAAI,CAAC,qBAAkB,GAAG,aAAH,GAAG,uBAAH,GAAG,CAAE,mBAAmB,CAAE,CAAC,CAAC;gBAC1D,CAAC;aACF,CAAC;YACF,GAAG,CAAC,MAAM,CAAC,MAAM,CAAC,CAAC;SACpB;QACD,MAAM;aACH,OAAO,CAAC,MAAM,CAAC;aACf,IAAI,CAAC,UAAC,IAAI,IAAK,OAAA,gBAAS,CAAC,IAAI,CAAC,EAAf,CAAe,CAAC;aAC/B,KAAK,CAAC,UAAC,GAAG,IAAK,OAAA,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,EAAnB,CAAmB,CAAC,CAAC;;;KACxC,CAAC"}
|
||||
{"version":3,"file":"util.js","sourceRoot":"./src/","sources":["util.ts"],"names":[],"mappings":";;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;;AAAA,6CAA4D;AAC5D,kDAAsC;AACtC,gDAAiE;AACjE,oDAAiC;AACjC,+CAAmC;AACnC,4CAAgC;AAEnB,QAAA,sBAAsB,GAAG;IACpC,IAAM,mBAAmB,GAAc,0BAAuB;SAC3D,KAAK,CAAC,GAAG,CAAC;SACV,MAAM,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,KAAK,EAAE,EAAR,CAAQ,CAAC;SACvB,GAAG,CAAC,UAAC,CAAC,IAAK,OAAA,CAAC,CAAC,IAAI,EAAE,EAAR,CAAQ,CAAC,CAAC;IACxB,IAAI,MAAM,GAAa,EAAE,CAAC;IAC1B,KAA+B,UAAmB,EAAnB,2CAAmB,EAAnB,iCAAmB,EAAnB,IAAmB,EAAE;QAA/C,IAAI,kBAAkB,4BAAA;QACzB,IAAI,KAAK,CAAC,MAAM,CAAC,kBAAkB,CAAC,CAAC,EAAE;YACrC,MAAM,IAAI,KAAK,CAAC,mBAAiB,kBAAkB,gBAAa,CAAC,CAAC;SACnE;QACD,MAAM,CAAC,IAAI,CAAC,MAAM,CAAC,kBAAkB,CAAC,CAAC,CAAC;KACzC;IACD,OAAO,MAAM,CAAC;AAChB,CAAC,CAAC;AAEW,QAAA,WAAW,GAAG,UAAC,GAAuB;IACjD,OAAO,IAAI,CAAC,SAAS,CAAC;QACpB,WAAW,EAAE,GAAG,CAAC,MAAM;QACvB,IAAI,EAAE,GAAG,CAAC,IAAI;QACd,OAAO,EAAE,GAAG,CAAC,OAAO;KACrB,CAAC,CAAC;AACL,CAAC,CAAC;AAEW,QAAA,cAAc,GAAG,UAAC,IAAY;IACzC,IAAI,MAAM,GAAqB,IAAI,CAAC;IAEpC,6BAA6B;IAC7B,IAAI;QACF,MAAM,GAAG,IAAI,CAAC,KAAK,CAAC,IAAI,CAAC,CAAC;QAC1B,OAAO,MAAM,CAAC;KACf;IAAC,WAAM;QACN,aAAa;KACd;IAED,8BAA8B;IAC9B,IAAI;QACF,MAAM,GAAG,IAAI,CAAC,IAAI,CAAC,IAAI,EAAE,EAAE,IAAI,EAAE,IAAI,EAAE,CAAC,CAAC;QACzC,OAAO,MAAM,CAAC;KACf;IAAC,WAAM;QACN,aAAa;KACd;IACD,OAAO,IAAI,CAAC;AACd,CAAC,CAAC;AAEW,QAAA,oBAAoB,GAAG,UAAO,MAA0B;;;;QAC7D,MAAM,GAAG,eAAK,CAAC,MAAM,EAAE,CAAC;QAC9B,IAAI,2BAAa,EAAE;YACjB,IAAI,KAAK,CAAC,MAAM,CAAC,2BAAa,CAAC,CAAC,EAAE;gBAChC,MAAM,IAAI,KAAK,CAAC,0BAA0B,CAAC,CAAC;aAC7C;YACD,MAAM,CAAC,QAAQ,CAAC,SAAS,GAAG;gBAC1B,QAAQ,EAAE,MAAM;gBAChB,KAAK,EAAE,MAAM,CAAC,2BAAa,CAAC;gBAC5B,kBAAkB,EAAE,OAAC,MAAM,CAAC,MAAM,mCAAI,EAAE,CAAC;gBACzC,cAAc,EAAE,UAAC,GAAG;oBAClB,IAAM,GAAG,GAAG,GAAG,CAAC,SAAS,CAAC,GAAG,CAAC,CAAC;oBAC/B,IAAI,CAAC,IAAI,CAAC,qBAAkB,GAAG,aAAH,GAAG,uBAAH,GAAG,CAAE,mBAAmB,CAAE,CAAC,CAAC;gBAC1D,CAAC;aACF,CAAC;YACF,GAAG,CAAC,MAAM,CAAC,MAAM,CAAC,CAAC;SACpB;QACD,MAAM;aACH,OAAO,CAAC,MAAM,CAAC;aACf,IAAI,CAAC,UAAC,IAAI,IAAK,OAAA,gBAAS,CAAC,IAAI,CAAC,EAAf,CAAe,CAAC;aAC/B,KAAK,CAAC,UAAC,GAAG,IAAK,OAAA,IAAI,CAAC,SAAS,CAAC,GAAG,CAAC,EAAnB,CAAmB,CAAC,CAAC;;;KACxC,CAAC"}
|
@ -58,6 +58,7 @@ export const sendRequestWithRetry = async (config: AxiosRequestConfig) => {
|
||||
client.defaults.raxConfig = {
|
||||
instance: client,
|
||||
retry: Number(INPUT_RETRIES),
|
||||
httpMethodsToRetry: [config.method ?? ''],
|
||||
onRetryAttempt: (err) => {
|
||||
const cfg = rax.getConfig(err);
|
||||
core.info(`Retry attempt #${cfg?.currentRetryAttempt}`);
|
||||
|
Loading…
x
Reference in New Issue
Block a user