| "use strict"; |
| var __awaiter = (this && this.__awaiter) || function (thisArg, _arguments, P, generator) { |
| function adopt(value) { return value instanceof P ? value : new P(function (resolve) { resolve(value); }); } |
| return new (P || (P = Promise))(function (resolve, reject) { |
| function fulfilled(value) { try { step(generator.next(value)); } catch (e) { reject(e); } } |
| function rejected(value) { try { step(generator["throw"](value)); } catch (e) { reject(e); } } |
| function step(result) { result.done ? resolve(result.value) : adopt(result.value).then(fulfilled, rejected); } |
| step((generator = generator.apply(thisArg, _arguments || [])).next()); |
| }); |
| }; |
| var __importStar = (this && this.__importStar) || function (mod) { |
| if (mod && mod.__esModule) return mod; |
| var result = {}; |
| if (mod != null) for (var k in mod) if (Object.hasOwnProperty.call(mod, k)) result[k] = mod[k]; |
| result["default"] = mod; |
| return result; |
| }; |
| Object.defineProperty(exports, "__esModule", { value: true }); |
| const core = __importStar(require("@actions/core")); |
| /** |
| * Internal class for retries |
| */ |
| class RetryHelper { |
| constructor(maxAttempts, minSeconds, maxSeconds) { |
| if (maxAttempts < 1) { |
| throw new Error('max attempts should be greater than or equal to 1'); |
| } |
| this.maxAttempts = maxAttempts; |
| this.minSeconds = Math.floor(minSeconds); |
| this.maxSeconds = Math.floor(maxSeconds); |
| if (this.minSeconds > this.maxSeconds) { |
| throw new Error('min seconds should be less than or equal to max seconds'); |
| } |
| } |
| execute(action, isRetryable) { |
| return __awaiter(this, void 0, void 0, function* () { |
| let attempt = 1; |
| while (attempt < this.maxAttempts) { |
| // Try |
| try { |
| return yield action(); |
| } |
| catch (err) { |
| if (isRetryable && !isRetryable(err)) { |
| throw err; |
| } |
| core.info(err.message); |
| } |
| // Sleep |
| const seconds = this.getSleepAmount(); |
| core.info(`Waiting ${seconds} seconds before trying again`); |
| yield this.sleep(seconds); |
| attempt++; |
| } |
| // Last attempt |
| return yield action(); |
| }); |
| } |
| getSleepAmount() { |
| return (Math.floor(Math.random() * (this.maxSeconds - this.minSeconds + 1)) + |
| this.minSeconds); |
| } |
| sleep(seconds) { |
| return __awaiter(this, void 0, void 0, function* () { |
| return new Promise(resolve => setTimeout(resolve, seconds * 1000)); |
| }); |
| } |
| } |
| exports.RetryHelper = RetryHelper; |
| //# sourceMappingURL=retry-helper.js.map |