Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
Socket
Sign inDemoInstall
Socket
Sign inDemoInstall

@aws-sdk/eventstream-marshaller

Package Overview
Dependencies
Maintainers
4
Versions
78
Alerts
File Explorer

Advanced tools

License
Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

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

Comparing version 0.1.0-preview.4 to 0.1.0-preview.5

build/EventStreamMarshaller.js.map
build/HeaderMarshaller.js.map
build/index.js.map
build/Int64.js.map
build/Message.js.map
build/splitMessage.js.map
jest.config.js

4

build/EventStreamMarshaller.d.ts

@@ -1,3 +0,3 @@

import { Message } from './Message';
import { Decoder, Encoder } from '@aws-sdk/types';
import { Message } from "./Message";
import { Decoder, Encoder } from "@aws-sdk/types";
/**

@@ -4,0 +4,0 @@ * A marshaller that can convert binary-packed event stream messages into

4

build/EventStreamMarshaller.js

@@ -24,3 +24,3 @@ "use strict";

var view = new DataView(out.buffer, out.byteOffset, out.byteLength);
var checksum = new crc32_1.Crc32;
var checksum = new crc32_1.Crc32();
// Format message

@@ -47,2 +47,2 @@ view.setUint32(0, length, false);

exports.EventStreamMarshaller = EventStreamMarshaller;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiRXZlbnRTdHJlYW1NYXJzaGFsbGVyLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vc3JjL0V2ZW50U3RyZWFtTWFyc2hhbGxlci50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOztBQUFBLHVEQUFzRDtBQUV0RCwrQ0FBOEM7QUFDOUMsMkNBQTBDO0FBSTFDOzs7R0FHRztBQUNIO0lBR0ksK0JBQVksTUFBZSxFQUFFLFFBQWlCO1FBQzFDLElBQUksQ0FBQyxnQkFBZ0IsR0FBRyxJQUFJLG1DQUFnQixDQUFDLE1BQU0sRUFBRSxRQUFRLENBQUMsQ0FBQztJQUNuRSxDQUFDO0lBRUQ7OztPQUdHO0lBQ0gsd0NBQVEsR0FBUixVQUFTLEVBQXNDO1lBQXBDLHVCQUFtQixFQUFFLGNBQUk7UUFDaEMsSUFBTSxPQUFPLEdBQUcsSUFBSSxDQUFDLGdCQUFnQixDQUFDLE1BQU0sQ0FBQyxVQUFVLENBQUMsQ0FBQztRQUN6RCxJQUFNLE1BQU0sR0FBRyxPQUFPLENBQUMsVUFBVSxHQUFHLElBQUksQ0FBQyxVQUFVLEdBQUcsRUFBRSxDQUFDO1FBRXpELElBQU0sR0FBRyxHQUFHLElBQUksVUFBVSxDQUFDLE1BQU0sQ0FBQyxDQUFDO1FBQ25DLElBQU0sSUFBSSxHQUFHLElBQUksUUFBUSxDQUFDLEdBQUcsQ0FBQyxNQUFNLEVBQUUsR0FBRyxDQUFDLFVBQVUsRUFBRSxHQUFHLENBQUMsVUFBVSxDQUFDLENBQUM7UUFDdEUsSUFBTSxRQUFRLEdBQUcsSUFBSSxhQUFLLENBQUM7UUFFM0IsaUJBQWlCO1FBQ2pCLElBQUksQ0FBQyxTQUFTLENBQUMsQ0FBQyxFQUFFLE1BQU0sRUFBRSxLQUFLLENBQUMsQ0FBQztRQUNqQyxJQUFJLENBQUMsU0FBUyxDQUFDLENBQUMsRUFBRSxPQUFPLENBQUMsVUFBVSxFQUFFLEtBQUssQ0FBQyxDQUFDO1FBQzdDLElBQUksQ0FBQyxTQUFTLENBQUMsQ0FBQyxFQUFFLFFBQVEsQ0FBQyxNQUFNLENBQUMsR0FBRyxDQUFDLFFBQVEsQ0FBQyxDQUFDLEVBQUUsQ0FBQyxDQUFDLENBQUMsQ0FBQyxNQUFNLEVBQUUsRUFBRSxLQUFLLENBQUMsQ0FBQztRQUN2RSxHQUFHLENBQUMsR0FBRyxDQUFDLE9BQU8sRUFBRSxFQUFFLENBQUMsQ0FBQztRQUNyQixHQUFHLENBQUMsR0FBRyxDQUFDLElBQUksRUFBRSxPQUFPLENBQUMsVUFBVSxHQUFHLEVBQUUsQ0FBQyxDQUFDO1FBRXZDLGtDQUFrQztRQUNsQyxJQUFJLENBQUMsU0FBUyxDQUNWLE1BQU0sR0FBRyxDQUFDLEVBQ1YsUUFBUSxDQUFDLE1BQU0sQ0FBQyxHQUFHLENBQUMsUUFBUSxDQUFDLENBQUMsRUFBRSxNQUFNLEdBQUcsQ0FBQyxDQUFDLENBQUMsQ0FBQyxNQUFNLEVBQUUsRUFDckQsS0FBSyxDQUNSLENBQUM7UUFFRixPQUFPLEdBQUcsQ0FBQztJQUNmLENBQUM7SUFFRDs7O09BR0c7SUFDSCwwQ0FBVSxHQUFWLFVBQVcsT0FBd0I7UUFDekIsSUFBQSx5Q0FBeUMsRUFBdkMsb0JBQU8sRUFBRSxjQUE4QixDQUFDO1FBRWhELE9BQU8sRUFBRSxPQUFPLEVBQUUsSUFBSSxDQUFDLGdCQUFnQixDQUFDLEtBQUssQ0FBQyxPQUFPLENBQUMsRUFBRSxJQUFJLE1BQUEsRUFBRSxDQUFDO0lBQ25FLENBQUM7SUFDTCw0QkFBQztBQUFELENBQUMsQUE3Q0QsSUE2Q0M7QUE3Q1ksc0RBQXFCIiwic291cmNlc0NvbnRlbnQiOlsiaW1wb3J0IHsgSGVhZGVyTWFyc2hhbGxlciB9IGZyb20gJy4vSGVhZGVyTWFyc2hhbGxlcic7XG5pbXBvcnQgeyBNZXNzYWdlLCBNZXNzYWdlSGVhZGVycywgTWVzc2FnZUhlYWRlclZhbHVlIH0gZnJvbSAnLi9NZXNzYWdlJztcbmltcG9ydCB7IHNwbGl0TWVzc2FnZSB9IGZyb20gJy4vc3BsaXRNZXNzYWdlJztcbmltcG9ydCB7IENyYzMyIH0gZnJvbSAnQGF3cy1jcnlwdG8vY3JjMzInO1xuaW1wb3J0IHsgRGVjb2RlciwgRW5jb2RlciB9IGZyb20gJ0Bhd3Mtc2RrL3R5cGVzJztcbmltcG9ydCB7IHRvSGV4IH0gZnJvbSAnQGF3cy1zZGsvdXRpbC1oZXgtZW5jb2RpbmcnO1xuXG4vKipcbiAqIEEgbWFyc2hhbGxlciB0aGF0IGNhbiBjb252ZXJ0IGJpbmFyeS1wYWNrZWQgZXZlbnQgc3RyZWFtIG1lc3NhZ2VzIGludG9cbiAqIEphdmFTY3JpcHQgb2JqZWN0cyBhbmQgYmFjayBhZ2FpbiBpbnRvIHRoZWlyIGJpbmFyeSBmb3JtYXQuXG4gKi9cbmV4cG9ydCBjbGFzcyBFdmVudFN0cmVhbU1hcnNoYWxsZXIge1xuICAgIHByaXZhdGUgcmVhZG9ubHkgaGVhZGVyTWFyc2hhbGxlcjogSGVhZGVyTWFyc2hhbGxlcjtcblxuICAgIGNvbnN0cnVjdG9yKHRvVXRmODogRW5jb2RlciwgZnJvbVV0Zjg6IERlY29kZXIpIHtcbiAgICAgICAgdGhpcy5oZWFkZXJNYXJzaGFsbGVyID0gbmV3IEhlYWRlck1hcnNoYWxsZXIodG9VdGY4LCBmcm9tVXRmOCk7XG4gICAgfVxuXG4gICAgLyoqXG4gICAgICogQ29udmVydCBhIHN0cnVjdHVyZWQgSmF2YVNjcmlwdCBvYmplY3Qgd2l0aCB0YWdnZWQgaGVhZGVycyBpbnRvIGEgYmluYXJ5XG4gICAgICogZXZlbnQgc3RyZWFtIG1lc3NhZ2UuXG4gICAgICovXG4gICAgbWFyc2hhbGwoeyBoZWFkZXJzOiByYXdIZWFkZXJzLCBib2R5IH06IE1lc3NhZ2UpOiBVaW50OEFycmF5IHtcbiAgICAgICAgY29uc3QgaGVhZGVycyA9IHRoaXMuaGVhZGVyTWFyc2hhbGxlci5mb3JtYXQocmF3SGVhZGVycyk7XG4gICAgICAgIGNvbnN0IGxlbmd0aCA9IGhlYWRlcnMuYnl0ZUxlbmd0aCArIGJvZHkuYnl0ZUxlbmd0aCArIDE2O1xuXG4gICAgICAgIGNvbnN0IG91dCA9IG5ldyBVaW50OEFycmF5KGxlbmd0aCk7XG4gICAgICAgIGNvbnN0IHZpZXcgPSBuZXcgRGF0YVZpZXcob3V0LmJ1ZmZlciwgb3V0LmJ5dGVPZmZzZXQsIG91dC5ieXRlTGVuZ3RoKTtcbiAgICAgICAgY29uc3QgY2hlY2tzdW0gPSBuZXcgQ3JjMzI7XG5cbiAgICAgICAgLy8gRm9ybWF0IG1lc3NhZ2VcbiAgICAgICAgdmlldy5zZXRVaW50MzIoMCwgbGVuZ3RoLCBmYWxzZSk7XG4gICAgICAgIHZpZXcuc2V0VWludDMyKDQsIGhlYWRlcnMuYnl0ZUxlbmd0aCwgZmFsc2UpO1xuICAgICAgICB2aWV3LnNldFVpbnQzMig4LCBjaGVja3N1bS51cGRhdGUob3V0LnN1YmFycmF5KDAsIDgpKS5kaWdlc3QoKSwgZmFsc2UpO1xuICAgICAgICBvdXQuc2V0KGhlYWRlcnMsIDEyKTtcbiAgICAgICAgb3V0LnNldChib2R5LCBoZWFkZXJzLmJ5dGVMZW5ndGggKyAxMik7XG5cbiAgICAgICAgLy8gV3JpdGUgdHJhaWxpbmcgbWVzc2FnZSBjaGVja3N1bVxuICAgICAgICB2aWV3LnNldFVpbnQzMihcbiAgICAgICAgICAgIGxlbmd0aCAtIDQsXG4gICAgICAgICAgICBjaGVja3N1bS51cGRhdGUob3V0LnN1YmFycmF5KDgsIGxlbmd0aCAtIDQpKS5kaWdlc3QoKSxcbiAgICAgICAgICAgIGZhbHNlXG4gICAgICAgICk7XG5cbiAgICAgICAgcmV0dXJuIG91dDtcbiAgICB9XG5cbiAgICAvKipcbiAgICAgKiBDb252ZXJ0IGEgYmluYXJ5IGV2ZW50IHN0cmVhbSBtZXNzYWdlIGludG8gYSBKYXZhU2NyaXB0IG9iamVjdCB3aXRoIGFuXG4gICAgICogb3BhcXVlLCBiaW5hcnkgYm9keSBhbmQgdGFnZ2VkLCBwYXJzZWQgaGVhZGVycy5cbiAgICAgKi9cbiAgICB1bm1hcnNoYWxsKG1lc3NhZ2U6IEFycmF5QnVmZmVyVmlldyk6IE1lc3NhZ2Uge1xuICAgICAgICBjb25zdCB7IGhlYWRlcnMsIGJvZHkgfSA9IHNwbGl0TWVzc2FnZShtZXNzYWdlKTtcblxuICAgICAgICByZXR1cm4geyBoZWFkZXJzOiB0aGlzLmhlYWRlck1hcnNoYWxsZXIucGFyc2UoaGVhZGVycyksIGJvZHkgfTtcbiAgICB9XG59XG4iXX0=
//# sourceMappingURL=EventStreamMarshaller.js.map

4

build/HeaderMarshaller.d.ts

@@ -1,3 +0,3 @@

import { MessageHeaders } from './Message';
import { Decoder, Encoder } from '@aws-sdk/types';
import { MessageHeaders } from "./Message";
import { Decoder, Encoder } from "@aws-sdk/types";
/**

@@ -4,0 +4,0 @@ * @internal

66

build/HeaderMarshaller.js

@@ -51,14 +51,11 @@ "use strict";

switch (header.type) {
case 'boolean':
case "boolean":
return Uint8Array.from([
header.value
? 0 /* boolTrue */
: 1 /* boolFalse */,
: 1 /* boolFalse */
]);
case 'byte':
return Uint8Array.from([
2 /* byte */,
header.value,
]);
case 'short':
case "byte":
return Uint8Array.from([2 /* byte */, header.value]);
case "short":
var shortView = new DataView(new ArrayBuffer(3));

