aws-event-stream - npm Package Compare versions

Comparing version 1.0.17 to 1.2.0

dist/event-store.d.ts

@@ -65,2 +65,9 @@ import { Event } from './model/event';
     /**
+     * Rertieve only one object containing all the events's data in the stream in order.
+     * @param offset The start position in the stream list
+     * @param limit The desired quantity events
+     * @return All the events
+     */
+    loadFromHistory(offset?: number, limit?: number): Promise<Event>;
+    /**
      * Add a new event to the end of the event stream.
@@ -67,0 +74,0 @@ * @param data The event data

dist/event-stream.d.ts

@@ -28,2 +28,9 @@ import { EventStore, EventStream } from './event-store';
     /**
+     * Rertieve only one object containing all the events's data in the stream in order.
+     * @param offset The start position in the stream list
+     * @param limit The desired quantity events
+     * @return All the events
+     */
+    loadFromHistory(offset?: number, limit?: number): Promise<Event>;
+    /**
      * Add a new event to the end of the event stream.
@@ -30,0 +37,0 @@ * @param data The event data

dist/event-stream.js

@@ -51,2 +51,3 @@ "use strict";
 exports.EventStreamImpl = void 0;
+var event_util_1 = require("./model/event-util");
 /**
@@ -91,2 +92,21 @@ * An Event Stream
     /**
+     * Rertieve only one object containing all the events's data in the stream in order.
+     * @param offset The start position in the stream list
+     * @param limit The desired quantity events
+     * @return All the events
+     */
+    EventStreamImpl.prototype.loadFromHistory = function (offset, limit) {
+        return __awaiter(this, void 0, void 0, function () {
+            var events;
+            return __generator(this, function (_a) {
+                switch (_a.label) {
+                    case 0: return [4 /*yield*/, this.getEvents(offset, limit)];
+                    case 1:
+                        events = _a.sent();
+                        return [2 /*return*/, event_util_1.eventMerge(events)];
+                }
+            });
+        });
+    };
+    /**
      * Add a new event to the end of the event stream.
@@ -93,0 +113,0 @@ * @param data The event data

dist/index.d.ts

@@ -11,3 +11,2 @@ import { Config } from './dynamodb/dynamodb-config';
 import { SNSPublisher } from './publisher/sns';
-import { SQSPublisher } from './publisher/sqs';
 export { PersistenceProvider };
@@ -24,3 +23,2 @@ export { Config };
 export { InMemoryPublisher };
-export { SQSPublisher };
 export { SNSPublisher };
@@ -27,0 +25,0 @@ export { DynamodbProvider };

dist/index.js

 'use strict';
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.InMemoryProvider = exports.DynamodbProvider = exports.SNSPublisher = exports.SQSPublisher = exports.InMemoryPublisher = exports.EventStore = void 0;
+exports.InMemoryProvider = exports.DynamodbProvider = exports.SNSPublisher = exports.InMemoryPublisher = exports.EventStore = void 0;
 var dynamodb_1 = require("./provider/dynamodb");
@@ -14,4 +14,2 @@ Object.defineProperty(exports, "DynamodbProvider", { enumerable: true, get: function () { return dynamodb_1.DynamodbProvider; } });
 Object.defineProperty(exports, "SNSPublisher", { enumerable: true, get: function () { return sns_1.SNSPublisher; } });
-var sqs_1 = require("./publisher/sqs");
-Object.defineProperty(exports, "SQSPublisher", { enumerable: true, get: function () { return sqs_1.SQSPublisher; } });
 //# sourceMappingURL=index.js.map

dist/model/event.d.ts

@@ -17,3 +17,3 @@ /**
     sequence?: number;
-    type?: string;
+    eventType?: string;
     id?: string;
@@ -20,0 +20,0 @@ }

dist/provider/dynamodb.js

@@ -71,2 +71,3 @@ 'use strict';
                             commitTimestamp: commitTimestamp,
+                            eventType: data.eventType,
                             payload: data,
@@ -130,2 +131,3 @@ stream: stream
                                 commitTimestamp: data.commitTimestamp,
+                                eventType: data.eventType || data.payload.eventType,
                                 payload: data.payload,
@@ -132,0 +134,0 @@ sequence: index,

dist/provider/memory.js

@@ -60,5 +60,5 @@ "use strict";
                             commitTimestamp: new Date().getTime(),
+                            eventType: type,
                             payload: data,
                             sequence: currentEvents.length,
-                            type: type
                         };
@@ -65,0 +65,0 @@ currentEvents.push(event);

dist/util.js

@@ -1,2 +0,2 @@
-"use strict";
+'use strict';
 Object.defineProperty(exports, "__esModule", { value: true });
@@ -3,0 +3,0 @@ exports.getEndpointUrl = void 0;

package.json

 {
   "name": "aws-event-stream",
-  "version": "1.0.17",
+  "version": "1.2.0",
   "description": "A simple and fast EventStore for AWS.",
@@ -99,4 +99,3 @@ "author": "Rodrigo Pinheiro de Almeida <[e-mail]>",
     "joi": "^13.7.0",
-    "lodash": "^4.17.20",
-    "sqs-consumer": "^5.4.0"
+    "lodash": "^4.17.20"
   },
@@ -103,0 +102,0 @@ "publishConfig": {

README.md

 
-aws-event-stream is an open source library to create Event Stores that works with AWS (at the moment, DynamoDB and SQS).
+# aws-event-stream
 
+**This library is based on https://github.com/thiagobustamante/node-eventstore
+
+It is an open source library to create Event Stores that works with AWS using DynamoDB as Provider and SNS to publish messages.
+
+[![npm version](https://badge.fury.io/js/aws-event-stream.svg)](https://badge.fury.io/js/aws-event-stream)
+![Master Workflow](https://github.com/rpinheiroalmeida/aws-event-stream/workflows/Master%20Workflow/badge.svg) ![Mutation Tests Workflow](https://github.com/rpinheiroalmeida/aws-event-stream/workflows/Mutation%20Tests%20Workflow/badge.svg) ![Publish Workflow](https://github.com/rpinheiroalmeida/aws-event-stream/workflows/Publish%20Workflow/badge.svg)
+
+
+## Motivation
+
+This is an open source library to create Event Stores that works with **DynamoDB** as persistence providers and **SNS** notification systems.
+
+The Event Store is a database accompanied by a publication and subscription system. The database stores all the events related to an event stream. The pub / sub system allows other systems or microservices to react to changes in event streams. It is a core component in any event sourcing + CQRS architectures.
+
 ## Installing
@@ -10,2 +24,87 @@
 
+## Usage
+
+### Create EventStore
+To Create an EventStore you must provide two implementations:
+
+   -  A DynamoDBProvider: Responsible for events persistence in the store.
+   -  A SNSPublisher (Optional): Responsible for notify any process interested in modifications on the store streams.
+
+If there is no publisher provided, the event store will not send any notification.
+
+```javascript
+const awsConfig = { region: 'us-east-1' };
+
+const dynamodbConfig = {
+    awsConfig: awsConfig,
+    dynamodb: {
+        tableName: 'events'
+    }
+} as Config;
+
+const eventStore = new EventStore(
+    new DynamodbProvider(dynamodbConfig),
+    new SNSPublisher('arn:sns', awsConfig),
+);
+
+```
+
+### Adding Events
+
+To add Events you need to ask to EventStore a reference to an EventStream. You can add Events passing anything you want as a payload. 
+
+```javascript
+const orderStream = eventStore.getEventStream('orders', '123');
+await orderStream.addEvent({ data: 'any data', eventType: 'PLACED' });
+```
+
+### Reading Events
+
+To read Events you need to ask to EventStore a reference to an EventStream. You can read a stream to receive an ordered list containing all the events in the store. 
+
+#### getEvents()
+
+Returns an array with all events published in the Stream specified.
+
+```javascript
+const orderStream = eventStore.getEventStream('orders', '123');
+const events = await orderStream.getEvents();
+```
+Example of event from **getEvents** method:
+
+```javascript
+[
+    { 
+        'commitTimestamp': 1611206813, 
+        'eventType': 'SENT', 
+        'payload': {'text': 'EVENT PAYLOAD', 'sequence': 1 }
+    },
+    { 
+        'commitTimestamp': 1611206823, 
+        'eventType': 'SENT', 
+        'payload': {'text': 'EVENT PAYLOAD', 'sequence': 2 }
+    }
+]
+```
+
+Or
+
+Returns an Object with all data from events happened in a Stream. What happens is a merge in all fields from all events, keeping the eventTypes as an array 
+
+```javascript
+const orderStream = eventStore.getEventStream('orders', '123');
+await orderStream.loadFromHistory();
+```
+
+Example of event from **loadFromHistory** method:
+
+```javascript
+    { 
+        'commitTimestamp': 1611206823, 
+        'eventTypes': ['SENT', 'PLACED'], 
+        'payload': {'text': "EVENT PAYLOAD", 'eventType': 'PLACED'}, 'sequence': 2 
+    }
+```
+
+
 ## Integration Test
@@ -12,0 +111,0 @@ Steps:

reports/coverage/coverage-final.json

 {"/home/runner/work/aws-event-stream/aws-event-stream/src/event-store.ts": {"path":"/home/runner/work/aws-event-stream/aws-event-stream/src/event-store.ts","statementMap":{"0":{"start":{"line":1,"column":0},"end":{"line":1,"column":28}},"1":{"start":{"line":2,"column":0},"end":{"line":2,"column":49}},"2":{"start":{"line":10,"column":0},"end":{"line":10,"column":13}},"3":{"start":{"line":16,"column":8},"end":{"line":16,"column":44}},"4":{"start":{"line":17,"column":8},"end":{"line":17,"column":40}},"5":{"start":{"line":20,"column":4},"end":{"line":25,"column":null}},"6":{"start":{"line":21,"column":8},"end":{"line":23,"column":null}},"7":{"start":{"line":22,"column":12},"end":{"line":22,"column":69}},"8":{"start":{"line":24,"column":8},"end":{"line":24,"column":40}},"9":{"start":{"line":27,"column":4},"end":{"line":29,"column":null}},"10":{"start":{"line":28,"column":8},"end":{"line":28,"column":35}},"11":{"start":{"line":38,"column":11},"end":{"line":40,"column":null}},"12":{"start":{"line":39,"column":8},"end":{"line":39,"column":85}},"13":{"start":{"line":49,"column":11},"end":{"line":55,"column":null}},"14":{"start":{"line":50,"column":8},"end":{"line":52,"column":null}},"15":{"start":{"line":51,"column":12},"end":{"line":51,"column":89}},"16":{"start":{"line":53,"column":8},"end":{"line":54,"column":81}},"17":{"start":{"line":63,"column":17},"end":{"line":65,"column":null}},"18":{"start":{"line":64,"column":8},"end":{"line":64,"column":60}},"19":{"start":{"line":74,"column":17},"end":{"line":76,"column":null}},"20":{"start":{"line":75,"column":8},"end":{"line":75,"column":68}},"21":{"start":{"line":77,"column":0},"end":{"line":77,"column":null}},"22":{"start":{"line":10,"column":13},"end":{"line":10,"column":23}}},"fnMap":{"0":{"name":"(anonymous_13)","decl":{"start":{"line":10,"column":0},"end":{"line":10,"column":13}},"loc":{"start":{"line":10,"column":0},"end":{"line":77,"column":null}}},"1":{"name":"EventStore","decl":{"start":{"line":15,"column":4},"end":{"line":15,"column":23}},"loc":{"start":{"line":15,"column":75},"end":{"line":18,"column":5}}},"2":{"name":"(anonymous_15)","decl":{"start":{"line":20,"column":4},"end":{"line":20,"column":15}},"loc":{"start":{"line":20,"column":4},"end":{"line":25,"column":5}}},"3":{"name":"(anonymous_16)","decl":{"start":{"line":27,"column":4},"end":{"line":27,"column":15}},"loc":{"start":{"line":27,"column":4},"end":{"line":29,"column":5}}},"4":{"name":"(anonymous_17)","decl":{"start":{"line":38,"column":4},"end":{"line":38,"column":11}},"loc":{"start":{"line":38,"column":63},"end":{"line":40,"column":5}}},"5":{"name":"(anonymous_18)","decl":{"start":{"line":49,"column":4},"end":{"line":49,"column":11}},"loc":{"start":{"line":49,"column":64},"end":{"line":55,"column":5}}},"6":{"name":"(anonymous_19)","decl":{"start":{"line":63,"column":4},"end":{"line":63,"column":17}},"loc":{"start":{"line":63,"column":64},"end":{"line":65,"column":null}}},"7":{"name":"(anonymous_22)","decl":{"start":{"line":74,"column":4},"end":{"line":74,"column":17}},"loc":{"start":{"line":74,"column":80},"end":{"line":76,"column":null}}}},"branchMap":{"0":{"loc":{"start":{"line":21,"column":8},"end":{"line":23,"column":null}},"type":"if","locations":[{"start":{"line":21,"column":8},"end":{"line":23,"column":null}},{"start":{"line":21,"column":8},"end":{"line":23,"column":null}}]},"1":{"loc":{"start":{"line":50,"column":8},"end":{"line":52,"column":null}},"type":"if","locations":[{"start":{"line":50,"column":8},"end":{"line":52,"column":null}},{"start":{"line":50,"column":8},"end":{"line":52,"column":null}}]},"2":{"loc":{"start":{"line":50,"column":12},"end":{"line":50,"column":26}},"type":"binary-expr","locations":[{"start":{"line":50,"column":12},"end":{"line":50,"column":26}},{"start":{"line":50,"column":31},"end":{"line":50,"column":74}}]}},"s":{"0":4,"1":4,"2":4,"3":17,"4":17,"5":4,"6":32,"7":1,"8":31,"9":4,"10":33,"11":4,"12":23,"13":4,"14":3,"15":2,"16":1,"17":4,"18":4,"19":4,"20":3,"21":4,"22":4},"f":{"0":4,"1":17,"2":32,"3":33,"4":23,"5":3,"6":4,"7":3},"b":{"0":[1,31],"1":[2,1],"2":[3,2]}}
-,"/home/runner/work/aws-event-stream/aws-event-stream/src/event-stream.ts": {"path":"/home/runner/work/aws-event-stream/aws-event-stream/src/event-stream.ts","statementMap":{"0":{"start":{"line":10,"column":0},"end":{"line":10,"column":13}},"1":{"start":{"line":15,"column":8},"end":{"line":15,"column":37}},"2":{"start":{"line":16,"column":8},"end":{"line":16,"column":29}},"3":{"start":{"line":23,"column":4},"end":{"line":25,"column":null}},"4":{"start":{"line":24,"column":8},"end":{"line":24,"column":30}},"5":{"start":{"line":30,"column":4},"end":{"line":32,"column":null}},"6":{"start":{"line":31,"column":8},"end":{"line":31,"column":39}},"7":{"start":{"line":40,"column":11},"end":{"line":42,"column":null}},"8":{"start":{"line":41,"column":8},"end":{"line":41,"column":72}},"9":{"start":{"line":50,"column":17},"end":{"line":63,"column":null}},"10":{"start":{"line":51,"column":32},"end":{"line":51,"column":null}},"11":{"start":{"line":51,"column":12},"end":{"line":51,"column":null}},"12":{"start":{"line":52,"column":12},"end":{"line":52,"column":16}},"13":{"start":{"line":53,"column":28},"end":{"line":56,"column":null}},"14":{"start":{"line":53,"column":18},"end":{"line":56,"column":null}},"15":{"start":{"line":57,"column":12},"end":{"line":60,"column":14}},"16":{"start":{"line":62,"column":8},"end":{"line":62,"column":26}},"17":{"start":{"line":65,"column":12},"end":{"line":67,"column":null}},"18":{"start":{"line":66,"column":8},"end":{"line":66,"column":40}},"19":{"start":{"line":68,"column":0},"end":{"line":68,"column":null}},"20":{"start":{"line":10,"column":13},"end":{"line":10,"column":28}}},"fnMap":{"0":{"name":"(anonymous_15)","decl":{"start":{"line":10,"column":0},"end":{"line":10,"column":13}},"loc":{"start":{"line":10,"column":0},"end":{"line":68,"column":null}}},"1":{"name":"EventStreamImpl","decl":{"start":{"line":14,"column":4},"end":{"line":14,"column":23}},"loc":{"start":{"line":14,"column":61},"end":{"line":17,"column":5}}},"2":{"name":"(anonymous_17)","decl":{"start":{"line":23,"column":4},"end":{"line":23,"column":15}},"loc":{"start":{"line":23,"column":4},"end":{"line":25,"column":5}}},"3":{"name":"(anonymous_18)","decl":{"start":{"line":30,"column":4},"end":{"line":30,"column":15}},"loc":{"start":{"line":30,"column":4},"end":{"line":32,"column":5}}},"4":{"name":"(anonymous_19)","decl":{"start":{"line":40,"column":4},"end":{"line":40,"column":11}},"loc":{"start":{"line":40,"column":52},"end":{"line":42,"column":5}}},"5":{"name":"(anonymous_20)","decl":{"start":{"line":50,"column":4},"end":{"line":50,"column":17}},"loc":{"start":{"line":50,"column":50},"end":{"line":63,"column":null}}},"6":{"name":"(anonymous_23)","decl":{"start":{"line":65,"column":4},"end":{"line":65,"column":12}},"loc":{"start":{"line":65,"column":4},"end":{"line":67,"column":5}}}},"branchMap":{"0":{"loc":{"start":{"line":51,"column":32},"end":{"line":51,"column":null}},"type":"switch","locations":[{"start":{"line":51,"column":32},"end":{"line":51,"column":null}},{"start":{"line":62,"column":8},"end":{"line":62,"column":26}}]},"1":{"loc":{"start":{"line":52,"column":12},"end":{"line":52,"column":16}},"type":"if","locations":[{"start":{"line":52,"column":12},"end":{"line":52,"column":16}},{"start":{"line":52,"column":12},"end":{"line":52,"column":16}}]}},"s":{"0":4,"1":23,"2":23,"3":4,"4":2,"5":4,"6":4,"7":4,"8":2,"9":4,"10":22,"11":22,"12":40,"13":4,"14":4,"15":4,"16":22,"17":4,"18":24,"19":4,"20":4},"f":{"0":4,"1":23,"2":2,"3":4,"4":2,"5":22,"6":24},"b":{"0":[22,22],"1":[18,4]}}
-,"/home/runner/work/aws-event-stream/aws-event-stream/src/index.ts": {"path":"/home/runner/work/aws-event-stream/aws-event-stream/src/index.ts","statementMap":{"0":{"start":{"line":4,"column":0},"end":{"line":4,"column":9}},"1":{"start":{"line":30,"column":9},"end":{"line":4,"column":55}},"2":{"start":{"line":6,"column":0},"end":{"line":6,"column":9}},"3":{"start":{"line":19,"column":9},"end":{"line":6,"column":56}},"4":{"start":{"line":9,"column":0},"end":{"line":9,"column":9}},"5":{"start":{"line":31,"column":9},"end":{"line":9,"column":53}},"6":{"start":{"line":11,"column":0},"end":{"line":11,"column":9}},"7":{"start":{"line":27,"column":9},"end":{"line":11,"column":55}},"8":{"start":{"line":13,"column":0},"end":{"line":13,"column":9}},"9":{"start":{"line":29,"column":9},"end":{"line":13,"column":47}},"10":{"start":{"line":14,"column":0},"end":{"line":14,"column":9}},"11":{"start":{"line":28,"column":9},"end":{"line":14,"column":47}}},"fnMap":{"0":{"name":"(anonymous_0)","decl":{"start":{"line":30,"column":9},"end":{"line":30,"column":25}},"loc":{"start":{"line":30,"column":9},"end":{"line":4,"column":55}}},"1":{"name":"(anonymous_1)","decl":{"start":{"line":19,"column":9},"end":{"line":19,"column":19}},"loc":{"start":{"line":19,"column":9},"end":{"line":6,"column":56}}},"2":{"name":"(anonymous_2)","decl":{"start":{"line":31,"column":9},"end":{"line":31,"column":25}},"loc":{"start":{"line":31,"column":9},"end":{"line":9,"column":53}}},"3":{"name":"(anonymous_3)","decl":{"start":{"line":27,"column":9},"end":{"line":27,"column":26}},"loc":{"start":{"line":27,"column":9},"end":{"line":11,"column":55}}},"4":{"name":"(anonymous_4)","decl":{"start":{"line":29,"column":9},"end":{"line":29,"column":21}},"loc":{"start":{"line":29,"column":9},"end":{"line":13,"column":47}}},"5":{"name":"(anonymous_5)","decl":{"start":{"line":28,"column":9},"end":{"line":28,"column":21}},"loc":{"start":{"line":28,"column":9},"end":{"line":14,"column":47}}}},"branchMap":{},"s":{"0":4,"1":12,"2":4,"3":21,"4":4,"5":20,"6":4,"7":13,"8":4,"9":4,"10":4,"11":4},"f":{"0":8,"1":17,"2":16,"3":9,"4":0,"5":0},"b":{}}
-,"/home/runner/work/aws-event-stream/aws-event-stream/src/util.ts": {"path":"/home/runner/work/aws-event-stream/aws-event-stream/src/util.ts","statementMap":{"0":{"start":{"line":1,"column":13},"end":{"line":6,"column":2}},"1":{"start":{"line":2,"column":4},"end":{"line":4,"column":null}},"2":{"start":{"line":3,"column":8},"end":{"line":3,"column":24}},"3":{"start":{"line":5,"column":4},"end":{"line":5,"column":21}}},"fnMap":{"0":{"name":"(anonymous_0)","decl":{"start":{"line":1,"column":30},"end":{"line":1,"column":31}},"loc":{"start":{"line":1,"column":48},"end":{"line":6,"column":1}}}},"branchMap":{"0":{"loc":{"start":{"line":2,"column":4},"end":{"line":4,"column":null}},"type":"if","locations":[{"start":{"line":2,"column":4},"end":{"line":4,"column":null}},{"start":{"line":2,"column":4},"end":{"line":4,"column":null}}]}},"s":{"0":6,"1":13,"2":1,"3":12},"f":{"0":13},"b":{"0":[1,12]}}
+,"/home/runner/work/aws-event-stream/aws-event-stream/src/event-stream.ts": {"path":"/home/runner/work/aws-event-stream/aws-event-stream/src/event-stream.ts","statementMap":{"0":{"start":{"line":6,"column":0},"end":{"line":6,"column":48}},"1":{"start":{"line":11,"column":0},"end":{"line":11,"column":13}},"2":{"start":{"line":16,"column":8},"end":{"line":16,"column":37}},"3":{"start":{"line":17,"column":8},"end":{"line":17,"column":29}},"4":{"start":{"line":24,"column":4},"end":{"line":26,"column":null}},"5":{"start":{"line":25,"column":8},"end":{"line":25,"column":30}},"6":{"start":{"line":31,"column":4},"end":{"line":33,"column":null}},"7":{"start":{"line":32,"column":8},"end":{"line":32,"column":39}},"8":{"start":{"line":41,"column":11},"end":{"line":43,"column":null}},"9":{"start":{"line":42,"column":8},"end":{"line":42,"column":72}},"10":{"start":{"line":51,"column":17},"end":{"line":55,"column":null}},"11":{"start":{"line":52,"column":23},"end":{"line":52,"column":null}},"12":{"start":{"line":52,"column":14},"end":{"line":52,"column":null}},"13":{"start":{"line":54,"column":8},"end":{"line":54,"column":34}},"14":{"start":{"line":63,"column":17},"end":{"line":76,"column":null}},"15":{"start":{"line":64,"column":32},"end":{"line":64,"column":null}},"16":{"start":{"line":64,"column":12},"end":{"line":64,"column":null}},"17":{"start":{"line":65,"column":12},"end":{"line":65,"column":16}},"18":{"start":{"line":66,"column":28},"end":{"line":69,"column":null}},"19":{"start":{"line":66,"column":18},"end":{"line":69,"column":null}},"20":{"start":{"line":70,"column":12},"end":{"line":73,"column":14}},"21":{"start":{"line":75,"column":8},"end":{"line":75,"column":26}},"22":{"start":{"line":78,"column":12},"end":{"line":80,"column":null}},"23":{"start":{"line":79,"column":8},"end":{"line":79,"column":40}},"24":{"start":{"line":81,"column":0},"end":{"line":81,"column":null}},"25":{"start":{"line":11,"column":13},"end":{"line":11,"column":28}}},"fnMap":{"0":{"name":"(anonymous_15)","decl":{"start":{"line":11,"column":0},"end":{"line":11,"column":13}},"loc":{"start":{"line":11,"column":0},"end":{"line":81,"column":null}}},"1":{"name":"EventStreamImpl","decl":{"start":{"line":15,"column":4},"end":{"line":15,"column":23}},"loc":{"start":{"line":15,"column":61},"end":{"line":18,"column":5}}},"2":{"name":"(anonymous_17)","decl":{"start":{"line":24,"column":4},"end":{"line":24,"column":15}},"loc":{"start":{"line":24,"column":4},"end":{"line":26,"column":5}}},"3":{"name":"(anonymous_18)","decl":{"start":{"line":31,"column":4},"end":{"line":31,"column":15}},"loc":{"start":{"line":31,"column":4},"end":{"line":33,"column":5}}},"4":{"name":"(anonymous_19)","decl":{"start":{"line":41,"column":4},"end":{"line":41,"column":11}},"loc":{"start":{"line":41,"column":52},"end":{"line":43,"column":5}}},"5":{"name":"(anonymous_20)","decl":{"start":{"line":51,"column":4},"end":{"line":51,"column":17}},"loc":{"start":{"line":51,"column":64},"end":{"line":55,"column":null}}},"6":{"name":"(anonymous_23)","decl":{"start":{"line":63,"column":4},"end":{"line":63,"column":17}},"loc":{"start":{"line":63,"column":50},"end":{"line":76,"column":null}}},"7":{"name":"(anonymous_26)","decl":{"start":{"line":78,"column":4},"end":{"line":78,"column":12}},"loc":{"start":{"line":78,"column":4},"end":{"line":80,"column":5}}}},"branchMap":{"0":{"loc":{"start":{"line":52,"column":23},"end":{"line":52,"column":null}},"type":"switch","locations":[{"start":{"line":52,"column":23},"end":{"line":52,"column":null}}]},"1":{"loc":{"start":{"line":64,"column":32},"end":{"line":64,"column":null}},"type":"switch","locations":[{"start":{"line":64,"column":32},"end":{"line":64,"column":null}},{"start":{"line":75,"column":8},"end":{"line":75,"column":26}}]},"2":{"loc":{"start":{"line":65,"column":12},"end":{"line":65,"column":16}},"type":"if","locations":[{"start":{"line":65,"column":12},"end":{"line":65,"column":16}},{"start":{"line":65,"column":12},"end":{"line":65,"column":16}}]}},"s":{"0":4,"1":4,"2":23,"3":23,"4":4,"5":2,"6":4,"7":4,"8":4,"9":2,"10":4,"11":0,"12":0,"13":0,"14":4,"15":22,"16":22,"17":40,"18":4,"19":4,"20":4,"21":22,"22":4,"23":24,"24":4,"25":4},"f":{"0":4,"1":23,"2":2,"3":4,"4":2,"5":0,"6":22,"7":24},"b":{"0":[0],"1":[22,22],"2":[18,4]}}
+,"/home/runner/work/aws-event-stream/aws-event-stream/src/index.ts": {"path":"/home/runner/work/aws-event-stream/aws-event-stream/src/index.ts","statementMap":{"0":{"start":{"line":4,"column":0},"end":{"line":4,"column":9}},"1":{"start":{"line":28,"column":9},"end":{"line":4,"column":55}},"2":{"start":{"line":6,"column":0},"end":{"line":6,"column":9}},"3":{"start":{"line":18,"column":9},"end":{"line":6,"column":56}},"4":{"start":{"line":9,"column":0},"end":{"line":9,"column":9}},"5":{"start":{"line":29,"column":9},"end":{"line":9,"column":53}},"6":{"start":{"line":11,"column":0},"end":{"line":11,"column":9}},"7":{"start":{"line":26,"column":9},"end":{"line":11,"column":55}},"8":{"start":{"line":13,"column":0},"end":{"line":13,"column":9}},"9":{"start":{"line":27,"column":9},"end":{"line":13,"column":47}}},"fnMap":{"0":{"name":"(anonymous_0)","decl":{"start":{"line":28,"column":9},"end":{"line":28,"column":25}},"loc":{"start":{"line":28,"column":9},"end":{"line":4,"column":55}}},"1":{"name":"(anonymous_1)","decl":{"start":{"line":18,"column":9},"end":{"line":18,"column":19}},"loc":{"start":{"line":18,"column":9},"end":{"line":6,"column":56}}},"2":{"name":"(anonymous_2)","decl":{"start":{"line":29,"column":9},"end":{"line":29,"column":25}},"loc":{"start":{"line":29,"column":9},"end":{"line":9,"column":53}}},"3":{"name":"(anonymous_3)","decl":{"start":{"line":26,"column":9},"end":{"line":26,"column":26}},"loc":{"start":{"line":26,"column":9},"end":{"line":11,"column":55}}},"4":{"name":"(anonymous_4)","decl":{"start":{"line":27,"column":9},"end":{"line":27,"column":21}},"loc":{"start":{"line":27,"column":9},"end":{"line":13,"column":47}}}},"branchMap":{},"s":{"0":4,"1":14,"2":4,"3":21,"4":4,"5":20,"6":4,"7":13,"8":4,"9":4},"f":{"0":10,"1":17,"2":16,"3":9,"4":0},"b":{}}
+,"/home/runner/work/aws-event-stream/aws-event-stream/src/util.ts": {"path":"/home/runner/work/aws-event-stream/aws-event-stream/src/util.ts","statementMap":{"0":{"start":{"line":3,"column":13},"end":{"line":8,"column":2}},"1":{"start":{"line":4,"column":4},"end":{"line":6,"column":null}},"2":{"start":{"line":5,"column":8},"end":{"line":5,"column":24}},"3":{"start":{"line":7,"column":4},"end":{"line":7,"column":21}}},"fnMap":{"0":{"name":"(anonymous_0)","decl":{"start":{"line":3,"column":30},"end":{"line":3,"column":31}},"loc":{"start":{"line":3,"column":48},"end":{"line":8,"column":1}}}},"branchMap":{"0":{"loc":{"start":{"line":4,"column":4},"end":{"line":6,"column":null}},"type":"if","locations":[{"start":{"line":4,"column":4},"end":{"line":6,"column":null}},{"start":{"line":4,"column":4},"end":{"line":6,"column":null}}]}},"s":{"0":6,"1":15,"2":1,"3":14},"f":{"0":15},"b":{"0":[1,14]}}
 ,"/home/runner/work/aws-event-stream/aws-event-stream/src/dynamodb/schema.ts": {"path":"/home/runner/work/aws-event-stream/aws-event-stream/src/dynamodb/schema.ts","statementMap":{"0":{"start":{"line":1,"column":0},"end":{"line":1,"column":32}},"1":{"start":{"line":5,"column":0},"end":{"line":5,"column":13}},"2":{"start":{"line":10,"column":8},"end":{"line":10,"column":29}},"3":{"start":{"line":11,"column":8},"end":{"line":11,"column":44}},"4":{"start":{"line":13,"column":8},"end":{"line":13,"column":43}},"5":{"start":{"line":16,"column":17},"end":{"line":21,"column":null}},"6":{"start":{"line":17,"column":28},"end":{"line":17,"column":null}},"7":{"start":{"line":17,"column":14},"end":{"line":17,"column":null}},"8":{"start":{"line":18,"column":12},"end":{"line":18,"column":13}},"9":{"start":{"line":19,"column":12},"end":{"line":19,"column":75}},"10":{"start":{"line":23,"column":18},"end":{"line":29,"column":null}},"11":{"start":{"line":24,"column":23},"end":{"line":24,"column":null}},"12":{"start":{"line":24,"column":14},"end":{"line":24,"column":null}},"13":{"start":{"line":26,"column":8},"end":{"line":28,"column":24}},"14":{"start":{"line":27,"column":12},"end":{"line":27,"column":64}},"15":{"start":{"line":31,"column":12},"end":{"line":59,"column":null}},"16":{"start":{"line":32,"column":8},"end":{"line":58,"column":10}},"17":{"start":{"line":60,"column":0},"end":{"line":60,"column":null}},"18":{"start":{"line":5,"column":13},"end":{"line":5,"column":19}}},"fnMap":{"0":{"name":"(anonymous_13)","decl":{"start":{"line":5,"column":0},"end":{"line":5,"column":13}},"loc":{"start":{"line":5,"column":0},"end":{"line":60,"column":null}}},"1":{"name":"Schema","decl":{"start":{"line":9,"column":4},"end":{"line":9,"column":16}},"loc":{"start":{"line":9,"column":30},"end":{"line":14,"column":5}}},"2":{"name":"(anonymous_15)","decl":{"start":{"line":16,"column":4},"end":{"line":16,"column":17}},"loc":{"start":{"line":16,"column":4},"end":{"line":21,"column":null}}},"3":{"name":"(anonymous_18)","decl":{"start":{"line":23,"column":4},"end":{"line":23,"column":18}},"loc":{"start":{"line":23,"column":4},"end":{"line":29,"column":null}}},"4":{"name":"(anonymous_21)","decl":{"start":{"line":26,"column":40},"end":{"line":26,"column":49}},"loc":{"start":{"line":26,"column":49},"end":{"line":28,"column":9}}},"5":{"name":"(anonymous_22)","decl":{"start":{"line":31,"column":4},"end":{"line":31,"column":12}},"loc":{"start":{"line":31,"column":4},"end":{"line":59,"column":5}}}},"branchMap":{"0":{"loc":{"start":{"line":17,"column":28},"end":{"line":17,"column":null}},"type":"switch","locations":[{"start":{"line":17,"column":28},"end":{"line":17,"column":null}}]},"1":{"loc":{"start":{"line":18,"column":12},"end":{"line":18,"column":13}},"type":"if","locations":[{"start":{"line":18,"column":12},"end":{"line":18,"column":13}},{"start":{"line":18,"column":12},"end":{"line":18,"column":13}}]},"2":{"loc":{"start":{"line":24,"column":23},"end":{"line":24,"column":null}},"type":"switch","locations":[{"start":{"line":24,"column":23},"end":{"line":24,"column":null}}]},"3":{"loc":{"start":{"line":54,"column":35},"end":{"line":54,"column":72}},"type":"binary-expr","locations":[{"start":{"line":54,"column":35},"end":{"line":54,"column":72}},{"start":{"line":54,"column":76},"end":{"line":54,"column":77}}]},"4":{"loc":{"start":{"line":55,"column":36},"end":{"line":55,"column":74}},"type":"binary-expr","locations":[{"start":{"line":55,"column":36},"end":{"line":55,"column":74}},{"start":{"line":55,"column":78},"end":{"line":55,"column":79}}]}},"s":{"0":5,"1":5,"2":3,"3":3,"4":3,"5":5,"6":3,"7":3,"8":4,"9":4,"10":5,"11":3,"12":3,"13":3,"14":10,"15":5,"16":2,"17":5,"18":5},"f":{"0":5,"1":3,"2":3,"3":3,"4":10,"5":2},"b":{"0":[3],"1":[1,2],"2":[3],"3":[2,1],"4":[2,1]}}
-,"/home/runner/work/aws-event-stream/aws-event-stream/src/provider/dynamodb.ts": {"path":"/home/runner/work/aws-event-stream/aws-event-stream/src/provider/dynamodb.ts","statementMap":{"0":{"start":{"line":3,"column":0},"end":{"line":3,"column":32}},"1":{"start":{"line":4,"column":0},"end":{"line":4,"column":81}},"2":{"start":{"line":5,"column":0},"end":{"line":5,"column":28}},"3":{"start":{"line":7,"column":0},"end":{"line":7,"column":44}},"4":{"start":{"line":11,"column":0},"end":{"line":11,"column":41}},"5":{"start":{"line":17,"column":0},"end":{"line":17,"column":13}},"6":{"start":{"line":24,"column":8},"end":{"line":24,"column":29}},"7":{"start":{"line":26,"column":8},"end":{"line":26,"column":44}},"8":{"start":{"line":27,"column":8},"end":{"line":31,"column":15}},"9":{"start":{"line":32,"column":8},"end":{"line":32,"column":46}},"10":{"start":{"line":35,"column":17},"end":{"line":57,"column":null}},"11":{"start":{"line":36,"column":8},"end":{"line":36,"column":34}},"12":{"start":{"line":37,"column":14},"end":{"line":37,"column":31}},"13":{"start":{"line":38,"column":14},"end":{"line":38,"column":46}},"14":{"start":{"line":39,"column":14},"end":{"line":44,"column":10}},"15":{"start":{"line":45,"column":14},"end":{"line":48,"column":10}},"16":{"start":{"line":50,"column":8},"end":{"line":50,"column":56}},"17":{"start":{"line":52,"column":8},"end":{"line":56,"column":10}},"18":{"start":{"line":60,"column":17},"end":{"line":93,"column":null}},"19":{"start":{"line":60,"column":43},"end":{"line":60,"column":63}},"20":{"start":{"line":60,"column":63},"end":{"line":60,"column":null}},"21":{"start":{"line":61,"column":8},"end":{"line":61,"column":34}},"22":{"start":{"line":63,"column":12},"end":{"line":68,"column":10}},"23":{"start":{"line":69,"column":14},"end":{"line":69,"column":40}},"24":{"start":{"line":70,"column":8},"end":{"line":72,"column":null}},"25":{"start":{"line":71,"column":12},"end":{"line":71,"column":55}},"26":{"start":{"line":74,"column":12},"end":{"line":74,"column":33}},"27":{"start":{"line":76,"column":12},"end":{"line":78,"column":null}},"28":{"start":{"line":77,"column":16},"end":{"line":77,"column":83}},"29":{"start":{"line":79,"column":46},"end":{"line":79,"column":96}},"30":{"start":{"line":79,"column":18},"end":{"line":79,"column":null}},"31":{"start":{"line":80,"column":12},"end":{"line":80,"column":69}},"32":{"start":{"line":81,"column":12},"end":{"line":81,"column":52}},"33":{"start":{"line":82,"column":17},"end":{"line":82,"column":null}},"34":{"start":{"line":82,"column":40},"end":{"line":82,"column":null}},"35":{"start":{"line":84,"column":14},"end":{"line":90,"column":11}},"36":{"start":{"line":85,"column":12},"end":{"line":89,"column":23}},"37":{"start":{"line":92,"column":8},"end":{"line":92,"column":87}},"38":{"start":{"line":95,"column":17},"end":{"line":97,"column":null}},"39":{"start":{"line":95,"column":33},"end":{"line":95,"column":53}},"40":{"start":{"line":95,"column":53},"end":{"line":95,"column":null}},"41":{"start":{"line":96,"column":8},"end":{"line":96,"column":48}},"42":{"start":{"line":99,"column":17},"end":{"line":101,"column":null}},"43":{"start":{"line":99,"column":49},"end":{"line":99,"column":69}},"44":{"start":{"line":99,"column":69},"end":{"line":99,"column":null}},"45":{"start":{"line":100,"column":8},"end":{"line":100,"column":48}},"46":{"start":{"line":103,"column":18},"end":{"line":108,"column":null}},"47":{"start":{"line":104,"column":12},"end":{"line":104,"column":13}},"48":{"start":{"line":105,"column":12},"end":{"line":105,"column":45}},"49":{"start":{"line":106,"column":12},"end":{"line":106,"column":36}},"50":{"start":{"line":110,"column":12},"end":{"line":112,"column":null}},"51":{"start":{"line":111,"column":8},"end":{"line":111,"column":52}},"52":{"start":{"line":113,"column":0},"end":{"line":113,"column":null}},"53":{"start":{"line":17,"column":13},"end":{"line":17,"column":29}}},"fnMap":{"0":{"name":"(anonymous_13)","decl":{"start":{"line":17,"column":0},"end":{"line":17,"column":13}},"loc":{"start":{"line":17,"column":0},"end":{"line":113,"column":null}}},"1":{"name":"DynamodbProvider","decl":{"start":{"line":23,"column":4},"end":{"line":23,"column":16}},"loc":{"start":{"line":23,"column":30},"end":{"line":33,"column":5}}},"2":{"name":"(anonymous_15)","decl":{"start":{"line":35,"column":4},"end":{"line":35,"column":17}},"loc":{"start":{"line":35,"column":51},"end":{"line":57,"column":null}}},"3":{"name":"(anonymous_18)","decl":{"start":{"line":60,"column":4},"end":{"line":60,"column":17}},"loc":{"start":{"line":60,"column":81},"end":{"line":93,"column":null}}},"4":{"name":"(anonymous_21)","decl":{"start":{"line":84,"column":33},"end":{"line":84,"column":34}},"loc":{"start":{"line":84,"column":45},"end":{"line":90,"column":9}}},"5":{"name":"(anonymous_22)","decl":{"start":{"line":95,"column":4},"end":{"line":95,"column":17}},"loc":{"start":{"line":95,"column":71},"end":{"line":97,"column":null}}},"6":{"name":"(anonymous_25)","decl":{"start":{"line":99,"column":4},"end":{"line":99,"column":17}},"loc":{"start":{"line":99,"column":87},"end":{"line":101,"column":null}}},"7":{"name":"(anonymous_28)","decl":{"start":{"line":103,"column":4},"end":{"line":103,"column":18}},"loc":{"start":{"line":103,"column":4},"end":{"line":108,"column":null}}},"8":{"name":"(anonymous_31)","decl":{"start":{"line":110,"column":4},"end":{"line":110,"column":12}},"loc":{"start":{"line":110,"column":33},"end":{"line":112,"column":5}}}},"branchMap":{"0":{"loc":{"start":{"line":30,"column":49},"end":{"line":30,"column":92}},"type":"cond-expr","locations":[{"start":{"line":30,"column":49},"end":{"line":30,"column":92}},{"start":{"line":30,"column":95},"end":{"line":30,"column":104}}]},"1":{"loc":{"start":{"line":36,"column":8},"end":{"line":36,"column":34}},"type":"switch","locations":[{"start":{"line":36,"column":8},"end":{"line":36,"column":34}}]},"2":{"loc":{"start":{"line":60,"column":43},"end":{"line":60,"column":63}},"type":"if","locations":[{"start":{"line":60,"column":43},"end":{"line":60,"column":63}},{"start":{"line":60,"column":43},"end":{"line":60,"column":63}}]},"3":{"loc":{"start":{"line":60,"column":63},"end":{"line":60,"column":null}},"type":"if","locations":[{"start":{"line":60,"column":63},"end":{"line":60,"column":null}},{"start":{"line":60,"column":63},"end":{"line":60,"column":null}}]},"4":{"loc":{"start":{"line":61,"column":8},"end":{"line":61,"column":34}},"type":"switch","locations":[{"start":{"line":61,"column":8},"end":{"line":61,"column":34}}]},"5":{"loc":{"start":{"line":70,"column":8},"end":{"line":72,"column":null}},"type":"if","locations":[{"start":{"line":70,"column":8},"end":{"line":72,"column":null}},{"start":{"line":70,"column":8},"end":{"line":72,"column":null}}]},"6":{"loc":{"start":{"line":76,"column":12},"end":{"line":78,"column":null}},"type":"if","locations":[{"start":{"line":76,"column":12},"end":{"line":78,"column":null}},{"start":{"line":76,"column":12},"end":{"line":78,"column":null}}]},"7":{"loc":{"start":{"line":80,"column":32},"end":{"line":80,"column":60}},"type":"binary-expr","locations":[{"start":{"line":80,"column":32},"end":{"line":80,"column":60}},{"start":{"line":80,"column":64},"end":{"line":80,"column":68}}]},"8":{"loc":{"start":{"line":82,"column":17},"end":{"line":82,"column":null}},"type":"if","locations":[{"start":{"line":82,"column":17},"end":{"line":82,"column":null}},{"start":{"line":82,"column":17},"end":{"line":82,"column":null}}]},"9":{"loc":{"start":{"line":92,"column":33},"end":{"line":92,"column":53}},"type":"cond-expr","locations":[{"start":{"line":92,"column":33},"end":{"line":92,"column":53}},{"start":{"line":92,"column":56},"end":{"line":92,"column":86}}]},"10":{"loc":{"start":{"line":95,"column":33},"end":{"line":95,"column":53}},"type":"if","locations":[{"start":{"line":95,"column":33},"end":{"line":95,"column":53}},{"start":{"line":95,"column":33},"end":{"line":95,"column":53}}]},"11":{"loc":{"start":{"line":95,"column":53},"end":{"line":95,"column":null}},"type":"if","locations":[{"start":{"line":95,"column":53},"end":{"line":95,"column":null}},{"start":{"line":95,"column":53},"end":{"line":95,"column":null}}]},"12":{"loc":{"start":{"line":99,"column":49},"end":{"line":99,"column":69}},"type":"if","locations":[{"start":{"line":99,"column":49},"end":{"line":99,"column":69}},{"start":{"line":99,"column":49},"end":{"line":99,"column":69}}]},"13":{"loc":{"start":{"line":99,"column":69},"end":{"line":99,"column":null}},"type":"if","locations":[{"start":{"line":99,"column":69},"end":{"line":99,"column":null}},{"start":{"line":99,"column":69},"end":{"line":99,"column":null}}]},"14":{"loc":{"start":{"line":104,"column":12},"end":{"line":104,"column":13}},"type":"if","locations":[{"start":{"line":104,"column":12},"end":{"line":104,"column":13}},{"start":{"line":104,"column":12},"end":{"line":104,"column":13}}]},"15":{"loc":{"start":{"line":104,"column":12},"end":{"line":104,"column":29}},"type":"binary-expr","locations":[{"start":{"line":104,"column":12},"end":{"line":104,"column":29}},{"start":{"line":104,"column":33},"end":{"line":104,"column":65}}]}},"s":{"0":4,"1":4,"2":4,"3":4,"4":4,"5":4,"6":8,"7":8,"8":8,"9":8,"10":4,"11":4,"12":2,"13":2,"14":2,"15":2,"16":4,"17":2,"18":4,"19":7,"20":7,"21":10,"22":5,"23":5,"24":5,"25":3,"26":5,"27":6,"28":1,"29":6,"30":6,"31":6,"32":6,"33":6,"34":1,"35":5,"36":32,"37":5,"38":4,"39":2,"40":2,"41":1,"42":4,"43":2,"44":2,"45":1,"46":4,"47":13,"48":2,"49":1,"50":4,"51":7,"52":4,"53":4},"f":{"0":4,"1":8,"2":2,"3":5,"4":32,"5":1,"6":1,"7":7,"8":7},"b":{"0":[8,0],"1":[2],"2":[2,3],"3":[2,3],"4":[5],"5":[3,2],"6":[1,5],"7":[6,5],"8":[1,5],"9":[2,3],"10":[1,0],"11":[1,0],"12":[1,0],"13":[1,0],"14":[6,1],"15":[7,7]}}
+,"/home/runner/work/aws-event-stream/aws-event-stream/src/model/event-util.ts": {"path":"/home/runner/work/aws-event-stream/aws-event-stream/src/model/event-util.ts","statementMap":{"0":{"start":{"line":3,"column":0},"end":{"line":3,"column":28}},"1":{"start":{"line":6,"column":13},"end":{"line":21,"column":2}},"2":{"start":{"line":7,"column":23},"end":{"line":10,"column":6}},"3":{"start":{"line":8,"column":26},"end":{"line":8,"column":68}},"4":{"start":{"line":9,"column":8},"end":{"line":9,"column":25}},"5":{"start":{"line":12,"column":19},"end":{"line":15,"column":5}},"6":{"start":{"line":13,"column":8},"end":{"line":13,"column":36}},"7":{"start":{"line":14,"column":8},"end":{"line":14,"column":38}},"8":{"start":{"line":17,"column":21},"end":{"line":17,"column":55}},"9":{"start":{"line":18,"column":4},"end":{"line":18,"column":29}},"10":{"start":{"line":19,"column":4},"end":{"line":19,"column":36}},"11":{"start":{"line":20,"column":4},"end":{"line":20,"column":19}}},"fnMap":{"0":{"name":"(anonymous_0)","decl":{"start":{"line":6,"column":26},"end":{"line":6,"column":27}},"loc":{"start":{"line":6,"column":47},"end":{"line":21,"column":1}}},"1":{"name":"(anonymous_1)","decl":{"start":{"line":7,"column":34},"end":{"line":7,"column":35}},"loc":{"start":{"line":7,"column":40},"end":{"line":10,"column":5}}},"2":{"name":"(anonymous_2)","decl":{"start":{"line":12,"column":19},"end":{"line":12,"column":20}},"loc":{"start":{"line":12,"column":43},"end":{"line":15,"column":5}}}},"branchMap":{"0":{"loc":{"start":{"line":8,"column":26},"end":{"line":8,"column":49}},"type":"binary-expr","locations":[{"start":{"line":8,"column":26},"end":{"line":8,"column":49}},{"start":{"line":8,"column":53},"end":{"line":8,"column":68}}]}},"s":{"0":5,"1":5,"2":3,"3":6,"4":6,"5":3,"6":3,"7":3,"8":3,"9":3,"10":3,"11":3},"f":{"0":3,"1":6,"2":3},"b":{"0":[6,0]}}
+,"/home/runner/work/aws-event-stream/aws-event-stream/src/provider/dynamodb.ts": {"path":"/home/runner/work/aws-event-stream/aws-event-stream/src/provider/dynamodb.ts","statementMap":{"0":{"start":{"line":3,"column":0},"end":{"line":3,"column":32}},"1":{"start":{"line":4,"column":0},"end":{"line":4,"column":81}},"2":{"start":{"line":5,"column":0},"end":{"line":5,"column":28}},"3":{"start":{"line":7,"column":0},"end":{"line":7,"column":44}},"4":{"start":{"line":10,"column":0},"end":{"line":10,"column":41}},"5":{"start":{"line":16,"column":0},"end":{"line":16,"column":13}},"6":{"start":{"line":23,"column":8},"end":{"line":23,"column":29}},"7":{"start":{"line":25,"column":8},"end":{"line":25,"column":44}},"8":{"start":{"line":26,"column":8},"end":{"line":30,"column":15}},"9":{"start":{"line":31,"column":8},"end":{"line":31,"column":46}},"10":{"start":{"line":34,"column":17},"end":{"line":57,"column":null}},"11":{"start":{"line":35,"column":8},"end":{"line":35,"column":34}},"12":{"start":{"line":36,"column":14},"end":{"line":36,"column":31}},"13":{"start":{"line":37,"column":14},"end":{"line":37,"column":46}},"14":{"start":{"line":38,"column":14},"end":{"line":44,"column":10}},"15":{"start":{"line":45,"column":14},"end":{"line":48,"column":10}},"16":{"start":{"line":50,"column":8},"end":{"line":50,"column":56}},"17":{"start":{"line":52,"column":8},"end":{"line":56,"column":10}},"18":{"start":{"line":59,"column":17},"end":{"line":93,"column":null}},"19":{"start":{"line":59,"column":43},"end":{"line":59,"column":63}},"20":{"start":{"line":59,"column":63},"end":{"line":59,"column":null}},"21":{"start":{"line":60,"column":8},"end":{"line":60,"column":34}},"22":{"start":{"line":62,"column":12},"end":{"line":67,"column":10}},"23":{"start":{"line":68,"column":14},"end":{"line":68,"column":40}},"24":{"start":{"line":69,"column":8},"end":{"line":71,"column":null}},"25":{"start":{"line":70,"column":12},"end":{"line":70,"column":55}},"26":{"start":{"line":73,"column":12},"end":{"line":73,"column":33}},"27":{"start":{"line":75,"column":12},"end":{"line":77,"column":null}},"28":{"start":{"line":76,"column":16},"end":{"line":76,"column":83}},"29":{"start":{"line":78,"column":46},"end":{"line":78,"column":96}},"30":{"start":{"line":78,"column":18},"end":{"line":78,"column":null}},"31":{"start":{"line":79,"column":12},"end":{"line":79,"column":69}},"32":{"start":{"line":80,"column":12},"end":{"line":80,"column":52}},"33":{"start":{"line":81,"column":17},"end":{"line":81,"column":null}},"34":{"start":{"line":81,"column":40},"end":{"line":81,"column":null}},"35":{"start":{"line":83,"column":14},"end":{"line":90,"column":11}},"36":{"start":{"line":84,"column":12},"end":{"line":89,"column":23}},"37":{"start":{"line":92,"column":8},"end":{"line":92,"column":87}},"38":{"start":{"line":95,"column":17},"end":{"line":97,"column":null}},"39":{"start":{"line":95,"column":33},"end":{"line":95,"column":53}},"40":{"start":{"line":95,"column":53},"end":{"line":95,"column":null}},"41":{"start":{"line":96,"column":8},"end":{"line":96,"column":48}},"42":{"start":{"line":99,"column":17},"end":{"line":101,"column":null}},"43":{"start":{"line":99,"column":49},"end":{"line":99,"column":69}},"44":{"start":{"line":99,"column":69},"end":{"line":99,"column":null}},"45":{"start":{"line":100,"column":8},"end":{"line":100,"column":48}},"46":{"start":{"line":103,"column":18},"end":{"line":108,"column":null}},"47":{"start":{"line":104,"column":12},"end":{"line":104,"column":13}},"48":{"start":{"line":105,"column":12},"end":{"line":105,"column":45}},"49":{"start":{"line":106,"column":12},"end":{"line":106,"column":36}},"50":{"start":{"line":110,"column":12},"end":{"line":112,"column":null}},"51":{"start":{"line":111,"column":8},"end":{"line":111,"column":52}},"52":{"start":{"line":113,"column":0},"end":{"line":113,"column":null}},"53":{"start":{"line":16,"column":13},"end":{"line":16,"column":29}}},"fnMap":{"0":{"name":"(anonymous_13)","decl":{"start":{"line":16,"column":0},"end":{"line":16,"column":13}},"loc":{"start":{"line":16,"column":0},"end":{"line":113,"column":null}}},"1":{"name":"DynamodbProvider","decl":{"start":{"line":22,"column":4},"end":{"line":22,"column":16}},"loc":{"start":{"line":22,"column":30},"end":{"line":32,"column":5}}},"2":{"name":"(anonymous_15)","decl":{"start":{"line":34,"column":4},"end":{"line":34,"column":17}},"loc":{"start":{"line":34,"column":51},"end":{"line":57,"column":null}}},"3":{"name":"(anonymous_18)","decl":{"start":{"line":59,"column":4},"end":{"line":59,"column":17}},"loc":{"start":{"line":59,"column":81},"end":{"line":93,"column":null}}},"4":{"name":"(anonymous_21)","decl":{"start":{"line":83,"column":33},"end":{"line":83,"column":34}},"loc":{"start":{"line":83,"column":45},"end":{"line":90,"column":9}}},"5":{"name":"(anonymous_22)","decl":{"start":{"line":95,"column":4},"end":{"line":95,"column":17}},"loc":{"start":{"line":95,"column":71},"end":{"line":97,"column":null}}},"6":{"name":"(anonymous_25)","decl":{"start":{"line":99,"column":4},"end":{"line":99,"column":17}},"loc":{"start":{"line":99,"column":87},"end":{"line":101,"column":null}}},"7":{"name":"(anonymous_28)","decl":{"start":{"line":103,"column":4},"end":{"line":103,"column":18}},"loc":{"start":{"line":103,"column":4},"end":{"line":108,"column":null}}},"8":{"name":"(anonymous_31)","decl":{"start":{"line":110,"column":4},"end":{"line":110,"column":12}},"loc":{"start":{"line":110,"column":33},"end":{"line":112,"column":5}}}},"branchMap":{"0":{"loc":{"start":{"line":29,"column":49},"end":{"line":29,"column":92}},"type":"cond-expr","locations":[{"start":{"line":29,"column":49},"end":{"line":29,"column":92}},{"start":{"line":29,"column":95},"end":{"line":29,"column":104}}]},"1":{"loc":{"start":{"line":35,"column":8},"end":{"line":35,"column":34}},"type":"switch","locations":[{"start":{"line":35,"column":8},"end":{"line":35,"column":34}}]},"2":{"loc":{"start":{"line":59,"column":43},"end":{"line":59,"column":63}},"type":"if","locations":[{"start":{"line":59,"column":43},"end":{"line":59,"column":63}},{"start":{"line":59,"column":43},"end":{"line":59,"column":63}}]},"3":{"loc":{"start":{"line":59,"column":63},"end":{"line":59,"column":null}},"type":"if","locations":[{"start":{"line":59,"column":63},"end":{"line":59,"column":null}},{"start":{"line":59,"column":63},"end":{"line":59,"column":null}}]},"4":{"loc":{"start":{"line":60,"column":8},"end":{"line":60,"column":34}},"type":"switch","locations":[{"start":{"line":60,"column":8},"end":{"line":60,"column":34}}]},"5":{"loc":{"start":{"line":69,"column":8},"end":{"line":71,"column":null}},"type":"if","locations":[{"start":{"line":69,"column":8},"end":{"line":71,"column":null}},{"start":{"line":69,"column":8},"end":{"line":71,"column":null}}]},"6":{"loc":{"start":{"line":75,"column":12},"end":{"line":77,"column":null}},"type":"if","locations":[{"start":{"line":75,"column":12},"end":{"line":77,"column":null}},{"start":{"line":75,"column":12},"end":{"line":77,"column":null}}]},"7":{"loc":{"start":{"line":79,"column":32},"end":{"line":79,"column":60}},"type":"binary-expr","locations":[{"start":{"line":79,"column":32},"end":{"line":79,"column":60}},{"start":{"line":79,"column":64},"end":{"line":79,"column":68}}]},"8":{"loc":{"start":{"line":81,"column":17},"end":{"line":81,"column":null}},"type":"if","locations":[{"start":{"line":81,"column":17},"end":{"line":81,"column":null}},{"start":{"line":81,"column":17},"end":{"line":81,"column":null}}]},"9":{"loc":{"start":{"line":86,"column":27},"end":{"line":86,"column":41}},"type":"binary-expr","locations":[{"start":{"line":86,"column":27},"end":{"line":86,"column":41}},{"start":{"line":86,"column":46},"end":{"line":86,"column":76}}]},"10":{"loc":{"start":{"line":92,"column":33},"end":{"line":92,"column":53}},"type":"cond-expr","locations":[{"start":{"line":92,"column":33},"end":{"line":92,"column":53}},{"start":{"line":92,"column":56},"end":{"line":92,"column":86}}]},"11":{"loc":{"start":{"line":95,"column":33},"end":{"line":95,"column":53}},"type":"if","locations":[{"start":{"line":95,"column":33},"end":{"line":95,"column":53}},{"start":{"line":95,"column":33},"end":{"line":95,"column":53}}]},"12":{"loc":{"start":{"line":95,"column":53},"end":{"line":95,"column":null}},"type":"if","locations":[{"start":{"line":95,"column":53},"end":{"line":95,"column":null}},{"start":{"line":95,"column":53},"end":{"line":95,"column":null}}]},"13":{"loc":{"start":{"line":99,"column":49},"end":{"line":99,"column":69}},"type":"if","locations":[{"start":{"line":99,"column":49},"end":{"line":99,"column":69}},{"start":{"line":99,"column":49},"end":{"line":99,"column":69}}]},"14":{"loc":{"start":{"line":99,"column":69},"end":{"line":99,"column":null}},"type":"if","locations":[{"start":{"line":99,"column":69},"end":{"line":99,"column":null}},{"start":{"line":99,"column":69},"end":{"line":99,"column":null}}]},"15":{"loc":{"start":{"line":104,"column":12},"end":{"line":104,"column":13}},"type":"if","locations":[{"start":{"line":104,"column":12},"end":{"line":104,"column":13}},{"start":{"line":104,"column":12},"end":{"line":104,"column":13}}]},"16":{"loc":{"start":{"line":104,"column":12},"end":{"line":104,"column":29}},"type":"binary-expr","locations":[{"start":{"line":104,"column":12},"end":{"line":104,"column":29}},{"start":{"line":104,"column":33},"end":{"line":104,"column":65}}]}},"s":{"0":4,"1":4,"2":4,"3":4,"4":4,"5":4,"6":10,"7":10,"8":10,"9":10,"10":4,"11":6,"12":3,"13":3,"14":3,"15":3,"16":6,"17":3,"18":4,"19":9,"20":9,"21":12,"22":6,"23":6,"24":6,"25":3,"26":6,"27":7,"28":1,"29":7,"30":7,"31":7,"32":7,"33":7,"34":1,"35":6,"36":33,"37":6,"38":4,"39":2,"40":2,"41":1,"42":4,"43":2,"44":2,"45":1,"46":4,"47":17,"48":2,"49":1,"50":4,"51":9,"52":4,"53":4},"f":{"0":4,"1":10,"2":3,"3":6,"4":33,"5":1,"6":1,"7":9,"8":9},"b":{"0":[10,0],"1":[3],"2":[3,3],"3":[3,3],"4":[6],"5":[3,3],"6":[1,6],"7":[7,6],"8":[1,6],"9":[33,1],"10":[3,3],"11":[1,0],"12":[1,0],"13":[1,0],"14":[1,0],"15":[8,1],"16":[9,9]}}
 ,"/home/runner/work/aws-event-stream/aws-event-stream/src/provider/memory.ts": {"path":"/home/runner/work/aws-event-stream/aws-event-stream/src/provider/memory.ts","statementMap":{"0":{"start":{"line":1,"column":0},"end":{"line":1,"column":28}},"1":{"start":{"line":10,"column":0},"end":{"line":10,"column":13}},"2":{"start":{"line":11,"column":12},"end":{"line":11,"column":70}},"3":{"start":{"line":13,"column":17},"end":{"line":23,"column":null}},"4":{"start":{"line":13,"column":53},"end":{"line":13,"column":null}},"5":{"start":{"line":14,"column":30},"end":{"line":14,"column":null}},"6":{"start":{"line":14,"column":14},"end":{"line":14,"column":null}},"7":{"start":{"line":15,"column":14},"end":{"line":20,"column":10}},"8":{"start":{"line":21,"column":8},"end":{"line":21,"column":34}},"9":{"start":{"line":22,"column":8},"end":{"line":22,"column":21}},"10":{"start":{"line":25,"column":17},"end":{"line":28,"column":null}},"11":{"start":{"line":25,"column":43},"end":{"line":25,"column":55}},"12":{"start":{"line":26,"column":14},"end":{"line":26,"column":74}},"13":{"start":{"line":27,"column":8},"end":{"line":27,"column":77}},"14":{"start":{"line":30,"column":17},"end":{"line":33,"column":null}},"15":{"start":{"line":30,"column":33},"end":{"line":30,"column":45}},"16":{"start":{"line":31,"column":14},"end":{"line":31,"column":51}},"17":{"start":{"line":32,"column":8},"end":{"line":32,"column":82}},"18":{"start":{"line":35,"column":17},"end":{"line":42,"column":null}},"19":{"start":{"line":35,"column":49},"end":{"line":35,"column":61}},"20":{"start":{"line":36,"column":14},"end":{"line":36,"column":52}},"21":{"start":{"line":37,"column":8},"end":{"line":40,"column":null}},"22":{"start":{"line":38,"column":18},"end":{"line":38,"column":52}},"23":{"start":{"line":39,"column":12},"end":{"line":39,"column":86}},"24":{"start":{"line":41,"column":8},"end":{"line":41,"column":18}},"25":{"start":{"line":44,"column":12},"end":{"line":56,"column":null}},"26":{"start":{"line":45,"column":22},"end":{"line":45,"column":49}},"27":{"start":{"line":46,"column":8},"end":{"line":49,"column":null}},"28":{"start":{"line":47,"column":12},"end":{"line":47,"column":54}},"29":{"start":{"line":48,"column":12},"end":{"line":48,"column":49}},"30":{"start":{"line":50,"column":22},"end":{"line":50,"column":43}},"31":{"start":{"line":51,"column":8},"end":{"line":54,"column":null}},"32":{"start":{"line":52,"column":12},"end":{"line":52,"column":41}},"33":{"start":{"line":53,"column":12},"end":{"line":53,"column":43}},"34":{"start":{"line":55,"column":8},"end":{"line":55,"column":23}},"35":{"start":{"line":57,"column":0},"end":{"line":57,"column":null}},"36":{"start":{"line":10,"column":13},"end":{"line":10,"column":29}}},"fnMap":{"0":{"name":"(anonymous_13)","decl":{"start":{"line":10,"column":0},"end":{"line":10,"column":13}},"loc":{"start":{"line":10,"column":0},"end":{"line":57,"column":null}}},"1":{"name":"(anonymous_15)","decl":{"start":{"line":13,"column":4},"end":{"line":13,"column":17}},"loc":{"start":{"line":13,"column":62},"end":{"line":23,"column":null}}},"2":{"name":"(anonymous_18)","decl":{"start":{"line":25,"column":4},"end":{"line":25,"column":17}},"loc":{"start":{"line":25,"column":69},"end":{"line":28,"column":null}}},"3":{"name":"(anonymous_21)","decl":{"start":{"line":30,"column":4},"end":{"line":30,"column":17}},"loc":{"start":{"line":30,"column":59},"end":{"line":33,"column":null}}},"4":{"name":"(anonymous_24)","decl":{"start":{"line":35,"column":4},"end":{"line":35,"column":17}},"loc":{"start":{"line":35,"column":75},"end":{"line":42,"column":null}}},"5":{"name":"(anonymous_27)","decl":{"start":{"line":44,"column":4},"end":{"line":44,"column":12}},"loc":{"start":{"line":44,"column":63},"end":{"line":56,"column":5}}}},"branchMap":{"0":{"loc":{"start":{"line":13,"column":53},"end":{"line":13,"column":null}},"type":"if","locations":[{"start":{"line":13,"column":53},"end":{"line":13,"column":null}},{"start":{"line":13,"column":53},"end":{"line":13,"column":null}}]},"1":{"loc":{"start":{"line":14,"column":30},"end":{"line":14,"column":null}},"type":"switch","locations":[{"start":{"line":14,"column":30},"end":{"line":14,"column":null}}]},"2":{"loc":{"start":{"line":25,"column":43},"end":{"line":25,"column":55}},"type":"if","locations":[{"start":{"line":25,"column":43},"end":{"line":25,"column":55}},{"start":{"line":25,"column":43},"end":{"line":25,"column":55}}]},"3":{"loc":{"start":{"line":27,"column":44},"end":{"line":27,"column":49}},"type":"binary-expr","locations":[{"start":{"line":27,"column":44},"end":{"line":27,"column":49}},{"start":{"line":27,"column":53},"end":{"line":27,"column":67}}]},"4":{"loc":{"start":{"line":30,"column":33},"end":{"line":30,"column":45}},"type":"if","locations":[{"start":{"line":30,"column":33},"end":{"line":30,"column":45}},{"start":{"line":30,"column":33},"end":{"line":30,"column":45}}]},"5":{"loc":{"start":{"line":32,"column":48},"end":{"line":32,"column":53}},"type":"binary-expr","locations":[{"start":{"line":32,"column":48},"end":{"line":32,"column":53}},{"start":{"line":32,"column":57},"end":{"line":32,"column":72}}]},"6":{"loc":{"start":{"line":35,"column":49},"end":{"line":35,"column":61}},"type":"if","locations":[{"start":{"line":35,"column":49},"end":{"line":35,"column":61}},{"start":{"line":35,"column":49},"end":{"line":35,"column":61}}]},"7":{"loc":{"start":{"line":37,"column":8},"end":{"line":40,"column":null}},"type":"if","locations":[{"start":{"line":37,"column":8},"end":{"line":40,"column":null}},{"start":{"line":37,"column":8},"end":{"line":40,"column":null}}]},"8":{"loc":{"start":{"line":39,"column":52},"end":{"line":39,"column":57}},"type":"binary-expr","locations":[{"start":{"line":39,"column":52},"end":{"line":39,"column":57}},{"start":{"line":39,"column":61},"end":{"line":39,"column":76}}]},"9":{"loc":{"start":{"line":46,"column":8},"end":{"line":49,"column":null}},"type":"if","locations":[{"start":{"line":46,"column":8},"end":{"line":49,"column":null}},{"start":{"line":46,"column":8},"end":{"line":49,"column":null}}]},"10":{"loc":{"start":{"line":51,"column":8},"end":{"line":54,"column":null}},"type":"if","locations":[{"start":{"line":51,"column":8},"end":{"line":54,"column":null}},{"start":{"line":51,"column":8},"end":{"line":54,"column":null}}]}},"s":{"0":4,"1":4,"2":16,"3":4,"4":44,"5":22,"6":22,"7":22,"8":22,"9":22,"10":4,"11":3,"12":2,"13":2,"14":4,"15":7,"16":4,"17":4,"18":4,"19":5,"20":3,"21":3,"22":2,"23":2,"24":1,"25":4,"26":24,"27":24,"28":13,"29":13,"30":24,"31":24,"32":18,"33":18,"34":24,"35":4,"36":4},"f":{"0":20,"1":22,"2":2,"3":4,"4":3,"5":24},"b":{"0":[22,0],"1":[22],"2":[1,1],"3":[2,1],"4":[3,1],"5":[4,3],"6":[2,1],"7":[2,1],"8":[2,1],"9":[13,11],"10":[18,6]}}
 ,"/home/runner/work/aws-event-stream/aws-event-stream/src/publisher/memory.ts": {"path":"/home/runner/work/aws-event-stream/aws-event-stream/src/publisher/memory.ts","statementMap":{"0":{"start":{"line":9,"column":0},"end":{"line":9,"column":13}},"1":{"start":{"line":11,"column":12},"end":{"line":11,"column":66}},"2":{"start":{"line":13,"column":17},"end":{"line":21,"column":null}},"3":{"start":{"line":14,"column":14},"end":{"line":14,"column":84}},"4":{"start":{"line":16,"column":8},"end":{"line":19,"column":null}},"5":{"start":{"line":17,"column":12},"end":{"line":17,"column":76}},"6":{"start":{"line":17,"column":55},"end":{"line":17,"column":75}},"7":{"start":{"line":18,"column":12},"end":{"line":18,"column":51}},"8":{"start":{"line":20,"column":8},"end":{"line":20,"column":20}},"9":{"start":{"line":23,"column":17},"end":{"line":36,"column":null}},"10":{"start":{"line":24,"column":12},"end":{"line":24,"column":65}},"11":{"start":{"line":25,"column":8},"end":{"line":28,"column":null}},"12":{"start":{"line":26,"column":12},"end":{"line":26,"column":57}},"13":{"start":{"line":27,"column":12},"end":{"line":27,"column":64}},"14":{"start":{"line":29,"column":8},"end":{"line":29,"column":44}},"15":{"start":{"line":30,"column":8},"end":{"line":35,"column":10}},"16":{"start":{"line":31,"column":20},"end":{"line":34,"column":null}},"17":{"start":{"line":32,"column":22},"end":{"line":32,"column":69}},"18":{"start":{"line":33,"column":16},"end":{"line":33,"column":52}},"19":{"start":{"line":37,"column":0},"end":{"line":37,"column":null}},"20":{"start":{"line":9,"column":13},"end":{"line":9,"column":30}}},"fnMap":{"0":{"name":"(anonymous_13)","decl":{"start":{"line":9,"column":0},"end":{"line":9,"column":13}},"loc":{"start":{"line":9,"column":0},"end":{"line":37,"column":null}}},"1":{"name":"(anonymous_15)","decl":{"start":{"line":13,"column":4},"end":{"line":13,"column":17}},"loc":{"start":{"line":13,"column":41},"end":{"line":21,"column":null}}},"2":{"name":"(anonymous_18)","decl":{"start":{"line":17,"column":41},"end":{"line":17,"column":51}},"loc":{"start":{"line":17,"column":51},"end":{"line":17,"column":65}}},"3":{"name":"(anonymous_19)","decl":{"start":{"line":23,"column":4},"end":{"line":23,"column":17}},"loc":{"start":{"line":23,"column":70},"end":{"line":36,"column":null}}},"4":{"name":"(anonymous_22)","decl":{"start":{"line":31,"column":20},"end":{"line":31,"column":null}},"loc":{"start":{"line":31,"column":20},"end":{"line":34,"column":null}}}},"branchMap":{"0":{"loc":{"start":{"line":16,"column":8},"end":{"line":19,"column":null}},"type":"if","locations":[{"start":{"line":16,"column":8},"end":{"line":19,"column":null}},{"start":{"line":16,"column":8},"end":{"line":19,"column":null}}]},"1":{"loc":{"start":{"line":16,"column":12},"end":{"line":16,"column":40}},"type":"binary-expr","locations":[{"start":{"line":16,"column":12},"end":{"line":16,"column":40}},{"start":{"line":16,"column":44},"end":{"line":16,"column":71}}]},"2":{"loc":{"start":{"line":25,"column":8},"end":{"line":28,"column":null}},"type":"if","locations":[{"start":{"line":25,"column":8},"end":{"line":28,"column":null}},{"start":{"line":25,"column":8},"end":{"line":28,"column":null}}]}},"s":{"0":4,"1":9,"2":4,"3":7,"4":7,"5":4,"6":5,"7":4,"8":3,"9":4,"10":5,"11":5,"12":4,"13":4,"14":5,"15":5,"16":1,"17":1,"18":1,"19":4,"20":4},"f":{"0":13,"1":7,"2":5,"3":5,"4":2},"b":{"0":[4,3],"1":[7,5],"2":[4,1]}}
 ,"/home/runner/work/aws-event-stream/aws-event-stream/src/publisher/sns.ts": {"path":"/home/runner/work/aws-event-stream/aws-event-stream/src/publisher/sns.ts","statementMap":{"0":{"start":{"line":2,"column":0},"end":{"line":2,"column":38}},"1":{"start":{"line":5,"column":0},"end":{"line":5,"column":41}},"2":{"start":{"line":15,"column":0},"end":{"line":15,"column":null}},"3":{"start":{"line":16,"column":4},"end":{"line":16,"column":19}},"4":{"start":{"line":16,"column":19},"end":{"line":16,"column":null}},"5":{"start":{"line":21,"column":0},"end":{"line":21,"column":13}},"6":{"start":{"line":29,"column":8},"end":{"line":29,"column":33}},"7":{"start":{"line":31,"column":8},"end":{"line":31,"column":60}},"8":{"start":{"line":32,"column":8},"end":{"line":32,"column":23}},"9":{"start":{"line":33,"column":8},"end":{"line":33,"column":36}},"10":{"start":{"line":36,"column":17},"end":{"line":49,"column":null}},"11":{"start":{"line":37,"column":14},"end":{"line":46,"column":10}},"12":{"start":{"line":48,"column":16},"end":{"line":48,"column":58}},"13":{"start":{"line":48,"column":8},"end":{"line":48,"column":69}},"14":{"start":{"line":51,"column":17},"end":{"line":74,"column":null}},"15":{"start":{"line":52,"column":8},"end":{"line":54,"column":null}},"16":{"start":{"line":53,"column":12},"end":{"line":53,"column":67}},"17":{"start":{"line":56,"column":14},"end":{"line":56,"column":73}},"18":{"start":{"line":57,"column":8},"end":{"line":59,"column":null}},"19":{"start":{"line":58,"column":12},"end":{"line":58,"column":79}},"20":{"start":{"line":60,"column":14},"end":{"line":64,"column":10}},"21":{"start":{"line":66,"column":8},"end":{"line":66,"column":54}},"22":{"start":{"line":68,"column":8},"end":{"line":73,"column":11}},"23":{"start":{"line":70,"column":16},"end":{"line":70,"column":49}},"24":{"start":{"line":71,"column":16},"end":{"line":71,"column":41}},"25":{"start":{"line":76,"column":12},"end":{"line":81,"column":null}},"26":{"start":{"line":77,"column":8},"end":{"line":79,"column":null}},"27":{"start":{"line":78,"column":12},"end":{"line":78,"column":71}},"28":{"start":{"line":80,"column":8},"end":{"line":80,"column":25}},"29":{"start":{"line":83,"column":0},"end":{"line":83,"column":null}},"30":{"start":{"line":21,"column":13},"end":{"line":21,"column":25}}},"fnMap":{"0":{"name":"(anonymous_13)","decl":{"start":{"line":15,"column":0},"end":{"line":15,"column":12}},"loc":{"start":{"line":15,"column":21},"end":{"line":17,"column":1}}},"1":{"name":"(anonymous_14)","decl":{"start":{"line":21,"column":0},"end":{"line":21,"column":13}},"loc":{"start":{"line":21,"column":0},"end":{"line":83,"column":null}}},"2":{"name":"SNSPublisher","decl":{"start":{"line":28,"column":4},"end":{"line":28,"column":16}},"loc":{"start":{"line":28,"column":73},"end":{"line":34,"column":5}}},"3":{"name":"(anonymous_16)","decl":{"start":{"line":36,"column":4},"end":{"line":36,"column":17}},"loc":{"start":{"line":36,"column":45},"end":{"line":49,"column":null}}},"4":{"name":"(anonymous_19)","decl":{"start":{"line":51,"column":4},"end":{"line":51,"column":17}},"loc":{"start":{"line":51,"column":52},"end":{"line":74,"column":null}}},"5":{"name":"(anonymous_22)","decl":{"start":{"line":69,"column":20},"end":{"line":69,"column":null}},"loc":{"start":{"line":69,"column":20},"end":{"line":72,"column":13}}},"6":{"name":"(anonymous_23)","decl":{"start":{"line":76,"column":4},"end":{"line":76,"column":12}},"loc":{"start":{"line":76,"column":47},"end":{"line":81,"column":5}}}},"branchMap":{"0":{"loc":{"start":{"line":15,"column":12},"end":{"line":15,"column":21}},"type":"binary-expr","locations":[{"start":{"line":15,"column":12},"end":{"line":15,"column":21}},{"start":{"line":15,"column":12},"end":{"line":15,"column":null}}]},"1":{"loc":{"start":{"line":48,"column":8},"end":{"line":48,"column":69}},"type":"switch","locations":[{"start":{"line":48,"column":8},"end":{"line":48,"column":69}}]},"2":{"loc":{"start":{"line":52,"column":8},"end":{"line":54,"column":null}},"type":"if","locations":[{"start":{"line":52,"column":8},"end":{"line":54,"column":null}},{"start":{"line":52,"column":8},"end":{"line":54,"column":null}}]},"3":{"loc":{"start":{"line":57,"column":8},"end":{"line":59,"column":null}},"type":"if","locations":[{"start":{"line":57,"column":8},"end":{"line":59,"column":null}},{"start":{"line":57,"column":8},"end":{"line":59,"column":null}}]},"4":{"loc":{"start":{"line":77,"column":8},"end":{"line":79,"column":null}},"type":"if","locations":[{"start":{"line":77,"column":8},"end":{"line":79,"column":null}},{"start":{"line":77,"column":8},"end":{"line":79,"column":null}}]}},"s":{"0":5,"1":5,"2":5,"3":5,"4":5,"5":5,"6":7,"7":7,"8":7,"9":7,"10":5,"11":4,"12":4,"13":4,"14":5,"15":3,"16":1,"17":2,"18":2,"19":1,"20":1,"21":2,"22":1,"23":1,"24":1,"25":5,"26":7,"27":2,"28":5,"29":5,"30":5},"f":{"0":5,"1":5,"2":7,"3":4,"4":3,"5":1,"6":7},"b":{"0":[5,5],"1":[4],"2":[1,2],"3":[1,1],"4":[2,5]}}
-,"/home/runner/work/aws-event-stream/aws-event-stream/src/publisher/sqs.ts": {"path":"/home/runner/work/aws-event-stream/aws-event-stream/src/publisher/sqs.ts","statementMap":{"0":{"start":{"line":3,"column":0},"end":{"line":3,"column":30}},"1":{"start":{"line":4,"column":0},"end":{"line":4,"column":32}},"2":{"start":{"line":5,"column":21},"end":{"line":5,"column":45}},"3":{"start":{"line":13,"column":0},"end":{"line":13,"column":13}},"4":{"start":{"line":18,"column":8},"end":{"line":18,"column":37}},"5":{"start":{"line":19,"column":8},"end":{"line":19,"column":29}},"6":{"start":{"line":20,"column":8},"end":{"line":20,"column":23}},"7":{"start":{"line":23,"column":17},"end":{"line":45,"column":null}},"8":{"start":{"line":24,"column":14},"end":{"line":41,"column":10}},"9":{"start":{"line":43,"column":16},"end":{"line":43,"column":62}},"10":{"start":{"line":43,"column":8},"end":{"line":43,"column":73}},"11":{"start":{"line":47,"column":17},"end":{"line":56,"column":null}},"12":{"start":{"line":48,"column":14},"end":{"line":51,"column":11}},"13":{"start":{"line":53,"column":8},"end":{"line":53,"column":25}},"14":{"start":{"line":55,"column":8},"end":{"line":55,"column":24}},"15":{"start":{"line":57,"column":0},"end":{"line":57,"column":null}},"16":{"start":{"line":13,"column":13},"end":{"line":13,"column":25}}},"fnMap":{"0":{"name":"(anonymous_13)","decl":{"start":{"line":13,"column":0},"end":{"line":13,"column":13}},"loc":{"start":{"line":13,"column":0},"end":{"line":57,"column":null}}},"1":{"name":"SQSPublisher","decl":{"start":{"line":17,"column":4},"end":{"line":17,"column":16}},"loc":{"start":{"line":17,"column":49},"end":{"line":21,"column":5}}},"2":{"name":"(anonymous_15)","decl":{"start":{"line":23,"column":4},"end":{"line":23,"column":17}},"loc":{"start":{"line":23,"column":41},"end":{"line":45,"column":null}}},"3":{"name":"(anonymous_18)","decl":{"start":{"line":47,"column":4},"end":{"line":47,"column":17}},"loc":{"start":{"line":47,"column":70},"end":{"line":56,"column":null}}}},"branchMap":{"0":{"loc":{"start":{"line":43,"column":8},"end":{"line":43,"column":73}},"type":"switch","locations":[{"start":{"line":43,"column":8},"end":{"line":43,"column":73}}]}},"s":{"0":5,"1":5,"2":5,"3":5,"4":3,"5":3,"6":3,"7":5,"8":3,"9":3,"10":3,"11":5,"12":0,"13":0,"14":0,"15":5,"16":5},"f":{"0":5,"1":3,"2":3,"3":0},"b":{"0":[3]}}
 }

src/event-store.ts

@@ -98,3 +98,12 @@ import * as _ from 'lodash';
     getEvents(offset?: number, limit?: number): Promise<Array<Event>>;
+
     /**
+     * Rertieve only one object containing all the events's data in the stream in order.
+     * @param offset The start position in the stream list
+     * @param limit The desired quantity events
+     * @return All the events
+     */
+    loadFromHistory(offset?: number, limit?: number): Promise<Event>;
+
+    /**
      * Add a new event to the end of the event stream.
@@ -101,0 +110,0 @@ * @param data The event data

src/event-stream.ts

@@ -6,2 +6,3 @@ import { EventStore, EventStream } from './event-store';
 import { Publisher } from './publisher/publisher';
+import { eventMerge } from './model/event-util';
 
@@ -46,2 +47,14 @@ /**
     /**
+     * Rertieve only one object containing all the events's data in the stream in order.
+     * @param offset The start position in the stream list
+     * @param limit The desired quantity events
+     * @return All the events
+     */
+    public async loadFromHistory(offset?: number, limit?: number): Promise<Event> {
+        const events = await this.getEvents(offset, limit);
+
+        return eventMerge(events);
+    }
+
+    /**
      * Add a new event to the end of the event stream.
@@ -48,0 +61,0 @@ * @param data The event data

src/index.ts

@@ -14,3 +14,2 @@ 'use strict';
 import { SNSPublisher } from './publisher/sns';
-import { SQSPublisher } from './publisher/sqs';
 
@@ -29,3 +28,2 @@ export { PersistenceProvider };
 export { InMemoryPublisher };
-export { SQSPublisher };
 export { SNSPublisher };
@@ -32,0 +30,0 @@ export { DynamodbProvider };

src/model/event.ts

@@ -18,3 +18,3 @@ /**
 
-    type?: string;
+    eventType?: string;
 
@@ -21,0 +21,0 @@ id?: string;

src/provider/dynamodb.ts

@@ -8,3 +8,2 @@ 'use strict';
 import { Schema } from '../dynamodb/schema';
-// import { Schema } from '../dynamodb/schema';
 import { Event, EventType } from '../model/event';
@@ -43,2 +42,3 @@ import { Stream } from '../model/stream';
             commitTimestamp: commitTimestamp,
+            eventType: data.eventType,
             payload: data,
@@ -61,3 +61,2 @@ stream: stream
 
-
     public async getEvents(stream: Stream, offset: number = 0, limit: number = -1): Promise<Array<Event>> {
@@ -90,2 +89,3 @@ await this.ensureTables();
                 commitTimestamp: data.commitTimestamp,
+                eventType: data.eventType || (data.payload as any).eventType,
                 payload: data.payload,
@@ -92,0 +92,0 @@ sequence: index,

src/provider/memory.ts

@@ -17,5 +17,5 @@ import * as _ from 'lodash';
             commitTimestamp: new Date().getTime(),
+            eventType: type,
             payload: data,
             sequence: currentEvents.length,
-            type: type
         };
@@ -22,0 +22,0 @@ currentEvents.push(event);

src/util.ts

@@ -0,1 +1,3 @@
+'use strict';
+
 export const getEndpointUrl = (endpoint?: string) => {
@@ -6,2 +8,2 @@ if (endpoint !== undefined) {
     return undefined;
-};
+};

No alert changes

Improved metrics

Total package byte prevSize

344157

0.73%

Dependency count

4

-20%

Number of package files

112

0.9%

Number of lines in readme file

115

618.75%

Worsened metrics

Lines of code

2744

-2.49%

Dependency changes

• - Removed

  sqs-consumer@^5.4.0

• - Removed

  debug@4.4.0
  (transitive)

• - Removed

  ms@2.1.3
  (transitive)

• - Removed

  sqs-consumer@5.8.0
  (transitive)