rgst-io/mise-action
3
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

npm update

Browse source
This commit is contained in:
Jeff Dickey 2024-02-08 16:04:21 -06:00
parent 5173b58ce8
commit e1f00a0bf8
No known key found for this signature in database
GPG key ID: 584DADE86724B407
5 changed files with 634 additions and 383 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

162
dist/cache-save/index.js generated vendored
View file

@ -319,7 +319,8 @@ function createHttpClient() {
return new http_client_1.HttpClient('actions/cache', [bearerCredentialHandler], getRequestOptions()); return new http_client_1.HttpClient('actions/cache', [bearerCredentialHandler], getRequestOptions());
} }
function getCacheVersion(paths, compressionMethod, enableCrossOsArchive = false) { function getCacheVersion(paths, compressionMethod, enableCrossOsArchive = false) {
const components = paths; // don't pass changes upstream
const components = paths.slice();
// Add compression method to cache version to restore // Add compression method to cache version to restore
// compressed cache as per compression method // compressed cache as per compression method
if (compressionMethod) { if (compressionMethod) {
@ -608,26 +609,21 @@ function resolvePaths(patterns) {
implicitDescendants: false implicitDescendants: false
}); });
try { try {
for (var _e = true, _f = __asyncValues(globber.globGenerator()), _g; _g = yield _f.next(), _a = _g.done, !_a;) { for (var _e = true, _f = __asyncValues(globber.globGenerator()), _g; _g = yield _f.next(), _a = _g.done, !_a; _e = true) {
_c = _g.value; _c = _g.value;
_e = false; _e = false;
try { const file = _c;
const file = _c; const relativeFile = path
const relativeFile = path .relative(workspace, file)
.relative(workspace, file) .replace(new RegExp(`\\${path.sep}`, 'g'), '/');
.replace(new RegExp(`\\${path.sep}`, 'g'), '/'); core.debug(`Matched: ${relativeFile}`);
core.debug(`Matched: ${relativeFile}`); // Paths are made relative so the tar entries are all relative to the root of the workspace.
// Paths are made relative so the tar entries are all relative to the root of the workspace. if (relativeFile === '') {
if (relativeFile === '') { // path.relative returns empty string if workspace and file are equal
// path.relative returns empty string if workspace and file are equal paths.push('.');
paths.push('.');
}
else {
paths.push(`${relativeFile}`);
}
} }
finally { else {
_e = true; paths.push(`${relativeFile}`);
} }
} }
} }
@ -711,7 +707,10 @@ function assertDefined(name, value) {
exports.assertDefined = assertDefined; exports.assertDefined = assertDefined;
function isGhes() { function isGhes() {
const ghUrl = new URL(process.env['GITHUB_SERVER_URL'] || 'https://github.com'); const ghUrl = new URL(process.env['GITHUB_SERVER_URL'] || 'https://github.com');
return ghUrl.hostname.toUpperCase() !== 'GITHUB.COM'; const hostname = ghUrl.hostname.trimEnd().toUpperCase();
const isGitHubHost = hostname === 'GITHUB.COM';
const isGheHost = hostname.endsWith('.GHE.COM') || hostname.endsWith('.GHE.LOCALHOST');
return !isGitHubHost && !isGheHost;
} }
exports.isGhes = isGhes; exports.isGhes = isGhes;
//# sourceMappingURL=cacheUtils.js.map //# sourceMappingURL=cacheUtils.js.map
@ -729,7 +728,7 @@ var CacheFilename;
(function (CacheFilename) { (function (CacheFilename) {
CacheFilename["Gzip"] = "cache.tgz"; CacheFilename["Gzip"] = "cache.tgz";
CacheFilename["Zstd"] = "cache.tzst"; CacheFilename["Zstd"] = "cache.tzst";
})(CacheFilename = exports.CacheFilename || (exports.CacheFilename = {})); })(CacheFilename || (exports.CacheFilename = CacheFilename = {}));
var CompressionMethod; var CompressionMethod;
(function (CompressionMethod) { (function (CompressionMethod) {
CompressionMethod["Gzip"] = "gzip"; CompressionMethod["Gzip"] = "gzip";
@ -737,12 +736,12 @@ var CompressionMethod;
// This enum is for earlier version of zstd that does not have --long support // This enum is for earlier version of zstd that does not have --long support
CompressionMethod["ZstdWithoutLong"] = "zstd-without-long"; CompressionMethod["ZstdWithoutLong"] = "zstd-without-long";
CompressionMethod["Zstd"] = "zstd"; CompressionMethod["Zstd"] = "zstd";
})(CompressionMethod = exports.CompressionMethod || (exports.CompressionMethod = {})); })(CompressionMethod || (exports.CompressionMethod = CompressionMethod = {}));
var ArchiveToolType; var ArchiveToolType;
(function (ArchiveToolType) { (function (ArchiveToolType) {
ArchiveToolType["GNU"] = "gnu"; ArchiveToolType["GNU"] = "gnu";
ArchiveToolType["BSD"] = "bsd"; ArchiveToolType["BSD"] = "bsd";
})(ArchiveToolType = exports.ArchiveToolType || (exports.ArchiveToolType = {})); })(ArchiveToolType || (exports.ArchiveToolType = ArchiveToolType = {}));
// The default number of retry attempts. // The default number of retry attempts.
exports.DefaultRetryAttempts = 2; exports.DefaultRetryAttempts = 2;
// The default delay in milliseconds between retry attempts. // The default delay in milliseconds between retry attempts.
@ -6745,6 +6744,18 @@ class AzureKeyCredential {
} }
// Copyright (c) Microsoft Corporation. // Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
/**
* Tests an object to determine whether it implements KeyCredential.
*
* @param credential - The assumed KeyCredential to be tested.
*/
function isKeyCredential(credential) {
return coreUtil.isObjectWithProperties(credential, ["key"]) && typeof credential.key === "string";
}
// Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
/** /**
* A static name/key-based credential that supports updating * A static name/key-based credential that supports updating
* the underlying name and key values. * the underlying name and key values.
@ -6805,6 +6816,7 @@ function isNamedKeyCredential(credential) {
} }
// Copyright (c) Microsoft Corporation. // Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
/** /**
* A static-signature-based credential that supports updating * A static-signature-based credential that supports updating
* the underlying signature value. * the underlying signature value.
@ -6874,6 +6886,7 @@ function isTokenCredential(credential) {
exports.AzureKeyCredential = AzureKeyCredential; exports.AzureKeyCredential = AzureKeyCredential;
exports.AzureNamedKeyCredential = AzureNamedKeyCredential; exports.AzureNamedKeyCredential = AzureNamedKeyCredential;
exports.AzureSASCredential = AzureSASCredential; exports.AzureSASCredential = AzureSASCredential;
exports.isKeyCredential = isKeyCredential;
exports.isNamedKeyCredential = isNamedKeyCredential; exports.isNamedKeyCredential = isNamedKeyCredential;
exports.isSASCredential = isSASCredential; exports.isSASCredential = isSASCredential;
exports.isTokenCredential = isTokenCredential; exports.isTokenCredential = isTokenCredential;
@ -13535,10 +13548,10 @@ exports["default"] = _default;
Object.defineProperty(exports, "__esModule", ({ value: true })); Object.defineProperty(exports, "__esModule", ({ value: true }));
var logger$1 = __nccwpck_require__(3233); var logger$1 = __nccwpck_require__(3233);
var abortController = __nccwpck_require__(2557);
var coreUtil = __nccwpck_require__(1333); var coreUtil = __nccwpck_require__(1333);
// Copyright (c) Microsoft Corporation. // Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
/** /**
* The `@azure/logger` configuration for this package. * The `@azure/logger` configuration for this package.
* @internal * @internal
@ -13557,6 +13570,7 @@ const POLL_INTERVAL_IN_MS = 2000;
const terminalStates = ["succeeded", "canceled", "failed"]; const terminalStates = ["succeeded", "canceled", "failed"];
// Copyright (c) Microsoft Corporation. // Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
/** /**
* Deserializes the state * Deserializes the state
*/ */
@ -13720,6 +13734,7 @@ async function pollOperation(inputs) {
} }
// Copyright (c) Microsoft Corporation. // Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
function getOperationLocationPollingUrl(inputs) { function getOperationLocationPollingUrl(inputs) {
const { azureAsyncOperation, operationLocation } = inputs; const { azureAsyncOperation, operationLocation } = inputs;
return operationLocation !== null && operationLocation !== void 0 ? operationLocation : azureAsyncOperation; return operationLocation !== null && operationLocation !== void 0 ? operationLocation : azureAsyncOperation;
@ -13861,7 +13876,7 @@ function parseRetryAfter({ rawResponse }) {
return undefined; return undefined;
} }
function getErrorFromResponse(response) { function getErrorFromResponse(response) {
const error = response.flatResponse.error; const error = accessBodyProperty(response, "error");
if (!error) { if (!error) {
logger.warning(`The long-running operation failed but there is no error property in the response's body`); logger.warning(`The long-running operation failed but there is no error property in the response's body`);
return; return;
@ -13957,12 +13972,14 @@ function getOperationStatus({ rawResponse }, state) {
throw new Error(`Internal error: Unexpected operation mode: ${mode}`); throw new Error(`Internal error: Unexpected operation mode: ${mode}`);
} }
} }
function getResourceLocation({ flatResponse }, state) { function accessBodyProperty({ flatResponse, rawResponse }, prop) {
if (typeof flatResponse === "object") { var _a, _b;
const resourceLocation = flatResponse.resourceLocation; return (_a = flatResponse === null || flatResponse === void 0 ? void 0 : flatResponse[prop]) !== null && _a !== void 0 ? _a : (_b = rawResponse.body) === null || _b === void 0 ? void 0 : _b[prop];
if (resourceLocation !== undefined) { }
state.config.resourceLocation = resourceLocation; function getResourceLocation(res, state) {
} const loc = accessBodyProperty(res, "resourceLocation");
if (loc && typeof loc === "string") {
state.config.resourceLocation = loc;
} }
return state.config.resourceLocation; return state.config.resourceLocation;
} }
@ -13997,6 +14014,7 @@ async function pollHttpOperation(inputs) {
} }
// Copyright (c) Microsoft Corporation. // Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
const createStateProxy$1 = () => ({ const createStateProxy$1 = () => ({
/** /**
* The state at this point is created to be of type OperationState<TResult>. * The state at this point is created to be of type OperationState<TResult>.
@ -14048,7 +14066,7 @@ function buildCreatePoller(inputs) {
setErrorAsResult: !resolveOnUnsuccessful, setErrorAsResult: !resolveOnUnsuccessful,
}); });
let resultPromise; let resultPromise;
const abortController$1 = new abortController.AbortController(); const abortController = new AbortController();
const handlers = new Map(); const handlers = new Map();
const handleProgressEvents = async () => handlers.forEach((h) => h(state)); const handleProgressEvents = async () => handlers.forEach((h) => h(state));
const cancelErrMsg = "Operation was canceled"; const cancelErrMsg = "Operation was canceled";
@ -14059,7 +14077,7 @@ function buildCreatePoller(inputs) {
isDone: () => ["succeeded", "failed", "canceled"].includes(state.status), isDone: () => ["succeeded", "failed", "canceled"].includes(state.status),
isStopped: () => resultPromise === undefined, isStopped: () => resultPromise === undefined,
stopPolling: () => { stopPolling: () => {
abortController$1.abort(); abortController.abort();
}, },
toString: () => JSON.stringify({ toString: () => JSON.stringify({
state, state,
@ -14071,16 +14089,29 @@ function buildCreatePoller(inputs) {
}, },
pollUntilDone: (pollOptions) => (resultPromise !== null && resultPromise !== void 0 ? resultPromise : (resultPromise = (async () => { pollUntilDone: (pollOptions) => (resultPromise !== null && resultPromise !== void 0 ? resultPromise : (resultPromise = (async () => {
const { abortSignal: inputAbortSignal } = pollOptions || {}; const { abortSignal: inputAbortSignal } = pollOptions || {};
const { signal: abortSignal } = inputAbortSignal // In the future we can use AbortSignal.any() instead
? new abortController.AbortController([inputAbortSignal, abortController$1.signal]) function abortListener() {
: abortController$1; abortController.abort();
if (!poller.isDone()) { }
await poller.poll({ abortSignal }); const abortSignal = abortController.signal;
while (!poller.isDone()) { if (inputAbortSignal === null || inputAbortSignal === void 0 ? void 0 : inputAbortSignal.aborted) {
await coreUtil.delay(currentPollIntervalInMs, { abortSignal }); abortController.abort();
}
else if (!abortSignal.aborted) {
inputAbortSignal === null || inputAbortSignal === void 0 ? void 0 : inputAbortSignal.addEventListener("abort", abortListener, { once: true });
}
try {
if (!poller.isDone()) {
await poller.poll({ abortSignal }); await poller.poll({ abortSignal });
while (!poller.isDone()) {
await coreUtil.delay(currentPollIntervalInMs, { abortSignal });
await poller.poll({ abortSignal });
}
} }
} }
finally {
inputAbortSignal === null || inputAbortSignal === void 0 ? void 0 : inputAbortSignal.removeEventListener("abort", abortListener);
}
if (resolveOnUnsuccessful) { if (resolveOnUnsuccessful) {
return poller.getResult(); return poller.getResult();
} }
@ -14150,6 +14181,7 @@ function buildCreatePoller(inputs) {
} }
// Copyright (c) Microsoft Corporation. // Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
/** /**
* Creates a poller that can be used to poll a long-running operation. * Creates a poller that can be used to poll a long-running operation.
* @param lro - Description of the long-running operation * @param lro - Description of the long-running operation
@ -14191,6 +14223,7 @@ async function createHttpPoller(lro, options) {
} }
// Copyright (c) Microsoft Corporation. // Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
const createStateProxy = () => ({ const createStateProxy = () => ({
initState: (config) => ({ config, isStarted: true }), initState: (config) => ({ config, isStarted: true }),
setCanceled: (state) => (state.isCancelled = true), setCanceled: (state) => (state.isCancelled = true),
@ -14669,6 +14702,7 @@ class Poller {
} }
// Copyright (c) Microsoft Corporation. // Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
/** /**
* The LRO Engine, a class that performs polling. * The LRO Engine, a class that performs polling.
*/ */
@ -15047,7 +15081,9 @@ exports.setSpanContext = setSpanContext;
"use strict"; "use strict";
var abortController = __nccwpck_require__(2557); Object.defineProperty(exports, "__esModule", ({ value: true }));
var abortController = __nccwpck_require__(4200);
var crypto = __nccwpck_require__(6113); var crypto = __nccwpck_require__(6113);
// Copyright (c) Microsoft Corporation. // Copyright (c) Microsoft Corporation.
@ -15119,7 +15155,7 @@ function delay(timeInMs, options) {
*/ */
async function cancelablePromiseRace(abortablePromiseBuilders, options) { async function cancelablePromiseRace(abortablePromiseBuilders, options) {
var _a, _b; var _a, _b;
const aborter = new abortController.AbortController(); const aborter = new AbortController();
function abortHandler() { function abortHandler() {
aborter.abort(); aborter.abort();
} }
@ -15404,6 +15440,47 @@ exports.uint8ArrayToString = uint8ArrayToString;
//# sourceMappingURL=index.js.map //# sourceMappingURL=index.js.map
/***/ }),
/***/ 4200:
/***/ ((__unused_webpack_module, exports) => {
"use strict";
Object.defineProperty(exports, "__esModule", ({ value: true }));
// Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
/**
* This error is thrown when an asynchronous operation has been aborted.
* Check for this error by testing the `name` that the name property of the
* error matches `"AbortError"`.
*
* @example
* ```ts
* const controller = new AbortController();
* controller.abort();
* try {
* doAsyncWork(controller.signal)
* } catch (e) {
* if (e.name === 'AbortError') {
* // handle abort error here.
* }
* }
* ```
*/
class AbortError extends Error {
constructor(message) {
super(message);
this.name = "AbortError";
}
}
exports.AbortError = AbortError;
//# sourceMappingURL=index.js.map
/***/ }), /***/ }),
/***/ 3233: /***/ 3233:
@ -63417,6 +63494,9 @@ function httpRedirectFetch (fetchParams, response) {
// https://fetch.spec.whatwg.org/#cors-non-wildcard-request-header-name // https://fetch.spec.whatwg.org/#cors-non-wildcard-request-header-name
request.headersList.delete('authorization') request.headersList.delete('authorization')
// https://fetch.spec.whatwg.org/#authentication-entries
request.headersList.delete('proxy-authorization', true)
// "Cookie" and "Host" are forbidden request-headers, which undici doesn't implement. // "Cookie" and "Host" are forbidden request-headers, which undici doesn't implement.
request.headersList.delete('cookie') request.headersList.delete('cookie')
request.headersList.delete('host') request.headersList.delete('host')

2
dist/cache-save/index.js.map generated vendored
View file

File diff suppressed because one or more lines are too long

162
dist/index.js generated vendored
View file

@ -319,7 +319,8 @@ function createHttpClient() {
return new http_client_1.HttpClient('actions/cache', [bearerCredentialHandler], getRequestOptions()); return new http_client_1.HttpClient('actions/cache', [bearerCredentialHandler], getRequestOptions());
} }
function getCacheVersion(paths, compressionMethod, enableCrossOsArchive = false) { function getCacheVersion(paths, compressionMethod, enableCrossOsArchive = false) {
const components = paths; // don't pass changes upstream
const components = paths.slice();
// Add compression method to cache version to restore // Add compression method to cache version to restore
// compressed cache as per compression method // compressed cache as per compression method
if (compressionMethod) { if (compressionMethod) {
@ -608,26 +609,21 @@ function resolvePaths(patterns) {
implicitDescendants: false implicitDescendants: false
}); });
try { try {
for (var _e = true, _f = __asyncValues(globber.globGenerator()), _g; _g = yield _f.next(), _a = _g.done, !_a;) { for (var _e = true, _f = __asyncValues(globber.globGenerator()), _g; _g = yield _f.next(), _a = _g.done, !_a; _e = true) {
_c = _g.value; _c = _g.value;
_e = false; _e = false;
try { const file = _c;
const file = _c; const relativeFile = path
const relativeFile = path .relative(workspace, file)
.relative(workspace, file) .replace(new RegExp(`\\${path.sep}`, 'g'), '/');
.replace(new RegExp(`\\${path.sep}`, 'g'), '/'); core.debug(`Matched: ${relativeFile}`);
core.debug(`Matched: ${relativeFile}`); // Paths are made relative so the tar entries are all relative to the root of the workspace.
// Paths are made relative so the tar entries are all relative to the root of the workspace. if (relativeFile === '') {
if (relativeFile === '') { // path.relative returns empty string if workspace and file are equal
// path.relative returns empty string if workspace and file are equal paths.push('.');
paths.push('.');
}
else {
paths.push(`${relativeFile}`);
}
} }
finally { else {
_e = true; paths.push(`${relativeFile}`);
} }
} }
} }
@ -711,7 +707,10 @@ function assertDefined(name, value) {
exports.assertDefined = assertDefined; exports.assertDefined = assertDefined;
function isGhes() { function isGhes() {
const ghUrl = new URL(process.env['GITHUB_SERVER_URL'] || 'https://github.com'); const ghUrl = new URL(process.env['GITHUB_SERVER_URL'] || 'https://github.com');
return ghUrl.hostname.toUpperCase() !== 'GITHUB.COM'; const hostname = ghUrl.hostname.trimEnd().toUpperCase();
const isGitHubHost = hostname === 'GITHUB.COM';
const isGheHost = hostname.endsWith('.GHE.COM') || hostname.endsWith('.GHE.LOCALHOST');
return !isGitHubHost && !isGheHost;
} }
exports.isGhes = isGhes; exports.isGhes = isGhes;
//# sourceMappingURL=cacheUtils.js.map //# sourceMappingURL=cacheUtils.js.map
@ -729,7 +728,7 @@ var CacheFilename;
(function (CacheFilename) { (function (CacheFilename) {
CacheFilename["Gzip"] = "cache.tgz"; CacheFilename["Gzip"] = "cache.tgz";
CacheFilename["Zstd"] = "cache.tzst"; CacheFilename["Zstd"] = "cache.tzst";
})(CacheFilename = exports.CacheFilename || (exports.CacheFilename = {})); })(CacheFilename || (exports.CacheFilename = CacheFilename = {}));
var CompressionMethod; var CompressionMethod;
(function (CompressionMethod) { (function (CompressionMethod) {
CompressionMethod["Gzip"] = "gzip"; CompressionMethod["Gzip"] = "gzip";
@ -737,12 +736,12 @@ var CompressionMethod;
// This enum is for earlier version of zstd that does not have --long support // This enum is for earlier version of zstd that does not have --long support
CompressionMethod["ZstdWithoutLong"] = "zstd-without-long"; CompressionMethod["ZstdWithoutLong"] = "zstd-without-long";
CompressionMethod["Zstd"] = "zstd"; CompressionMethod["Zstd"] = "zstd";
})(CompressionMethod = exports.CompressionMethod || (exports.CompressionMethod = {})); })(CompressionMethod || (exports.CompressionMethod = CompressionMethod = {}));
var ArchiveToolType; var ArchiveToolType;
(function (ArchiveToolType) { (function (ArchiveToolType) {
ArchiveToolType["GNU"] = "gnu"; ArchiveToolType["GNU"] = "gnu";
ArchiveToolType["BSD"] = "bsd"; ArchiveToolType["BSD"] = "bsd";
})(ArchiveToolType = exports.ArchiveToolType || (exports.ArchiveToolType = {})); })(ArchiveToolType || (exports.ArchiveToolType = ArchiveToolType = {}));
// The default number of retry attempts. // The default number of retry attempts.
exports.DefaultRetryAttempts = 2; exports.DefaultRetryAttempts = 2;
// The default delay in milliseconds between retry attempts. // The default delay in milliseconds between retry attempts.
@ -7937,6 +7936,18 @@ class AzureKeyCredential {
} }
// Copyright (c) Microsoft Corporation. // Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
/**
* Tests an object to determine whether it implements KeyCredential.
*
* @param credential - The assumed KeyCredential to be tested.
*/
function isKeyCredential(credential) {
return coreUtil.isObjectWithProperties(credential, ["key"]) && typeof credential.key === "string";
}
// Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
/** /**
* A static name/key-based credential that supports updating * A static name/key-based credential that supports updating
* the underlying name and key values. * the underlying name and key values.
@ -7997,6 +8008,7 @@ function isNamedKeyCredential(credential) {
} }
// Copyright (c) Microsoft Corporation. // Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
/** /**
* A static-signature-based credential that supports updating * A static-signature-based credential that supports updating
* the underlying signature value. * the underlying signature value.
@ -8066,6 +8078,7 @@ function isTokenCredential(credential) {
exports.AzureKeyCredential = AzureKeyCredential; exports.AzureKeyCredential = AzureKeyCredential;
exports.AzureNamedKeyCredential = AzureNamedKeyCredential; exports.AzureNamedKeyCredential = AzureNamedKeyCredential;
exports.AzureSASCredential = AzureSASCredential; exports.AzureSASCredential = AzureSASCredential;
exports.isKeyCredential = isKeyCredential;
exports.isNamedKeyCredential = isNamedKeyCredential; exports.isNamedKeyCredential = isNamedKeyCredential;
exports.isSASCredential = isSASCredential; exports.isSASCredential = isSASCredential;
exports.isTokenCredential = isTokenCredential; exports.isTokenCredential = isTokenCredential;
@ -14727,10 +14740,10 @@ exports["default"] = _default;
Object.defineProperty(exports, "__esModule", ({ value: true })); Object.defineProperty(exports, "__esModule", ({ value: true }));
var logger$1 = __nccwpck_require__(3233); var logger$1 = __nccwpck_require__(3233);
var abortController = __nccwpck_require__(2557);
var coreUtil = __nccwpck_require__(1333); var coreUtil = __nccwpck_require__(1333);
// Copyright (c) Microsoft Corporation. // Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
/** /**
* The `@azure/logger` configuration for this package. * The `@azure/logger` configuration for this package.
* @internal * @internal
@ -14749,6 +14762,7 @@ const POLL_INTERVAL_IN_MS = 2000;
const terminalStates = ["succeeded", "canceled", "failed"]; const terminalStates = ["succeeded", "canceled", "failed"];
// Copyright (c) Microsoft Corporation. // Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
/** /**
* Deserializes the state * Deserializes the state
*/ */
@ -14912,6 +14926,7 @@ async function pollOperation(inputs) {
} }
// Copyright (c) Microsoft Corporation. // Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
function getOperationLocationPollingUrl(inputs) { function getOperationLocationPollingUrl(inputs) {
const { azureAsyncOperation, operationLocation } = inputs; const { azureAsyncOperation, operationLocation } = inputs;
return operationLocation !== null && operationLocation !== void 0 ? operationLocation : azureAsyncOperation; return operationLocation !== null && operationLocation !== void 0 ? operationLocation : azureAsyncOperation;
@ -15053,7 +15068,7 @@ function parseRetryAfter({ rawResponse }) {
return undefined; return undefined;
} }
function getErrorFromResponse(response) { function getErrorFromResponse(response) {
const error = response.flatResponse.error; const error = accessBodyProperty(response, "error");
if (!error) { if (!error) {
logger.warning(`The long-running operation failed but there is no error property in the response's body`); logger.warning(`The long-running operation failed but there is no error property in the response's body`);
return; return;
@ -15149,12 +15164,14 @@ function getOperationStatus({ rawResponse }, state) {
throw new Error(`Internal error: Unexpected operation mode: ${mode}`); throw new Error(`Internal error: Unexpected operation mode: ${mode}`);
} }
} }
function getResourceLocation({ flatResponse }, state) { function accessBodyProperty({ flatResponse, rawResponse }, prop) {
if (typeof flatResponse === "object") { var _a, _b;
const resourceLocation = flatResponse.resourceLocation; return (_a = flatResponse === null || flatResponse === void 0 ? void 0 : flatResponse[prop]) !== null && _a !== void 0 ? _a : (_b = rawResponse.body) === null || _b === void 0 ? void 0 : _b[prop];
if (resourceLocation !== undefined) { }
state.config.resourceLocation = resourceLocation; function getResourceLocation(res, state) {
} const loc = accessBodyProperty(res, "resourceLocation");
if (loc && typeof loc === "string") {
state.config.resourceLocation = loc;
} }
return state.config.resourceLocation; return state.config.resourceLocation;
} }
@ -15189,6 +15206,7 @@ async function pollHttpOperation(inputs) {
} }
// Copyright (c) Microsoft Corporation. // Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
const createStateProxy$1 = () => ({ const createStateProxy$1 = () => ({
/** /**
* The state at this point is created to be of type OperationState<TResult>. * The state at this point is created to be of type OperationState<TResult>.
@ -15240,7 +15258,7 @@ function buildCreatePoller(inputs) {
setErrorAsResult: !resolveOnUnsuccessful, setErrorAsResult: !resolveOnUnsuccessful,
}); });
let resultPromise; let resultPromise;
const abortController$1 = new abortController.AbortController(); const abortController = new AbortController();
const handlers = new Map(); const handlers = new Map();
const handleProgressEvents = async () => handlers.forEach((h) => h(state)); const handleProgressEvents = async () => handlers.forEach((h) => h(state));
const cancelErrMsg = "Operation was canceled"; const cancelErrMsg = "Operation was canceled";
@ -15251,7 +15269,7 @@ function buildCreatePoller(inputs) {
isDone: () => ["succeeded", "failed", "canceled"].includes(state.status), isDone: () => ["succeeded", "failed", "canceled"].includes(state.status),
isStopped: () => resultPromise === undefined, isStopped: () => resultPromise === undefined,
stopPolling: () => { stopPolling: () => {
abortController$1.abort(); abortController.abort();
}, },
toString: () => JSON.stringify({ toString: () => JSON.stringify({
state, state,
@ -15263,16 +15281,29 @@ function buildCreatePoller(inputs) {
}, },
pollUntilDone: (pollOptions) => (resultPromise !== null && resultPromise !== void 0 ? resultPromise : (resultPromise = (async () => { pollUntilDone: (pollOptions) => (resultPromise !== null && resultPromise !== void 0 ? resultPromise : (resultPromise = (async () => {
const { abortSignal: inputAbortSignal } = pollOptions || {}; const { abortSignal: inputAbortSignal } = pollOptions || {};
const { signal: abortSignal } = inputAbortSignal // In the future we can use AbortSignal.any() instead
? new abortController.AbortController([inputAbortSignal, abortController$1.signal]) function abortListener() {
: abortController$1; abortController.abort();
if (!poller.isDone()) { }
await poller.poll({ abortSignal }); const abortSignal = abortController.signal;
while (!poller.isDone()) { if (inputAbortSignal === null || inputAbortSignal === void 0 ? void 0 : inputAbortSignal.aborted) {
await coreUtil.delay(currentPollIntervalInMs, { abortSignal }); abortController.abort();
}
else if (!abortSignal.aborted) {
inputAbortSignal === null || inputAbortSignal === void 0 ? void 0 : inputAbortSignal.addEventListener("abort", abortListener, { once: true });
}
try {
if (!poller.isDone()) {
await poller.poll({ abortSignal }); await poller.poll({ abortSignal });
while (!poller.isDone()) {
await coreUtil.delay(currentPollIntervalInMs, { abortSignal });
await poller.poll({ abortSignal });
}
} }
} }
finally {
inputAbortSignal === null || inputAbortSignal === void 0 ? void 0 : inputAbortSignal.removeEventListener("abort", abortListener);
}
if (resolveOnUnsuccessful) { if (resolveOnUnsuccessful) {
return poller.getResult(); return poller.getResult();
} }
@ -15342,6 +15373,7 @@ function buildCreatePoller(inputs) {
} }
// Copyright (c) Microsoft Corporation. // Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
/** /**
* Creates a poller that can be used to poll a long-running operation. * Creates a poller that can be used to poll a long-running operation.
* @param lro - Description of the long-running operation * @param lro - Description of the long-running operation
@ -15383,6 +15415,7 @@ async function createHttpPoller(lro, options) {
} }
// Copyright (c) Microsoft Corporation. // Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
const createStateProxy = () => ({ const createStateProxy = () => ({
initState: (config) => ({ config, isStarted: true }), initState: (config) => ({ config, isStarted: true }),
setCanceled: (state) => (state.isCancelled = true), setCanceled: (state) => (state.isCancelled = true),
@ -15861,6 +15894,7 @@ class Poller {
} }
// Copyright (c) Microsoft Corporation. // Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
/** /**
* The LRO Engine, a class that performs polling. * The LRO Engine, a class that performs polling.
*/ */
@ -16239,7 +16273,9 @@ exports.setSpanContext = setSpanContext;
"use strict"; "use strict";
var abortController = __nccwpck_require__(2557); Object.defineProperty(exports, "__esModule", ({ value: true }));
var abortController = __nccwpck_require__(4200);
var crypto = __nccwpck_require__(6113); var crypto = __nccwpck_require__(6113);
// Copyright (c) Microsoft Corporation. // Copyright (c) Microsoft Corporation.
@ -16311,7 +16347,7 @@ function delay(timeInMs, options) {
*/ */
async function cancelablePromiseRace(abortablePromiseBuilders, options) { async function cancelablePromiseRace(abortablePromiseBuilders, options) {
var _a, _b; var _a, _b;
const aborter = new abortController.AbortController(); const aborter = new AbortController();
function abortHandler() { function abortHandler() {
aborter.abort(); aborter.abort();
} }
@ -16596,6 +16632,47 @@ exports.uint8ArrayToString = uint8ArrayToString;
//# sourceMappingURL=index.js.map //# sourceMappingURL=index.js.map
/***/ }),
/***/ 4200:
/***/ ((__unused_webpack_module, exports) => {
"use strict";
Object.defineProperty(exports, "__esModule", ({ value: true }));
// Copyright (c) Microsoft Corporation.
// Licensed under the MIT license.
/**
* This error is thrown when an asynchronous operation has been aborted.
* Check for this error by testing the `name` that the name property of the
* error matches `"AbortError"`.
*
* @example
* ```ts
* const controller = new AbortController();
* controller.abort();
* try {
* doAsyncWork(controller.signal)
* } catch (e) {
* if (e.name === 'AbortError') {
* // handle abort error here.
* }
* }
* ```
*/
class AbortError extends Error {
constructor(message) {
super(message);
this.name = "AbortError";
}
}
exports.AbortError = AbortError;
//# sourceMappingURL=index.js.map
/***/ }), /***/ }),
/***/ 3233: /***/ 3233:
@ -64609,6 +64686,9 @@ function httpRedirectFetch (fetchParams, response) {
// https://fetch.spec.whatwg.org/#cors-non-wildcard-request-header-name // https://fetch.spec.whatwg.org/#cors-non-wildcard-request-header-name
request.headersList.delete('authorization') request.headersList.delete('authorization')
// https://fetch.spec.whatwg.org/#authentication-entries
request.headersList.delete('proxy-authorization', true)
// "Cookie" and "Host" are forbidden request-headers, which undici doesn't implement. // "Cookie" and "Host" are forbidden request-headers, which undici doesn't implement.
request.headersList.delete('cookie') request.headersList.delete('cookie')
request.headersList.delete('host') request.headersList.delete('host')

2
dist/index.js.map generated vendored
View file

File diff suppressed because one or more lines are too long

689
package-lock.json generated
View file

File diff suppressed because it is too large Load diff