@@ -68,3 +65,3 @@ shortView.setUint8(0, 3 /* short */);

return new Uint8Array(shortView.buffer);
case 'integer':
case "integer":
var intView = new DataView(new ArrayBuffer(5));

@@ -74,3 +71,3 @@ intView.setUint8(0, 4 /* integer */);

return new Uint8Array(intView.buffer);
case 'long':
case "long":
var longBytes = new Uint8Array(9);

@@ -80,3 +77,3 @@ longBytes[0] = 5 /* long */;

return longBytes;
case 'binary':
case "binary":
var binView = new DataView(new ArrayBuffer(3 + header.value.byteLength));

@@ -88,3 +85,3 @@ binView.setUint8(0, 6 /* byteArray */);

return binBytes;
case 'string':
case "string":
var utf8Bytes = this.fromUtf8(header.value);

@@ -97,3 +94,3 @@ var strView = new DataView(new ArrayBuffer(3 + utf8Bytes.byteLength));

return strBytes;
case 'timestamp':
case "timestamp":
var tsBytes = new Uint8Array(9);

@@ -103,3 +100,3 @@ tsBytes[0] = 8 /* timestamp */;

return tsBytes;
case 'uuid':
case "uuid":
if (!UUID_PATTERN.test(header.value)) {

@@ -110,3 +107,3 @@ throw new Error("Invalid UUID received: " + header.value);

uuidBytes[0] = 9 /* uuid */;
uuidBytes.set(util_hex_encoding_1.fromHex(header.value.replace(/\-/g, '')), 1);
uuidBytes.set(util_hex_encoding_1.fromHex(header.value.replace(/\-/g, "")), 1);
return uuidBytes;

@@ -126,3 +123,3 @@ }

type: BOOLEAN_TAG,
value: true,
value: true
};

@@ -133,3 +130,3 @@ break;

type: BOOLEAN_TAG,
value: false,
value: false
};

@@ -140,3 +137,3 @@ break;

type: BYTE_TAG,
value: headers.getInt8(position++),
value: headers.getInt8(position++)
};

@@ -147,3 +144,3 @@ break;

type: SHORT_TAG,
value: headers.getInt16(position, false),
value: headers.getInt16(position, false)
};

@@ -155,3 +152,3 @@ position += 2;

type: INT_TAG,
value: headers.getInt32(position, false),
value: headers.getInt32(position, false)
};

@@ -172,3 +169,3 @@ position += 4;

type: BINARY_TAG,
value: new Uint8Array(headers.buffer, headers.byteOffset + position, binaryLength),
value: new Uint8Array(headers.buffer, headers.byteOffset + position, binaryLength)
};

@@ -182,3 +179,3 @@ position += binaryLength;

type: STRING_TAG,
value: this.toUtf8(new Uint8Array(headers.buffer, headers.byteOffset + position, stringLength)),
value: this.toUtf8(new Uint8Array(headers.buffer, headers.byteOffset + position, stringLength))
};

@@ -190,3 +187,3 @@ position += stringLength;

type: TIMESTAMP_TAG,
value: new Date(new Int64_1.Int64(new Uint8Array(headers.buffer, headers.byteOffset + position, 8)).valueOf()),
value: new Date(new Int64_1.Int64(new Uint8Array(headers.buffer, headers.byteOffset + position, 8)).valueOf())
};

@@ -200,3 +197,3 @@ position += 8;

type: UUID_TAG,
value: util_hex_encoding_1.toHex(uuidBytes.subarray(0, 4)) + "-" + util_hex_encoding_1.toHex(uuidBytes.subarray(4, 6)) + "-" + util_hex_encoding_1.toHex(uuidBytes.subarray(6, 8)) + "-" + util_hex_encoding_1.toHex(uuidBytes.subarray(8, 10)) + "-" + util_hex_encoding_1.toHex(uuidBytes.subarray(10)),
value: util_hex_encoding_1.toHex(uuidBytes.subarray(0, 4)) + "-" + util_hex_encoding_1.toHex(uuidBytes.subarray(4, 6)) + "-" + util_hex_encoding_1.toHex(uuidBytes.subarray(6, 8)) + "-" + util_hex_encoding_1.toHex(uuidBytes.subarray(8, 10)) + "-" + util_hex_encoding_1.toHex(uuidBytes.subarray(10))
};

@@ -213,13 +210,12 @@ break;

