Socket
Socket
Sign inDemoInstall

@aws-sdk/middleware-eventstream

Package Overview
Dependencies
Maintainers
5
Versions
150
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@aws-sdk/middleware-eventstream - npm Package Compare versions

Comparing version 3.489.0 to 3.495.0

18

dist-cjs/eventStreamConfiguration.js

@@ -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");

109

dist-cjs/index.js

@@ -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
});
{
"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 @@ },

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc