51 lines
2.9 KiB
JavaScript
51 lines
2.9 KiB
JavaScript
|
"use strict";
|
||
|
|
Object.defineProperty(exports, "__esModule", { value: true });
|
||
|
|
exports.getSigV4AuthPlugin = exports.getAwsAuthPlugin = exports.awsAuthMiddlewareOptions = exports.awsAuthMiddleware = void 0;
|
||
|
|
const protocol_http_1 = require("@aws-sdk/protocol-http");
|
||
|
|
const getSkewCorrectedDate_1 = require("./utils/getSkewCorrectedDate");
|
||
|
|
const getUpdatedSystemClockOffset_1 = require("./utils/getUpdatedSystemClockOffset");
|
||
|
|
const awsAuthMiddleware = (options) => (next, context) => async function (args) {
|
||
|
|
var _a, _b, _c, _d;
|
||
|
|
if (!protocol_http_1.HttpRequest.isInstance(args.request))
|
||
|
|
return next(args);
|
||
|
|
const authScheme = (_c = (_b = (_a = context.endpointV2) === null || _a === void 0 ? void 0 : _a.properties) === null || _b === void 0 ? void 0 : _b.authSchemes) === null || _c === void 0 ? void 0 : _c[0];
|
||
|
|
const multiRegionOverride = (authScheme === null || authScheme === void 0 ? void 0 : authScheme.name) === "sigv4a" ? (_d = authScheme === null || authScheme === void 0 ? void 0 : authScheme.signingRegionSet) === null || _d === void 0 ? void 0 : _d.join(",") : undefined;
|
||
|
|
const signer = await options.signer(authScheme);
|
||
|
|
const output = await next({
|
||
|
|
...args,
|
||
|
|
request: await signer.sign(args.request, {
|
||
|
|
signingDate: (0, getSkewCorrectedDate_1.getSkewCorrectedDate)(options.systemClockOffset),
|
||
|
|
signingRegion: multiRegionOverride || context["signing_region"],
|
||
|
|
signingService: context["signing_service"],
|
||
|
|
}),
|
||
|
|
}).catch((error) => {
|
||
|
|
var _a;
|
||
|
|
const serverTime = (_a = error.ServerTime) !== null && _a !== void 0 ? _a : getDateHeader(error.$response);
|
||
|
|
if (serverTime) {
|
||
|
|
options.systemClockOffset = (0, getUpdatedSystemClockOffset_1.getUpdatedSystemClockOffset)(serverTime, options.systemClockOffset);
|
||
|
|
}
|
||
|
|
throw error;
|
||
|
|
});
|
||
|
|
const dateHeader = getDateHeader(output.response);
|
||
|
|
if (dateHeader) {
|
||
|
|
options.systemClockOffset = (0, getUpdatedSystemClockOffset_1.getUpdatedSystemClockOffset)(dateHeader, options.systemClockOffset);
|
||
|
|
}
|
||
|
|
return output;
|
||
|
|
};
|
||
|
|
exports.awsAuthMiddleware = awsAuthMiddleware;
|
||
|
|
const getDateHeader = (response) => { var _a, _b, _c; return protocol_http_1.HttpResponse.isInstance(response) ? (_b = (_a = response.headers) === null || _a === void 0 ? void 0 : _a.date) !== null && _b !== void 0 ? _b : (_c = response.headers) === null || _c === void 0 ? void 0 : _c.Date : undefined; };
|
||
|
|
exports.awsAuthMiddlewareOptions = {
|
||
|
|
name: "awsAuthMiddleware",
|
||
|
|
tags: ["SIGNATURE", "AWSAUTH"],
|
||
|
|
relation: "after",
|
||
|
|
toMiddleware: "retryMiddleware",
|
||
|
|
override: true,
|
||
|
|
};
|
||
|
|
const getAwsAuthPlugin = (options) => ({
|
||
|
|
applyToStack: (clientStack) => {
|
||
|
|
clientStack.addRelativeTo((0, exports.awsAuthMiddleware)(options), exports.awsAuthMiddlewareOptions);
|
||
|
|
},
|
||
|
|
});
|
||
|
|
exports.getAwsAuthPlugin = getAwsAuthPlugin;
|
||
|
|
exports.getSigV4AuthPlugin = exports.getAwsAuthPlugin;
|