@aws-sdk/middleware-stack
Advanced tools
Comparing version 3.178.0 to 3.183.0
@@ -6,2 +6,10 @@ # Change Log | ||
# [3.183.0](https://github.com/aws/aws-sdk-js-v3/compare/v3.182.0...v3.183.0) (2022-10-03) | ||
**Note:** Version bump only for package @aws-sdk/middleware-stack | ||
# [3.178.0](https://github.com/aws/aws-sdk-js-v3/compare/v3.177.0...v3.178.0) (2022-09-23) | ||
@@ -8,0 +16,0 @@ |
@@ -1,15 +0,10 @@ | ||
import { __assign, __read, __spreadArray, __values } from "tslib"; | ||
export var constructStack = function () { | ||
var absoluteEntries = []; | ||
var relativeEntries = []; | ||
var entriesNameSet = new Set(); | ||
var sort = function (entries) { | ||
return entries.sort(function (a, b) { | ||
return stepWeights[b.step] - stepWeights[a.step] || | ||
priorityWeights[b.priority || "normal"] - priorityWeights[a.priority || "normal"]; | ||
}); | ||
}; | ||
var removeByName = function (toRemove) { | ||
var isRemoved = false; | ||
var filterCb = function (entry) { | ||
export const constructStack = () => { | ||
let absoluteEntries = []; | ||
let relativeEntries = []; | ||
const entriesNameSet = new Set(); | ||
const sort = (entries) => entries.sort((a, b) => stepWeights[b.step] - stepWeights[a.step] || | ||
priorityWeights[b.priority || "normal"] - priorityWeights[a.priority || "normal"]); | ||
const removeByName = (toRemove) => { | ||
let isRemoved = false; | ||
const filterCb = (entry) => { | ||
if (entry.name && entry.name === toRemove) { | ||
@@ -26,5 +21,5 @@ isRemoved = true; | ||
}; | ||
var removeByReference = function (toRemove) { | ||
var isRemoved = false; | ||
var filterCb = function (entry) { | ||
const removeByReference = (toRemove) => { | ||
let isRemoved = false; | ||
const filterCb = (entry) => { | ||
if (entry.middleware === toRemove) { | ||
@@ -42,14 +37,14 @@ isRemoved = true; | ||
}; | ||
var cloneTo = function (toStack) { | ||
absoluteEntries.forEach(function (entry) { | ||
toStack.add(entry.middleware, __assign({}, entry)); | ||
const cloneTo = (toStack) => { | ||
absoluteEntries.forEach((entry) => { | ||
toStack.add(entry.middleware, { ...entry }); | ||
}); | ||
relativeEntries.forEach(function (entry) { | ||
toStack.addRelativeTo(entry.middleware, __assign({}, entry)); | ||
relativeEntries.forEach((entry) => { | ||
toStack.addRelativeTo(entry.middleware, { ...entry }); | ||
}); | ||
return toStack; | ||
}; | ||
var expandRelativeMiddlewareList = function (from) { | ||
var expandedMiddlewareList = []; | ||
from.before.forEach(function (entry) { | ||
const expandRelativeMiddlewareList = (from) => { | ||
const expandedMiddlewareList = []; | ||
from.before.forEach((entry) => { | ||
if (entry.before.length === 0 && entry.after.length === 0) { | ||
@@ -59,7 +54,7 @@ expandedMiddlewareList.push(entry); | ||
else { | ||
expandedMiddlewareList.push.apply(expandedMiddlewareList, __spreadArray([], __read(expandRelativeMiddlewareList(entry)), false)); | ||
expandedMiddlewareList.push(...expandRelativeMiddlewareList(entry)); | ||
} | ||
}); | ||
expandedMiddlewareList.push(from); | ||
from.after.reverse().forEach(function (entry) { | ||
from.after.reverse().forEach((entry) => { | ||
if (entry.before.length === 0 && entry.after.length === 0) { | ||
@@ -69,3 +64,3 @@ expandedMiddlewareList.push(entry); | ||
else { | ||
expandedMiddlewareList.push.apply(expandedMiddlewareList, __spreadArray([], __read(expandRelativeMiddlewareList(entry)), false)); | ||
expandedMiddlewareList.push(...expandRelativeMiddlewareList(entry)); | ||
} | ||
@@ -75,9 +70,12 @@ }); | ||
}; | ||
var getMiddlewareList = function (debug) { | ||
if (debug === void 0) { debug = false; } | ||
var normalizedAbsoluteEntries = []; | ||
var normalizedRelativeEntries = []; | ||
var normalizedEntriesNameMap = {}; | ||
absoluteEntries.forEach(function (entry) { | ||
var normalizedEntry = __assign(__assign({}, entry), { before: [], after: [] }); | ||
const getMiddlewareList = (debug = false) => { | ||
const normalizedAbsoluteEntries = []; | ||
const normalizedRelativeEntries = []; | ||
const normalizedEntriesNameMap = {}; | ||
absoluteEntries.forEach((entry) => { | ||
const normalizedEntry = { | ||
...entry, | ||
before: [], | ||
after: [], | ||
}; | ||
if (normalizedEntry.name) | ||
@@ -87,4 +85,8 @@ normalizedEntriesNameMap[normalizedEntry.name] = normalizedEntry; | ||
}); | ||
relativeEntries.forEach(function (entry) { | ||
var normalizedEntry = __assign(__assign({}, entry), { before: [], after: [] }); | ||
relativeEntries.forEach((entry) => { | ||
const normalizedEntry = { | ||
...entry, | ||
before: [], | ||
after: [], | ||
}; | ||
if (normalizedEntry.name) | ||
@@ -94,5 +96,5 @@ normalizedEntriesNameMap[normalizedEntry.name] = normalizedEntry; | ||
}); | ||
normalizedRelativeEntries.forEach(function (entry) { | ||
normalizedRelativeEntries.forEach((entry) => { | ||
if (entry.toMiddleware) { | ||
var toMiddleware = normalizedEntriesNameMap[entry.toMiddleware]; | ||
const toMiddleware = normalizedEntriesNameMap[entry.toMiddleware]; | ||
if (toMiddleware === undefined) { | ||
@@ -102,3 +104,3 @@ if (debug) { | ||
} | ||
throw new Error("".concat(entry.toMiddleware, " is not found when adding ").concat(entry.name || "anonymous", " middleware ").concat(entry.relation, " ").concat(entry.toMiddleware)); | ||
throw new Error(`${entry.toMiddleware} is not found when adding ${entry.name || "anonymous"} middleware ${entry.relation} ${entry.toMiddleware}`); | ||
} | ||
@@ -113,6 +115,6 @@ if (entry.relation === "after") { | ||
}); | ||
var mainChain = sort(normalizedAbsoluteEntries) | ||
const mainChain = sort(normalizedAbsoluteEntries) | ||
.map(expandRelativeMiddlewareList) | ||
.reduce(function (wholeList, expendedMiddlewareList) { | ||
wholeList.push.apply(wholeList, __spreadArray([], __read(expendedMiddlewareList), false)); | ||
.reduce((wholeList, expendedMiddlewareList) => { | ||
wholeList.push(...expendedMiddlewareList); | ||
return wholeList; | ||
@@ -122,16 +124,20 @@ }, []); | ||
}; | ||
var stack = { | ||
add: function (middleware, options) { | ||
if (options === void 0) { options = {}; } | ||
var name = options.name, override = options.override; | ||
var entry = __assign({ step: "initialize", priority: "normal", middleware: middleware }, options); | ||
const stack = { | ||
add: (middleware, options = {}) => { | ||
const { name, override } = options; | ||
const entry = { | ||
step: "initialize", | ||
priority: "normal", | ||
middleware, | ||
...options, | ||
}; | ||
if (name) { | ||
if (entriesNameSet.has(name)) { | ||
if (!override) | ||
throw new Error("Duplicate middleware name '".concat(name, "'")); | ||
var toOverrideIndex = absoluteEntries.findIndex(function (entry) { return entry.name === name; }); | ||
var toOverride = absoluteEntries[toOverrideIndex]; | ||
throw new Error(`Duplicate middleware name '${name}'`); | ||
const toOverrideIndex = absoluteEntries.findIndex((entry) => entry.name === name); | ||
const toOverride = absoluteEntries[toOverrideIndex]; | ||
if (toOverride.step !== entry.step || toOverride.priority !== entry.priority) { | ||
throw new Error("\"".concat(name, "\" middleware with ").concat(toOverride.priority, " priority in ").concat(toOverride.step, " step cannot be ") + | ||
"overridden by same-name middleware with ".concat(entry.priority, " priority in ").concat(entry.step, " step.")); | ||
throw new Error(`"${name}" middleware with ${toOverride.priority} priority in ${toOverride.step} step cannot be ` + | ||
`overridden by same-name middleware with ${entry.priority} priority in ${entry.step} step.`); | ||
} | ||
@@ -144,14 +150,17 @@ absoluteEntries.splice(toOverrideIndex, 1); | ||
}, | ||
addRelativeTo: function (middleware, options) { | ||
var name = options.name, override = options.override; | ||
var entry = __assign({ middleware: middleware }, options); | ||
addRelativeTo: (middleware, options) => { | ||
const { name, override } = options; | ||
const entry = { | ||
middleware, | ||
...options, | ||
}; | ||
if (name) { | ||
if (entriesNameSet.has(name)) { | ||
if (!override) | ||
throw new Error("Duplicate middleware name '".concat(name, "'")); | ||
var toOverrideIndex = relativeEntries.findIndex(function (entry) { return entry.name === name; }); | ||
var toOverride = relativeEntries[toOverrideIndex]; | ||
throw new Error(`Duplicate middleware name '${name}'`); | ||
const toOverrideIndex = relativeEntries.findIndex((entry) => entry.name === name); | ||
const toOverride = relativeEntries[toOverrideIndex]; | ||
if (toOverride.toMiddleware !== entry.toMiddleware || toOverride.relation !== entry.relation) { | ||
throw new Error("\"".concat(name, "\" middleware ").concat(toOverride.relation, " \"").concat(toOverride.toMiddleware, "\" middleware cannot be overridden ") + | ||
"by same-name middleware ".concat(entry.relation, " \"").concat(entry.toMiddleware, "\" middleware.")); | ||
throw new Error(`"${name}" middleware ${toOverride.relation} "${toOverride.toMiddleware}" middleware cannot be overridden ` + | ||
`by same-name middleware ${entry.relation} "${entry.toMiddleware}" middleware.`); | ||
} | ||
@@ -164,7 +173,7 @@ relativeEntries.splice(toOverrideIndex, 1); | ||
}, | ||
clone: function () { return cloneTo(constructStack()); }, | ||
use: function (plugin) { | ||
clone: () => cloneTo(constructStack()), | ||
use: (plugin) => { | ||
plugin.applyToStack(stack); | ||
}, | ||
remove: function (toRemove) { | ||
remove: (toRemove) => { | ||
if (typeof toRemove === "string") | ||
@@ -175,6 +184,6 @@ return removeByName(toRemove); | ||
}, | ||
removeByTag: function (toRemove) { | ||
var isRemoved = false; | ||
var filterCb = function (entry) { | ||
var tags = entry.tags, name = entry.name; | ||
removeByTag: (toRemove) => { | ||
let isRemoved = false; | ||
const filterCb = (entry) => { | ||
const { tags, name } = entry; | ||
if (tags && tags.includes(toRemove)) { | ||
@@ -192,4 +201,4 @@ if (name) | ||
}, | ||
concat: function (from) { | ||
var cloned = cloneTo(constructStack()); | ||
concat: (from) => { | ||
const cloned = cloneTo(constructStack()); | ||
cloned.use(from); | ||
@@ -199,24 +208,13 @@ return cloned; | ||
applyToStack: cloneTo, | ||
identify: function () { | ||
return getMiddlewareList(true).map(function (mw) { | ||
identify: () => { | ||
return getMiddlewareList(true).map((mw) => { | ||
return mw.name + ": " + (mw.tags || []).join(","); | ||
}); | ||
}, | ||
resolve: function (handler, context) { | ||
var e_1, _a; | ||
try { | ||
for (var _b = __values(getMiddlewareList() | ||
.map(function (entry) { return entry.middleware; }) | ||
.reverse()), _c = _b.next(); !_c.done; _c = _b.next()) { | ||
var middleware = _c.value; | ||
handler = middleware(handler, context); | ||
} | ||
resolve: (handler, context) => { | ||
for (const middleware of getMiddlewareList() | ||
.map((entry) => entry.middleware) | ||
.reverse()) { | ||
handler = middleware(handler, context); | ||
} | ||
catch (e_1_1) { e_1 = { error: e_1_1 }; } | ||
finally { | ||
try { | ||
if (_c && !_c.done && (_a = _b.return)) _a.call(_b); | ||
} | ||
finally { if (e_1) throw e_1.error; } | ||
} | ||
return handler; | ||
@@ -227,3 +225,3 @@ }, | ||
}; | ||
var stepWeights = { | ||
const stepWeights = { | ||
initialize: 5, | ||
@@ -235,3 +233,3 @@ serialize: 4, | ||
}; | ||
var priorityWeights = { | ||
const priorityWeights = { | ||
high: 3, | ||
@@ -238,0 +236,0 @@ normal: 2, |
{ | ||
"name": "@aws-sdk/middleware-stack", | ||
"version": "3.178.0", | ||
"version": "3.183.0", | ||
"description": "Provides a means for composing multiple middleware functions into a single handler", | ||
@@ -28,3 +28,3 @@ "scripts": { | ||
"devDependencies": { | ||
"@aws-sdk/types": "3.178.0", | ||
"@aws-sdk/types": "3.183.0", | ||
"@tsconfig/recommended": "1.0.1", | ||
@@ -31,0 +31,0 @@ "concurrently": "7.0.0", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
76379
532