exports.HeaderMarshaller = HeaderMarshaller;
;
var BOOLEAN_TAG = 'boolean';
var BYTE_TAG = 'byte';
var SHORT_TAG = 'short';
var INT_TAG = 'integer';
var LONG_TAG = 'long';
var BINARY_TAG = 'binary';
var STRING_TAG = 'string';
var TIMESTAMP_TAG = 'timestamp';
var UUID_TAG = 'uuid';
var BOOLEAN_TAG = "boolean";
var BYTE_TAG = "byte";
var SHORT_TAG = "short";
var INT_TAG = "integer";
var LONG_TAG = "long";
var BINARY_TAG = "binary";
var STRING_TAG = "string";
var TIMESTAMP_TAG = "timestamp";
var UUID_TAG = "uuid";
var UUID_PATTERN = /^[a-f0-9]{8}-[a-f0-9]{4}-[a-f0-9]{4}-[a-f0-9]{4}-[a-f0-9]{12}$/;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiSGVhZGVyTWFyc2hhbGxlci5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3NyYy9IZWFkZXJNYXJzaGFsbGVyLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiI7OztBQUVBLGdFQUE0RDtBQUM1RCxpQ0FBZ0M7QUFFaEM7O0dBRUc7QUFDSDtJQUNJLDBCQUNxQixNQUFlLEVBQ2YsUUFBaUI7UUFEakIsV0FBTSxHQUFOLE1BQU0sQ0FBUztRQUNmLGFBQVEsR0FBUixRQUFRLENBQVM7SUFDbkMsQ0FBQztJQUVKLGlDQUFNLEdBQU4sVUFBTyxPQUF1Qjs7UUFDMUIsSUFBTSxNQUFNLEdBQXNCLEVBQUUsQ0FBQzs7WUFFckMsS0FBeUIsSUFBQSxLQUFBLGlCQUFBLE1BQU0sQ0FBQyxJQUFJLENBQUMsT0FBTyxDQUFDLENBQUEsZ0JBQUEsNEJBQUU7Z0JBQTFDLElBQU0sVUFBVSxXQUFBO2dCQUNqQixJQUFNLEtBQUssR0FBRyxJQUFJLENBQUMsUUFBUSxDQUFDLFVBQVUsQ0FBQyxDQUFDO2dCQUN4QyxNQUFNLENBQUMsSUFBSSxDQUNQLFVBQVUsQ0FBQyxJQUFJLENBQUMsQ0FBQyxLQUFLLENBQUMsVUFBVSxDQUFDLENBQUMsRUFDbkMsS0FBSyxFQUNMLElBQUksQ0FBQyxpQkFBaUIsQ0FBQyxPQUFPLENBQUMsVUFBVSxDQUFDLENBQUMsQ0FDOUMsQ0FBQzthQUNMOzs7Ozs7Ozs7UUFFRCxJQUFNLEdBQUcsR0FBRyxJQUFJLFVBQVUsQ0FDdEIsTUFBTSxDQUFDLE1BQU0sQ0FBQyxVQUFDLEtBQUssRUFBRSxLQUFLLElBQUssT0FBQSxLQUFLLEdBQUcsS0FBSyxDQUFDLFVBQVUsRUFBeEIsQ0FBd0IsRUFBRSxDQUFDLENBQUMsQ0FDL0QsQ0FBQztRQUNGLElBQUksUUFBUSxHQUFHLENBQUMsQ0FBQzs7WUFDakIsS0FBb0IsSUFBQSxXQUFBLGlCQUFBLE1BQU0sQ0FBQSw4QkFBQSxrREFBRTtnQkFBdkIsSUFBTSxLQUFLLG1CQUFBO2dCQUNaLEdBQUcsQ0FBQyxHQUFHLENBQUMsS0FBSyxFQUFFLFFBQVEsQ0FBQyxDQUFDO2dCQUN6QixRQUFRLElBQUksS0FBSyxDQUFDLFVBQVUsQ0FBQzthQUNoQzs7Ozs7Ozs7O1FBRUQsT0FBTyxHQUFHLENBQUM7SUFDZixDQUFDO0lBRU8sNENBQWlCLEdBQXpCLFVBQTBCLE1BQTBCO1FBQ2hELFFBQVEsTUFBTSxDQUFDLElBQUksRUFBRTtZQUNqQixLQUFLLFNBQVM7Z0JBQ1YsT0FBTyxVQUFVLENBQUMsSUFBSSxDQUFDO29CQUNuQixNQUFNLENBQUMsS0FBSzt3QkFDUixDQUFDO3dCQUNELENBQUMsa0JBQTRCO2lCQUNwQyxDQUFDLENBQUM7WUFDUCxLQUFLLE1BQU07Z0JBQ1AsT0FBTyxVQUFVLENBQUMsSUFBSSxDQUFDOztvQkFFbkIsTUFBTSxDQUFDLEtBQUs7aUJBQ2YsQ0FBQyxDQUFDO1lBQ1AsS0FBSyxPQUFPO2dCQUNSLElBQU0sU0FBUyxHQUFHLElBQUksUUFBUSxDQUFDLElBQUksV0FBVyxDQUFDLENBQUMsQ0FBQyxDQUFDLENBQUM7Z0JBQ25ELFNBQVMsQ0FBQyxRQUFRLENBQUMsQ0FBQyxnQkFBMEIsQ0FBQztnQkFDL0MsU0FBUyxDQUFDLFFBQVEsQ0FBQyxDQUFDLEVBQUUsTUFBTSxDQUFDLEtBQUssRUFBRSxLQUFLLENBQUMsQ0FBQztnQkFDM0MsT0FBTyxJQUFJLFVBQVUsQ0FBQyxTQUFTLENBQUMsTUFBTSxDQUFDLENBQUM7WUFDNUMsS0FBSyxTQUFTO2dCQUNWLElBQU0sT0FBTyxHQUFHLElBQUksUUFBUSxDQUFDLElBQUksV0FBVyxDQUFDLENBQUMsQ0FBQyxDQUFDLENBQUM7Z0JBQ2pELE9BQU8sQ0FBQyxRQUFRLENBQUMsQ0FBQyxrQkFBNEIsQ0FBQztnQkFDL0MsT0FBTyxDQUFDLFFBQVEsQ0FBQyxDQUFDLEVBQUUsTUFBTSxDQUFDLEtBQUssRUFBRSxLQUFLLENBQUMsQ0FBQztnQkFDekMsT0FBTyxJQUFJLFVBQVUsQ0FBQyxPQUFPLENBQUMsTUFBTSxDQUFDLENBQUM7WUFDMUMsS0FBSyxNQUFNO2dCQUNQLElBQU0sU0FBUyxHQUFHLElBQUksVUFBVSxDQUFDLENBQUMsQ0FBQyxDQUFDO2dCQUNwQyxTQUFTLENBQUMsQ0FBQyxDQUFDLGVBQXlCLENBQUM7Z0JBQ3RDLFNBQVMsQ0FBQyxHQUFHLENBQUMsTUFBTSxDQUFDLEtBQUssQ0FBQyxLQUFLLEVBQUUsQ0FBQyxDQUFDLENBQUM7Z0JBQ3JDLE9BQU8sU0FBUyxDQUFDO1lBQ3JCLEtBQUssUUFBUTtnQkFDVCxJQUFNLE9BQU8sR0FBRyxJQUFJLFFBQVEsQ0FDeEIsSUFBSSxXQUFXLENBQUMsQ0FBQyxHQUFHLE1BQU0sQ0FBQyxLQUFLLENBQUMsVUFBVSxDQUFDLENBQy9DLENBQUM7Z0JBQ0YsT0FBTyxDQUFDLFFBQVEsQ0FBQyxDQUFDLG9CQUE4QixDQUFDO2dCQUNqRCxPQUFPLENBQUMsU0FBUyxDQUFDLENBQUMsRUFBRSxNQUFNLENBQUMsS0FBSyxDQUFDLFVBQVUsRUFBRSxLQUFLLENBQUMsQ0FBQztnQkFDckQsSUFBTSxRQUFRLEdBQUcsSUFBSSxVQUFVLENBQUMsT0FBTyxDQUFDLE1BQU0sQ0FBQyxDQUFDO2dCQUNoRCxRQUFRLENBQUMsR0FBRyxDQUFDLE1BQU0sQ0FBQyxLQUFLLEVBQUUsQ0FBQyxDQUFDLENBQUM7Z0JBQzlCLE9BQU8sUUFBUSxDQUFDO1lBQ3BCLEtBQUssUUFBUTtnQkFDVCxJQUFNLFNBQVMsR0FBRyxJQUFJLENBQUMsUUFBUSxDQUFDLE1BQU0sQ0FBQyxLQUFLLENBQUMsQ0FBQztnQkFDOUMsSUFBTSxPQUFPLEdBQUcsSUFBSSxRQUFRLENBQ3hCLElBQUksV0FBVyxDQUFDLENBQUMsR0FBRyxTQUFTLENBQUMsVUFBVSxDQUFDLENBQzVDLENBQUM7Z0JBQ0YsT0FBTyxDQUFDLFFBQVEsQ0FBQyxDQUFDLGlCQUEyQixDQUFDO2dCQUM5QyxPQUFPLENBQUMsU0FBUyxDQUFDLENBQUMsRUFBRSxTQUFTLENBQUMsVUFBVSxFQUFFLEtBQUssQ0FBQyxDQUFDO2dCQUNsRCxJQUFNLFFBQVEsR0FBRyxJQUFJLFVBQVUsQ0FBQyxPQUFPLENBQUMsTUFBTSxDQUFDLENBQUM7Z0JBQ2hELFFBQVEsQ0FBQyxHQUFHLENBQUMsU0FBUyxFQUFFLENBQUMsQ0FBQyxDQUFDO2dCQUMzQixPQUFPLFFBQVEsQ0FBQztZQUNwQixLQUFLLFdBQVc7Z0JBQ1osSUFBTSxPQUFPLEdBQUcsSUFBSSxVQUFVLENBQUMsQ0FBQyxDQUFDLENBQUM7Z0JBQ2xDLE9BQU8sQ0FBQyxDQUFDLENBQUMsb0JBQThCLENBQUM7Z0JBQ3pDLE9BQU8sQ0FBQyxHQUFHLENBQUMsYUFBSyxDQUFDLFVBQVUsQ0FBQyxNQUFNLENBQUMsS0FBSyxDQUFDLE9BQU8sRUFBRSxDQUFDLENBQUMsS0FBSyxFQUFFLENBQUMsQ0FBQyxDQUFDO2dCQUMvRCxPQUFPLE9BQU8sQ0FBQztZQUNuQixLQUFLLE1BQU07Z0JBQ1AsSUFBSSxDQUFDLFlBQVksQ0FBQyxJQUFJLENBQUMsTUFBTSxDQUFDLEtBQUssQ0FBQyxFQUFFO29CQUNsQyxNQUFNLElBQUksS0FBSyxDQUFDLDRCQUEwQixNQUFNLENBQUMsS0FBTyxDQUFDLENBQUM7aUJBQzdEO2dCQUVELElBQU0sU0FBUyxHQUFHLElBQUksVUFBVSxDQUFDLEVBQUUsQ0FBQyxDQUFDO2dCQUNyQyxTQUFTLENBQUMsQ0FBQyxDQUFDLGVBQXlCLENBQUM7Z0JBQ3RDLFNBQVMsQ0FBQyxHQUFHLENBQUMsMkJBQU8sQ0FBQyxNQUFNLENBQUMsS0FBSyxDQUFDLE9BQU8sQ0FBQyxLQUFLLEVBQUUsRUFBRSxDQUFDLENBQUMsRUFBRSxDQUFDLENBQUMsQ0FBQztnQkFDM0QsT0FBTyxTQUFTLENBQUM7U0FDeEI7SUFDTCxDQUFDO0lBRUQsZ0NBQUssR0FBTCxVQUFNLE9BQWlCO1FBQ25CLElBQU0sR0FBRyxHQUFtQixFQUFFLENBQUM7UUFDL0IsSUFBSSxRQUFRLEdBQUcsQ0FBQyxDQUFDO1FBRWpCLE9BQU8sUUFBUSxHQUFHLE9BQU8sQ0FBQyxVQUFVLEVBQUU7WUFDbEMsSUFBTSxVQUFVLEdBQUcsT0FBTyxDQUFDLFFBQVEsQ0FBQyxRQUFRLEVBQUUsQ0FBQyxDQUFDO1lBQ2hELElBQU0sSUFBSSxHQUFHLElBQUksQ0FBQyxNQUFNLENBQUMsSUFBSSxVQUFVLENBQ25DLE9BQU8sQ0FBQyxNQUFNLEVBQ2QsT0FBTyxDQUFDLFVBQVUsR0FBRyxRQUFRLEVBQzdCLFVBQVUsQ0FDYixDQUFDLENBQUM7WUFDSCxRQUFRLElBQUksVUFBVSxDQUFDO1lBRXZCLFFBQVEsT0FBTyxDQUFDLFFBQVEsQ0FBQyxRQUFRLEVBQUUsQ0FBQyxFQUFFO2dCQUNsQztvQkFDSSxHQUFHLENBQUMsSUFBSSxDQUFDLEdBQUc7d0JBQ1IsSUFBSSxFQUFFLFdBQVc7d0JBQ2pCLEtBQUssRUFBRSxJQUFJO3FCQUNkLENBQUM7b0JBQ0YsTUFBTTtnQkFDVjtvQkFDSSxHQUFHLENBQUMsSUFBSSxDQUFDLEdBQUc7d0JBQ1IsSUFBSSxFQUFFLFdBQVc7d0JBQ2pCLEtBQUssRUFBRSxLQUFLO3FCQUNmLENBQUM7b0JBQ0YsTUFBTTtnQkFDVjtvQkFDSSxHQUFHLENBQUMsSUFBSSxDQUFDLEdBQUc7d0JBQ1IsSUFBSSxFQUFFLFFBQVE7d0JBQ2QsS0FBSyxFQUFFLE9BQU8sQ0FBQyxPQUFPLENBQUMsUUFBUSxFQUFFLENBQUM7cUJBQ3JDLENBQUM7b0JBQ0YsTUFBTTtnQkFDVjtvQkFDSSxHQUFHLENBQUMsSUFBSSxDQUFDLEdBQUc7d0JBQ1IsSUFBSSxFQUFFLFNBQVM7d0JBQ2YsS0FBSyxFQUFFLE9BQU8sQ0FBQyxRQUFRLENBQUMsUUFBUSxFQUFFLEtBQUssQ0FBQztxQkFDM0MsQ0FBQztvQkFDRixRQUFRLElBQUksQ0FBQyxDQUFDO29CQUNkLE1BQU07Z0JBQ1Y7b0JBQ0ksR0FBRyxDQUFDLElBQUksQ0FBQyxHQUFHO3dCQUNSLElBQUksRUFBRSxPQUFPO3dCQUNiLEtBQUssRUFBRSxPQUFPLENBQUMsUUFBUSxDQUFDLFFBQVEsRUFBRSxLQUFLLENBQUM7cUJBQzNDLENBQUM7b0JBQ0YsUUFBUSxJQUFJLENBQUMsQ0FBQztvQkFDZCxNQUFNO2dCQUNWO29CQUNJLEdBQUcsQ0FBQyxJQUFJLENBQUMsR0FBRzt3QkFDUixJQUFJLEVBQUUsUUFBUTt3QkFDZCxLQUFLLEVBQUUsSUFBSSxhQUFLLENBQUMsSUFBSSxVQUFVLENBQzNCLE9BQU8sQ0FBQyxNQUFNLEVBQ2QsT0FBTyxDQUFDLFVBQVUsR0FBRyxRQUFRLEVBQzdCLENBQUMsQ0FDSixDQUFDO3FCQUNMLENBQUM7b0JBQ0YsUUFBUSxJQUFJLENBQUMsQ0FBQztvQkFDZCxNQUFNO2dCQUNWO29CQUNJLElBQU0sWUFBWSxHQUFHLE9BQU8sQ0FBQyxTQUFTLENBQUMsUUFBUSxFQUFFLEtBQUssQ0FBQyxDQUFDO29CQUN4RCxRQUFRLElBQUksQ0FBQyxDQUFDO29CQUNkLEdBQUcsQ0FBQyxJQUFJLENBQUMsR0FBRzt3QkFDUixJQUFJLEVBQUUsVUFBVTt3QkFDaEIsS0FBSyxFQUFFLElBQUksVUFBVSxDQUNqQixPQUFPLENBQUMsTUFBTSxFQUNkLE9BQU8sQ0FBQyxVQUFVLEdBQUcsUUFBUSxFQUM3QixZQUFZLENBQ2Y7cUJBQ0osQ0FBQztvQkFDRixRQUFRLElBQUksWUFBWSxDQUFDO29CQUN6QixNQUFNO2dCQUNWO29CQUNJLElBQU0sWUFBWSxHQUFHLE9BQU8sQ0FBQyxTQUFTLENBQUMsUUFBUSxFQUFFLEtBQUssQ0FBQyxDQUFDO29CQUN4RCxRQUFRLElBQUksQ0FBQyxDQUFDO29CQUNkLEdBQUcsQ0FBQyxJQUFJLENBQUMsR0FBRzt3QkFDUixJQUFJLEVBQUUsVUFBVTt3QkFDaEIsS0FBSyxFQUFFLElBQUksQ0FBQyxNQUFNLENBQUMsSUFBSSxVQUFVLENBQzdCLE9BQU8sQ0FBQyxNQUFNLEVBQ2QsT0FBTyxDQUFDLFVBQVUsR0FBRyxRQUFRLEVBQzdCLFlBQVksQ0FDZixDQUFDO3FCQUNMLENBQUM7b0JBQ0YsUUFBUSxJQUFJLFlBQVksQ0FBQztvQkFDekIsTUFBTTtnQkFDVjtvQkFDSSxHQUFHLENBQUMsSUFBSSxDQUFDLEdBQUc7d0JBQ1IsSUFBSSxFQUFFLGFBQWE7d0JBQ25CLEtBQUssRUFBRSxJQUFJLElBQUksQ0FBQyxJQUFJLGFBQUssQ0FBQyxJQUFJLFVBQVUsQ0FDcEMsT0FBTyxDQUFDLE1BQU0sRUFDZCxPQUFPLENBQUMsVUFBVSxHQUFHLFFBQVEsRUFDN0IsQ0FBQyxDQUNKLENBQUMsQ0FBQyxPQUFPLEVBQUUsQ0FBQztxQkFDaEIsQ0FBQztvQkFDRixRQUFRLElBQUksQ0FBQyxDQUFDO29CQUNkLE1BQU07Z0JBQ1Y7b0JBQ0ksSUFBTSxTQUFTLEdBQUcsSUFBSSxVQUFVLENBQzVCLE9BQU8sQ0FBQyxNQUFNLEVBQ2QsT0FBTyxDQUFDLFVBQVUsR0FBRyxRQUFRLEVBQzdCLEVBQUUsQ0FDTCxDQUFDO29CQUNGLFFBQVEsSUFBSSxFQUFFLENBQUM7b0JBQ2YsR0FBRyxDQUFDLElBQUksQ0FBQyxHQUFHO3dCQUNSLElBQUksRUFBRSxRQUFRO3dCQUNkLEtBQUssRUFDRCx5QkFBSyxDQUFDLFNBQVMsQ0FBQyxRQUFRLENBQUMsQ0FBQyxFQUFFLENBQUMsQ0FBQyxDQUFDLFNBRS9CLHlCQUFLLENBQUMsU0FBUyxDQUFDLFFBQVEsQ0FBQyxDQUFDLEVBQUUsQ0FBQyxDQUFDLENBQUMsU0FFL0IseUJBQUssQ0FBQyxTQUFTLENBQUMsUUFBUSxDQUFDLENBQUMsRUFBRSxDQUFDLENBQUMsQ0FBQyxTQUUvQix5QkFBSyxDQUFDLFNBQVMsQ0FBQyxRQUFRLENBQUMsQ0FBQyxFQUFFLEVBQUUsQ0FBQyxDQUFDLFNBRWhDLHlCQUFLLENBQUMsU0FBUyxDQUFDLFFBQVEsQ0FBQyxFQUFFLENBQUMsQ0FDOUI7cUJBQ0wsQ0FBQztvQkFDRixNQUFNO2dCQUNWO29CQUNJLE1BQU0sSUFBSSxLQUFLLENBQUMsOEJBQThCLENBQUMsQ0FBQzthQUN2RDtTQUNKO1FBRUQsT0FBTyxHQUFHLENBQUM7SUFDZixDQUFDO0lBQ0wsdUJBQUM7QUFBRCxDQUFDLEFBek5ELElBeU5DO0FBek5ZLDRDQUFnQjtBQXNPNUIsQ0FBQztBQUVGLElBQU0sV0FBVyxHQUFHLFNBQVMsQ0FBQztBQUM5QixJQUFNLFFBQVEsR0FBRyxNQUFNLENBQUM7QUFDeEIsSUFBTSxTQUFTLEdBQUcsT0FBTyxDQUFDO0FBQzFCLElBQU0sT0FBTyxHQUFHLFNBQVMsQ0FBQztBQUMxQixJQUFNLFFBQVEsR0FBRyxNQUFNLENBQUM7QUFDeEIsSUFBTSxVQUFVLEdBQUcsUUFBUSxDQUFDO0FBQzVCLElBQU0sVUFBVSxHQUFHLFFBQVEsQ0FBQztBQUM1QixJQUFNLGFBQWEsR0FBRyxXQUFXLENBQUM7QUFDbEMsSUFBTSxRQUFRLEdBQUcsTUFBTSxDQUFDO0FBRXhCLElBQU0sWUFBWSxHQUFHLGdFQUFnRSxDQUFDIiwic291cmNlc0NvbnRlbnQiOlsiaW1wb3J0IHsgTWVzc2FnZUhlYWRlcnMsIE1lc3NhZ2VIZWFkZXJWYWx1ZSB9IGZyb20gJy4vTWVzc2FnZSc7XG5pbXBvcnQgeyBEZWNvZGVyLCBFbmNvZGVyIH0gZnJvbSAnQGF3cy1zZGsvdHlwZXMnO1xuaW1wb3J0IHsgZnJvbUhleCwgdG9IZXggfSBmcm9tICdAYXdzLXNkay91dGlsLWhleC1lbmNvZGluZyc7XG5pbXBvcnQgeyBJbnQ2NCB9IGZyb20gJy4vSW50NjQnO1xuXG4vKipcbiAqIEBpbnRlcm5hbFxuICovXG5leHBvcnQgY2xhc3MgSGVhZGVyTWFyc2hhbGxlciB7XG4gICAgY29uc3RydWN0b3IoXG4gICAgICAgIHByaXZhdGUgcmVhZG9ubHkgdG9VdGY4OiBFbmNvZGVyLFxuICAgICAgICBwcml2YXRlIHJlYWRvbmx5IGZyb21VdGY4OiBEZWNvZGVyXG4gICAgKSB7fVxuXG4gICAgZm9ybWF0KGhlYWRlcnM6IE1lc3NhZ2VIZWFkZXJzKTogVWludDhBcnJheSB7XG4gICAgICAgIGNvbnN0IGNodW5rczogQXJyYXk8VWludDhBcnJheT4gPSBbXTtcblxuICAgICAgICBmb3IgKGNvbnN0IGhlYWRlck5hbWUgb2YgT2JqZWN0LmtleXMoaGVhZGVycykpIHtcbiAgICAgICAgICAgIGNvbnN0IGJ5dGVzID0gdGhpcy5mcm9tVXRmOChoZWFkZXJOYW1lKTtcbiAgICAgICAgICAgIGNodW5rcy5wdXNoKFxuICAgICAgICAgICAgICAgIFVpbnQ4QXJyYXkuZnJvbShbYnl0ZXMuYnl0ZUxlbmd0aF0pLFxuICAgICAgICAgICAgICAgIGJ5dGVzLFxuICAgICAgICAgICAgICAgIHRoaXMuZm9ybWF0SGVhZGVyVmFsdWUoaGVhZGVyc1toZWFkZXJOYW1lXSlcbiAgICAgICAgICAgICk7XG4gICAgICAgIH1cblxuICAgICAgICBjb25zdCBvdXQgPSBuZXcgVWludDhBcnJheShcbiAgICAgICAgICAgIGNodW5rcy5yZWR1Y2UoKGNhcnJ5LCBieXRlcykgPT4gY2FycnkgKyBieXRlcy5ieXRlTGVuZ3RoLCAwKVxuICAgICAgICApO1xuICAgICAgICBsZXQgcG9zaXRpb24gPSAwO1xuICAgICAgICBmb3IgKGNvbnN0IGNodW5rIG9mIGNodW5rcykge1xuICAgICAgICAgICAgb3V0LnNldChjaHVuaywgcG9zaXRpb24pO1xuICAgICAgICAgICAgcG9zaXRpb24gKz0gY2h1bmsuYnl0ZUxlbmd0aDtcbiAgICAgICAgfVxuXG4gICAgICAgIHJldHVybiBvdXQ7XG4gICAgfVxuXG4gICAgcHJpdmF0ZSBmb3JtYXRIZWFkZXJWYWx1ZShoZWFkZXI6IE1lc3NhZ2VIZWFkZXJWYWx1ZSk6IFVpbnQ4QXJyYXkge1xuICAgICAgICBzd2l0Y2ggKGhlYWRlci50eXBlKSB7XG4gICAgICAgICAgICBjYXNlICdib29sZWFuJzpcbiAgICAgICAgICAgICAgICByZXR1cm4gVWludDhBcnJheS5mcm9tKFtcbiAgICAgICAgICAgICAgICAgICAgaGVhZGVyLnZhbHVlXG4gICAgICAgICAgICAgICAgICAgICAgICA/IEhFQURFUl9WQUxVRV9UWVBFLmJvb2xUcnVlXG4gICAgICAgICAgICAgICAgICAgICAgICA6IEhFQURFUl9WQUxVRV9UWVBFLmJvb2xGYWxzZSxcbiAgICAgICAgICAgICAgICBdKTtcbiAgICAgICAgICAgIGNhc2UgJ2J5dGUnOlxuICAgICAgICAgICAgICAgIHJldHVybiBVaW50OEFycmF5LmZyb20oW1xuICAgICAgICAgICAgICAgICAgICBIRUFERVJfVkFMVUVfVFlQRS5ieXRlLFxuICAgICAgICAgICAgICAgICAgICBoZWFkZXIudmFsdWUsXG4gICAgICAgICAgICAgICAgXSk7XG4gICAgICAgICAgICBjYXNlICdzaG9ydCc6XG4gICAgICAgICAgICAgICAgY29uc3Qgc2hvcnRWaWV3ID0gbmV3IERhdGFWaWV3KG5ldyBBcnJheUJ1ZmZlcigzKSk7XG4gICAgICAgICAgICAgICAgc2hvcnRWaWV3LnNldFVpbnQ4KDAsIEhFQURFUl9WQUxVRV9UWVBFLnNob3J0KTtcbiAgICAgICAgICAgICAgICBzaG9ydFZpZXcuc2V0SW50MTYoMSwgaGVhZGVyLnZhbHVlLCBmYWxzZSk7XG4gICAgICAgICAgICAgICAgcmV0dXJuIG5ldyBVaW50OEFycmF5KHNob3J0Vmlldy5idWZmZXIpO1xuICAgICAgICAgICAgY2FzZSAnaW50ZWdlcic6XG4gICAgICAgICAgICAgICAgY29uc3QgaW50VmlldyA9IG5ldyBEYXRhVmlldyhuZXcgQXJyYXlCdWZmZXIoNSkpO1xuICAgICAgICAgICAgICAgIGludFZpZXcuc2V0VWludDgoMCwgSEVBREVSX1ZBTFVFX1RZUEUuaW50ZWdlcik7XG4gICAgICAgICAgICAgICAgaW50Vmlldy5zZXRJbnQzMigxLCBoZWFkZXIudmFsdWUsIGZhbHNlKTtcbiAgICAgICAgICAgICAgICByZXR1cm4gbmV3IFVpbnQ4QXJyYXkoaW50Vmlldy5idWZmZXIpO1xuICAgICAgICAgICAgY2FzZSAnbG9uZyc6XG4gICAgICAgICAgICAgICAgY29uc3QgbG9uZ0J5dGVzID0gbmV3IFVpbnQ4QXJyYXkoOSk7XG4gICAgICAgICAgICAgICAgbG9uZ0J5dGVzWzBdID0gSEVBREVSX1ZBTFVFX1RZUEUubG9uZztcbiAgICAgICAgICAgICAgICBsb25nQnl0ZXMuc2V0KGhlYWRlci52YWx1ZS5ieXRlcywgMSk7XG4gICAgICAgICAgICAgICAgcmV0dXJuIGxvbmdCeXRlcztcbiAgICAgICAgICAgIGNhc2UgJ2JpbmFyeSc6XG4gICAgICAgICAgICAgICAgY29uc3QgYmluVmlldyA9IG5ldyBEYXRhVmlldyhcbiAgICAgICAgICAgICAgICAgICAgbmV3IEFycmF5QnVmZmVyKDMgKyBoZWFkZXIudmFsdWUuYnl0ZUxlbmd0aClcbiAgICAgICAgICAgICAgICApO1xuICAgICAgICAgICAgICAgIGJpblZpZXcuc2V0VWludDgoMCwgSEVBREVSX1ZBTFVFX1RZUEUuYnl0ZUFycmF5KTtcbiAgICAgICAgICAgICAgICBiaW5WaWV3LnNldFVpbnQxNigxLCBoZWFkZXIudmFsdWUuYnl0ZUxlbmd0aCwgZmFsc2UpO1xuICAgICAgICAgICAgICAgIGNvbnN0IGJpbkJ5dGVzID0gbmV3IFVpbnQ4QXJyYXkoYmluVmlldy5idWZmZXIpO1xuICAgICAgICAgICAgICAgIGJpbkJ5dGVzLnNldChoZWFkZXIudmFsdWUsIDMpO1xuICAgICAgICAgICAgICAgIHJldHVybiBiaW5CeXRlcztcbiAgICAgICAgICAgIGNhc2UgJ3N0cmluZyc6XG4gICAgICAgICAgICAgICAgY29uc3QgdXRmOEJ5dGVzID0gdGhpcy5mcm9tVXRmOChoZWFkZXIudmFsdWUpO1xuICAgICAgICAgICAgICAgIGNvbnN0IHN0clZpZXcgPSBuZXcgRGF0YVZpZXcoXG4gICAgICAgICAgICAgICAgICAgIG5ldyBBcnJheUJ1ZmZlcigzICsgdXRmOEJ5dGVzLmJ5dGVMZW5ndGgpXG4gICAgICAgICAgICAgICAgKTtcbiAgICAgICAgICAgICAgICBzdHJWaWV3LnNldFVpbnQ4KDAsIEhFQURFUl9WQUxVRV9UWVBFLnN0cmluZyk7XG4gICAgICAgICAgICAgICAgc3RyVmlldy5zZXRVaW50MTYoMSwgdXRmOEJ5dGVzLmJ5dGVMZW5ndGgsIGZhbHNlKTtcbiAgICAgICAgICAgICAgICBjb25zdCBzdHJCeXRlcyA9IG5ldyBVaW50OEFycmF5KHN0clZpZXcuYnVmZmVyKTtcbiAgICAgICAgICAgICAgICBzdHJCeXRlcy5zZXQodXRmOEJ5dGVzLCAzKTtcbiAgICAgICAgICAgICAgICByZXR1cm4gc3RyQnl0ZXM7XG4gICAgICAgICAgICBjYXNlICd0aW1lc3RhbXAnOlxuICAgICAgICAgICAgICAgIGNvbnN0IHRzQnl0ZXMgPSBuZXcgVWludDhBcnJheSg5KTtcbiAgICAgICAgICAgICAgICB0c0J5dGVzWzBdID0gSEVBREVSX1ZBTFVFX1RZUEUudGltZXN0YW1wO1xuICAgICAgICAgICAgICAgIHRzQnl0ZXMuc2V0KEludDY0LmZyb21OdW1iZXIoaGVhZGVyLnZhbHVlLnZhbHVlT2YoKSkuYnl0ZXMsIDEpO1xuICAgICAgICAgICAgICAgIHJldHVybiB0c0J5dGVzO1xuICAgICAgICAgICAgY2FzZSAndXVpZCc6XG4gICAgICAgICAgICAgICAgaWYgKCFVVUlEX1BBVFRFUk4udGVzdChoZWFkZXIudmFsdWUpKSB7XG4gICAgICAgICAgICAgICAgICAgIHRocm93IG5ldyBFcnJvcihgSW52YWxpZCBVVUlEIHJlY2VpdmVkOiAke2hlYWRlci52YWx1ZX1gKTtcbiAgICAgICAgICAgICAgICB9XG5cbiAgICAgICAgICAgICAgICBjb25zdCB1dWlkQnl0ZXMgPSBuZXcgVWludDhBcnJheSgxNyk7XG4gICAgICAgICAgICAgICAgdXVpZEJ5dGVzWzBdID0gSEVBREVSX1ZBTFVFX1RZUEUudXVpZDtcbiAgICAgICAgICAgICAgICB1dWlkQnl0ZXMuc2V0KGZyb21IZXgoaGVhZGVyLnZhbHVlLnJlcGxhY2UoL1xcLS9nLCAnJykpLCAxKTtcbiAgICAgICAgICAgICAgICByZXR1cm4gdXVpZEJ5dGVzO1xuICAgICAgICB9XG4gICAgfVxuXG4gICAgcGFyc2UoaGVhZGVyczogRGF0YVZpZXcpOiBNZXNzYWdlSGVhZGVycyB7XG4gICAgICAgIGNvbnN0IG91dDogTWVzc2FnZUhlYWRlcnMgPSB7fTtcbiAgICAgICAgbGV0IHBvc2l0aW9uID0gMDtcblxuICAgICAgICB3aGlsZSAocG9zaXRpb24gPCBoZWFkZXJzLmJ5dGVMZW5ndGgpIHtcbiAgICAgICAgICAgIGNvbnN0IG5hbWVMZW5ndGggPSBoZWFkZXJzLmdldFVpbnQ4KHBvc2l0aW9uKyspO1xuICAgICAgICAgICAgY29uc3QgbmFtZSA9IHRoaXMudG9VdGY4KG5ldyBVaW50OEFycmF5KFxuICAgICAgICAgICAgICAgIGhlYWRlcnMuYnVmZmVyLFxuICAgICAgICAgICAgICAgIGhlYWRlcnMuYnl0ZU9mZnNldCArIHBvc2l0aW9uLFxuICAgICAgICAgICAgICAgIG5hbWVMZW5ndGhcbiAgICAgICAgICAgICkpO1xuICAgICAgICAgICAgcG9zaXRpb24gKz0gbmFtZUxlbmd0aDtcblxuICAgICAgICAgICAgc3dpdGNoIChoZWFkZXJzLmdldFVpbnQ4KHBvc2l0aW9uKyspKSB7XG4gICAgICAgICAgICAgICAgY2FzZSBIRUFERVJfVkFMVUVfVFlQRS5ib29sVHJ1ZTpcbiAgICAgICAgICAgICAgICAgICAgb3V0W25hbWVdID0ge1xuICAgICAgICAgICAgICAgICAgICAgICAgdHlwZTogQk9PTEVBTl9UQUcsXG4gICAgICAgICAgICAgICAgICAgICAgICB2YWx1ZTogdHJ1ZSxcbiAgICAgICAgICAgICAgICAgICAgfTtcbiAgICAgICAgICAgICAgICAgICAgYnJlYWs7XG4gICAgICAgICAgICAgICAgY2FzZSBIRUFERVJfVkFMVUVfVFlQRS5ib29sRmFsc2U6XG4gICAgICAgICAgICAgICAgICAgIG91dFtuYW1lXSA9IHtcbiAgICAgICAgICAgICAgICAgICAgICAgIHR5cGU6IEJPT0xFQU5fVEFHLFxuICAgICAgICAgICAgICAgICAgICAgICAgdmFsdWU6IGZhbHNlLFxuICAgICAgICAgICAgICAgICAgICB9O1xuICAgICAgICAgICAgICAgICAgICBicmVhaztcbiAgICAgICAgICAgICAgICBjYXNlIEhFQURFUl9WQUxVRV9UWVBFLmJ5dGU6XG4gICAgICAgICAgICAgICAgICAgIG91dFtuYW1lXSA9IHtcbiAgICAgICAgICAgICAgICAgICAgICAgIHR5cGU6IEJZVEVfVEFHLFxuICAgICAgICAgICAgICAgICAgICAgICAgdmFsdWU6IGhlYWRlcnMuZ2V0SW50OChwb3NpdGlvbisrKSxcbiAgICAgICAgICAgICAgICAgICAgfTtcbiAgICAgICAgICAgICAgICAgICAgYnJlYWs7XG4gICAgICAgICAgICAgICAgY2FzZSBIRUFERVJfVkFMVUVfVFlQRS5zaG9ydDpcbiAgICAgICAgICAgICAgICAgICAgb3V0W25hbWVdID0ge1xuICAgICAgICAgICAgICAgICAgICAgICAgdHlwZTogU0hPUlRfVEFHLFxuICAgICAgICAgICAgICAgICAgICAgICAgdmFsdWU6IGhlYWRlcnMuZ2V0SW50MTYocG9zaXRpb24sIGZhbHNlKSxcbiAgICAgICAgICAgICAgICAgICAgfTtcbiAgICAgICAgICAgICAgICAgICAgcG9zaXRpb24gKz0gMjtcbiAgICAgICAgICAgICAgICAgICAgYnJlYWs7XG4gICAgICAgICAgICAgICAgY2FzZSBIRUFERVJfVkFMVUVfVFlQRS5pbnRlZ2VyOlxuICAgICAgICAgICAgICAgICAgICBvdXRbbmFtZV0gPSB7XG4gICAgICAgICAgICAgICAgICAgICAgICB0eXBlOiBJTlRfVEFHLFxuICAgICAgICAgICAgICAgICAgICAgICAgdmFsdWU6IGhlYWRlcnMuZ2V0SW50MzIocG9zaXRpb24sIGZhbHNlKSxcbiAgICAgICAgICAgICAgICAgICAgfTtcbiAgICAgICAgICAgICAgICAgICAgcG9zaXRpb24gKz0gNDtcbiAgICAgICAgICAgICAgICAgICAgYnJlYWs7XG4gICAgICAgICAgICAgICAgY2FzZSBIRUFERVJfVkFMVUVfVFlQRS5sb25nOlxuICAgICAgICAgICAgICAgICAgICBvdXRbbmFtZV0gPSB7XG4gICAgICAgICAgICAgICAgICAgICAgICB0eXBlOiBMT05HX1RBRyxcbiAgICAgICAgICAgICAgICAgICAgICAgIHZhbHVlOiBuZXcgSW50NjQobmV3IFVpbnQ4QXJyYXkoXG4gICAgICAgICAgICAgICAgICAgICAgICAgICAgaGVhZGVycy5idWZmZXIsXG4gICAgICAgICAgICAgICAgICAgICAgICAgICAgaGVhZGVycy5ieXRlT2Zmc2V0ICsgcG9zaXRpb24sXG4gICAgICAgICAgICAgICAgICAgICAgICAgICAgOFxuICAgICAgICAgICAgICAgICAgICAgICAgKSlcbiAgICAgICAgICAgICAgICAgICAgfTtcbiAgICAgICAgICAgICAgICAgICAgcG9zaXRpb24gKz0gODtcbiAgICAgICAgICAgICAgICAgICAgYnJlYWs7XG4gICAgICAgICAgICAgICAgY2FzZSBIRUFERVJfVkFMVUVfVFlQRS5ieXRlQXJyYXk6XG4gICAgICAgICAgICAgICAgICAgIGNvbnN0IGJpbmFyeUxlbmd0aCA9IGhlYWRlcnMuZ2V0VWludDE2KHBvc2l0aW9uLCBmYWxzZSk7XG4gICAgICAgICAgICAgICAgICAgIHBvc2l0aW9uICs9IDI7XG4gICAgICAgICAgICAgICAgICAgIG91dFtuYW1lXSA9IHtcbiAgICAgICAgICAgICAgICAgICAgICAgIHR5cGU6IEJJTkFSWV9UQUcsXG4gICAgICAgICAgICAgICAgICAgICAgICB2YWx1ZTogbmV3IFVpbnQ4QXJyYXkoXG4gICAgICAgICAgICAgICAgICAgICAgICAgICAgaGVhZGVycy5idWZmZXIsXG4gICAgICAgICAgICAgICAgICAgICAgICAgICAgaGVhZGVycy5ieXRlT2Zmc2V0ICsgcG9zaXRpb24sXG4gICAgICAgICAgICAgICAgICAgICAgICAgICAgYmluYXJ5TGVuZ3RoXG4gICAgICAgICAgICAgICAgICAgICAgICApLFxuICAgICAgICAgICAgICAgICAgICB9O1xuICAgICAgICAgICAgICAgICAgICBwb3NpdGlvbiArPSBiaW5hcnlMZW5ndGg7XG4gICAgICAgICAgICAgICAgICAgIGJyZWFrO1xuICAgICAgICAgICAgICAgIGNhc2UgSEVBREVSX1ZBTFVFX1RZUEUuc3RyaW5nOlxuICAgICAgICAgICAgICAgICAgICBjb25zdCBzdHJpbmdMZW5ndGggPSBoZWFkZXJzLmdldFVpbnQxNihwb3NpdGlvbiwgZmFsc2UpO1xuICAgICAgICAgICAgICAgICAgICBwb3NpdGlvbiArPSAyO1xuICAgICAgICAgICAgICAgICAgICBvdXRbbmFtZV0gPSB7XG4gICAgICAgICAgICAgICAgICAgICAgICB0eXBlOiBTVFJJTkdfVEFHLFxuICAgICAgICAgICAgICAgICAgICAgICAgdmFsdWU6IHRoaXMudG9VdGY4KG5ldyBVaW50OEFycmF5KFxuICAgICAgICAgICAgICAgICAgICAgICAgICAgIGhlYWRlcnMuYnVmZmVyLFxuICAgICAgICAgICAgICAgICAgICAgICAgICAgIGhlYWRlcnMuYnl0ZU9mZnNldCArIHBvc2l0aW9uLFxuICAgICAgICAgICAgICAgICAgICAgICAgICAgIHN0cmluZ0xlbmd0aFxuICAgICAgICAgICAgICAgICAgICAgICAgKSksXG4gICAgICAgICAgICAgICAgICAgIH07XG4gICAgICAgICAgICAgICAgICAgIHBvc2l0aW9uICs9IHN0cmluZ0xlbmd0aDtcbiAgICAgICAgICAgICAgICAgICAgYnJlYWs7XG4gICAgICAgICAgICAgICAgY2FzZSBIRUFERVJfVkFMVUVfVFlQRS50aW1lc3RhbXA6XG4gICAgICAgICAgICAgICAgICAgIG91dFtuYW1lXSA9IHtcbiAgICAgICAgICAgICAgICAgICAgICAgIHR5cGU6IFRJTUVTVEFNUF9UQUcsXG4gICAgICAgICAgICAgICAgICAgICAgICB2YWx1ZTogbmV3IERhdGUobmV3IEludDY0KG5ldyBVaW50OEFycmF5KFxuICAgICAgICAgICAgICAgICAgICAgICAgICAgIGhlYWRlcnMuYnVmZmVyLFxuICAgICAgICAgICAgICAgICAgICAgICAgICAgIGhlYWRlcnMuYnl0ZU9mZnNldCArIHBvc2l0aW9uLFxuICAgICAgICAgICAgICAgICAgICAgICAgICAgIDhcbiAgICAgICAgICAgICAgICAgICAgICAgICkpLnZhbHVlT2YoKSksXG4gICAgICAgICAgICAgICAgICAgIH07XG4gICAgICAgICAgICAgICAgICAgIHBvc2l0aW9uICs9IDg7XG4gICAgICAgICAgICAgICAgICAgIGJyZWFrO1xuICAgICAgICAgICAgICAgIGNhc2UgSEVBREVSX1ZBTFVFX1RZUEUudXVpZDpcbiAgICAgICAgICAgICAgICAgICAgY29uc3QgdXVpZEJ5dGVzID0gbmV3IFVpbnQ4QXJyYXkoXG4gICAgICAgICAgICAgICAgICAgICAgICBoZWFkZXJzLmJ1ZmZlcixcbiAgICAgICAgICAgICAgICAgICAgICAgIGhlYWRlcnMuYnl0ZU9mZnNldCArIHBvc2l0aW9uLFxuICAgICAgICAgICAgICAgICAgICAgICAgMTZcbiAgICAgICAgICAgICAgICAgICAgKTtcbiAgICAgICAgICAgICAgICAgICAgcG9zaXRpb24gKz0gMTY7XG4gICAgICAgICAgICAgICAgICAgIG91dFtuYW1lXSA9IHtcbiAgICAgICAgICAgICAgICAgICAgICAgIHR5cGU6IFVVSURfVEFHLFxuICAgICAgICAgICAgICAgICAgICAgICAgdmFsdWU6IGAke1xuICAgICAgICAgICAgICAgICAgICAgICAgICAgIHRvSGV4KHV1aWRCeXRlcy5zdWJhcnJheSgwLCA0KSlcbiAgICAgICAgICAgICAgICAgICAgICAgIH0tJHtcbiAgICAgICAgICAgICAgICAgICAgICAgICAgICB0b0hleCh1dWlkQnl0ZXMuc3ViYXJyYXkoNCwgNikpXG4gICAgICAgICAgICAgICAgICAgICAgICB9LSR7XG4gICAgICAgICAgICAgICAgICAgICAgICAgICAgdG9IZXgodXVpZEJ5dGVzLnN1YmFycmF5KDYsIDgpKVxuICAgICAgICAgICAgICAgICAgICAgICAgfS0ke1xuICAgICAgICAgICAgICAgICAgICAgICAgICAgIHRvSGV4KHV1aWRCeXRlcy5zdWJhcnJheSg4LCAxMCkpXG4gICAgICAgICAgICAgICAgICAgICAgICB9LSR7XG4gICAgICAgICAgICAgICAgICAgICAgICAgICAgdG9IZXgodXVpZEJ5dGVzLnN1YmFycmF5KDEwKSlcbiAgICAgICAgICAgICAgICAgICAgICAgIH1gLFxuICAgICAgICAgICAgICAgICAgICB9O1xuICAgICAgICAgICAgICAgICAgICBicmVhaztcbiAgICAgICAgICAgICAgICBkZWZhdWx0OlxuICAgICAgICAgICAgICAgICAgICB0aHJvdyBuZXcgRXJyb3IoYFVucmVjb2duaXplZCBoZWFkZXIgdHlwZSB0YWdgKTtcbiAgICAgICAgICAgIH1cbiAgICAgICAgfVxuXG4gICAgICAgIHJldHVybiBvdXQ7XG4gICAgfVxufVxuXG5jb25zdCBlbnVtIEhFQURFUl9WQUxVRV9UWVBFIHtcbiAgICBib29sVHJ1ZSA9IDAsXG4gICAgYm9vbEZhbHNlLFxuICAgIGJ5dGUsXG4gICAgc2hvcnQsXG4gICAgaW50ZWdlcixcbiAgICBsb25nLFxuICAgIGJ5dGVBcnJheSxcbiAgICBzdHJpbmcsXG4gICAgdGltZXN0YW1wLFxuICAgIHV1aWQsXG59O1xuXG5jb25zdCBCT09MRUFOX1RBRyA9ICdib29sZWFuJztcbmNvbnN0IEJZVEVfVEFHID0gJ2J5dGUnO1xuY29uc3QgU0hPUlRfVEFHID0gJ3Nob3J0JztcbmNvbnN0IElOVF9UQUcgPSAnaW50ZWdlcic7XG5jb25zdCBMT05HX1RBRyA9ICdsb25nJztcbmNvbnN0IEJJTkFSWV9UQUcgPSAnYmluYXJ5JztcbmNvbnN0IFNUUklOR19UQUcgPSAnc3RyaW5nJztcbmNvbnN0IFRJTUVTVEFNUF9UQUcgPSAndGltZXN0YW1wJztcbmNvbnN0IFVVSURfVEFHID0gJ3V1aWQnO1xuXG5jb25zdCBVVUlEX1BBVFRFUk4gPSAvXlthLWYwLTldezh9LVthLWYwLTldezR9LVthLWYwLTldezR9LVthLWYwLTldezR9LVthLWYwLTldezEyfSQvO1xuIl19
//# sourceMappingURL=HeaderMarshaller.js.map

