Socket
Socket
Sign inDemoInstall

@aws-sdk/eventstream-handler-node

Package Overview
Dependencies
Maintainers
5
Versions
145
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@aws-sdk/eventstream-handler-node - npm Package Compare versions

Comparing version 1.0.0-gamma.7 to 1.0.0-rc.1

11

CHANGELOG.md

@@ -6,2 +6,13 @@ # Change Log

# [1.0.0-rc.1](https://github.com/aws/aws-sdk-js-v3/compare/v1.0.0-gamma.11...v1.0.0-rc.1) (2020-10-19)
### Features
* ready for release candidate ([#1578](https://github.com/aws/aws-sdk-js-v3/issues/1578)) ([519f66c](https://github.com/aws/aws-sdk-js-v3/commit/519f66c6388b91d0bd750a511e6d1af56196835e))
# [1.0.0-gamma.7](https://github.com/aws/aws-sdk-js-v3/compare/@aws-sdk/eventstream-handler-node@1.0.0-gamma.6...@aws-sdk/eventstream-handler-node@1.0.0-gamma.7) (2020-10-07)

@@ -8,0 +19,0 @@

104

dist/cjs/EventSigningStream.js
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.EventSigningStream = void 0;
var tslib_1 = require("tslib");
var stream_1 = require("stream");
const stream_1 = require("stream");
/**
* A transform stream that signs the eventstream
*/
var EventSigningStream = /** @class */ (function (_super) {
tslib_1.__extends(EventSigningStream, _super);
function EventSigningStream(options) {
var _this = _super.call(this, tslib_1.__assign({ readableObjectMode: true, writableObjectMode: true }, options)) || this;
_this.priorSignature = options.priorSignature;
_this.eventSigner = options.eventSigner;
_this.eventMarshaller = options.eventMarshaller;
class EventSigningStream extends stream_1.Transform {
constructor(options) {
super({
readableObjectMode: true,
writableObjectMode: true,
...options,
});
this.priorSignature = options.priorSignature;
this.eventSigner = options.eventSigner;
this.eventMarshaller = options.eventMarshaller;
//TODO: use 'autoDestroy' when targeting Node 11
//reference: https://nodejs.org/dist/latest-v13.x/docs/api/stream.html#stream_new_stream_readable_options
_this.on("error", function () {
_this.destroy();
this.on("error", () => {
this.destroy();
});
_this.on("end", function () {
_this.destroy();
this.on("end", () => {
this.destroy();
});
return _this;
}
EventSigningStream.prototype._transform = function (chunk, encoding, callback) {
return tslib_1.__awaiter(this, void 0, void 0, function () {
var now, dateHeader, signature, serializedSigned, err_1;
return tslib_1.__generator(this, function (_a) {
switch (_a.label) {
case 0:
_a.trys.push([0, 2, , 3]);
now = new Date();
dateHeader = {
":date": { type: "timestamp", value: now },
};
return [4 /*yield*/, this.eventSigner.sign({
payload: chunk,
headers: this.eventMarshaller.formatHeaders(dateHeader),
}, {
priorSignature: this.priorSignature,
signingDate: now,
})];
case 1:
signature = _a.sent();
this.priorSignature = signature;
serializedSigned = this.eventMarshaller.marshall({
headers: tslib_1.__assign(tslib_1.__assign({}, dateHeader), { ":chunk-signature": {
type: "binary",
value: getSignatureBinary(signature),
} }),
body: chunk,
});
this.push(serializedSigned);
return [2 /*return*/, callback()];
case 2:
err_1 = _a.sent();
callback(err_1);
return [3 /*break*/, 3];
case 3: return [2 /*return*/];
}
async _transform(chunk, encoding, callback) {
try {
const now = new Date();
const dateHeader = {
":date": { type: "timestamp", value: now },
};
const signature = await this.eventSigner.sign({
payload: chunk,
headers: this.eventMarshaller.formatHeaders(dateHeader),
}, {
priorSignature: this.priorSignature,
signingDate: now,
});
});
};
return EventSigningStream;
}(stream_1.Transform));
this.priorSignature = signature;
const serializedSigned = this.eventMarshaller.marshall({
headers: {
...dateHeader,
":chunk-signature": {
type: "binary",
value: getSignatureBinary(signature),
},
},
body: chunk,
});
this.push(serializedSigned);
return callback();
}
catch (err) {
callback(err);
}
}
}
exports.EventSigningStream = EventSigningStream;
function getSignatureBinary(signature) {
var buf = Buffer.from(signature, "hex");
const buf = Buffer.from(signature, "hex");
return new Uint8Array(buf.buffer, buf.byteOffset, buf.byteLength / Uint8Array.BYTES_PER_ELEMENT);
}
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiRXZlbnRTaWduaW5nU3RyZWFtLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vc3JjL0V2ZW50U2lnbmluZ1N0cmVhbS50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7O0FBRUEsaUNBQXdFO0FBUXhFOztHQUVHO0FBQ0g7SUFBd0MsOENBQVM7SUFJL0MsNEJBQVksT0FBa0M7UUFBOUMsWUFDRSxxQ0FDRSxrQkFBa0IsRUFBRSxJQUFJLEVBQ3hCLGtCQUFrQixFQUFFLElBQUksSUFDckIsT0FBTyxFQUNWLFNBWUg7UUFYQyxLQUFJLENBQUMsY0FBYyxHQUFHLE9BQU8sQ0FBQyxjQUFjLENBQUM7UUFDN0MsS0FBSSxDQUFDLFdBQVcsR0FBRyxPQUFPLENBQUMsV0FBVyxDQUFDO1FBQ3ZDLEtBQUksQ0FBQyxlQUFlLEdBQUcsT0FBTyxDQUFDLGVBQWUsQ0FBQztRQUMvQyxnREFBZ0Q7UUFDaEQseUdBQXlHO1FBQ3pHLEtBQUksQ0FBQyxFQUFFLENBQUMsT0FBTyxFQUFFO1lBQ2YsS0FBSSxDQUFDLE9BQU8sRUFBRSxDQUFDO1FBQ2pCLENBQUMsQ0FBQyxDQUFDO1FBQ0gsS0FBSSxDQUFDLEVBQUUsQ0FBQyxLQUFLLEVBQUU7WUFDYixLQUFJLENBQUMsT0FBTyxFQUFFLENBQUM7UUFDakIsQ0FBQyxDQUFDLENBQUM7O0lBQ0wsQ0FBQztJQUVLLHVDQUFVLEdBQWhCLFVBQWlCLEtBQWlCLEVBQUUsUUFBZ0IsRUFBRSxRQUEyQjs7Ozs7Ozt3QkFFdkUsR0FBRyxHQUFHLElBQUksSUFBSSxFQUFFLENBQUM7d0JBQ2pCLFVBQVUsR0FBbUI7NEJBQ2pDLE9BQU8sRUFBRSxFQUFFLElBQUksRUFBRSxXQUFXLEVBQUUsS0FBSyxFQUFFLEdBQUcsRUFBRTt5QkFDM0MsQ0FBQzt3QkFDZ0IscUJBQU0sSUFBSSxDQUFDLFdBQVcsQ0FBQyxJQUFJLENBQzNDO2dDQUNFLE9BQU8sRUFBRSxLQUFLO2dDQUNkLE9BQU8sRUFBRSxJQUFJLENBQUMsZUFBZSxDQUFDLGFBQWEsQ0FBQyxVQUFVLENBQUM7NkJBQ3hELEVBQ0Q7Z0NBQ0UsY0FBYyxFQUFFLElBQUksQ0FBQyxjQUFjO2dDQUNuQyxXQUFXLEVBQUUsR0FBRzs2QkFDakIsQ0FDRixFQUFBOzt3QkFUSyxTQUFTLEdBQUcsU0FTakI7d0JBQ0QsSUFBSSxDQUFDLGNBQWMsR0FBRyxTQUFTLENBQUM7d0JBQzFCLGdCQUFnQixHQUFHLElBQUksQ0FBQyxlQUFlLENBQUMsUUFBUSxDQUFDOzRCQUNyRCxPQUFPLHdDQUNGLFVBQVUsS0FDYixrQkFBa0IsRUFBRTtvQ0FDbEIsSUFBSSxFQUFFLFFBQVE7b0NBQ2QsS0FBSyxFQUFFLGtCQUFrQixDQUFDLFNBQVMsQ0FBQztpQ0FDckMsR0FDRjs0QkFDRCxJQUFJLEVBQUUsS0FBSzt5QkFDWixDQUFDLENBQUM7d0JBQ0gsSUFBSSxDQUFDLElBQUksQ0FBQyxnQkFBZ0IsQ0FBQyxDQUFDO3dCQUM1QixzQkFBTyxRQUFRLEVBQUUsRUFBQzs7O3dCQUVsQixRQUFRLENBQUMsS0FBRyxDQUFDLENBQUM7Ozs7OztLQUVqQjtJQUNILHlCQUFDO0FBQUQsQ0FBQyxBQXhERCxDQUF3QyxrQkFBUyxHQXdEaEQ7QUF4RFksZ0RBQWtCO0FBMEQvQixTQUFTLGtCQUFrQixDQUFDLFNBQWlCO0lBQzNDLElBQU0sR0FBRyxHQUFHLE1BQU0sQ0FBQyxJQUFJLENBQUMsU0FBUyxFQUFFLEtBQUssQ0FBQyxDQUFDO0lBQzFDLE9BQU8sSUFBSSxVQUFVLENBQUMsR0FBRyxDQUFDLE1BQU0sRUFBRSxHQUFHLENBQUMsVUFBVSxFQUFFLEdBQUcsQ0FBQyxVQUFVLEdBQUcsVUFBVSxDQUFDLGlCQUFpQixDQUFDLENBQUM7QUFDbkcsQ0FBQyIsInNvdXJjZXNDb250ZW50IjpbImltcG9ydCB7IEV2ZW50U3RyZWFtTWFyc2hhbGxlciBhcyBFdmVudE1hcnNoYWxsZXIgfSBmcm9tIFwiQGF3cy1zZGsvZXZlbnRzdHJlYW0tbWFyc2hhbGxlclwiO1xuaW1wb3J0IHsgRXZlbnRTaWduZXIsIE1lc3NhZ2VIZWFkZXJzIH0gZnJvbSBcIkBhd3Mtc2RrL3R5cGVzXCI7XG5pbXBvcnQgeyBUcmFuc2Zvcm0sIFRyYW5zZm9ybUNhbGxiYWNrLCBUcmFuc2Zvcm1PcHRpb25zIH0gZnJvbSBcInN0cmVhbVwiO1xuXG5leHBvcnQgaW50ZXJmYWNlIEV2ZW50U2lnbmluZ1N0cmVhbU9wdGlvbnMgZXh0ZW5kcyBUcmFuc2Zvcm1PcHRpb25zIHtcbiAgcHJpb3JTaWduYXR1cmU6IHN0cmluZztcbiAgZXZlbnRTaWduZXI6IEV2ZW50U2lnbmVyO1xuICBldmVudE1hcnNoYWxsZXI6IEV2ZW50TWFyc2hhbGxlcjtcbn1cblxuLyoqXG4gKiBBIHRyYW5zZm9ybSBzdHJlYW0gdGhhdCBzaWducyB0aGUgZXZlbnRzdHJlYW1cbiAqL1xuZXhwb3J0IGNsYXNzIEV2ZW50U2lnbmluZ1N0cmVhbSBleHRlbmRzIFRyYW5zZm9ybSB7XG4gIHByaXZhdGUgcHJpb3JTaWduYXR1cmU6IHN0cmluZztcbiAgcHJpdmF0ZSBldmVudFNpZ25lcjogRXZlbnRTaWduZXI7XG4gIHByaXZhdGUgZXZlbnRNYXJzaGFsbGVyOiBFdmVudE1hcnNoYWxsZXI7XG4gIGNvbnN0cnVjdG9yKG9wdGlvbnM6IEV2ZW50U2lnbmluZ1N0cmVhbU9wdGlvbnMpIHtcbiAgICBzdXBlcih7XG4gICAgICByZWFkYWJsZU9iamVjdE1vZGU6IHRydWUsXG4gICAgICB3cml0YWJsZU9iamVjdE1vZGU6IHRydWUsXG4gICAgICAuLi5vcHRpb25zLFxuICAgIH0pO1xuICAgIHRoaXMucHJpb3JTaWduYXR1cmUgPSBvcHRpb25zLnByaW9yU2lnbmF0dXJlO1xuICAgIHRoaXMuZXZlbnRTaWduZXIgPSBvcHRpb25zLmV2ZW50U2lnbmVyO1xuICAgIHRoaXMuZXZlbnRNYXJzaGFsbGVyID0gb3B0aW9ucy5ldmVudE1hcnNoYWxsZXI7XG4gICAgLy9UT0RPOiB1c2UgJ2F1dG9EZXN0cm95JyB3aGVuIHRhcmdldGluZyBOb2RlIDExXG4gICAgLy9yZWZlcmVuY2U6IGh0dHBzOi8vbm9kZWpzLm9yZy9kaXN0L2xhdGVzdC12MTMueC9kb2NzL2FwaS9zdHJlYW0uaHRtbCNzdHJlYW1fbmV3X3N0cmVhbV9yZWFkYWJsZV9vcHRpb25zXG4gICAgdGhpcy5vbihcImVycm9yXCIsICgpID0+IHtcbiAgICAgIHRoaXMuZGVzdHJveSgpO1xuICAgIH0pO1xuICAgIHRoaXMub24oXCJlbmRcIiwgKCkgPT4ge1xuICAgICAgdGhpcy5kZXN0cm95KCk7XG4gICAgfSk7XG4gIH1cblxuICBhc3luYyBfdHJhbnNmb3JtKGNodW5rOiBVaW50OEFycmF5LCBlbmNvZGluZzogc3RyaW5nLCBjYWxsYmFjazogVHJhbnNmb3JtQ2FsbGJhY2spOiBQcm9taXNlPHZvaWQ+IHtcbiAgICB0cnkge1xuICAgICAgY29uc3Qgbm93ID0gbmV3IERhdGUoKTtcbiAgICAgIGNvbnN0IGRhdGVIZWFkZXI6IE1lc3NhZ2VIZWFkZXJzID0ge1xuICAgICAgICBcIjpkYXRlXCI6IHsgdHlwZTogXCJ0aW1lc3RhbXBcIiwgdmFsdWU6IG5vdyB9LFxuICAgICAgfTtcbiAgICAgIGNvbnN0IHNpZ25hdHVyZSA9IGF3YWl0IHRoaXMuZXZlbnRTaWduZXIuc2lnbihcbiAgICAgICAge1xuICAgICAgICAgIHBheWxvYWQ6IGNodW5rLFxuICAgICAgICAgIGhlYWRlcnM6IHRoaXMuZXZlbnRNYXJzaGFsbGVyLmZvcm1hdEhlYWRlcnMoZGF0ZUhlYWRlciksXG4gICAgICAgIH0sXG4gICAgICAgIHtcbiAgICAgICAgICBwcmlvclNpZ25hdHVyZTogdGhpcy5wcmlvclNpZ25hdHVyZSxcbiAgICAgICAgICBzaWduaW5nRGF0ZTogbm93LFxuICAgICAgICB9XG4gICAgICApO1xuICAgICAgdGhpcy5wcmlvclNpZ25hdHVyZSA9IHNpZ25hdHVyZTtcbiAgICAgIGNvbnN0IHNlcmlhbGl6ZWRTaWduZWQgPSB0aGlzLmV2ZW50TWFyc2hhbGxlci5tYXJzaGFsbCh7XG4gICAgICAgIGhlYWRlcnM6IHtcbiAgICAgICAgICAuLi5kYXRlSGVhZGVyLFxuICAgICAgICAgIFwiOmNodW5rLXNpZ25hdHVyZVwiOiB7XG4gICAgICAgICAgICB0eXBlOiBcImJpbmFyeVwiLFxuICAgICAgICAgICAgdmFsdWU6IGdldFNpZ25hdHVyZUJpbmFyeShzaWduYXR1cmUpLFxuICAgICAgICAgIH0sXG4gICAgICAgIH0sXG4gICAgICAgIGJvZHk6IGNodW5rLFxuICAgICAgfSk7XG4gICAgICB0aGlzLnB1c2goc2VyaWFsaXplZFNpZ25lZCk7XG4gICAgICByZXR1cm4gY2FsbGJhY2soKTtcbiAgICB9IGNhdGNoIChlcnIpIHtcbiAgICAgIGNhbGxiYWNrKGVycik7XG4gICAgfVxuICB9XG59XG5cbmZ1bmN0aW9uIGdldFNpZ25hdHVyZUJpbmFyeShzaWduYXR1cmU6IHN0cmluZyk6IFVpbnQ4QXJyYXkge1xuICBjb25zdCBidWYgPSBCdWZmZXIuZnJvbShzaWduYXR1cmUsIFwiaGV4XCIpO1xuICByZXR1cm4gbmV3IFVpbnQ4QXJyYXkoYnVmLmJ1ZmZlciwgYnVmLmJ5dGVPZmZzZXQsIGJ1Zi5ieXRlTGVuZ3RoIC8gVWludDhBcnJheS5CWVRFU19QRVJfRUxFTUVOVCk7XG59XG4iXX0=
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiRXZlbnRTaWduaW5nU3RyZWFtLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vLi4vc3JjL0V2ZW50U2lnbmluZ1N0cmVhbS50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOzs7QUFFQSxtQ0FBd0U7QUFReEU7O0dBRUc7QUFDSCxNQUFhLGtCQUFtQixTQUFRLGtCQUFTO0lBSS9DLFlBQVksT0FBa0M7UUFDNUMsS0FBSyxDQUFDO1lBQ0osa0JBQWtCLEVBQUUsSUFBSTtZQUN4QixrQkFBa0IsRUFBRSxJQUFJO1lBQ3hCLEdBQUcsT0FBTztTQUNYLENBQUMsQ0FBQztRQUNILElBQUksQ0FBQyxjQUFjLEdBQUcsT0FBTyxDQUFDLGNBQWMsQ0FBQztRQUM3QyxJQUFJLENBQUMsV0FBVyxHQUFHLE9BQU8sQ0FBQyxXQUFXLENBQUM7UUFDdkMsSUFBSSxDQUFDLGVBQWUsR0FBRyxPQUFPLENBQUMsZUFBZSxDQUFDO1FBQy9DLGdEQUFnRDtRQUNoRCx5R0FBeUc7UUFDekcsSUFBSSxDQUFDLEVBQUUsQ0FBQyxPQUFPLEVBQUUsR0FBRyxFQUFFO1lBQ3BCLElBQUksQ0FBQyxPQUFPLEVBQUUsQ0FBQztRQUNqQixDQUFDLENBQUMsQ0FBQztRQUNILElBQUksQ0FBQyxFQUFFLENBQUMsS0FBSyxFQUFFLEdBQUcsRUFBRTtZQUNsQixJQUFJLENBQUMsT0FBTyxFQUFFLENBQUM7UUFDakIsQ0FBQyxDQUFDLENBQUM7SUFDTCxDQUFDO0lBRUQsS0FBSyxDQUFDLFVBQVUsQ0FBQyxLQUFpQixFQUFFLFFBQWdCLEVBQUUsUUFBMkI7UUFDL0UsSUFBSTtZQUNGLE1BQU0sR0FBRyxHQUFHLElBQUksSUFBSSxFQUFFLENBQUM7WUFDdkIsTUFBTSxVQUFVLEdBQW1CO2dCQUNqQyxPQUFPLEVBQUUsRUFBRSxJQUFJLEVBQUUsV0FBVyxFQUFFLEtBQUssRUFBRSxHQUFHLEVBQUU7YUFDM0MsQ0FBQztZQUNGLE1BQU0sU0FBUyxHQUFHLE1BQU0sSUFBSSxDQUFDLFdBQVcsQ0FBQyxJQUFJLENBQzNDO2dCQUNFLE9BQU8sRUFBRSxLQUFLO2dCQUNkLE9BQU8sRUFBRSxJQUFJLENBQUMsZUFBZSxDQUFDLGFBQWEsQ0FBQyxVQUFVLENBQUM7YUFDeEQsRUFDRDtnQkFDRSxjQUFjLEVBQUUsSUFBSSxDQUFDLGNBQWM7Z0JBQ25DLFdBQVcsRUFBRSxHQUFHO2FBQ2pCLENBQ0YsQ0FBQztZQUNGLElBQUksQ0FBQyxjQUFjLEdBQUcsU0FBUyxDQUFDO1lBQ2hDLE1BQU0sZ0JBQWdCLEdBQUcsSUFBSSxDQUFDLGVBQWUsQ0FBQyxRQUFRLENBQUM7Z0JBQ3JELE9BQU8sRUFBRTtvQkFDUCxHQUFHLFVBQVU7b0JBQ2Isa0JBQWtCLEVBQUU7d0JBQ2xCLElBQUksRUFBRSxRQUFRO3dCQUNkLEtBQUssRUFBRSxrQkFBa0IsQ0FBQyxTQUFTLENBQUM7cUJBQ3JDO2lCQUNGO2dCQUNELElBQUksRUFBRSxLQUFLO2FBQ1osQ0FBQyxDQUFDO1lBQ0gsSUFBSSxDQUFDLElBQUksQ0FBQyxnQkFBZ0IsQ0FBQyxDQUFDO1lBQzVCLE9BQU8sUUFBUSxFQUFFLENBQUM7U0FDbkI7UUFBQyxPQUFPLEdBQUcsRUFBRTtZQUNaLFFBQVEsQ0FBQyxHQUFHLENBQUMsQ0FBQztTQUNmO0lBQ0gsQ0FBQztDQUNGO0FBeERELGdEQXdEQztBQUVELFNBQVMsa0JBQWtCLENBQUMsU0FBaUI7SUFDM0MsTUFBTSxHQUFHLEdBQUcsTUFBTSxDQUFDLElBQUksQ0FBQyxTQUFTLEVBQUUsS0FBSyxDQUFDLENBQUM7SUFDMUMsT0FBTyxJQUFJLFVBQVUsQ0FBQyxHQUFHLENBQUMsTUFBTSxFQUFFLEdBQUcsQ0FBQyxVQUFVLEVBQUUsR0FBRyxDQUFDLFVBQVUsR0FBRyxVQUFVLENBQUMsaUJBQWlCLENBQUMsQ0FBQztBQUNuRyxDQUFDIiwic291cmNlc0NvbnRlbnQiOlsiaW1wb3J0IHsgRXZlbnRTdHJlYW1NYXJzaGFsbGVyIGFzIEV2ZW50TWFyc2hhbGxlciB9IGZyb20gXCJAYXdzLXNkay9ldmVudHN0cmVhbS1tYXJzaGFsbGVyXCI7XG5pbXBvcnQgeyBFdmVudFNpZ25lciwgTWVzc2FnZUhlYWRlcnMgfSBmcm9tIFwiQGF3cy1zZGsvdHlwZXNcIjtcbmltcG9ydCB7IFRyYW5zZm9ybSwgVHJhbnNmb3JtQ2FsbGJhY2ssIFRyYW5zZm9ybU9wdGlvbnMgfSBmcm9tIFwic3RyZWFtXCI7XG5cbmV4cG9ydCBpbnRlcmZhY2UgRXZlbnRTaWduaW5nU3RyZWFtT3B0aW9ucyBleHRlbmRzIFRyYW5zZm9ybU9wdGlvbnMge1xuICBwcmlvclNpZ25hdHVyZTogc3RyaW5nO1xuICBldmVudFNpZ25lcjogRXZlbnRTaWduZXI7XG4gIGV2ZW50TWFyc2hhbGxlcjogRXZlbnRNYXJzaGFsbGVyO1xufVxuXG4vKipcbiAqIEEgdHJhbnNmb3JtIHN0cmVhbSB0aGF0IHNpZ25zIHRoZSBldmVudHN0cmVhbVxuICovXG5leHBvcnQgY2xhc3MgRXZlbnRTaWduaW5nU3RyZWFtIGV4dGVuZHMgVHJhbnNmb3JtIHtcbiAgcHJpdmF0ZSBwcmlvclNpZ25hdHVyZTogc3RyaW5nO1xuICBwcml2YXRlIGV2ZW50U2lnbmVyOiBFdmVudFNpZ25lcjtcbiAgcHJpdmF0ZSBldmVudE1hcnNoYWxsZXI6IEV2ZW50TWFyc2hhbGxlcjtcbiAgY29uc3RydWN0b3Iob3B0aW9uczogRXZlbnRTaWduaW5nU3RyZWFtT3B0aW9ucykge1xuICAgIHN1cGVyKHtcbiAgICAgIHJlYWRhYmxlT2JqZWN0TW9kZTogdHJ1ZSxcbiAgICAgIHdyaXRhYmxlT2JqZWN0TW9kZTogdHJ1ZSxcbiAgICAgIC4uLm9wdGlvbnMsXG4gICAgfSk7XG4gICAgdGhpcy5wcmlvclNpZ25hdHVyZSA9IG9wdGlvbnMucHJpb3JTaWduYXR1cmU7XG4gICAgdGhpcy5ldmVudFNpZ25lciA9IG9wdGlvbnMuZXZlbnRTaWduZXI7XG4gICAgdGhpcy5ldmVudE1hcnNoYWxsZXIgPSBvcHRpb25zLmV2ZW50TWFyc2hhbGxlcjtcbiAgICAvL1RPRE86IHVzZSAnYXV0b0Rlc3Ryb3knIHdoZW4gdGFyZ2V0aW5nIE5vZGUgMTFcbiAgICAvL3JlZmVyZW5jZTogaHR0cHM6Ly9ub2RlanMub3JnL2Rpc3QvbGF0ZXN0LXYxMy54L2RvY3MvYXBpL3N0cmVhbS5odG1sI3N0cmVhbV9uZXdfc3RyZWFtX3JlYWRhYmxlX29wdGlvbnNcbiAgICB0aGlzLm9uKFwiZXJyb3JcIiwgKCkgPT4ge1xuICAgICAgdGhpcy5kZXN0cm95KCk7XG4gICAgfSk7XG4gICAgdGhpcy5vbihcImVuZFwiLCAoKSA9PiB7XG4gICAgICB0aGlzLmRlc3Ryb3koKTtcbiAgICB9KTtcbiAgfVxuXG4gIGFzeW5jIF90cmFuc2Zvcm0oY2h1bms6IFVpbnQ4QXJyYXksIGVuY29kaW5nOiBzdHJpbmcsIGNhbGxiYWNrOiBUcmFuc2Zvcm1DYWxsYmFjayk6IFByb21pc2U8dm9pZD4ge1xuICAgIHRyeSB7XG4gICAgICBjb25zdCBub3cgPSBuZXcgRGF0ZSgpO1xuICAgICAgY29uc3QgZGF0ZUhlYWRlcjogTWVzc2FnZUhlYWRlcnMgPSB7XG4gICAgICAgIFwiOmRhdGVcIjogeyB0eXBlOiBcInRpbWVzdGFtcFwiLCB2YWx1ZTogbm93IH0sXG4gICAgICB9O1xuICAgICAgY29uc3Qgc2lnbmF0dXJlID0gYXdhaXQgdGhpcy5ldmVudFNpZ25lci5zaWduKFxuICAgICAgICB7XG4gICAgICAgICAgcGF5bG9hZDogY2h1bmssXG4gICAgICAgICAgaGVhZGVyczogdGhpcy5ldmVudE1hcnNoYWxsZXIuZm9ybWF0SGVhZGVycyhkYXRlSGVhZGVyKSxcbiAgICAgICAgfSxcbiAgICAgICAge1xuICAgICAgICAgIHByaW9yU2lnbmF0dXJlOiB0aGlzLnByaW9yU2lnbmF0dXJlLFxuICAgICAgICAgIHNpZ25pbmdEYXRlOiBub3csXG4gICAgICAgIH1cbiAgICAgICk7XG4gICAgICB0aGlzLnByaW9yU2lnbmF0dXJlID0gc2lnbmF0dXJlO1xuICAgICAgY29uc3Qgc2VyaWFsaXplZFNpZ25lZCA9IHRoaXMuZXZlbnRNYXJzaGFsbGVyLm1hcnNoYWxsKHtcbiAgICAgICAgaGVhZGVyczoge1xuICAgICAgICAgIC4uLmRhdGVIZWFkZXIsXG4gICAgICAgICAgXCI6Y2h1bmstc2lnbmF0dXJlXCI6IHtcbiAgICAgICAgICAgIHR5cGU6IFwiYmluYXJ5XCIsXG4gICAgICAgICAgICB2YWx1ZTogZ2V0U2lnbmF0dXJlQmluYXJ5KHNpZ25hdHVyZSksXG4gICAgICAgICAgfSxcbiAgICAgICAgfSxcbiAgICAgICAgYm9keTogY2h1bmssXG4gICAgICB9KTtcbiAgICAgIHRoaXMucHVzaChzZXJpYWxpemVkU2lnbmVkKTtcbiAgICAgIHJldHVybiBjYWxsYmFjaygpO1xuICAgIH0gY2F0Y2ggKGVycikge1xuICAgICAgY2FsbGJhY2soZXJyKTtcbiAgICB9XG4gIH1cbn1cblxuZnVuY3Rpb24gZ2V0U2lnbmF0dXJlQmluYXJ5KHNpZ25hdHVyZTogc3RyaW5nKTogVWludDhBcnJheSB7XG4gIGNvbnN0IGJ1ZiA9IEJ1ZmZlci5mcm9tKHNpZ25hdHVyZSwgXCJoZXhcIik7XG4gIHJldHVybiBuZXcgVWludDhBcnJheShidWYuYnVmZmVyLCBidWYuYnl0ZU9mZnNldCwgYnVmLmJ5dGVMZW5ndGggLyBVaW50OEFycmF5LkJZVEVTX1BFUl9FTEVNRU5UKTtcbn1cbiJdfQ==

104

dist/cjs/EventStreamPayloadHandler.js
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.EventStreamPayloadHandler = void 0;
var tslib_1 = require("tslib");
var eventstream_marshaller_1 = require("@aws-sdk/eventstream-marshaller");
var stream_1 = require("stream");
var EventSigningStream_1 = require("./EventSigningStream");
const eventstream_marshaller_1 = require("@aws-sdk/eventstream-marshaller");
const stream_1 = require("stream");
const EventSigningStream_1 = require("./EventSigningStream");
/**

@@ -15,64 +14,47 @@ * A handler that control the eventstream payload flow:

*/
var EventStreamPayloadHandler = /** @class */ (function () {
function EventStreamPayloadHandler(options) {
class EventStreamPayloadHandler {
constructor(options) {
this.eventSigner = options.eventSigner;
this.eventMarshaller = new eventstream_marshaller_1.EventStreamMarshaller(options.utf8Encoder, options.utf8Decoder);
}
EventStreamPayloadHandler.prototype.handle = function (next, args,
async handle(next, args,
// eslint-disable-next-line @typescript-eslint/no-unused-vars
context) {
if (context === void 0) { context = {}; }
return tslib_1.__awaiter(this, void 0, void 0, function () {
var request, payload, payloadStream, result, e_1, match, priorSignature, signingStream, _a;
var _b;
return tslib_1.__generator(this, function (_c) {
switch (_c.label) {
case 0:
request = args.request;
payload = request.body;
if (!(payload instanceof stream_1.Readable)) {
throw new Error("Eventstream payload must be a Readable stream.");
}
payloadStream = payload;
request.body = new stream_1.PassThrough({
objectMode: true,
});
_c.label = 1;
case 1:
_c.trys.push([1, 3, , 4]);
return [4 /*yield*/, next(args)];
case 2:
result = _c.sent();
return [3 /*break*/, 4];
case 3:
e_1 = _c.sent();
// Close the payload stream otherwise the retry would hang
// because of the previous connection.
request.body.end();
throw e_1;
case 4:
match = (request.headers["authorization"] || "").match(/Signature=([\w]+)$/);
priorSignature = (match || [])[1];
_a = EventSigningStream_1.EventSigningStream.bind;
_b = {
priorSignature: priorSignature,
eventMarshaller: this.eventMarshaller
};
return [4 /*yield*/, this.eventSigner()];
case 5:
signingStream = new (_a.apply(EventSigningStream_1.EventSigningStream, [void 0, (_b.eventSigner = _c.sent(),
_b)]))();
stream_1.pipeline(payloadStream, signingStream, request.body, function (err) {
if (err) {
throw err;
}
});
return [2 /*return*/, result];
}
});
context = {}) {
const request = args.request;
const { body: payload } = request;
if (!(payload instanceof stream_1.Readable)) {
throw new Error("Eventstream payload must be a Readable stream.");
}
const payloadStream = payload;
request.body = new stream_1.PassThrough({
objectMode: true,
});
};
return EventStreamPayloadHandler;
}());
let result;
try {
result = await next(args);
}
catch (e) {
// Close the payload stream otherwise the retry would hang
// because of the previous connection.
request.body.end();
throw e;
}
// If response is successful, start piping the payload stream
const match = (request.headers["authorization"] || "").match(/Signature=([\w]+)$/);
// Sign the eventstream based on the signature from initial request.
const priorSignature = (match || [])[1];
const signingStream = new EventSigningStream_1.EventSigningStream({
priorSignature,
eventMarshaller: this.eventMarshaller,
eventSigner: await this.eventSigner(),
});
stream_1.pipeline(payloadStream, signingStream, request.body, (err) => {
if (err) {
throw err;
}
});
return result;
}
}
exports.EventStreamPayloadHandler = EventStreamPayloadHandler;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiRXZlbnRTdHJlYW1QYXlsb2FkSGFuZGxlci5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uL3NyYy9FdmVudFN0cmVhbVBheWxvYWRIYW5kbGVyLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7Ozs7QUFBQSwwRUFBMkY7QUFjM0YsaUNBQXlEO0FBRXpELDJEQUEwRDtBQVExRDs7Ozs7O0dBTUc7QUFDSDtJQUdFLG1DQUFZLE9BQXlDO1FBQ25ELElBQUksQ0FBQyxXQUFXLEdBQUcsT0FBTyxDQUFDLFdBQVcsQ0FBQztRQUN2QyxJQUFJLENBQUMsZUFBZSxHQUFHLElBQUksOENBQWUsQ0FBQyxPQUFPLENBQUMsV0FBVyxFQUFFLE9BQU8sQ0FBQyxXQUFXLENBQUMsQ0FBQztJQUN2RixDQUFDO0lBRUssMENBQU0sR0FBWixVQUNFLElBQTZCLEVBQzdCLElBQW1DO0lBQ25DLDZEQUE2RDtJQUM3RCxPQUE0QztRQUE1Qyx3QkFBQSxFQUFBLFVBQW1DLEVBQVM7Ozs7Ozs7d0JBRXRDLE9BQU8sR0FBRyxJQUFJLENBQUMsT0FBc0IsQ0FBQzt3QkFDOUIsT0FBTyxHQUFLLE9BQU8sS0FBWixDQUFhO3dCQUNsQyxJQUFJLENBQUMsQ0FBQyxPQUFPLFlBQVksaUJBQVEsQ0FBQyxFQUFFOzRCQUNsQyxNQUFNLElBQUksS0FBSyxDQUFDLGdEQUFnRCxDQUFDLENBQUM7eUJBQ25FO3dCQUNLLGFBQWEsR0FBRyxPQUFtQixDQUFDO3dCQUMxQyxPQUFPLENBQUMsSUFBSSxHQUFHLElBQUksb0JBQVcsQ0FBQzs0QkFDN0IsVUFBVSxFQUFFLElBQUk7eUJBQ2pCLENBQUMsQ0FBQzs7Ozt3QkFHUSxxQkFBTSxJQUFJLENBQUMsSUFBSSxDQUFDLEVBQUE7O3dCQUF6QixNQUFNLEdBQUcsU0FBZ0IsQ0FBQzs7Ozt3QkFFMUIsMERBQTBEO3dCQUMxRCxzQ0FBc0M7d0JBQ3RDLE9BQU8sQ0FBQyxJQUFJLENBQUMsR0FBRyxFQUFFLENBQUM7d0JBQ25CLE1BQU0sR0FBQyxDQUFDOzt3QkFHSixLQUFLLEdBQUcsQ0FBQyxPQUFPLENBQUMsT0FBTyxDQUFDLGVBQWUsQ0FBQyxJQUFJLEVBQUUsQ0FBQyxDQUFDLEtBQUssQ0FBQyxvQkFBb0IsQ0FBQyxDQUFDO3dCQUU3RSxjQUFjLEdBQUcsQ0FBQyxLQUFLLElBQUksRUFBRSxDQUFDLENBQUMsQ0FBQyxDQUFDLENBQUM7NkJBQ2QsdUNBQWtCOzs0QkFDMUMsY0FBYyxnQkFBQTs0QkFDZCxlQUFlLEVBQUUsSUFBSSxDQUFDLGVBQWU7O3dCQUN4QixxQkFBTSxJQUFJLENBQUMsV0FBVyxFQUFFLEVBQUE7O3dCQUhqQyxhQUFhLEdBQUcsY0FBSSx1Q0FBa0IsWUFHMUMsY0FBVyxHQUFFLFNBQXdCO3dDQUNyQzt3QkFDRixpQkFBUSxDQUFDLGFBQWEsRUFBRSxhQUFhLEVBQUUsT0FBTyxDQUFDLElBQUksRUFBRSxVQUFDLEdBQUc7NEJBQ3ZELElBQUksR0FBRyxFQUFFO2dDQUNQLE1BQU0sR0FBRyxDQUFDOzZCQUNYO3dCQUNILENBQUMsQ0FBQyxDQUFDO3dCQUNILHNCQUFPLE1BQU0sRUFBQzs7OztLQUNmO0lBQ0gsZ0NBQUM7QUFBRCxDQUFDLEFBaERELElBZ0RDO0FBaERZLDhEQUF5QiIsInNvdXJjZXNDb250ZW50IjpbImltcG9ydCB7IEV2ZW50U3RyZWFtTWFyc2hhbGxlciBhcyBFdmVudE1hcnNoYWxsZXIgfSBmcm9tIFwiQGF3cy1zZGsvZXZlbnRzdHJlYW0tbWFyc2hhbGxlclwiO1xuaW1wb3J0IHtcbiAgRGVjb2RlcixcbiAgRW5jb2RlcixcbiAgRXZlbnRTaWduZXIsXG4gIEV2ZW50U3RyZWFtUGF5bG9hZEhhbmRsZXIgYXMgSUV2ZW50U3RyZWFtUGF5bG9hZEhhbmRsZXIsXG4gIEZpbmFsaXplSGFuZGxlcixcbiAgRmluYWxpemVIYW5kbGVyQXJndW1lbnRzLFxuICBGaW5hbGl6ZUhhbmRsZXJPdXRwdXQsXG4gIEhhbmRsZXJFeGVjdXRpb25Db250ZXh0LFxuICBIdHRwUmVxdWVzdCxcbiAgTWV0YWRhdGFCZWFyZXIsXG4gIFByb3ZpZGVyLFxufSBmcm9tIFwiQGF3cy1zZGsvdHlwZXNcIjtcbmltcG9ydCB7IFBhc3NUaHJvdWdoLCBwaXBlbGluZSwgUmVhZGFibGUgfSBmcm9tIFwic3RyZWFtXCI7XG5cbmltcG9ydCB7IEV2ZW50U2lnbmluZ1N0cmVhbSB9IGZyb20gXCIuL0V2ZW50U2lnbmluZ1N0cmVhbVwiO1xuXG5leHBvcnQgaW50ZXJmYWNlIEV2ZW50U3RyZWFtUGF5bG9hZEhhbmRsZXJPcHRpb25zIHtcbiAgZXZlbnRTaWduZXI6IFByb3ZpZGVyPEV2ZW50U2lnbmVyPjtcbiAgdXRmOEVuY29kZXI6IEVuY29kZXI7XG4gIHV0ZjhEZWNvZGVyOiBEZWNvZGVyO1xufVxuXG4vKipcbiAqIEEgaGFuZGxlciB0aGF0IGNvbnRyb2wgdGhlIGV2ZW50c3RyZWFtIHBheWxvYWQgZmxvdzpcbiAqIDEuIFBhdXNlIHN0cmVhbSBmb3IgaW5pdGlhbCBhdHRlbXB0LlxuICogMi4gQ2xvc2UgdGhlIHN0cmVhbSBpcyBhdHRlbXB0IGZhaWxzLlxuICogMy4gU3RhcnQgcGlwaW5nIHBheWxvYWQgd2hlbiBjb25uZWN0aW9uIGlzIGVzdGFibGlzaGVkLlxuICogNC4gU2lnbiB0aGUgcGF5bG9hZCBhZnRlciBwYXlsb2FkIHN0cmVhbSBzdGFydGluZyB0byBmbG93LlxuICovXG5leHBvcnQgY2xhc3MgRXZlbnRTdHJlYW1QYXlsb2FkSGFuZGxlciBpbXBsZW1lbnRzIElFdmVudFN0cmVhbVBheWxvYWRIYW5kbGVyIHtcbiAgcHJpdmF0ZSByZWFkb25seSBldmVudFNpZ25lcjogUHJvdmlkZXI8RXZlbnRTaWduZXI+O1xuICBwcml2YXRlIHJlYWRvbmx5IGV2ZW50TWFyc2hhbGxlcjogRXZlbnRNYXJzaGFsbGVyO1xuICBjb25zdHJ1Y3RvcihvcHRpb25zOiBFdmVudFN0cmVhbVBheWxvYWRIYW5kbGVyT3B0aW9ucykge1xuICAgIHRoaXMuZXZlbnRTaWduZXIgPSBvcHRpb25zLmV2ZW50U2lnbmVyO1xuICAgIHRoaXMuZXZlbnRNYXJzaGFsbGVyID0gbmV3IEV2ZW50TWFyc2hhbGxlcihvcHRpb25zLnV0ZjhFbmNvZGVyLCBvcHRpb25zLnV0ZjhEZWNvZGVyKTtcbiAgfVxuXG4gIGFzeW5jIGhhbmRsZTxUIGV4dGVuZHMgTWV0YWRhdGFCZWFyZXI+KFxuICAgIG5leHQ6IEZpbmFsaXplSGFuZGxlcjxhbnksIFQ+LFxuICAgIGFyZ3M6IEZpbmFsaXplSGFuZGxlckFyZ3VtZW50czxhbnk+LFxuICAgIC8vIGVzbGludC1kaXNhYmxlLW5leHQtbGluZSBAdHlwZXNjcmlwdC1lc2xpbnQvbm8tdW51c2VkLXZhcnNcbiAgICBjb250ZXh0OiBIYW5kbGVyRXhlY3V0aW9uQ29udGV4dCA9IHt9IGFzIGFueVxuICApOiBQcm9taXNlPEZpbmFsaXplSGFuZGxlck91dHB1dDxUPj4ge1xuICAgIGNvbnN0IHJlcXVlc3QgPSBhcmdzLnJlcXVlc3QgYXMgSHR0cFJlcXVlc3Q7XG4gICAgY29uc3QgeyBib2R5OiBwYXlsb2FkIH0gPSByZXF1ZXN0O1xuICAgIGlmICghKHBheWxvYWQgaW5zdGFuY2VvZiBSZWFkYWJsZSkpIHtcbiAgICAgIHRocm93IG5ldyBFcnJvcihcIkV2ZW50c3RyZWFtIHBheWxvYWQgbXVzdCBiZSBhIFJlYWRhYmxlIHN0cmVhbS5cIik7XG4gICAgfVxuICAgIGNvbnN0IHBheWxvYWRTdHJlYW0gPSBwYXlsb2FkIGFzIFJlYWRhYmxlO1xuICAgIHJlcXVlc3QuYm9keSA9IG5ldyBQYXNzVGhyb3VnaCh7XG4gICAgICBvYmplY3RNb2RlOiB0cnVlLFxuICAgIH0pO1xuICAgIGxldCByZXN1bHQ6IEZpbmFsaXplSGFuZGxlck91dHB1dDxhbnk+O1xuICAgIHRyeSB7XG4gICAgICByZXN1bHQgPSBhd2FpdCBuZXh0KGFyZ3MpO1xuICAgIH0gY2F0Y2ggKGUpIHtcbiAgICAgIC8vIENsb3NlIHRoZSBwYXlsb2FkIHN0cmVhbSBvdGhlcndpc2UgdGhlIHJldHJ5IHdvdWxkIGhhbmdcbiAgICAgIC8vIGJlY2F1c2Ugb2YgdGhlIHByZXZpb3VzIGNvbm5lY3Rpb24uXG4gICAgICByZXF1ZXN0LmJvZHkuZW5kKCk7XG4gICAgICB0aHJvdyBlO1xuICAgIH1cbiAgICAvLyBJZiByZXNwb25zZSBpcyBzdWNjZXNzZnVsLCBzdGFydCBwaXBpbmcgdGhlIHBheWxvYWQgc3RyZWFtXG4gICAgY29uc3QgbWF0Y2ggPSAocmVxdWVzdC5oZWFkZXJzW1wiYXV0aG9yaXphdGlvblwiXSB8fCBcIlwiKS5tYXRjaCgvU2lnbmF0dXJlPShbXFx3XSspJC8pO1xuICAgIC8vIFNpZ24gdGhlIGV2ZW50c3RyZWFtIGJhc2VkIG9uIHRoZSBzaWduYXR1cmUgZnJvbSBpbml0aWFsIHJlcXVlc3QuXG4gICAgY29uc3QgcHJpb3JTaWduYXR1cmUgPSAobWF0Y2ggfHwgW10pWzFdO1xuICAgIGNvbnN0IHNpZ25pbmdTdHJlYW0gPSBuZXcgRXZlbnRTaWduaW5nU3RyZWFtKHtcbiAgICAgIHByaW9yU2lnbmF0dXJlLFxuICAgICAgZXZlbnRNYXJzaGFsbGVyOiB0aGlzLmV2ZW50TWFyc2hhbGxlcixcbiAgICAgIGV2ZW50U2lnbmVyOiBhd2FpdCB0aGlzLmV2ZW50U2lnbmVyKCksXG4gICAgfSk7XG4gICAgcGlwZWxpbmUocGF5bG9hZFN0cmVhbSwgc2lnbmluZ1N0cmVhbSwgcmVxdWVzdC5ib2R5LCAoZXJyKSA9PiB7XG4gICAgICBpZiAoZXJyKSB7XG4gICAgICAgIHRocm93IGVycjtcbiAgICAgIH1cbiAgICB9KTtcbiAgICByZXR1cm4gcmVzdWx0O1xuICB9XG59XG4iXX0=
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiRXZlbnRTdHJlYW1QYXlsb2FkSGFuZGxlci5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uLy4uL3NyYy9FdmVudFN0cmVhbVBheWxvYWRIYW5kbGVyLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7OztBQUFBLDRFQUEyRjtBQWMzRixtQ0FBeUQ7QUFFekQsNkRBQTBEO0FBUTFEOzs7Ozs7R0FNRztBQUNILE1BQWEseUJBQXlCO0lBR3BDLFlBQVksT0FBeUM7UUFDbkQsSUFBSSxDQUFDLFdBQVcsR0FBRyxPQUFPLENBQUMsV0FBVyxDQUFDO1FBQ3ZDLElBQUksQ0FBQyxlQUFlLEdBQUcsSUFBSSw4Q0FBZSxDQUFDLE9BQU8sQ0FBQyxXQUFXLEVBQUUsT0FBTyxDQUFDLFdBQVcsQ0FBQyxDQUFDO0lBQ3ZGLENBQUM7SUFFRCxLQUFLLENBQUMsTUFBTSxDQUNWLElBQTZCLEVBQzdCLElBQW1DO0lBQ25DLDZEQUE2RDtJQUM3RCxVQUFtQyxFQUFTO1FBRTVDLE1BQU0sT0FBTyxHQUFHLElBQUksQ0FBQyxPQUFzQixDQUFDO1FBQzVDLE1BQU0sRUFBRSxJQUFJLEVBQUUsT0FBTyxFQUFFLEdBQUcsT0FBTyxDQUFDO1FBQ2xDLElBQUksQ0FBQyxDQUFDLE9BQU8sWUFBWSxpQkFBUSxDQUFDLEVBQUU7WUFDbEMsTUFBTSxJQUFJLEtBQUssQ0FBQyxnREFBZ0QsQ0FBQyxDQUFDO1NBQ25FO1FBQ0QsTUFBTSxhQUFhLEdBQUcsT0FBbUIsQ0FBQztRQUMxQyxPQUFPLENBQUMsSUFBSSxHQUFHLElBQUksb0JBQVcsQ0FBQztZQUM3QixVQUFVLEVBQUUsSUFBSTtTQUNqQixDQUFDLENBQUM7UUFDSCxJQUFJLE1BQWtDLENBQUM7UUFDdkMsSUFBSTtZQUNGLE1BQU0sR0FBRyxNQUFNLElBQUksQ0FBQyxJQUFJLENBQUMsQ0FBQztTQUMzQjtRQUFDLE9BQU8sQ0FBQyxFQUFFO1lBQ1YsMERBQTBEO1lBQzFELHNDQUFzQztZQUN0QyxPQUFPLENBQUMsSUFBSSxDQUFDLEdBQUcsRUFBRSxDQUFDO1lBQ25CLE1BQU0sQ0FBQyxDQUFDO1NBQ1Q7UUFDRCw2REFBNkQ7UUFDN0QsTUFBTSxLQUFLLEdBQUcsQ0FBQyxPQUFPLENBQUMsT0FBTyxDQUFDLGVBQWUsQ0FBQyxJQUFJLEVBQUUsQ0FBQyxDQUFDLEtBQUssQ0FBQyxvQkFBb0IsQ0FBQyxDQUFDO1FBQ25GLG9FQUFvRTtRQUNwRSxNQUFNLGNBQWMsR0FBRyxDQUFDLEtBQUssSUFBSSxFQUFFLENBQUMsQ0FBQyxDQUFDLENBQUMsQ0FBQztRQUN4QyxNQUFNLGFBQWEsR0FBRyxJQUFJLHVDQUFrQixDQUFDO1lBQzNDLGNBQWM7WUFDZCxlQUFlLEVBQUUsSUFBSSxDQUFDLGVBQWU7WUFDckMsV0FBVyxFQUFFLE1BQU0sSUFBSSxDQUFDLFdBQVcsRUFBRTtTQUN0QyxDQUFDLENBQUM7UUFDSCxpQkFBUSxDQUFDLGFBQWEsRUFBRSxhQUFhLEVBQUUsT0FBTyxDQUFDLElBQUksRUFBRSxDQUFDLEdBQUcsRUFBRSxFQUFFO1lBQzNELElBQUksR0FBRyxFQUFFO2dCQUNQLE1BQU0sR0FBRyxDQUFDO2FBQ1g7UUFDSCxDQUFDLENBQUMsQ0FBQztRQUNILE9BQU8sTUFBTSxDQUFDO0lBQ2hCLENBQUM7Q0FDRjtBQWhERCw4REFnREMiLCJzb3VyY2VzQ29udGVudCI6WyJpbXBvcnQgeyBFdmVudFN0cmVhbU1hcnNoYWxsZXIgYXMgRXZlbnRNYXJzaGFsbGVyIH0gZnJvbSBcIkBhd3Mtc2RrL2V2ZW50c3RyZWFtLW1hcnNoYWxsZXJcIjtcbmltcG9ydCB7XG4gIERlY29kZXIsXG4gIEVuY29kZXIsXG4gIEV2ZW50U2lnbmVyLFxuICBFdmVudFN0cmVhbVBheWxvYWRIYW5kbGVyIGFzIElFdmVudFN0cmVhbVBheWxvYWRIYW5kbGVyLFxuICBGaW5hbGl6ZUhhbmRsZXIsXG4gIEZpbmFsaXplSGFuZGxlckFyZ3VtZW50cyxcbiAgRmluYWxpemVIYW5kbGVyT3V0cHV0LFxuICBIYW5kbGVyRXhlY3V0aW9uQ29udGV4dCxcbiAgSHR0cFJlcXVlc3QsXG4gIE1ldGFkYXRhQmVhcmVyLFxuICBQcm92aWRlcixcbn0gZnJvbSBcIkBhd3Mtc2RrL3R5cGVzXCI7XG5pbXBvcnQgeyBQYXNzVGhyb3VnaCwgcGlwZWxpbmUsIFJlYWRhYmxlIH0gZnJvbSBcInN0cmVhbVwiO1xuXG5pbXBvcnQgeyBFdmVudFNpZ25pbmdTdHJlYW0gfSBmcm9tIFwiLi9FdmVudFNpZ25pbmdTdHJlYW1cIjtcblxuZXhwb3J0IGludGVyZmFjZSBFdmVudFN0cmVhbVBheWxvYWRIYW5kbGVyT3B0aW9ucyB7XG4gIGV2ZW50U2lnbmVyOiBQcm92aWRlcjxFdmVudFNpZ25lcj47XG4gIHV0ZjhFbmNvZGVyOiBFbmNvZGVyO1xuICB1dGY4RGVjb2RlcjogRGVjb2Rlcjtcbn1cblxuLyoqXG4gKiBBIGhhbmRsZXIgdGhhdCBjb250cm9sIHRoZSBldmVudHN0cmVhbSBwYXlsb2FkIGZsb3c6XG4gKiAxLiBQYXVzZSBzdHJlYW0gZm9yIGluaXRpYWwgYXR0ZW1wdC5cbiAqIDIuIENsb3NlIHRoZSBzdHJlYW0gaXMgYXR0ZW1wdCBmYWlscy5cbiAqIDMuIFN0YXJ0IHBpcGluZyBwYXlsb2FkIHdoZW4gY29ubmVjdGlvbiBpcyBlc3RhYmxpc2hlZC5cbiAqIDQuIFNpZ24gdGhlIHBheWxvYWQgYWZ0ZXIgcGF5bG9hZCBzdHJlYW0gc3RhcnRpbmcgdG8gZmxvdy5cbiAqL1xuZXhwb3J0IGNsYXNzIEV2ZW50U3RyZWFtUGF5bG9hZEhhbmRsZXIgaW1wbGVtZW50cyBJRXZlbnRTdHJlYW1QYXlsb2FkSGFuZGxlciB7XG4gIHByaXZhdGUgcmVhZG9ubHkgZXZlbnRTaWduZXI6IFByb3ZpZGVyPEV2ZW50U2lnbmVyPjtcbiAgcHJpdmF0ZSByZWFkb25seSBldmVudE1hcnNoYWxsZXI6IEV2ZW50TWFyc2hhbGxlcjtcbiAgY29uc3RydWN0b3Iob3B0aW9uczogRXZlbnRTdHJlYW1QYXlsb2FkSGFuZGxlck9wdGlvbnMpIHtcbiAgICB0aGlzLmV2ZW50U2lnbmVyID0gb3B0aW9ucy5ldmVudFNpZ25lcjtcbiAgICB0aGlzLmV2ZW50TWFyc2hhbGxlciA9IG5ldyBFdmVudE1hcnNoYWxsZXIob3B0aW9ucy51dGY4RW5jb2Rlciwgb3B0aW9ucy51dGY4RGVjb2Rlcik7XG4gIH1cblxuICBhc3luYyBoYW5kbGU8VCBleHRlbmRzIE1ldGFkYXRhQmVhcmVyPihcbiAgICBuZXh0OiBGaW5hbGl6ZUhhbmRsZXI8YW55LCBUPixcbiAgICBhcmdzOiBGaW5hbGl6ZUhhbmRsZXJBcmd1bWVudHM8YW55PixcbiAgICAvLyBlc2xpbnQtZGlzYWJsZS1uZXh0LWxpbmUgQHR5cGVzY3JpcHQtZXNsaW50L25vLXVudXNlZC12YXJzXG4gICAgY29udGV4dDogSGFuZGxlckV4ZWN1dGlvbkNvbnRleHQgPSB7fSBhcyBhbnlcbiAgKTogUHJvbWlzZTxGaW5hbGl6ZUhhbmRsZXJPdXRwdXQ8VD4+IHtcbiAgICBjb25zdCByZXF1ZXN0ID0gYXJncy5yZXF1ZXN0IGFzIEh0dHBSZXF1ZXN0O1xuICAgIGNvbnN0IHsgYm9keTogcGF5bG9hZCB9ID0gcmVxdWVzdDtcbiAgICBpZiAoIShwYXlsb2FkIGluc3RhbmNlb2YgUmVhZGFibGUpKSB7XG4gICAgICB0aHJvdyBuZXcgRXJyb3IoXCJFdmVudHN0cmVhbSBwYXlsb2FkIG11c3QgYmUgYSBSZWFkYWJsZSBzdHJlYW0uXCIpO1xuICAgIH1cbiAgICBjb25zdCBwYXlsb2FkU3RyZWFtID0gcGF5bG9hZCBhcyBSZWFkYWJsZTtcbiAgICByZXF1ZXN0LmJvZHkgPSBuZXcgUGFzc1Rocm91Z2goe1xuICAgICAgb2JqZWN0TW9kZTogdHJ1ZSxcbiAgICB9KTtcbiAgICBsZXQgcmVzdWx0OiBGaW5hbGl6ZUhhbmRsZXJPdXRwdXQ8YW55PjtcbiAgICB0cnkge1xuICAgICAgcmVzdWx0ID0gYXdhaXQgbmV4dChhcmdzKTtcbiAgICB9IGNhdGNoIChlKSB7XG4gICAgICAvLyBDbG9zZSB0aGUgcGF5bG9hZCBzdHJlYW0gb3RoZXJ3aXNlIHRoZSByZXRyeSB3b3VsZCBoYW5nXG4gICAgICAvLyBiZWNhdXNlIG9mIHRoZSBwcmV2aW91cyBjb25uZWN0aW9uLlxuICAgICAgcmVxdWVzdC5ib2R5LmVuZCgpO1xuICAgICAgdGhyb3cgZTtcbiAgICB9XG4gICAgLy8gSWYgcmVzcG9uc2UgaXMgc3VjY2Vzc2Z1bCwgc3RhcnQgcGlwaW5nIHRoZSBwYXlsb2FkIHN0cmVhbVxuICAgIGNvbnN0IG1hdGNoID0gKHJlcXVlc3QuaGVhZGVyc1tcImF1dGhvcml6YXRpb25cIl0gfHwgXCJcIikubWF0Y2goL1NpZ25hdHVyZT0oW1xcd10rKSQvKTtcbiAgICAvLyBTaWduIHRoZSBldmVudHN0cmVhbSBiYXNlZCBvbiB0aGUgc2lnbmF0dXJlIGZyb20gaW5pdGlhbCByZXF1ZXN0LlxuICAgIGNvbnN0IHByaW9yU2lnbmF0dXJlID0gKG1hdGNoIHx8IFtdKVsxXTtcbiAgICBjb25zdCBzaWduaW5nU3RyZWFtID0gbmV3IEV2ZW50U2lnbmluZ1N0cmVhbSh7XG4gICAgICBwcmlvclNpZ25hdHVyZSxcbiAgICAgIGV2ZW50TWFyc2hhbGxlcjogdGhpcy5ldmVudE1hcnNoYWxsZXIsXG4gICAgICBldmVudFNpZ25lcjogYXdhaXQgdGhpcy5ldmVudFNpZ25lcigpLFxuICAgIH0pO1xuICAgIHBpcGVsaW5lKHBheWxvYWRTdHJlYW0sIHNpZ25pbmdTdHJlYW0sIHJlcXVlc3QuYm9keSwgKGVycikgPT4ge1xuICAgICAgaWYgKGVycikge1xuICAgICAgICB0aHJvdyBlcnI7XG4gICAgICB9XG4gICAgfSk7XG4gICAgcmV0dXJuIHJlc3VsdDtcbiAgfVxufVxuIl19

6

dist/cjs/provider.js
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.eventStreamPayloadHandlerProvider = void 0;
var EventStreamPayloadHandler_1 = require("./EventStreamPayloadHandler");
const EventStreamPayloadHandler_1 = require("./EventStreamPayloadHandler");
/** NodeJS event stream utils provider */
exports.eventStreamPayloadHandlerProvider = function (options) { return new EventStreamPayloadHandler_1.EventStreamPayloadHandler(options); };
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoicHJvdmlkZXIuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi8uLi9zcmMvcHJvdmlkZXIudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7O0FBRUEseUVBQXdFO0FBRXhFLHlDQUF5QztBQUM1QixRQUFBLGlDQUFpQyxHQUFzQyxVQUFDLE9BSXBGLElBQUssT0FBQSxJQUFJLHFEQUF5QixDQUFDLE9BQU8sQ0FBQyxFQUF0QyxDQUFzQyxDQUFDIiwic291cmNlc0NvbnRlbnQiOlsiaW1wb3J0IHsgRGVjb2RlciwgRW5jb2RlciwgRXZlbnRTaWduZXIsIEV2ZW50U3RyZWFtUGF5bG9hZEhhbmRsZXJQcm92aWRlciwgUHJvdmlkZXIgfSBmcm9tIFwiQGF3cy1zZGsvdHlwZXNcIjtcblxuaW1wb3J0IHsgRXZlbnRTdHJlYW1QYXlsb2FkSGFuZGxlciB9IGZyb20gXCIuL0V2ZW50U3RyZWFtUGF5bG9hZEhhbmRsZXJcIjtcblxuLyoqIE5vZGVKUyBldmVudCBzdHJlYW0gdXRpbHMgcHJvdmlkZXIgKi9cbmV4cG9ydCBjb25zdCBldmVudFN0cmVhbVBheWxvYWRIYW5kbGVyUHJvdmlkZXI6IEV2ZW50U3RyZWFtUGF5bG9hZEhhbmRsZXJQcm92aWRlciA9IChvcHRpb25zOiB7XG4gIHV0ZjhFbmNvZGVyOiBFbmNvZGVyO1xuICB1dGY4RGVjb2RlcjogRGVjb2RlcjtcbiAgZXZlbnRTaWduZXI6IFByb3ZpZGVyPEV2ZW50U2lnbmVyPjtcbn0pID0+IG5ldyBFdmVudFN0cmVhbVBheWxvYWRIYW5kbGVyKG9wdGlvbnMpO1xuIl19
exports.eventStreamPayloadHandlerProvider = (options) => new EventStreamPayloadHandler_1.EventStreamPayloadHandler(options);
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoicHJvdmlkZXIuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi8uLi9zcmMvcHJvdmlkZXIudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7O0FBRUEsMkVBQXdFO0FBRXhFLHlDQUF5QztBQUM1QixRQUFBLGlDQUFpQyxHQUFzQyxDQUFDLE9BSXBGLEVBQUUsRUFBRSxDQUFDLElBQUkscURBQXlCLENBQUMsT0FBTyxDQUFDLENBQUMiLCJzb3VyY2VzQ29udGVudCI6WyJpbXBvcnQgeyBEZWNvZGVyLCBFbmNvZGVyLCBFdmVudFNpZ25lciwgRXZlbnRTdHJlYW1QYXlsb2FkSGFuZGxlclByb3ZpZGVyLCBQcm92aWRlciB9IGZyb20gXCJAYXdzLXNkay90eXBlc1wiO1xuXG5pbXBvcnQgeyBFdmVudFN0cmVhbVBheWxvYWRIYW5kbGVyIH0gZnJvbSBcIi4vRXZlbnRTdHJlYW1QYXlsb2FkSGFuZGxlclwiO1xuXG4vKiogTm9kZUpTIGV2ZW50IHN0cmVhbSB1dGlscyBwcm92aWRlciAqL1xuZXhwb3J0IGNvbnN0IGV2ZW50U3RyZWFtUGF5bG9hZEhhbmRsZXJQcm92aWRlcjogRXZlbnRTdHJlYW1QYXlsb2FkSGFuZGxlclByb3ZpZGVyID0gKG9wdGlvbnM6IHtcbiAgdXRmOEVuY29kZXI6IEVuY29kZXI7XG4gIHV0ZjhEZWNvZGVyOiBEZWNvZGVyO1xuICBldmVudFNpZ25lcjogUHJvdmlkZXI8RXZlbnRTaWduZXI+O1xufSkgPT4gbmV3IEV2ZW50U3RyZWFtUGF5bG9hZEhhbmRsZXIob3B0aW9ucyk7XG4iXX0=

8

package.json
{
"name": "@aws-sdk/eventstream-handler-node",
"version": "1.0.0-gamma.7",
"version": "1.0.0-rc.1",
"scripts": {

@@ -21,8 +21,8 @@ "prepublishOnly": "yarn build:cjs && yarn build:es",

"dependencies": {
"@aws-sdk/eventstream-marshaller": "1.0.0-gamma.8",
"@aws-sdk/types": "1.0.0-gamma.7",
"@aws-sdk/eventstream-marshaller": "1.0.0-rc.1",
"@aws-sdk/types": "1.0.0-rc.1",
"tslib": "^1.8.0"
},
"devDependencies": {
"@aws-sdk/util-utf8-node": "1.0.0-gamma.7",
"@aws-sdk/util-utf8-node": "1.0.0-rc.1",
"@types/jest": "^26.0.4",

@@ -29,0 +29,0 @@ "jest": "^26.1.0",

9

tsconfig.cjs.json
{
"compilerOptions": {
"declaration": true,
"strict": true,
"sourceMap": false,
"downlevelIteration": true,
"importHelpers": true,
"noEmitHelpers": true,
"lib": ["es2018.asynciterable"],
"rootDir": "./src",
"outDir": "./dist/cjs",
"inlineSourceMap": true,
"inlineSources": true,
"baseUrl": "."

@@ -15,0 +6,0 @@ },

8

tsconfig.es.json
{
"compilerOptions": {
"declaration": true,
"strict": true,
"sourceMap": false,
"downlevelIteration": true,
"importHelpers": true,
"noEmitHelpers": true,
"lib": ["es2018.asynciterable"],
"rootDir": "./src",
"outDir": "./dist/es",
"inlineSourceMap": true,
"inlineSources": true,
"baseUrl": "."

@@ -15,0 +7,0 @@ },

SocketSocket SOC 2 Logo

Product

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

About

Packages

npm

Go

Maven

PyPI

Rubygems

Stay in touch

Get open source security insights delivered straight into your inbox.

  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc