Permalink
Cannot retrieve contributors at this time
117 lines (113 sloc)
4.06 KB
Name already in use
A tag already exists with the provided branch name. Many Git commands accept both tag and branch names, so creating this branch may cause unexpected behavior. Are you sure you want to create this branch?
codeql-action/node_modules/@octokit/plugin-retry/dist-node/index.js
Go to fileThis commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
"use strict"; | |
var __create = Object.create; | |
var __defProp = Object.defineProperty; | |
var __getOwnPropDesc = Object.getOwnPropertyDescriptor; | |
var __getOwnPropNames = Object.getOwnPropertyNames; | |
var __getProtoOf = Object.getPrototypeOf; | |
var __hasOwnProp = Object.prototype.hasOwnProperty; | |
var __export = (target, all) => { | |
for (var name in all) | |
__defProp(target, name, { get: all[name], enumerable: true }); | |
}; | |
var __copyProps = (to, from, except, desc) => { | |
if (from && typeof from === "object" || typeof from === "function") { | |
for (let key of __getOwnPropNames(from)) | |
if (!__hasOwnProp.call(to, key) && key !== except) | |
__defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable }); | |
} | |
return to; | |
}; | |
var __toESM = (mod, isNodeMode, target) => (target = mod != null ? __create(__getProtoOf(mod)) : {}, __copyProps( | |
// If the importer is in node compatibility mode or this is not an ESM | |
// file that has been converted to a CommonJS file using a Babel- | |
// compatible transform (i.e. "__esModule" has not been set), then set | |
// "default" to the CommonJS "module.exports" for node compatibility. | |
isNodeMode || !mod || !mod.__esModule ? __defProp(target, "default", { value: mod, enumerable: true }) : target, | |
mod | |
)); | |
var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod); | |
// pkg/dist-src/index.js | |
var dist_src_exports = {}; | |
__export(dist_src_exports, { | |
VERSION: () => VERSION, | |
retry: () => retry | |
}); | |
module.exports = __toCommonJS(dist_src_exports); | |
var import_core = require("@octokit/core"); | |
// pkg/dist-src/error-request.js | |
async function errorRequest(state, octokit, error, options) { | |
if (!error.request || !error.request.request) { | |
throw error; | |
} | |
if (error.status >= 400 && !state.doNotRetry.includes(error.status)) { | |
const retries = options.request.retries != null ? options.request.retries : state.retries; | |
const retryAfter = Math.pow((options.request.retryCount || 0) + 1, 2); | |
throw octokit.retry.retryRequest(error, retries, retryAfter); | |
} | |
throw error; | |
} | |
// pkg/dist-src/wrap-request.js | |
var import_light = __toESM(require("bottleneck/light")); | |
var import_request_error = require("@octokit/request-error"); | |
async function wrapRequest(state, octokit, request, options) { | |
const limiter = new import_light.default(); | |
limiter.on("failed", function(error, info) { | |
const maxRetries = ~~error.request.request.retries; | |
const after = ~~error.request.request.retryAfter; | |
options.request.retryCount = info.retryCount + 1; | |
if (maxRetries > info.retryCount) { | |
return after * state.retryAfterBaseValue; | |
} | |
}); | |
return limiter.schedule( | |
requestWithGraphqlErrorHandling.bind(null, state, octokit, request), | |
options | |
); | |
} | |
async function requestWithGraphqlErrorHandling(state, octokit, request, options) { | |
const response = await request(request, options); | |
if (response.data && response.data.errors && /Something went wrong while executing your query/.test( | |
response.data.errors[0].message | |
)) { | |
const error = new import_request_error.RequestError(response.data.errors[0].message, 500, { | |
request: options, | |
response | |
}); | |
return errorRequest(state, octokit, error, options); | |
} | |
return response; | |
} | |
// pkg/dist-src/index.js | |
var VERSION = "5.0.5"; | |
function retry(octokit, octokitOptions) { | |
const state = Object.assign( | |
{ | |
enabled: true, | |
retryAfterBaseValue: 1e3, | |
doNotRetry: [400, 401, 403, 404, 422, 451], | |
retries: 3 | |
}, | |
octokitOptions.retry | |
); | |
if (state.enabled) { | |
octokit.hook.error("request", errorRequest.bind(null, state, octokit)); | |
octokit.hook.wrap("request", wrapRequest.bind(null, state, octokit)); | |
} | |
return { | |
retry: { | |
retryRequest: (error, retries, retryAfter) => { | |
error.request.request = Object.assign({}, error.request.request, { | |
retries, | |
retryAfter | |
}); | |
return error; | |
} | |
} | |
}; | |
} | |
retry.VERSION = VERSION; | |
// Annotate the CommonJS export names for ESM import in node: | |
0 && (module.exports = { | |
VERSION, | |
retry | |
}); |