| 'use strict'; | |
| Object.defineProperty(exports, '__esModule', { value: true }); | |
| function _interopDefault (ex) { return (ex && (typeof ex === 'object') && 'default' in ex) ? ex['default'] : ex; } | |
| var endpoint = require('@octokit/endpoint'); | |
| var universalUserAgent = require('universal-user-agent'); | |
| var isPlainObject = require('is-plain-object'); | |
| var nodeFetch = _interopDefault(require('node-fetch')); | |
| var requestError = require('@octokit/request-error'); | |
| const VERSION = "5.6.3"; | |
| function getBufferResponse(response) { | |
| return response.arrayBuffer(); | |
| } | |
| function fetchWrapper(requestOptions) { | |
| const log = requestOptions.request && requestOptions.request.log ? requestOptions.request.log : console; | |
| if (isPlainObject.isPlainObject(requestOptions.body) || Array.isArray(requestOptions.body)) { | |
| requestOptions.body = JSON.stringify(requestOptions.body); | |
| } | |
| let headers = {}; | |
| let status; | |
| let url; | |
| const fetch = requestOptions.request && requestOptions.request.fetch || nodeFetch; | |
| return fetch(requestOptions.url, Object.assign({ | |
| method: requestOptions.method, | |
| body: requestOptions.body, | |
| headers: requestOptions.headers, | |
| redirect: requestOptions.redirect | |
| }, // `requestOptions.request.agent` type is incompatible | |
| // see https://github.com/octokit/types.ts/pull/264 | |
| requestOptions.request)).then(async response => { | |
| url = response.url; | |
| status = response.status; | |
| for (const keyAndValue of response.headers) { | |
| headers[keyAndValue[0]] = keyAndValue[1]; | |
| } | |
| if ("deprecation" in headers) { | |
| const matches = headers.link && headers.link.match(/<([^>]+)>; rel="deprecation"/); | |
| const deprecationLink = matches && matches.pop(); | |
| log.warn(`[@octokit/request] "${requestOptions.method} ${requestOptions.url}" is deprecated. It is scheduled to be removed on ${headers.sunset}${deprecationLink ? `. See ${deprecationLink}` : ""}`); | |
| } | |
| if (status === 204 || status === 205) { | |
| return; | |
| } // GitHub API returns 200 for HEAD requests | |
| if (requestOptions.method === "HEAD") { | |
| if (status < 400) { | |
| return; | |
| } | |
| throw new requestError.RequestError(response.statusText, status, { | |
| response: { | |
| url, | |
| status, | |
| headers, | |
| data: undefined | |
| }, | |
| request: requestOptions | |
| }); | |
| } | |
| if (status === 304) { | |
| throw new requestError.RequestError("Not modified", status, { | |
| response: { | |
| url, | |
| status, | |
| headers, | |
| data: await getResponseData(response) | |
| }, | |
| request: requestOptions | |
| }); | |
| } | |
| if (status >= 400) { | |
| const data = await getResponseData(response); | |
| const error = new requestError.RequestError(toErrorMessage(data), status, { | |
| response: { | |
| url, | |
| status, | |
| headers, | |
| data | |
| }, | |
| request: requestOptions | |
| }); | |
| throw error; | |
| } | |
| return getResponseData(response); | |
| }).then(data => { | |
| return { | |
| status, | |
| url, | |
| headers, | |
| data | |
| }; | |
| }).catch(error => { | |
| if (error instanceof requestError.RequestError) throw error; | |
| throw new requestError.RequestError(error.message, 500, { | |
| request: requestOptions | |
| }); | |
| }); | |
| } | |
| async function getResponseData(response) { | |
| const contentType = response.headers.get("content-type"); | |
| if (/application\/json/.test(contentType)) { | |
| return response.json(); | |
| } | |
| if (!contentType || /^text\/|charset=utf-8$/.test(contentType)) { | |
| return response.text(); | |
| } | |
| return getBufferResponse(response); | |
| } | |
| function toErrorMessage(data) { | |
| if (typeof data === "string") return data; // istanbul ignore else - just in case | |
| if ("message" in data) { | |
| if (Array.isArray(data.errors)) { | |
| return `${data.message}: ${data.errors.map(JSON.stringify).join(", ")}`; | |
| } | |
| return data.message; | |
| } // istanbul ignore next - just in case | |
| return `Unknown error: ${JSON.stringify(data)}`; | |
| } | |
| function withDefaults(oldEndpoint, newDefaults) { | |
| const endpoint = oldEndpoint.defaults(newDefaults); | |
| const newApi = function (route, parameters) { | |
| const endpointOptions = endpoint.merge(route, parameters); | |
| if (!endpointOptions.request || !endpointOptions.request.hook) { | |
| return fetchWrapper(endpoint.parse(endpointOptions)); | |
| } | |
| const request = (route, parameters) => { | |
| return fetchWrapper(endpoint.parse(endpoint.merge(route, parameters))); | |
| }; | |
| Object.assign(request, { | |
| endpoint, | |
| defaults: withDefaults.bind(null, endpoint) | |
| }); | |
| return endpointOptions.request.hook(request, endpointOptions); | |
| }; | |
| return Object.assign(newApi, { | |
| endpoint, | |
| defaults: withDefaults.bind(null, endpoint) | |
| }); | |
| } | |
| const request = withDefaults(endpoint.endpoint, { | |
| headers: { | |
| "user-agent": `octokit-request.js/${VERSION} ${universalUserAgent.getUserAgent()}` | |
| } | |
| }); | |
| exports.request = request; | |
| //# sourceMappingURL=index.js.map |