6

build/index.d.ts

@@ -1,3 +0,3 @@

export * from './EventStreamMarshaller';
export * from './Int64';
export * from './Message';
export * from "./EventStreamMarshaller";
export * from "./Int64";
export * from "./Message";

2

build/index.js

@@ -6,2 +6,2 @@ "use strict";

tslib_1.__exportStar(require("./Int64"), exports);
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiaW5kZXguanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi9zcmMvaW5kZXgudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7O0FBQUEsa0VBQXdDO0FBQ3hDLGtEQUF3QiIsInNvdXJjZXNDb250ZW50IjpbImV4cG9ydCAqIGZyb20gJy4vRXZlbnRTdHJlYW1NYXJzaGFsbGVyJztcbmV4cG9ydCAqIGZyb20gJy4vSW50NjQnO1xuZXhwb3J0ICogZnJvbSAnLi9NZXNzYWdlJztcbiJdfQ==
//# sourceMappingURL=index.js.map

6

build/Int64.js

@@ -15,3 +15,3 @@ "use strict";

if (bytes.byteLength !== 8) {
throw new Error('Int64 buffers must be exactly 8 bytes');
throw new Error("Int64 buffers must be exactly 8 bytes");
}

@@ -51,3 +51,3 @@ }

for (var i = 0; i < 8; i++) {
bytes[i] ^= 0xFF;
bytes[i] ^= 0xff;
}

@@ -60,2 +60,2 @@ for (var i = 7; i > -1; i--) {

}
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiSW50NjQuanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyIuLi9zcmMvSW50NjQudHMiXSwibmFtZXMiOltdLCJtYXBwaW5ncyI6Ijs7QUFBQSxnRUFBbUQ7QUFFbkQ7Ozs7OztHQU1HO0FBQ0g7SUFDSSxlQUFxQixLQUFpQjtRQUFqQixVQUFLLEdBQUwsS0FBSyxDQUFZO1FBQ2xDLElBQUksS0FBSyxDQUFDLFVBQVUsS0FBSyxDQUFDLEVBQUU7WUFDeEIsTUFBTSxJQUFJLEtBQUssQ0FBQyx1Q0FBdUMsQ0FBQyxDQUFBO1NBQzNEO0lBQ0wsQ0FBQztJQUVNLGdCQUFVLEdBQWpCLFVBQWtCLE1BQWM7UUFDNUIsSUFBSSxNQUFNLEdBQUcsbUJBQW1CLElBQUksTUFBTSxHQUFHLENBQUMsbUJBQW1CLEVBQUU7WUFDL0QsTUFBTSxJQUFJLEtBQUssQ0FDUixNQUFNLHdFQUFxRSxDQUNqRixDQUFDO1NBQ0w7UUFFRCxJQUFNLEtBQUssR0FBRyxJQUFJLFVBQVUsQ0FBQyxDQUFDLENBQUMsQ0FBQTtRQUMvQixLQUNJLElBQUksQ0FBQyxHQUFHLENBQUMsRUFBRSxTQUFTLEdBQUcsSUFBSSxDQUFDLEdBQUcsQ0FBQyxJQUFJLENBQUMsS0FBSyxDQUFDLE1BQU0sQ0FBQyxDQUFDLEVBQ25ELENBQUMsR0FBRyxDQUFDLENBQUMsSUFBSSxTQUFTLEdBQUcsQ0FBQyxFQUN2QixDQUFDLEVBQUUsRUFBRSxTQUFTLElBQUksR0FBRyxFQUN2QjtZQUNFLEtBQUssQ0FBQyxDQUFDLENBQUMsR0FBRyxTQUFTLENBQUE7U0FDdkI7UUFFRCxJQUFJLE1BQU0sR0FBRyxDQUFDLEVBQUU7WUFDWixNQUFNLENBQUMsS0FBSyxDQUFDLENBQUM7U0FDakI7UUFFRCxPQUFPLElBQUksS0FBSyxDQUFDLEtBQUssQ0FBQyxDQUFDO0lBQzVCLENBQUM7SUFFRDs7T0FFRztJQUNILHVCQUFPLEdBQVA7UUFDSSxJQUFNLEtBQUssR0FBRyxJQUFJLENBQUMsS0FBSyxDQUFDLEtBQUssQ0FBQyxDQUFDLENBQUMsQ0FBQTtRQUNqQyxJQUFNLFFBQVEsR0FBRyxLQUFLLENBQUMsQ0FBQyxDQUFDLEdBQUcsR0FBVSxDQUFBO1FBQ3RDLElBQUksUUFBUSxFQUFFO1lBQ1YsTUFBTSxDQUFDLEtBQUssQ0FBQyxDQUFDO1NBQ2pCO1FBRUQsT0FBTyxRQUFRLENBQUMseUJBQUssQ0FBQyxLQUFLLENBQUMsRUFBRSxFQUFFLENBQUMsR0FBRyxDQUFDLFFBQVEsQ0FBQyxDQUFDLENBQUMsQ0FBQyxDQUFDLENBQUMsQ0FBQyxDQUFDLENBQUMsQ0FBQyxDQUFBO0lBQzNELENBQUM7SUFFRCx3QkFBUSxHQUFSO1FBQ0ksT0FBTyxNQUFNLENBQUMsSUFBSSxDQUFDLE9BQU8sRUFBRSxDQUFDLENBQUE7SUFDakMsQ0FBQztJQUNMLFlBQUM7QUFBRCxDQUFDLEFBOUNELElBOENDO0FBOUNZLHNCQUFLO0FBZ0RsQixTQUFTLE1BQU0sQ0FBQyxLQUFpQjtJQUM3QixLQUFLLElBQUksQ0FBQyxHQUFHLENBQUMsRUFBRSxDQUFDLEdBQUcsQ0FBQyxFQUFFLENBQUMsRUFBRSxFQUFFO1FBQ3hCLEtBQUssQ0FBQyxDQUFDLENBQUMsSUFBSSxJQUFJLENBQUE7S0FDbkI7SUFFRCxLQUFLLElBQUksQ0FBQyxHQUFHLENBQUMsRUFBRSxDQUFDLEdBQUcsQ0FBQyxDQUFDLEVBQUUsQ0FBQyxFQUFFLEVBQUU7UUFDekIsS0FBSyxDQUFDLENBQUMsQ0FBQyxFQUFFLENBQUE7UUFDVixJQUFJLEtBQUssQ0FBQyxDQUFDLENBQUMsS0FBSyxDQUFDO1lBQUUsTUFBSztLQUM1QjtBQUNMLENBQUMiLCJzb3VyY2VzQ29udGVudCI6WyJpbXBvcnQgeyB0b0hleCB9IGZyb20gJ0Bhd3Mtc2RrL3V0aWwtaGV4LWVuY29kaW5nJztcblxuLyoqXG4gKiBBIGxvc3NsZXNzIHJlcHJlc2VudGF0aW9uIG9mIGEgc2lnbmVkLCA2NC1iaXQgaW50ZWdlci4gSW5zdGFuY2VzIG9mIHRoaXNcbiAqIGNsYXNzIG1heSBiZSB1c2VkIGluIGFyaXRobWV0aWMgZXhwcmVzc2lvbnMgYXMgaWYgdGhleSB3ZXJlIG51bWVyaWNcbiAqIHByaW1pdGl2ZXMsIGJ1dCB0aGUgYmluYXJ5IHJlcHJlc2VudGF0aW9uIHdpbGwgYmUgcHJlc2VydmVkIHVuY2hhbmdlZCBhcyB0aGVcbiAqIGBieXRlc2AgcHJvcGVydHkgb2YgdGhlIG9iamVjdC4gVGhlIGJ5dGVzIHNob3VsZCBiZSBlbmNvZGVkIGFzIGJpZy1lbmRpYW4sXG4gKiB0d28ncyBjb21wbGVtZW50IGludGVnZXJzLlxuICovXG5leHBvcnQgY2xhc3MgSW50NjQge1xuICAgIGNvbnN0cnVjdG9yKHJlYWRvbmx5IGJ5dGVzOiBVaW50OEFycmF5KSB7XG4gICAgICAgIGlmIChieXRlcy5ieXRlTGVuZ3RoICE9PSA4KSB7XG4gICAgICAgICAgICB0aHJvdyBuZXcgRXJyb3IoJ0ludDY0IGJ1ZmZlcnMgbXVzdCBiZSBleGFjdGx5IDggYnl0ZXMnKVxuICAgICAgICB9XG4gICAgfVxuXG4gICAgc3RhdGljIGZyb21OdW1iZXIobnVtYmVyOiBudW1iZXIpOiBJbnQ2NCB7XG4gICAgICAgIGlmIChudW1iZXIgPiA5MjIzMzcyMDM2ODU0Nzc1ODA3IHx8IG51bWJlciA8IC05MjIzMzcyMDM2ODU0Nzc1ODA4KSB7XG4gICAgICAgICAgICB0aHJvdyBuZXcgRXJyb3IoXG4gICAgICAgICAgICAgICAgYCR7bnVtYmVyfSBpcyB0b28gbGFyZ2UgKG9yLCBpZiBuZWdhdGl2ZSwgdG9vIHNtYWxsKSB0byByZXByZXNlbnQgYXMgYW4gSW50NjRgXG4gICAgICAgICAgICApO1xuICAgICAgICB9XG5cbiAgICAgICAgY29uc3QgYnl0ZXMgPSBuZXcgVWludDhBcnJheSg4KVxuICAgICAgICBmb3IgKFxuICAgICAgICAgICAgbGV0IGkgPSA3LCByZW1haW5pbmcgPSBNYXRoLmFicyhNYXRoLnJvdW5kKG51bWJlcikpO1xuICAgICAgICAgICAgaSA+IC0xICYmIHJlbWFpbmluZyA+IDA7XG4gICAgICAgICAgICBpLS0sIHJlbWFpbmluZyAvPSAyNTZcbiAgICAgICAgKSB7XG4gICAgICAgICAgICBieXRlc1tpXSA9IHJlbWFpbmluZ1xuICAgICAgICB9XG5cbiAgICAgICAgaWYgKG51bWJlciA8IDApIHtcbiAgICAgICAgICAgIG5lZ2F0ZShieXRlcyk7XG4gICAgICAgIH1cblxuICAgICAgICByZXR1cm4gbmV3IEludDY0KGJ5dGVzKTtcbiAgICB9XG5cbiAgICAvKipcbiAgICAgKiBDYWxsZWQgaW1wbGljaXRseSBieSBpbmZpeCBhcml0aG1ldGljIG9wZXJhdG9ycy5cbiAgICAgKi9cbiAgICB2YWx1ZU9mKCk6IG51bWJlciB7XG4gICAgICAgIGNvbnN0IGJ5dGVzID0gdGhpcy5ieXRlcy5zbGljZSgwKVxuICAgICAgICBjb25zdCBuZWdhdGl2ZSA9IGJ5dGVzWzBdICYgMGIxMDAwMDAwMFxuICAgICAgICBpZiAobmVnYXRpdmUpIHtcbiAgICAgICAgICAgIG5lZ2F0ZShieXRlcyk7XG4gICAgICAgIH1cblxuICAgICAgICByZXR1cm4gcGFyc2VJbnQodG9IZXgoYnl0ZXMpLCAxNikgKiAobmVnYXRpdmUgPyAtMSA6IDEpXG4gICAgfVxuXG4gICAgdG9TdHJpbmcoKSB7XG4gICAgICAgIHJldHVybiBTdHJpbmcodGhpcy52YWx1ZU9mKCkpXG4gICAgfVxufVxuXG5mdW5jdGlvbiBuZWdhdGUoYnl0ZXM6IFVpbnQ4QXJyYXkpOiB2b2lkIHtcbiAgICBmb3IgKGxldCBpID0gMDsgaSA8IDg7IGkrKykge1xuICAgICAgICBieXRlc1tpXSBePSAweEZGXG4gICAgfVxuXG4gICAgZm9yIChsZXQgaSA9IDc7IGkgPiAtMTsgaS0tKSB7XG4gICAgICAgIGJ5dGVzW2ldKytcbiAgICAgICAgaWYgKGJ5dGVzW2ldICE9PSAwKSBicmVha1xuICAgIH1cbn1cbiJdfQ==
//# sourceMappingURL=Int64.js.map

