chore: Update dist

This commit is contained in:
GitHub Actions
2026-04-07 03:56:24 +00:00
parent d3bef17c22
commit 930440c681
2 changed files with 231 additions and 151 deletions
+33 -33
View File
@@ -643,16 +643,16 @@ Apache License
The following npm packages may be included in this product: The following npm packages may be included in this product:
- @aws-sdk/client-sts@3.1020.0 - @aws-sdk/client-sts@3.1025.0
- @aws-sdk/util-user-agent-browser@3.972.8 - @aws-sdk/util-user-agent-browser@3.972.8
- @aws-sdk/util-user-agent-node@3.973.13 - @aws-sdk/util-user-agent-node@3.973.14
- @smithy/middleware-retry@4.4.45 - @smithy/middleware-retry@4.5.0
- @smithy/querystring-builder@4.2.13 - @smithy/querystring-builder@4.2.13
- @smithy/querystring-parser@4.2.12 - @smithy/querystring-parser@4.2.13
- @smithy/service-error-classification@4.2.12 - @smithy/service-error-classification@4.2.13
- @smithy/url-parser@4.2.12 - @smithy/url-parser@4.2.13
- @smithy/util-defaults-mode-browser@4.3.44 - @smithy/util-defaults-mode-browser@4.3.45
- @smithy/util-defaults-mode-node@4.2.48 - @smithy/util-defaults-mode-node@4.2.49
These packages each contain the following license: These packages each contain the following license:
@@ -864,12 +864,12 @@ The following npm packages may be included in this product:
- @aws-sdk/middleware-host-header@3.972.8 - @aws-sdk/middleware-host-header@3.972.8
- @aws-sdk/middleware-recursion-detection@3.972.9 - @aws-sdk/middleware-recursion-detection@3.972.9
- @aws-sdk/middleware-user-agent@3.972.27 - @aws-sdk/middleware-user-agent@3.972.28
- @smithy/core@3.23.13 - @smithy/core@3.23.14
- @smithy/invalid-dependency@4.2.12 - @smithy/invalid-dependency@4.2.13
- @smithy/middleware-serde@4.2.16 - @smithy/middleware-serde@4.2.17
- @smithy/protocol-http@5.3.13 - @smithy/protocol-http@5.3.13
- @smithy/smithy-client@4.12.8 - @smithy/smithy-client@4.12.9
- @smithy/types@4.14.0 - @smithy/types@4.14.0
These packages each contain the following license: These packages each contain the following license:
@@ -1689,26 +1689,26 @@ Apache License
The following npm packages may be included in this product: The following npm packages may be included in this product:
- @aws-sdk/credential-provider-env@3.972.24 - @aws-sdk/credential-provider-env@3.972.24
- @aws-sdk/credential-provider-ini@3.972.27 - @aws-sdk/credential-provider-ini@3.972.28
- @aws-sdk/credential-provider-node@3.972.28 - @aws-sdk/credential-provider-node@3.972.29
- @aws-sdk/region-config-resolver@3.972.10 - @aws-sdk/region-config-resolver@3.972.10
- @aws-sdk/token-providers@3.1020.0 - @aws-sdk/token-providers@3.1021.0
- @aws-sdk/types@3.973.6 - @aws-sdk/types@3.973.6
- @aws-sdk/util-endpoints@3.996.5 - @aws-sdk/util-endpoints@3.996.5
- @aws-sdk/util-locate-window@3.965.5 - @aws-sdk/util-locate-window@3.965.5
- @aws-sdk/xml-builder@3.972.16 - @aws-sdk/xml-builder@3.972.16
- @smithy/config-resolver@4.4.13 - @smithy/config-resolver@4.4.14
- @smithy/credential-provider-imds@4.2.12 - @smithy/credential-provider-imds@4.2.13
- @smithy/fetch-http-handler@5.3.15 - @smithy/fetch-http-handler@5.3.16
- @smithy/hash-node@4.2.12 - @smithy/hash-node@4.2.13
- @smithy/is-array-buffer@2.2.0 - @smithy/is-array-buffer@2.2.0
- @smithy/is-array-buffer@4.2.2 - @smithy/is-array-buffer@4.2.2
- @smithy/middleware-content-length@4.2.12 - @smithy/middleware-content-length@4.2.13
- @smithy/middleware-endpoint@4.4.28 - @smithy/middleware-endpoint@4.4.29
- @smithy/middleware-stack@4.2.12 - @smithy/middleware-stack@4.2.13
- @smithy/node-http-handler@4.5.2 - @smithy/node-http-handler@4.5.2
- @smithy/property-provider@4.2.13 - @smithy/property-provider@4.2.13
- @smithy/shared-ini-file-loader@4.4.7 - @smithy/shared-ini-file-loader@4.4.8
- @smithy/signature-v4@5.3.12 - @smithy/signature-v4@5.3.12
- @smithy/util-base64@4.3.2 - @smithy/util-base64@4.3.2
- @smithy/util-body-length-browser@4.2.2 - @smithy/util-body-length-browser@4.2.2
@@ -1716,7 +1716,7 @@ The following npm packages may be included in this product:
- @smithy/util-buffer-from@2.2.0 - @smithy/util-buffer-from@2.2.0
- @smithy/util-buffer-from@4.2.2 - @smithy/util-buffer-from@4.2.2
- @smithy/util-hex-encoding@4.2.2 - @smithy/util-hex-encoding@4.2.2
- @smithy/util-stream@4.5.21 - @smithy/util-stream@4.5.22
- @smithy/util-uri-escape@4.2.2 - @smithy/util-uri-escape@4.2.2
- @smithy/util-utf8@2.3.0 - @smithy/util-utf8@2.3.0
- @smithy/util-utf8@4.2.2 - @smithy/util-utf8@4.2.2
@@ -1931,8 +1931,8 @@ Apache License
The following npm packages may be included in this product: The following npm packages may be included in this product:
- @aws-sdk/credential-provider-process@3.972.24 - @aws-sdk/credential-provider-process@3.972.24
- @aws-sdk/credential-provider-sso@3.972.27 - @aws-sdk/credential-provider-sso@3.972.28
- @aws-sdk/credential-provider-web-identity@3.972.27 - @aws-sdk/credential-provider-web-identity@3.972.28
These packages each contain the following license: These packages each contain the following license:
@@ -2143,7 +2143,7 @@ Apache License
The following npm packages may be included in this product: The following npm packages may be included in this product:
- @aws-sdk/middleware-logger@3.972.8 - @aws-sdk/middleware-logger@3.972.8
- @smithy/node-config-provider@4.3.12 - @smithy/node-config-provider@4.3.13
- @smithy/util-config-provider@4.2.2 - @smithy/util-config-provider@4.2.2
These packages each contain the following license: These packages each contain the following license:
@@ -2354,9 +2354,9 @@ Apache License
The following npm packages may be included in this product: The following npm packages may be included in this product:
- @smithy/util-endpoints@3.3.3 - @smithy/util-endpoints@3.3.4
- @smithy/util-middleware@4.2.12 - @smithy/util-middleware@4.2.13
- @smithy/util-retry@4.2.12 - @smithy/util-retry@4.3.0
These packages each contain the following license: These packages each contain the following license:
@@ -2567,8 +2567,8 @@ Apache License
The following npm packages may be included in this product: The following npm packages may be included in this product:
- @aws-sdk/credential-provider-http@3.972.26 - @aws-sdk/credential-provider-http@3.972.26
- @aws-sdk/credential-provider-login@3.972.27 - @aws-sdk/credential-provider-login@3.972.28
- @aws-sdk/nested-clients@3.996.17 - @aws-sdk/nested-clients@3.996.18
These packages each contain the following license: These packages each contain the following license:
Generated Vendored
+198 -118
View File
@@ -29006,8 +29006,8 @@ var require_dist_cjs23 = __commonJS({
minFillRate; minFillRate;
scaleConstant; scaleConstant;
smooth; smooth;
currentCapacity = 0;
enabled = false; enabled = false;
availableTokens = 0;
lastMaxRate = 0; lastMaxRate = 0;
measuredTxRate = 0; measuredTxRate = 0;
requestCount = 0; requestCount = 0;
@@ -29023,43 +29023,20 @@ var require_dist_cjs23 = __commonJS({
this.minFillRate = options?.minFillRate ?? 0.5; this.minFillRate = options?.minFillRate ?? 0.5;
this.scaleConstant = options?.scaleConstant ?? 0.4; this.scaleConstant = options?.scaleConstant ?? 0.4;
this.smooth = options?.smooth ?? 0.8; this.smooth = options?.smooth ?? 0.8;
const currentTimeInSeconds = this.getCurrentTimeInSeconds(); this.lastThrottleTime = this.getCurrentTimeInSeconds();
this.lastThrottleTime = currentTimeInSeconds;
this.lastTxRateBucket = Math.floor(this.getCurrentTimeInSeconds()); this.lastTxRateBucket = Math.floor(this.getCurrentTimeInSeconds());
this.fillRate = this.minFillRate; this.fillRate = this.minFillRate;
this.maxCapacity = this.minCapacity; this.maxCapacity = this.minCapacity;
} }
getCurrentTimeInSeconds() {
return Date.now() / 1e3;
}
async getSendToken() { async getSendToken() {
return this.acquireTokenBucket(1); return this.acquireTokenBucket(1);
} }
async acquireTokenBucket(amount) {
if (!this.enabled) {
return;
}
this.refillTokenBucket();
if (amount > this.currentCapacity) {
const delay = (amount - this.currentCapacity) / this.fillRate * 1e3;
await new Promise((resolve) => _DefaultRateLimiter.setTimeoutFn(resolve, delay));
}
this.currentCapacity = this.currentCapacity - amount;
}
refillTokenBucket() {
const timestamp = this.getCurrentTimeInSeconds();
if (!this.lastTimestamp) {
this.lastTimestamp = timestamp;
return;
}
const fillAmount = (timestamp - this.lastTimestamp) * this.fillRate;
this.currentCapacity = Math.min(this.maxCapacity, this.currentCapacity + fillAmount);
this.lastTimestamp = timestamp;
}
updateClientSendingRate(response) { updateClientSendingRate(response) {
let calculatedRate; let calculatedRate;
this.updateMeasuredRate(); this.updateMeasuredRate();
if (serviceErrorClassification.isThrottlingError(response)) { const retryErrorInfo = response;
const isThrottling = retryErrorInfo?.errorType === "THROTTLING" || serviceErrorClassification.isThrottlingError(retryErrorInfo?.error ?? response);
if (isThrottling) {
const rateToUse = !this.enabled ? this.measuredTxRate : Math.min(this.measuredTxRate, this.fillRate); const rateToUse = !this.enabled ? this.measuredTxRate : Math.min(this.measuredTxRate, this.fillRate);
this.lastMaxRate = rateToUse; this.lastMaxRate = rateToUse;
this.calculateTimeWindow(); this.calculateTimeWindow();
@@ -29073,6 +29050,30 @@ var require_dist_cjs23 = __commonJS({
const newRate = Math.min(calculatedRate, 2 * this.measuredTxRate); const newRate = Math.min(calculatedRate, 2 * this.measuredTxRate);
this.updateTokenBucketRate(newRate); this.updateTokenBucketRate(newRate);
} }
getCurrentTimeInSeconds() {
return Date.now() / 1e3;
}
async acquireTokenBucket(amount) {
if (!this.enabled) {
return;
}
this.refillTokenBucket();
if (amount > this.availableTokens) {
const delay = (amount - this.availableTokens) / this.fillRate * 1e3;
await new Promise((resolve) => _DefaultRateLimiter.setTimeoutFn(resolve, delay));
}
this.availableTokens = this.availableTokens - amount;
}
refillTokenBucket() {
const timestamp = this.getCurrentTimeInSeconds();
if (!this.lastTimestamp) {
this.lastTimestamp = timestamp;
return;
}
const fillAmount = (timestamp - this.lastTimestamp) * this.fillRate;
this.availableTokens = Math.min(this.maxCapacity, this.availableTokens + fillAmount);
this.lastTimestamp = timestamp;
}
calculateTimeWindow() { calculateTimeWindow() {
this.timeWindow = this.getPrecise(Math.pow(this.lastMaxRate * (1 - this.beta) / this.scaleConstant, 1 / 3)); this.timeWindow = this.getPrecise(Math.pow(this.lastMaxRate * (1 - this.beta) / this.scaleConstant, 1 / 3));
} }
@@ -29089,7 +29090,7 @@ var require_dist_cjs23 = __commonJS({
this.refillTokenBucket(); this.refillTokenBucket();
this.fillRate = Math.max(newRate, this.minFillRate); this.fillRate = Math.max(newRate, this.minFillRate);
this.maxCapacity = Math.max(newRate, this.minCapacity); this.maxCapacity = Math.max(newRate, this.minCapacity);
this.currentCapacity = Math.min(this.currentCapacity, this.maxCapacity); this.availableTokens = Math.min(this.availableTokens, this.maxCapacity);
} }
updateMeasuredRate() { updateMeasuredRate() {
const t5 = this.getCurrentTimeInSeconds(); const t5 = this.getCurrentTimeInSeconds();
@@ -29115,64 +29116,106 @@ var require_dist_cjs23 = __commonJS({
var NO_RETRY_INCREMENT = 1; var NO_RETRY_INCREMENT = 1;
var INVOCATION_ID_HEADER = "amz-sdk-invocation-id"; var INVOCATION_ID_HEADER = "amz-sdk-invocation-id";
var REQUEST_HEADER = "amz-sdk-request"; var REQUEST_HEADER = "amz-sdk-request";
var getDefaultRetryBackoffStrategy = () => { var Retry = class _Retry {
let delayBase = DEFAULT_RETRY_DELAY_BASE; static v2026 = typeof process !== "undefined" && process.env?.SMITHY_NEW_RETRIES_2026 === "true";
const computeNextBackoffDelay = (attempts) => { static delay() {
return Math.floor(Math.min(MAXIMUM_RETRY_DELAY, Math.random() * 2 ** attempts * delayBase)); return _Retry.v2026 ? 50 : 100;
}; }
const setDelayBase = (delay) => { static throttlingDelay() {
delayBase = delay; return _Retry.v2026 ? 1e3 : 500;
}; }
return { static cost() {
computeNextBackoffDelay, return _Retry.v2026 ? 14 : 5;
setDelayBase }
}; static throttlingCost() {
return _Retry.v2026 ? 5 : 10;
}
static modifiedCostType() {
return _Retry.v2026 ? "THROTTLING" : "TRANSIENT";
}
}; };
var createDefaultRetryToken = ({ retryDelay, retryCount, retryCost }) => { var DefaultRetryBackoffStrategy = class {
const getRetryCount = () => retryCount; x = Retry.delay();
const getRetryDelay = () => Math.min(MAXIMUM_RETRY_DELAY, retryDelay); computeNextBackoffDelay(i5) {
const getRetryCost = () => retryCost; const b6 = Math.random();
return { const r5 = 2;
getRetryCount, const t_i = b6 * Math.min(this.x * r5 ** i5, MAXIMUM_RETRY_DELAY);
getRetryDelay, return Math.floor(t_i);
getRetryCost }
}; setDelayBase(delay) {
this.x = delay;
}
};
var DefaultRetryToken = class {
delay;
count;
cost;
longPoll;
constructor(delay, count, cost, longPoll) {
this.delay = delay;
this.count = count;
this.cost = cost;
this.longPoll = longPoll;
}
getRetryCount() {
return this.count;
}
getRetryDelay() {
return Math.min(MAXIMUM_RETRY_DELAY, this.delay);
}
getRetryCost() {
return this.cost;
}
isLongPoll() {
return this.longPoll;
}
}; };
var StandardRetryStrategy = class { var StandardRetryStrategy = class {
maxAttempts;
mode = exports2.RETRY_MODES.STANDARD; mode = exports2.RETRY_MODES.STANDARD;
capacity = INITIAL_RETRY_TOKENS; capacity = INITIAL_RETRY_TOKENS;
retryBackoffStrategy = getDefaultRetryBackoffStrategy(); retryBackoffStrategy;
maxAttemptsProvider; maxAttemptsProvider;
constructor(maxAttempts) { baseDelay;
this.maxAttempts = maxAttempts; constructor(arg1) {
this.maxAttemptsProvider = typeof maxAttempts === "function" ? maxAttempts : async () => maxAttempts; if (typeof arg1 === "number") {
this.maxAttemptsProvider = async () => arg1;
} else if (typeof arg1 === "function") {
this.maxAttemptsProvider = arg1;
} else if (arg1 && typeof arg1 === "object") {
this.maxAttemptsProvider = async () => arg1.maxAttempts;
this.baseDelay = arg1.baseDelay;
this.retryBackoffStrategy = arg1.backoff;
}
this.maxAttemptsProvider ??= async () => DEFAULT_MAX_ATTEMPTS;
this.baseDelay ??= Retry.delay();
this.retryBackoffStrategy ??= new DefaultRetryBackoffStrategy();
} }
async acquireInitialRetryToken(retryTokenScope) { async acquireInitialRetryToken(retryTokenScope) {
return createDefaultRetryToken({ return new DefaultRetryToken(Retry.delay(), 0, void 0, Retry.v2026 && retryTokenScope.includes(":longpoll"));
retryDelay: DEFAULT_RETRY_DELAY_BASE,
retryCount: 0
});
} }
async refreshRetryTokenForRetry(token, errorInfo) { async refreshRetryTokenForRetry(token, errorInfo) {
const maxAttempts = await this.getMaxAttempts(); const maxAttempts = await this.getMaxAttempts();
if (this.shouldRetry(token, errorInfo, maxAttempts)) { const shouldRetry = this.shouldRetry(token, errorInfo, maxAttempts);
if (shouldRetry || token.isLongPoll?.()) {
const errorType = errorInfo.errorType; const errorType = errorInfo.errorType;
this.retryBackoffStrategy.setDelayBase(errorType === "THROTTLING" ? THROTTLING_RETRY_DELAY_BASE : DEFAULT_RETRY_DELAY_BASE); this.retryBackoffStrategy.setDelayBase(errorType === "THROTTLING" ? Retry.throttlingDelay() : this.baseDelay);
const delayFromErrorType = this.retryBackoffStrategy.computeNextBackoffDelay(token.getRetryCount()); const delayFromErrorType = this.retryBackoffStrategy.computeNextBackoffDelay(token.getRetryCount());
const retryDelay = errorInfo.retryAfterHint ? Math.max(errorInfo.retryAfterHint.getTime() - Date.now() || 0, delayFromErrorType) : delayFromErrorType; let retryDelay = delayFromErrorType;
const capacityCost = this.getCapacityCost(errorType); if (errorInfo.retryAfterHint instanceof Date) {
this.capacity -= capacityCost; retryDelay = Math.max(delayFromErrorType, Math.min(errorInfo.retryAfterHint.getTime() - Date.now(), delayFromErrorType + 5e3));
return createDefaultRetryToken({ }
retryDelay, if (!shouldRetry) {
retryCount: token.getRetryCount() + 1, throw Object.assign(new Error("No retry token available"), { $backoff: Retry.v2026 ? retryDelay : 0 });
retryCost: capacityCost } else {
}); const capacityCost = this.getCapacityCost(errorType);
this.capacity -= capacityCost;
return new DefaultRetryToken(retryDelay, token.getRetryCount() + 1, capacityCost, token.isLongPoll?.() ?? false);
}
} }
throw new Error("No retry token available"); throw new Error("No retry token available");
} }
recordSuccess(token) { recordSuccess(token) {
this.capacity = Math.max(INITIAL_RETRY_TOKENS, this.capacity + (token.getRetryCost() ?? NO_RETRY_INCREMENT)); this.capacity = Math.min(INITIAL_RETRY_TOKENS, this.capacity + (token.getRetryCost() ?? NO_RETRY_INCREMENT));
} }
getCapacity() { getCapacity() {
return this.capacity; return this.capacity;
@@ -29190,22 +29233,23 @@ var require_dist_cjs23 = __commonJS({
return attempts < maxAttempts && this.capacity >= this.getCapacityCost(errorInfo.errorType) && this.isRetryableError(errorInfo.errorType); return attempts < maxAttempts && this.capacity >= this.getCapacityCost(errorInfo.errorType) && this.isRetryableError(errorInfo.errorType);
} }
getCapacityCost(errorType) { getCapacityCost(errorType) {
return errorType === "TRANSIENT" ? TIMEOUT_RETRY_COST : RETRY_COST; return errorType === Retry.modifiedCostType() ? Retry.throttlingCost() : Retry.cost();
} }
isRetryableError(errorType) { isRetryableError(errorType) {
return errorType === "THROTTLING" || errorType === "TRANSIENT"; return errorType === "THROTTLING" || errorType === "TRANSIENT";
} }
}; };
var AdaptiveRetryStrategy = class { var AdaptiveRetryStrategy = class {
maxAttemptsProvider; mode = exports2.RETRY_MODES.ADAPTIVE;
rateLimiter; rateLimiter;
standardRetryStrategy; standardRetryStrategy;
mode = exports2.RETRY_MODES.ADAPTIVE;
constructor(maxAttemptsProvider, options) { constructor(maxAttemptsProvider, options) {
this.maxAttemptsProvider = maxAttemptsProvider;
const { rateLimiter } = options ?? {}; const { rateLimiter } = options ?? {};
this.rateLimiter = rateLimiter ?? new DefaultRateLimiter(); this.rateLimiter = rateLimiter ?? new DefaultRateLimiter();
this.standardRetryStrategy = new StandardRetryStrategy(maxAttemptsProvider); this.standardRetryStrategy = options ? new StandardRetryStrategy({
maxAttempts: typeof maxAttemptsProvider === "number" ? maxAttemptsProvider : 3,
...options
}) : new StandardRetryStrategy(maxAttemptsProvider);
} }
async acquireInitialRetryToken(retryTokenScope) { async acquireInitialRetryToken(retryTokenScope) {
await this.rateLimiter.getSendToken(); await this.rateLimiter.getSendToken();
@@ -29222,7 +29266,7 @@ var require_dist_cjs23 = __commonJS({
}; };
var ConfiguredRetryStrategy = class extends StandardRetryStrategy { var ConfiguredRetryStrategy = class extends StandardRetryStrategy {
computeNextBackoffDelay; computeNextBackoffDelay;
constructor(maxAttempts, computeNextBackoffDelay = DEFAULT_RETRY_DELAY_BASE) { constructor(maxAttempts, computeNextBackoffDelay = Retry.delay()) {
super(typeof maxAttempts === "function" ? maxAttempts : async () => maxAttempts); super(typeof maxAttempts === "function" ? maxAttempts : async () => maxAttempts);
if (typeof computeNextBackoffDelay === "number") { if (typeof computeNextBackoffDelay === "number") {
this.computeNextBackoffDelay = () => computeNextBackoffDelay; this.computeNextBackoffDelay = () => computeNextBackoffDelay;
@@ -29248,6 +29292,7 @@ var require_dist_cjs23 = __commonJS({
exports2.NO_RETRY_INCREMENT = NO_RETRY_INCREMENT; exports2.NO_RETRY_INCREMENT = NO_RETRY_INCREMENT;
exports2.REQUEST_HEADER = REQUEST_HEADER; exports2.REQUEST_HEADER = REQUEST_HEADER;
exports2.RETRY_COST = RETRY_COST; exports2.RETRY_COST = RETRY_COST;
exports2.Retry = Retry;
exports2.StandardRetryStrategy = StandardRetryStrategy; exports2.StandardRetryStrategy = StandardRetryStrategy;
exports2.THROTTLING_RETRY_DELAY_BASE = THROTTLING_RETRY_DELAY_BASE; exports2.THROTTLING_RETRY_DELAY_BASE = THROTTLING_RETRY_DELAY_BASE;
exports2.TIMEOUT_RETRY_COST = TIMEOUT_RETRY_COST; exports2.TIMEOUT_RETRY_COST = TIMEOUT_RETRY_COST;
@@ -30271,10 +30316,10 @@ var require_dist_cjs31 = __commonJS({
var require_dist_cjs32 = __commonJS({ var require_dist_cjs32 = __commonJS({
"node_modules/@smithy/middleware-endpoint/dist-cjs/index.js"(exports2) { "node_modules/@smithy/middleware-endpoint/dist-cjs/index.js"(exports2) {
"use strict"; "use strict";
var getEndpointFromConfig = require_getEndpointFromConfig();
var urlParser = require_dist_cjs18();
var core5 = (init_dist_es(), __toCommonJS(dist_es_exports)); var core5 = (init_dist_es(), __toCommonJS(dist_es_exports));
var utilMiddleware = require_dist_cjs6(); var utilMiddleware = require_dist_cjs6();
var getEndpointFromConfig = require_getEndpointFromConfig();
var urlParser = require_dist_cjs18();
var middlewareSerde = require_dist_cjs31(); var middlewareSerde = require_dist_cjs31();
var resolveParamsForS3 = async (endpointParams) => { var resolveParamsForS3 = async (endpointParams) => {
const bucket = endpointParams?.Bucket || ""; const bucket = endpointParams?.Bucket || "";
@@ -30797,10 +30842,10 @@ var require_dist_cjs34 = __commonJS({
"node_modules/@smithy/smithy-client/dist-cjs/index.js"(exports2) { "node_modules/@smithy/smithy-client/dist-cjs/index.js"(exports2) {
"use strict"; "use strict";
var middlewareStack = require_dist_cjs33(); var middlewareStack = require_dist_cjs33();
var protocols2 = (init_protocols(), __toCommonJS(protocols_exports));
var types3 = require_dist_cjs(); var types3 = require_dist_cjs();
var schema = (init_schema(), __toCommonJS(schema_exports)); var schema = (init_schema(), __toCommonJS(schema_exports));
var serde = (init_serde(), __toCommonJS(serde_exports)); var serde = (init_serde(), __toCommonJS(serde_exports));
var protocols2 = (init_protocols(), __toCommonJS(protocols_exports));
var Client2 = class { var Client2 = class {
config; config;
middlewareStack = middlewareStack.constructStack(); middlewareStack = middlewareStack.constructStack();
@@ -31417,6 +31462,16 @@ var require_dist_cjs35 = __commonJS({
var utilMiddleware = require_dist_cjs6(); var utilMiddleware = require_dist_cjs6();
var smithyClient = require_dist_cjs34(); var smithyClient = require_dist_cjs34();
var isStreamingPayload = require_isStreamingPayload(); var isStreamingPayload = require_isStreamingPayload();
var serde = (init_serde(), __toCommonJS(serde_exports));
var asSdkError = (error2) => {
if (error2 instanceof Error)
return error2;
if (error2 instanceof Object)
return Object.assign(new Error(), error2);
if (typeof error2 === "string")
return new Error(error2);
return new Error(`AWS SDK error wrapper for ${error2}`);
};
var getDefaultRetryQuota = (initialRetryTokens, options) => { var getDefaultRetryQuota = (initialRetryTokens, options) => {
const MAX_CAPACITY = initialRetryTokens; const MAX_CAPACITY = initialRetryTokens;
const noRetryIncrement = utilRetry.NO_RETRY_INCREMENT; const noRetryIncrement = utilRetry.NO_RETRY_INCREMENT;
@@ -31450,15 +31505,6 @@ var require_dist_cjs35 = __commonJS({
} }
return serviceErrorClassification.isRetryableByTrait(error2) || serviceErrorClassification.isClockSkewError(error2) || serviceErrorClassification.isThrottlingError(error2) || serviceErrorClassification.isTransientError(error2); return serviceErrorClassification.isRetryableByTrait(error2) || serviceErrorClassification.isClockSkewError(error2) || serviceErrorClassification.isThrottlingError(error2) || serviceErrorClassification.isTransientError(error2);
}; };
var asSdkError = (error2) => {
if (error2 instanceof Error)
return error2;
if (error2 instanceof Object)
return Object.assign(new Error(), error2);
if (typeof error2 === "string")
return new Error(error2);
return new Error(`AWS SDK error wrapper for ${error2}`);
};
var StandardRetryStrategy = class { var StandardRetryStrategy = class {
maxAttemptsProvider; maxAttemptsProvider;
retryDecider; retryDecider;
@@ -31624,12 +31670,54 @@ var require_dist_cjs35 = __commonJS({
clientStack.addRelativeTo(omitRetryHeadersMiddleware(), omitRetryHeadersMiddlewareOptions); clientStack.addRelativeTo(omitRetryHeadersMiddleware(), omitRetryHeadersMiddlewareOptions);
} }
}); });
function parseRetryAfterHeader(response, logger2) {
if (!protocolHttp.HttpResponse.isInstance(response)) {
return;
}
for (const header of Object.keys(response.headers)) {
const h5 = header.toLowerCase();
if (h5 === "retry-after") {
const retryAfter = response.headers[header];
let retryAfterSeconds = NaN;
if (retryAfter.endsWith("GMT")) {
try {
const date2 = serde.parseRfc7231DateTime(retryAfter);
retryAfterSeconds = (date2.getTime() - Date.now()) / 1e3;
} catch (e5) {
logger2?.trace?.("Failed to parse retry-after header");
logger2?.trace?.(e5);
}
} else if (retryAfter.match(/ GMT, ((\d+)|(\d+\.\d+))$/)) {
retryAfterSeconds = Number(retryAfter.match(/ GMT, ([\d.]+)$/)?.[1]);
} else if (retryAfter.match(/^((\d+)|(\d+\.\d+))$/)) {
retryAfterSeconds = Number(retryAfter);
} else if (Date.parse(retryAfter) >= Date.now()) {
retryAfterSeconds = (Date.parse(retryAfter) - Date.now()) / 1e3;
}
if (isNaN(retryAfterSeconds)) {
return;
}
return new Date(Date.now() + retryAfterSeconds * 1e3);
} else if (h5 === "x-amz-retry-after") {
const v5 = response.headers[header];
const backoffMilliseconds = Number(v5);
if (isNaN(backoffMilliseconds)) {
logger2?.trace?.(`Failed to parse x-amz-retry-after=${v5}`);
return;
}
return new Date(Date.now() + backoffMilliseconds);
}
}
}
function getRetryAfterHint(response, logger2) {
return parseRetryAfterHeader(response, logger2);
}
var retryMiddleware = (options) => (next, context) => async (args) => { var retryMiddleware = (options) => (next, context) => async (args) => {
let retryStrategy = await options.retryStrategy(); let retryStrategy = await options.retryStrategy();
const maxAttempts = await options.maxAttempts(); const maxAttempts = await options.maxAttempts();
if (isRetryStrategyV2(retryStrategy)) { if (isRetryStrategyV2(retryStrategy)) {
retryStrategy = retryStrategy; retryStrategy = retryStrategy;
let retryToken = await retryStrategy.acquireInitialRetryToken(context["partition_id"]); let retryToken = await retryStrategy.acquireInitialRetryToken((context["partition_id"] ?? "") + (context.__retryLongPoll ? ":longpoll" : ""));
let lastError = new Error(); let lastError = new Error();
let attempts = 0; let attempts = 0;
let totalRetryDelay = 0; let totalRetryDelay = 0;
@@ -31649,7 +31737,7 @@ var require_dist_cjs35 = __commonJS({
output.$metadata.totalRetryDelay = totalRetryDelay; output.$metadata.totalRetryDelay = totalRetryDelay;
return { response, output }; return { response, output };
} catch (e5) { } catch (e5) {
const retryErrorInfo = getRetryErrorInfo(e5); const retryErrorInfo = getRetryErrorInfo(e5, options.logger);
lastError = asSdkError(e5); lastError = asSdkError(e5);
if (isRequest && isStreamingPayload.isStreamingPayload(request)) { if (isRequest && isStreamingPayload.isStreamingPayload(request)) {
(context.logger instanceof smithyClient.NoOpLogger ? console : context.logger)?.warn("An error was encountered in a non-retryable streaming request."); (context.logger instanceof smithyClient.NoOpLogger ? console : context.logger)?.warn("An error was encountered in a non-retryable streaming request.");
@@ -31658,6 +31746,9 @@ var require_dist_cjs35 = __commonJS({
try { try {
retryToken = await retryStrategy.refreshRetryTokenForRetry(retryToken, retryErrorInfo); retryToken = await retryStrategy.refreshRetryTokenForRetry(retryToken, retryErrorInfo);
} catch (refreshError) { } catch (refreshError) {
if (typeof refreshError.$backoff === "number") {
await cooldown(refreshError.$backoff);
}
if (!lastError.$metadata) { if (!lastError.$metadata) {
lastError.$metadata = {}; lastError.$metadata = {};
} }
@@ -31668,23 +31759,25 @@ var require_dist_cjs35 = __commonJS({
attempts = retryToken.getRetryCount(); attempts = retryToken.getRetryCount();
const delay = retryToken.getRetryDelay(); const delay = retryToken.getRetryDelay();
totalRetryDelay += delay; totalRetryDelay += delay;
await new Promise((resolve) => setTimeout(resolve, delay)); await cooldown(delay);
} }
} }
} else { } else {
retryStrategy = retryStrategy; retryStrategy = retryStrategy;
if (retryStrategy?.mode) if (retryStrategy?.mode) {
context.userAgent = [...context.userAgent || [], ["cfg/retry-mode", retryStrategy.mode]]; context.userAgent = [...context.userAgent || [], ["cfg/retry-mode", retryStrategy.mode]];
}
return retryStrategy.retry(next, args); return retryStrategy.retry(next, args);
} }
}; };
var cooldown = (ms) => new Promise((resolve) => setTimeout(resolve, ms));
var isRetryStrategyV2 = (retryStrategy) => typeof retryStrategy.acquireInitialRetryToken !== "undefined" && typeof retryStrategy.refreshRetryTokenForRetry !== "undefined" && typeof retryStrategy.recordSuccess !== "undefined"; var isRetryStrategyV2 = (retryStrategy) => typeof retryStrategy.acquireInitialRetryToken !== "undefined" && typeof retryStrategy.refreshRetryTokenForRetry !== "undefined" && typeof retryStrategy.recordSuccess !== "undefined";
var getRetryErrorInfo = (error2) => { var getRetryErrorInfo = (error2, logger2) => {
const errorInfo = { const errorInfo = {
error: error2, error: error2,
errorType: getRetryErrorType(error2) errorType: getRetryErrorType(error2)
}; };
const retryAfterHint = getRetryAfterHint(error2.$response); const retryAfterHint = parseRetryAfterHeader(error2.$response, logger2);
if (retryAfterHint) { if (retryAfterHint) {
errorInfo.retryAfterHint = retryAfterHint; errorInfo.retryAfterHint = retryAfterHint;
} }
@@ -31711,19 +31804,6 @@ var require_dist_cjs35 = __commonJS({
clientStack.add(retryMiddleware(options), retryMiddlewareOptions); clientStack.add(retryMiddleware(options), retryMiddlewareOptions);
} }
}); });
var getRetryAfterHint = (response) => {
if (!protocolHttp.HttpResponse.isInstance(response))
return;
const retryAfterHeaderName = Object.keys(response.headers).find((key) => key.toLowerCase() === "retry-after");
if (!retryAfterHeaderName)
return;
const retryAfter = response.headers[retryAfterHeaderName];
const retryAfterSeconds = Number(retryAfter);
if (!Number.isNaN(retryAfterSeconds))
return new Date(retryAfterSeconds * 1e3);
const retryAfterDate = new Date(retryAfter);
return retryAfterDate;
};
exports2.AdaptiveRetryStrategy = AdaptiveRetryStrategy; exports2.AdaptiveRetryStrategy = AdaptiveRetryStrategy;
exports2.CONFIG_MAX_ATTEMPTS = CONFIG_MAX_ATTEMPTS; exports2.CONFIG_MAX_ATTEMPTS = CONFIG_MAX_ATTEMPTS;
exports2.CONFIG_RETRY_MODE = CONFIG_RETRY_MODE; exports2.CONFIG_RETRY_MODE = CONFIG_RETRY_MODE;
@@ -32774,7 +32854,7 @@ var require_package = __commonJS({
module2.exports = { module2.exports = {
name: "@aws-sdk/client-sts", name: "@aws-sdk/client-sts",
description: "AWS SDK for JavaScript Sts Client for Node.js, Browser and React Native", description: "AWS SDK for JavaScript Sts Client for Node.js, Browser and React Native",
version: "3.1020.0", version: "3.1025.0",
scripts: { scripts: {
build: "concurrently 'yarn:build:types' 'yarn:build:es' && yarn build:cjs", build: "concurrently 'yarn:build:types' 'yarn:build:es' && yarn build:cjs",
"build:cjs": "node ../../scripts/compilation/inline client-sts", "build:cjs": "node ../../scripts/compilation/inline client-sts",
@@ -32801,16 +32881,16 @@ var require_package = __commonJS({
"@aws-crypto/sha256-browser": "5.2.0", "@aws-crypto/sha256-browser": "5.2.0",
"@aws-crypto/sha256-js": "5.2.0", "@aws-crypto/sha256-js": "5.2.0",
"@aws-sdk/core": "^3.973.26", "@aws-sdk/core": "^3.973.26",
"@aws-sdk/credential-provider-node": "^3.972.28", "@aws-sdk/credential-provider-node": "^3.972.29",
"@aws-sdk/middleware-host-header": "^3.972.8", "@aws-sdk/middleware-host-header": "^3.972.8",
"@aws-sdk/middleware-logger": "^3.972.8", "@aws-sdk/middleware-logger": "^3.972.8",
"@aws-sdk/middleware-recursion-detection": "^3.972.9", "@aws-sdk/middleware-recursion-detection": "^3.972.9",
"@aws-sdk/middleware-user-agent": "^3.972.27", "@aws-sdk/middleware-user-agent": "^3.972.28",
"@aws-sdk/region-config-resolver": "^3.972.10", "@aws-sdk/region-config-resolver": "^3.972.10",
"@aws-sdk/types": "^3.973.6", "@aws-sdk/types": "^3.973.6",
"@aws-sdk/util-endpoints": "^3.996.5", "@aws-sdk/util-endpoints": "^3.996.5",
"@aws-sdk/util-user-agent-browser": "^3.972.8", "@aws-sdk/util-user-agent-browser": "^3.972.8",
"@aws-sdk/util-user-agent-node": "^3.973.13", "@aws-sdk/util-user-agent-node": "^3.973.14",
"@smithy/config-resolver": "^4.4.13", "@smithy/config-resolver": "^4.4.13",
"@smithy/core": "^3.23.13", "@smithy/core": "^3.23.13",
"@smithy/fetch-http-handler": "^5.3.15", "@smithy/fetch-http-handler": "^5.3.15",
@@ -32818,7 +32898,7 @@ var require_package = __commonJS({
"@smithy/invalid-dependency": "^4.2.12", "@smithy/invalid-dependency": "^4.2.12",
"@smithy/middleware-content-length": "^4.2.12", "@smithy/middleware-content-length": "^4.2.12",
"@smithy/middleware-endpoint": "^4.4.28", "@smithy/middleware-endpoint": "^4.4.28",
"@smithy/middleware-retry": "^4.4.45", "@smithy/middleware-retry": "^4.4.46",
"@smithy/middleware-serde": "^4.2.16", "@smithy/middleware-serde": "^4.2.16",
"@smithy/middleware-stack": "^4.2.12", "@smithy/middleware-stack": "^4.2.12",
"@smithy/node-config-provider": "^4.3.12", "@smithy/node-config-provider": "^4.3.12",
@@ -32834,7 +32914,7 @@ var require_package = __commonJS({
"@smithy/util-defaults-mode-node": "^4.2.48", "@smithy/util-defaults-mode-node": "^4.2.48",
"@smithy/util-endpoints": "^3.3.3", "@smithy/util-endpoints": "^3.3.3",
"@smithy/util-middleware": "^4.2.12", "@smithy/util-middleware": "^4.2.12",
"@smithy/util-retry": "^4.2.12", "@smithy/util-retry": "^4.2.13",
"@smithy/util-utf8": "^4.2.2", "@smithy/util-utf8": "^4.2.2",
tslib: "^2.6.2" tslib: "^2.6.2"
}, },
@@ -33555,7 +33635,7 @@ var init_package = __esm({
"node_modules/@aws-sdk/nested-clients/package.json"() { "node_modules/@aws-sdk/nested-clients/package.json"() {
package_default = { package_default = {
name: "@aws-sdk/nested-clients", name: "@aws-sdk/nested-clients",
version: "3.996.17", version: "3.996.18",
description: "Nested clients for AWS SDK packages.", description: "Nested clients for AWS SDK packages.",
main: "./dist-cjs/index.js", main: "./dist-cjs/index.js",
module: "./dist-es/index.js", module: "./dist-es/index.js",
@@ -33588,12 +33668,12 @@ var init_package = __esm({
"@aws-sdk/middleware-host-header": "^3.972.8", "@aws-sdk/middleware-host-header": "^3.972.8",
"@aws-sdk/middleware-logger": "^3.972.8", "@aws-sdk/middleware-logger": "^3.972.8",
"@aws-sdk/middleware-recursion-detection": "^3.972.9", "@aws-sdk/middleware-recursion-detection": "^3.972.9",
"@aws-sdk/middleware-user-agent": "^3.972.27", "@aws-sdk/middleware-user-agent": "^3.972.28",
"@aws-sdk/region-config-resolver": "^3.972.10", "@aws-sdk/region-config-resolver": "^3.972.10",
"@aws-sdk/types": "^3.973.6", "@aws-sdk/types": "^3.973.6",
"@aws-sdk/util-endpoints": "^3.996.5", "@aws-sdk/util-endpoints": "^3.996.5",
"@aws-sdk/util-user-agent-browser": "^3.972.8", "@aws-sdk/util-user-agent-browser": "^3.972.8",
"@aws-sdk/util-user-agent-node": "^3.973.13", "@aws-sdk/util-user-agent-node": "^3.973.14",
"@smithy/config-resolver": "^4.4.13", "@smithy/config-resolver": "^4.4.13",
"@smithy/core": "^3.23.13", "@smithy/core": "^3.23.13",
"@smithy/fetch-http-handler": "^5.3.15", "@smithy/fetch-http-handler": "^5.3.15",
@@ -33601,7 +33681,7 @@ var init_package = __esm({
"@smithy/invalid-dependency": "^4.2.12", "@smithy/invalid-dependency": "^4.2.12",
"@smithy/middleware-content-length": "^4.2.12", "@smithy/middleware-content-length": "^4.2.12",
"@smithy/middleware-endpoint": "^4.4.28", "@smithy/middleware-endpoint": "^4.4.28",
"@smithy/middleware-retry": "^4.4.45", "@smithy/middleware-retry": "^4.4.46",
"@smithy/middleware-serde": "^4.2.16", "@smithy/middleware-serde": "^4.2.16",
"@smithy/middleware-stack": "^4.2.12", "@smithy/middleware-stack": "^4.2.12",
"@smithy/node-config-provider": "^4.3.12", "@smithy/node-config-provider": "^4.3.12",
@@ -33617,7 +33697,7 @@ var init_package = __esm({
"@smithy/util-defaults-mode-node": "^4.2.48", "@smithy/util-defaults-mode-node": "^4.2.48",
"@smithy/util-endpoints": "^3.3.3", "@smithy/util-endpoints": "^3.3.3",
"@smithy/util-middleware": "^4.2.12", "@smithy/util-middleware": "^4.2.12",
"@smithy/util-retry": "^4.2.12", "@smithy/util-retry": "^4.2.13",
"@smithy/util-utf8": "^4.2.2", "@smithy/util-utf8": "^4.2.2",
tslib: "^2.6.2" tslib: "^2.6.2"
}, },