@aws-sdk/middleware-eventstream
Advanced tools
@@ -1,17 +0,1 @@ | ||
| "use strict"; | ||
| Object.defineProperty(exports, "__esModule", { value: true }); | ||
| exports.resolveEventStreamConfig = void 0; | ||
| function resolveEventStreamConfig(input) { | ||
| const eventSigner = input.signer; | ||
| const messageSigner = input.signer; | ||
| const eventStreamPayloadHandler = input.eventStreamPayloadHandlerProvider({ | ||
| ...input, | ||
| messageSigner, | ||
| }); | ||
| return { | ||
| ...input, | ||
| eventSigner, | ||
| eventStreamPayloadHandler, | ||
| }; | ||
| } | ||
| exports.resolveEventStreamConfig = resolveEventStreamConfig; | ||
| module.exports = require("./index.js"); |
@@ -1,18 +0,1 @@ | ||
| "use strict"; | ||
| Object.defineProperty(exports, "__esModule", { value: true }); | ||
| exports.eventStreamHandlingMiddlewareOptions = exports.eventStreamHandlingMiddleware = void 0; | ||
| const protocol_http_1 = require("@smithy/protocol-http"); | ||
| const eventStreamHandlingMiddleware = (options) => (next, context) => async (args) => { | ||
| const { request } = args; | ||
| if (!protocol_http_1.HttpRequest.isInstance(request)) | ||
| return next(args); | ||
| return options.eventStreamPayloadHandler.handle(next, args, context); | ||
| }; | ||
| exports.eventStreamHandlingMiddleware = eventStreamHandlingMiddleware; | ||
| exports.eventStreamHandlingMiddlewareOptions = { | ||
| tags: ["EVENT_STREAM", "SIGNATURE", "HANDLE"], | ||
| name: "eventStreamHandlingMiddleware", | ||
| relation: "after", | ||
| toMiddleware: "awsAuthMiddleware", | ||
| override: true, | ||
| }; | ||
| module.exports = require("./index.js"); |
@@ -1,25 +0,1 @@ | ||
| "use strict"; | ||
| Object.defineProperty(exports, "__esModule", { value: true }); | ||
| exports.eventStreamHeaderMiddlewareOptions = exports.eventStreamHeaderMiddleware = void 0; | ||
| const protocol_http_1 = require("@smithy/protocol-http"); | ||
| const eventStreamHeaderMiddleware = (next) => async (args) => { | ||
| const { request } = args; | ||
| if (!protocol_http_1.HttpRequest.isInstance(request)) | ||
| return next(args); | ||
| request.headers = { | ||
| ...request.headers, | ||
| "Content-Type": "application/vnd.amazon.eventstream", | ||
| "x-amz-content-sha256": "STREAMING-AWS4-HMAC-SHA256-EVENTS", | ||
| }; | ||
| return next({ | ||
| ...args, | ||
| request, | ||
| }); | ||
| }; | ||
| exports.eventStreamHeaderMiddleware = eventStreamHeaderMiddleware; | ||
| exports.eventStreamHeaderMiddlewareOptions = { | ||
| step: "build", | ||
| tags: ["EVENT_STREAM", "HEADER", "CONTENT_TYPE", "CONTENT_SHA256"], | ||
| name: "eventStreamHeaderMiddleware", | ||
| override: true, | ||
| }; | ||
| module.exports = require("./index.js"); |
@@ -1,12 +0,1 @@ | ||
| "use strict"; | ||
| Object.defineProperty(exports, "__esModule", { value: true }); | ||
| exports.getEventStreamPlugin = void 0; | ||
| const eventStreamHandlingMiddleware_1 = require("./eventStreamHandlingMiddleware"); | ||
| const eventStreamHeaderMiddleware_1 = require("./eventStreamHeaderMiddleware"); | ||
| const getEventStreamPlugin = (options) => ({ | ||
| applyToStack: (clientStack) => { | ||
| clientStack.addRelativeTo((0, eventStreamHandlingMiddleware_1.eventStreamHandlingMiddleware)(options), eventStreamHandlingMiddleware_1.eventStreamHandlingMiddlewareOptions); | ||
| clientStack.add(eventStreamHeaderMiddleware_1.eventStreamHeaderMiddleware, eventStreamHeaderMiddleware_1.eventStreamHeaderMiddlewareOptions); | ||
| }, | ||
| }); | ||
| exports.getEventStreamPlugin = getEventStreamPlugin; | ||
| module.exports = require("./index.js"); |
+102
-7
@@ -1,7 +0,102 @@ | ||
| "use strict"; | ||
| Object.defineProperty(exports, "__esModule", { value: true }); | ||
| const tslib_1 = require("tslib"); | ||
| tslib_1.__exportStar(require("./eventStreamConfiguration"), exports); | ||
| tslib_1.__exportStar(require("./eventStreamHandlingMiddleware"), exports); | ||
| tslib_1.__exportStar(require("./eventStreamHeaderMiddleware"), exports); | ||
| tslib_1.__exportStar(require("./getEventStreamPlugin"), exports); | ||
| var __defProp = Object.defineProperty; | ||
| var __getOwnPropDesc = Object.getOwnPropertyDescriptor; | ||
| var __getOwnPropNames = Object.getOwnPropertyNames; | ||
| var __hasOwnProp = Object.prototype.hasOwnProperty; | ||
| var __name = (target, value) => __defProp(target, "name", { value, configurable: true }); | ||
| var __export = (target, all) => { | ||
| for (var name in all) | ||
| __defProp(target, name, { get: all[name], enumerable: true }); | ||
| }; | ||
| var __copyProps = (to, from, except, desc) => { | ||
| if (from && typeof from === "object" || typeof from === "function") { | ||
| for (let key of __getOwnPropNames(from)) | ||
| if (!__hasOwnProp.call(to, key) && key !== except) | ||
| __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable }); | ||
| } | ||
| return to; | ||
| }; | ||
| var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod); | ||
| // src/index.ts | ||
| var src_exports = {}; | ||
| __export(src_exports, { | ||
| eventStreamHandlingMiddleware: () => eventStreamHandlingMiddleware, | ||
| eventStreamHandlingMiddlewareOptions: () => eventStreamHandlingMiddlewareOptions, | ||
| eventStreamHeaderMiddleware: () => eventStreamHeaderMiddleware, | ||
| eventStreamHeaderMiddlewareOptions: () => eventStreamHeaderMiddlewareOptions, | ||
| getEventStreamPlugin: () => getEventStreamPlugin, | ||
| resolveEventStreamConfig: () => resolveEventStreamConfig | ||
| }); | ||
| module.exports = __toCommonJS(src_exports); | ||
| // src/eventStreamConfiguration.ts | ||
| function resolveEventStreamConfig(input) { | ||
| const eventSigner = input.signer; | ||
| const messageSigner = input.signer; | ||
| const eventStreamPayloadHandler = input.eventStreamPayloadHandlerProvider({ | ||
| ...input, | ||
| messageSigner | ||
| }); | ||
| return { | ||
| ...input, | ||
| eventSigner, | ||
| eventStreamPayloadHandler | ||
| }; | ||
| } | ||
| __name(resolveEventStreamConfig, "resolveEventStreamConfig"); | ||
| // src/eventStreamHandlingMiddleware.ts | ||
| var import_protocol_http = require("@smithy/protocol-http"); | ||
| var eventStreamHandlingMiddleware = /* @__PURE__ */ __name((options) => (next, context) => async (args) => { | ||
| const { request } = args; | ||
| if (!import_protocol_http.HttpRequest.isInstance(request)) | ||
| return next(args); | ||
| return options.eventStreamPayloadHandler.handle(next, args, context); | ||
| }, "eventStreamHandlingMiddleware"); | ||
| var eventStreamHandlingMiddlewareOptions = { | ||
| tags: ["EVENT_STREAM", "SIGNATURE", "HANDLE"], | ||
| name: "eventStreamHandlingMiddleware", | ||
| relation: "after", | ||
| toMiddleware: "awsAuthMiddleware", | ||
| override: true | ||
| }; | ||
| // src/eventStreamHeaderMiddleware.ts | ||
| var eventStreamHeaderMiddleware = /* @__PURE__ */ __name((next) => async (args) => { | ||
| const { request } = args; | ||
| if (!import_protocol_http.HttpRequest.isInstance(request)) | ||
| return next(args); | ||
| request.headers = { | ||
| ...request.headers, | ||
| "Content-Type": "application/vnd.amazon.eventstream", | ||
| "x-amz-content-sha256": "STREAMING-AWS4-HMAC-SHA256-EVENTS" | ||
| }; | ||
| return next({ | ||
| ...args, | ||
| request | ||
| }); | ||
| }, "eventStreamHeaderMiddleware"); | ||
| var eventStreamHeaderMiddlewareOptions = { | ||
| step: "build", | ||
| tags: ["EVENT_STREAM", "HEADER", "CONTENT_TYPE", "CONTENT_SHA256"], | ||
| name: "eventStreamHeaderMiddleware", | ||
| override: true | ||
| }; | ||
| // src/getEventStreamPlugin.ts | ||
| var getEventStreamPlugin = /* @__PURE__ */ __name((options) => ({ | ||
| applyToStack: (clientStack) => { | ||
| clientStack.addRelativeTo(eventStreamHandlingMiddleware(options), eventStreamHandlingMiddlewareOptions); | ||
| clientStack.add(eventStreamHeaderMiddleware, eventStreamHeaderMiddlewareOptions); | ||
| } | ||
| }), "getEventStreamPlugin"); | ||
| // Annotate the CommonJS export names for ESM import in node: | ||
| 0 && (module.exports = { | ||
| eventStreamHandlingMiddleware, | ||
| eventStreamHandlingMiddlewareOptions, | ||
| eventStreamHeaderMiddleware, | ||
| eventStreamHeaderMiddlewareOptions, | ||
| getEventStreamPlugin, | ||
| resolveEventStreamConfig | ||
| }); |
+5
-5
| { | ||
| "name": "@aws-sdk/middleware-eventstream", | ||
| "version": "3.489.0", | ||
| "version": "3.495.0", | ||
| "scripts": { | ||
| "build": "concurrently 'yarn:build:cjs' 'yarn:build:es' 'yarn:build:types'", | ||
| "build:cjs": "tsc -p tsconfig.cjs.json", | ||
| "build:cjs": "node ../../scripts/compilation/inline middleware-eventstream", | ||
| "build:es": "tsc -p tsconfig.es.json", | ||
@@ -24,5 +24,5 @@ "build:include:deps": "lerna run --scope $npm_package_name --include-dependencies build", | ||
| "dependencies": { | ||
| "@aws-sdk/types": "3.489.0", | ||
| "@smithy/protocol-http": "^3.0.12", | ||
| "@smithy/types": "^2.8.0", | ||
| "@aws-sdk/types": "3.495.0", | ||
| "@smithy/protocol-http": "^3.1.0", | ||
| "@smithy/types": "^2.9.0", | ||
| "tslib": "^2.5.0" | ||
@@ -29,0 +29,0 @@ }, |
23138
2.45%239
7.66%+ Added
- Removed
Updated
Updated
Updated