20

build/Message.d.ts

@@ -1,2 +0,2 @@

import { Int64 } from './Int64';
import { Int64 } from "./Int64";
/**

@@ -15,37 +15,37 @@ * An event stream message. The headers and body properties will always be

export interface BooleanHeaderValue {
type: 'boolean';
type: "boolean";
value: boolean;
}
export interface ByteHeaderValue {
type: 'byte';
type: "byte";
value: number;
}
export interface ShortHeaderValue {
type: 'short';
type: "short";
value: number;
}
export interface IntegerHeaderValue {
type: 'integer';
type: "integer";
value: number;
}
export interface LongHeaderValue {
type: 'long';
type: "long";
value: Int64;
}
export interface BinaryHeaderValue {
type: 'binary';
type: "binary";
value: Uint8Array;
}
export interface StringHeaderValue {
type: 'string';
type: "string";
value: string;
}
export interface TimestampHeaderValue {
type: 'timestamp';
type: "timestamp";
value: Date;
}
export interface UuidHeaderValue {
type: 'uuid';
type: "uuid";
value: string;
}
export declare type MessageHeaderValue = BooleanHeaderValue | ByteHeaderValue | ShortHeaderValue | IntegerHeaderValue | LongHeaderValue | BinaryHeaderValue | StringHeaderValue | TimestampHeaderValue | UuidHeaderValue;

2

build/Message.js
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoiTWVzc2FnZS5qcyIsInNvdXJjZVJvb3QiOiIiLCJzb3VyY2VzIjpbIi4uL3NyYy9NZXNzYWdlLnRzIl0sIm5hbWVzIjpbXSwibWFwcGluZ3MiOiIiLCJzb3VyY2VzQ29udGVudCI6WyJpbXBvcnQgeyBJbnQ2NCB9IGZyb20gJy4vSW50NjQnO1xuXG4vKipcbiAqIEFuIGV2ZW50IHN0cmVhbSBtZXNzYWdlLiBUaGUgaGVhZGVycyBhbmQgYm9keSBwcm9wZXJ0aWVzIHdpbGwgYWx3YXlzIGJlXG4gKiBkZWZpbmVkLCB3aXRoIGVtcHR5IGhlYWRlcnMgcmVwcmVzZW50ZWQgYXMgYW4gb2JqZWN0IHdpdGggbm8ga2V5cyBhbmQgYW5cbiAqIGVtcHR5IGJvZHkgcmVwcmVzZW50ZWQgYXMgYSB6ZXJvLWxlbmd0aCBVaW50OEFycmF5LlxuICovXG5leHBvcnQgaW50ZXJmYWNlIE1lc3NhZ2Uge1xuICAgIGhlYWRlcnM6IE1lc3NhZ2VIZWFkZXJzO1xuICAgIGJvZHk6IFVpbnQ4QXJyYXk7XG59XG5cbmV4cG9ydCBpbnRlcmZhY2UgTWVzc2FnZUhlYWRlcnMge1xuICAgIFtuYW1lOiBzdHJpbmddOiBNZXNzYWdlSGVhZGVyVmFsdWU7XG59XG5cbmV4cG9ydCBpbnRlcmZhY2UgQm9vbGVhbkhlYWRlclZhbHVlIHtcbiAgICB0eXBlOiAnYm9vbGVhbic7XG4gICAgdmFsdWU6IGJvb2xlYW47XG59XG5cbmV4cG9ydCBpbnRlcmZhY2UgQnl0ZUhlYWRlclZhbHVlIHtcbiAgICB0eXBlOiAnYnl0ZSc7XG4gICAgdmFsdWU6IG51bWJlcjtcbn1cblxuZXhwb3J0IGludGVyZmFjZSBTaG9ydEhlYWRlclZhbHVlIHtcbiAgICB0eXBlOiAnc2hvcnQnO1xuICAgIHZhbHVlOiBudW1iZXI7XG59XG5cbmV4cG9ydCBpbnRlcmZhY2UgSW50ZWdlckhlYWRlclZhbHVlIHtcbiAgICB0eXBlOiAnaW50ZWdlcic7XG4gICAgdmFsdWU6IG51bWJlcjtcbn1cblxuZXhwb3J0IGludGVyZmFjZSBMb25nSGVhZGVyVmFsdWUge1xuICAgIHR5cGU6ICdsb25nJztcbiAgICB2YWx1ZTogSW50NjQ7XG59XG5cbmV4cG9ydCBpbnRlcmZhY2UgQmluYXJ5SGVhZGVyVmFsdWUge1xuICAgIHR5cGU6ICdiaW5hcnknO1xuICAgIHZhbHVlOiBVaW50OEFycmF5O1xufVxuXG5leHBvcnQgaW50ZXJmYWNlIFN0cmluZ0hlYWRlclZhbHVlIHtcbiAgICB0eXBlOiAnc3RyaW5nJztcbiAgICB2YWx1ZTogc3RyaW5nO1xufVxuXG5leHBvcnQgaW50ZXJmYWNlIFRpbWVzdGFtcEhlYWRlclZhbHVlIHtcbiAgICB0eXBlOiAndGltZXN0YW1wJztcbiAgICB2YWx1ZTogRGF0ZTtcbn1cblxuZXhwb3J0IGludGVyZmFjZSBVdWlkSGVhZGVyVmFsdWUge1xuICAgIHR5cGU6ICd1dWlkJztcbiAgICB2YWx1ZTogc3RyaW5nO1xufVxuXG5leHBvcnQgdHlwZSBNZXNzYWdlSGVhZGVyVmFsdWUgPVxuICAgIEJvb2xlYW5IZWFkZXJWYWx1ZSB8XG4gICAgQnl0ZUhlYWRlclZhbHVlIHxcbiAgICBTaG9ydEhlYWRlclZhbHVlIHxcbiAgICBJbnRlZ2VySGVhZGVyVmFsdWUgfFxuICAgIExvbmdIZWFkZXJWYWx1ZSB8XG4gICAgQmluYXJ5SGVhZGVyVmFsdWUgfFxuICAgIFN0cmluZ0hlYWRlclZhbHVlIHxcbiAgICBUaW1lc3RhbXBIZWFkZXJWYWx1ZSB8XG4gICAgVXVpZEhlYWRlclZhbHVlO1xuIl19
//# sourceMappingURL=Message.js.map

12

build/splitMessage.js

@@ -18,3 +18,3 @@ "use strict";

if (byteLength < MINIMUM_MESSAGE_LENGTH) {
throw new Error('Provided message too short to accommodate event stream message overhead');
throw new Error("Provided message too short to accommodate event stream message overhead");
}

@@ -24,3 +24,3 @@ var view = new DataView(buffer, byteOffset, byteLength);

if (byteLength !== messageLength) {
throw new Error('Reported message length does not match received message length');
throw new Error("Reported message length does not match received message length");
}

@@ -30,3 +30,3 @@ var headerLength = view.getUint32(PRELUDE_MEMBER_LENGTH, false);

var expectedMessageChecksum = view.getUint32(byteLength - CHECKSUM_LENGTH, false);
var checksummer = (new crc32_1.Crc32).update(new Uint8Array(buffer, byteOffset, PRELUDE_LENGTH));
var checksummer = new crc32_1.Crc32().update(new Uint8Array(buffer, byteOffset, PRELUDE_LENGTH));
if (expectedPreludeChecksum !== checksummer.digest()) {

@@ -41,6 +41,8 @@ throw new Error("The prelude checksum specified in the message (" + expectedPreludeChecksum + ") does not match the calculated CRC32 checksum (" + checksummer.digest() + ")");

headers: new DataView(buffer, byteOffset + PRELUDE_LENGTH + CHECKSUM_LENGTH, headerLength),
body: new Uint8Array(buffer, byteOffset + PRELUDE_LENGTH + CHECKSUM_LENGTH + headerLength, messageLength - headerLength - (PRELUDE_LENGTH + CHECKSUM_LENGTH + CHECKSUM_LENGTH))
body: new Uint8Array(buffer, byteOffset + PRELUDE_LENGTH + CHECKSUM_LENGTH + headerLength, messageLength -
headerLength -
(PRELUDE_LENGTH + CHECKSUM_LENGTH + CHECKSUM_LENGTH))
};
}
exports.splitMessage = splitMessage;
//# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoic3BsaXRNZXNzYWdlLmpzIiwic291cmNlUm9vdCI6IiIsInNvdXJjZXMiOlsiLi4vc3JjL3NwbGl0TWVzc2FnZS50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiOztBQUFBLDJDQUEwQztBQUUxQyx1REFBdUQ7QUFDdkQsSUFBTSxxQkFBcUIsR0FBRyxDQUFDLENBQUM7QUFDaEMseUNBQXlDO0FBQ3pDLElBQU0sY0FBYyxHQUFHLHFCQUFxQixHQUFHLENBQUMsQ0FBQztBQUNqRCxxQ0FBcUM7QUFDckMsSUFBTSxlQUFlLEdBQUcsQ0FBQyxDQUFDO0FBQzFCLG1GQUFtRjtBQUNuRixJQUFNLHNCQUFzQixHQUFHLGNBQWMsR0FBRyxlQUFlLEdBQUcsQ0FBQyxDQUFDO0FBVXBFOztHQUVHO0FBQ0gsU0FBZ0IsWUFBWSxDQUN4QixFQUFtRDtRQUFqRCwwQkFBVSxFQUFFLDBCQUFVLEVBQUUsa0JBQU07SUFFaEMsSUFBSSxVQUFVLEdBQUcsc0JBQXNCLEVBQUU7UUFDckMsTUFBTSxJQUFJLEtBQUssQ0FDWCx5RUFBeUUsQ0FDNUUsQ0FBQztLQUNMO0lBRUQsSUFBTSxJQUFJLEdBQUcsSUFBSSxRQUFRLENBQUMsTUFBTSxFQUFFLFVBQVUsRUFBRSxVQUFVLENBQUMsQ0FBQztJQUUxRCxJQUFNLGFBQWEsR0FBRyxJQUFJLENBQUMsU0FBUyxDQUFDLENBQUMsRUFBRSxLQUFLLENBQUMsQ0FBQztJQUUvQyxJQUFJLFVBQVUsS0FBSyxhQUFhLEVBQUU7UUFDOUIsTUFBTSxJQUFJLEtBQUssQ0FDWCxnRUFBZ0UsQ0FDbkUsQ0FBQztLQUNMO0lBRUQsSUFBTSxZQUFZLEdBQUcsSUFBSSxDQUFDLFNBQVMsQ0FBQyxxQkFBcUIsRUFBRSxLQUFLLENBQUMsQ0FBQztJQUNsRSxJQUFNLHVCQUF1QixHQUFHLElBQUksQ0FBQyxTQUFTLENBQUMsY0FBYyxFQUFFLEtBQUssQ0FBQyxDQUFDO0lBQ3RFLElBQU0sdUJBQXVCLEdBQUcsSUFBSSxDQUFDLFNBQVMsQ0FDMUMsVUFBVSxHQUFHLGVBQWUsRUFDNUIsS0FBSyxDQUNSLENBQUM7SUFFRixJQUFNLFdBQVcsR0FBRyxDQUFDLElBQUksYUFBSyxDQUFDLENBQUMsTUFBTSxDQUNsQyxJQUFJLFVBQVUsQ0FBQyxNQUFNLEVBQUUsVUFBVSxFQUFFLGNBQWMsQ0FBQyxDQUNyRCxDQUFDO0lBQ0YsSUFDSSx1QkFBdUIsS0FBSyxXQUFXLENBQUMsTUFBTSxFQUFFLEVBQ2xEO1FBQ0UsTUFBTSxJQUFJLEtBQUssQ0FDWCxvREFDSSx1QkFBdUIsd0RBRXZCLFdBQVcsQ0FBQyxNQUFNLEVBQUUsTUFDckIsQ0FDTixDQUFDO0tBQ0w7SUFFRCxXQUFXLENBQUMsTUFBTSxDQUFDLElBQUksVUFBVSxDQUM3QixNQUFNLEVBQ04sVUFBVSxHQUFHLGNBQWMsRUFDM0IsVUFBVSxHQUFHLENBQUMsY0FBYyxHQUFHLGVBQWUsQ0FBQyxDQUNsRCxDQUFDLENBQUM7SUFDSCxJQUFJLHVCQUF1QixLQUFLLFdBQVcsQ0FBQyxNQUFNLEVBQUUsRUFBRTtRQUNsRCxNQUFNLElBQUksS0FBSyxDQUNYLDJCQUNJLFdBQVcsQ0FBQyxNQUFNLEVBQUUsOENBQ2lCLHVCQUF5QixDQUNyRSxDQUFBO0tBQ0o7SUFFRCxPQUFPO1FBQ0gsT0FBTyxFQUFFLElBQUksUUFBUSxDQUNqQixNQUFNLEVBQ04sVUFBVSxHQUFHLGNBQWMsR0FBRyxlQUFlLEVBQzdDLFlBQVksQ0FDZjtRQUNELElBQUksRUFBRSxJQUFJLFVBQVUsQ0FDaEIsTUFBTSxFQUNOLFVBQVUsR0FBRyxjQUFjLEdBQUcsZUFBZSxHQUFHLFlBQVksRUFDNUQsYUFBYSxHQUFHLFlBQVksR0FBRyxDQUMzQixjQUFjLEdBQUcsZUFBZSxHQUFHLGVBQWUsQ0FDckQsQ0FDSjtLQUNKLENBQUM7QUFDTixDQUFDO0FBcEVELG9DQW9FQyIsInNvdXJjZXNDb250ZW50IjpbImltcG9ydCB7IENyYzMyIH0gZnJvbSAnQGF3cy1jcnlwdG8vY3JjMzInO1xuXG4vLyBBbGwgcHJlbHVkZSBjb21wb25lbnRzIGFyZSB1bnNpZ25lZCwgMzItYml0IGludGVnZXJzXG5jb25zdCBQUkVMVURFX01FTUJFUl9MRU5HVEggPSA0O1xuLy8gVGhlIHByZWx1ZGUgY29uc2lzdHMgb2YgdHdvIGNvbXBvbmVudHNcbmNvbnN0IFBSRUxVREVfTEVOR1RIID0gUFJFTFVERV9NRU1CRVJfTEVOR1RIICogMjtcbi8vIENoZWNrc3VtcyBhcmUgYWx3YXlzIENSQzMyIGhhc2hlcy5cbmNvbnN0IENIRUNLU1VNX0xFTkdUSCA9IDQ7XG4vLyBNZXNzYWdlcyBtdXN0IGluY2x1ZGUgYSBmdWxsIHByZWx1ZGUsIGEgcHJlbHVkZSBjaGVja3N1bSwgYW5kIGEgbWVzc2FnZSBjaGVja3N1bVxuY29uc3QgTUlOSU1VTV9NRVNTQUdFX0xFTkdUSCA9IFBSRUxVREVfTEVOR1RIICsgQ0hFQ0tTVU1fTEVOR1RIICogMjtcblxuLyoqXG4gKiBAaW50ZXJuYWxcbiAqL1xuZXhwb3J0IGludGVyZmFjZSBNZXNzYWdlUGFydHMge1xuICAgIGhlYWRlcnM6IERhdGFWaWV3O1xuICAgIGJvZHk6IFVpbnQ4QXJyYXk7XG59XG5cbi8qKlxuICogQGludGVybmFsXG4gKi9cbmV4cG9ydCBmdW5jdGlvbiBzcGxpdE1lc3NhZ2UoXG4gICAgeyBieXRlTGVuZ3RoLCBieXRlT2Zmc2V0LCBidWZmZXIgfTogQXJyYXlCdWZmZXJWaWV3XG4pOiBNZXNzYWdlUGFydHMge1xuICAgIGlmIChieXRlTGVuZ3RoIDwgTUlOSU1VTV9NRVNTQUdFX0xFTkdUSCkge1xuICAgICAgICB0aHJvdyBuZXcgRXJyb3IoXG4gICAgICAgICAgICAnUHJvdmlkZWQgbWVzc2FnZSB0b28gc2hvcnQgdG8gYWNjb21tb2RhdGUgZXZlbnQgc3RyZWFtIG1lc3NhZ2Ugb3ZlcmhlYWQnXG4gICAgICAgICk7XG4gICAgfVxuXG4gICAgY29uc3QgdmlldyA9IG5ldyBEYXRhVmlldyhidWZmZXIsIGJ5dGVPZmZzZXQsIGJ5dGVMZW5ndGgpO1xuXG4gICAgY29uc3QgbWVzc2FnZUxlbmd0aCA9IHZpZXcuZ2V0VWludDMyKDAsIGZhbHNlKTtcblxuICAgIGlmIChieXRlTGVuZ3RoICE9PSBtZXNzYWdlTGVuZ3RoKSB7XG4gICAgICAgIHRocm93IG5ldyBFcnJvcihcbiAgICAgICAgICAgICdSZXBvcnRlZCBtZXNzYWdlIGxlbmd0aCBkb2VzIG5vdCBtYXRjaCByZWNlaXZlZCBtZXNzYWdlIGxlbmd0aCdcbiAgICAgICAgKTtcbiAgICB9XG5cbiAgICBjb25zdCBoZWFkZXJMZW5ndGggPSB2aWV3LmdldFVpbnQzMihQUkVMVURFX01FTUJFUl9MRU5HVEgsIGZhbHNlKTtcbiAgICBjb25zdCBleHBlY3RlZFByZWx1ZGVDaGVja3N1bSA9IHZpZXcuZ2V0VWludDMyKFBSRUxVREVfTEVOR1RILCBmYWxzZSk7XG4gICAgY29uc3QgZXhwZWN0ZWRNZXNzYWdlQ2hlY2tzdW0gPSB2aWV3LmdldFVpbnQzMihcbiAgICAgICAgYnl0ZUxlbmd0aCAtIENIRUNLU1VNX0xFTkdUSCxcbiAgICAgICAgZmFsc2VcbiAgICApO1xuXG4gICAgY29uc3QgY2hlY2tzdW1tZXIgPSAobmV3IENyYzMyKS51cGRhdGUoXG4gICAgICAgIG5ldyBVaW50OEFycmF5KGJ1ZmZlciwgYnl0ZU9mZnNldCwgUFJFTFVERV9MRU5HVEgpXG4gICAgKTtcbiAgICBpZiAoXG4gICAgICAgIGV4cGVjdGVkUHJlbHVkZUNoZWNrc3VtICE9PSBjaGVja3N1bW1lci5kaWdlc3QoKVxuICAgICkge1xuICAgICAgICB0aHJvdyBuZXcgRXJyb3IoXG4gICAgICAgICAgICBgVGhlIHByZWx1ZGUgY2hlY2tzdW0gc3BlY2lmaWVkIGluIHRoZSBtZXNzYWdlICgke1xuICAgICAgICAgICAgICAgIGV4cGVjdGVkUHJlbHVkZUNoZWNrc3VtXG4gICAgICAgICAgICB9KSBkb2VzIG5vdCBtYXRjaCB0aGUgY2FsY3VsYXRlZCBDUkMzMiBjaGVja3N1bSAoJHtcbiAgICAgICAgICAgICAgICBjaGVja3N1bW1lci5kaWdlc3QoKVxuICAgICAgICAgICAgfSlgXG4gICAgICAgICk7XG4gICAgfVxuXG4gICAgY2hlY2tzdW1tZXIudXBkYXRlKG5ldyBVaW50OEFycmF5KFxuICAgICAgICBidWZmZXIsXG4gICAgICAgIGJ5dGVPZmZzZXQgKyBQUkVMVURFX0xFTkdUSCxcbiAgICAgICAgYnl0ZUxlbmd0aCAtIChQUkVMVURFX0xFTkdUSCArIENIRUNLU1VNX0xFTkdUSClcbiAgICApKTtcbiAgICBpZiAoZXhwZWN0ZWRNZXNzYWdlQ2hlY2tzdW0gIT09IGNoZWNrc3VtbWVyLmRpZ2VzdCgpKSB7XG4gICAgICAgIHRocm93IG5ldyBFcnJvcihcbiAgICAgICAgICAgIGBUaGUgbWVzc2FnZSBjaGVja3N1bSAoJHtcbiAgICAgICAgICAgICAgICBjaGVja3N1bW1lci5kaWdlc3QoKVxuICAgICAgICAgICAgfSkgZGlkIG5vdCBtYXRjaCB0aGUgZXhwZWN0ZWQgdmFsdWUgb2YgJHtleHBlY3RlZE1lc3NhZ2VDaGVja3N1bX1gXG4gICAgICAgIClcbiAgICB9XG5cbiAgICByZXR1cm4ge1xuICAgICAgICBoZWFkZXJzOiBuZXcgRGF0YVZpZXcoXG4gICAgICAgICAgICBidWZmZXIsXG4gICAgICAgICAgICBieXRlT2Zmc2V0ICsgUFJFTFVERV9MRU5HVEggKyBDSEVDS1NVTV9MRU5HVEgsXG4gICAgICAgICAgICBoZWFkZXJMZW5ndGhcbiAgICAgICAgKSxcbiAgICAgICAgYm9keTogbmV3IFVpbnQ4QXJyYXkoXG4gICAgICAgICAgICBidWZmZXIsXG4gICAgICAgICAgICBieXRlT2Zmc2V0ICsgUFJFTFVERV9MRU5HVEggKyBDSEVDS1NVTV9MRU5HVEggKyBoZWFkZXJMZW5ndGgsXG4gICAgICAgICAgICBtZXNzYWdlTGVuZ3RoIC0gaGVhZGVyTGVuZ3RoIC0gKFxuICAgICAgICAgICAgICAgIFBSRUxVREVfTEVOR1RIICsgQ0hFQ0tTVU1fTEVOR1RIICsgQ0hFQ0tTVU1fTEVOR1RIXG4gICAgICAgICAgICApXG4gICAgICAgIClcbiAgICB9O1xufVxuIl19
//# sourceMappingURL=splitMessage.js.map

16

CHANGELOG.md

@@ -6,12 +6,24 @@ # Change Log

# [0.1.0-preview.4](https://github.com/aws/aws-sdk-js-v3/compare/@aws-sdk/eventstream-marshaller@0.1.0-preview.3...@aws-sdk/eventstream-marshaller@0.1.0-preview.4) (2019-04-19)
# [0.1.0-preview.5](https://github.com/aws/aws-sdk-js-v3/compare/@aws-sdk/eventstream-marshaller@0.1.0-preview.3...@aws-sdk/eventstream-marshaller@0.1.0-preview.5) (2019-07-12)
**Note:** Version bump only for package @aws-sdk/eventstream-marshaller
### Features
* add npm badges for individual packages ([#251](https://github.com/aws/aws-sdk-js-v3/issues/251)) ([8adc10c](https://github.com/aws/aws-sdk-js-v3/commit/8adc10c))
* update jest v20 to v24 ([#243](https://github.com/aws/aws-sdk-js-v3/issues/243)) ([1e156ab](https://github.com/aws/aws-sdk-js-v3/commit/1e156ab))
# 0.1.0 (2019-04-19)
# [0.1.0-preview.4](https://github.com/aws/aws-sdk-js-v3/compare/@aws-sdk/eventstream-marshaller@0.1.0-preview.3...@aws-sdk/eventstream-marshaller@0.1.0-preview.4) (2019-04-19)
**Note:** Version bump only for package @aws-sdk/eventstream-marshaller
# [0.1.0-preview.3](https://github.com/aws/aws-sdk-js-v3/compare/@aws-sdk/eventstream-marshaller@0.1.0-preview.2...@aws-sdk/eventstream-marshaller@0.1.0-preview.3) (2019-03-27)
**Note:** Version bump only for package @aws-sdk/eventstream-marshaller

56

package.json
{
"name": "@aws-sdk/eventstream-marshaller",
"version": "0.1.0-preview.4",
"scripts": {
"prepublishOnly": "tsc",
"pretest": "tsc -p tsconfig.test.json",
"test": "jest --coverage --mapCoverage"
},
"main": "./build/index.js",
"types": "./build/index.d.ts",
"author": {
"name": "AWS SDK for JavaScript Team",
"email": "aws-sdk-js@amazon.com",
"url": "https://aws.amazon.com/javascript/"
},
"license": "Apache-2.0",
"dependencies": {
"@aws-crypto/crc32": "^0.1.0-preview.1",
"@aws-sdk/types": "^0.1.0-preview.3",
"@aws-sdk/util-hex-encoding": "^0.1.0-preview.1",
"tslib": "^1.8.0"
},
"devDependencies": {
"@aws-sdk/util-utf8-universal": "^0.1.0-preview.1",
"@types/jest": "^20.0.2",
"@types/node": "^8.10.29",
"jest": "^20.0.4",
"typescript": "^3.0.0"
}
"name": "@aws-sdk/eventstream-marshaller",
"version": "0.1.0-preview.5",
"scripts": {
"prepublishOnly": "tsc",
"pretest": "tsc -p tsconfig.test.json",
"test": "jest --coverage"
},
"main": "./build/index.js",
"types": "./build/index.d.ts",
"author": {
"name": "AWS SDK for JavaScript Team",
"email": "",
"url": "https://aws.amazon.com/javascript/"
},
"license": "Apache-2.0",
"dependencies": {
"@aws-crypto/crc32": "^0.1.0-preview.1",
"@aws-sdk/types": "^0.1.0-preview.4",
"@aws-sdk/util-hex-encoding": "^0.1.0-preview.2",
"tslib": "^1.8.0"
},
"devDependencies": {
"@aws-sdk/util-utf8-universal": "^0.1.0-preview.2",
"@types/jest": "^24.0.12",
"@types/node": "^10.0.0",
"jest": "^24.7.1",
"typescript": "~3.4.0"
}
}

3

README.md
# @aws-sdk/eventstream-marshaller
[![NPM version](https://img.shields.io/npm/v/@aws-sdk/eventstream-marshaller/preview.svg)](https://www.npmjs.com/package/@aws-sdk/eventstream-marshaller)
[![NPM downloads](https://img.shields.io/npm/dm/@aws-sdk/eventstream-marshaller.svg)](https://www.npmjs.com/package/@aws-sdk/eventstream-marshaller)

40

tsconfig.json
{
"compilerOptions": {
"target": "es5",
"module": "commonjs",
"declaration": true,
"strict": true,
"sourceMap": true,
"downlevelIteration": true,
"importHelpers": true,
"noEmitHelpers": true,
"lib": [
"es5",
"es2015.promise",
"es2015.collection",
"es2015.iterable",
"es2015.symbol.wellknown"
],
"rootDir": "./src",
"outDir": "./build"
}
}
"compilerOptions": {
"target": "es5",
"module": "commonjs",
"declaration": true,
"strict": true,
"sourceMap": true,
"downlevelIteration": true,
"importHelpers": true,
"noEmitHelpers": true,
"lib": [
"es5",
"es2015.promise",
"es2015.collection",
"es2015.iterable",
"es2015.symbol.wellknown"
],
"rootDir": "./src",
"outDir": "./build"
}
}
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