@schemeless/event-store - npm Package Compare versions

Comparing version 2.2.3 to 2.3.0

dist/makeReplay.d.ts

 import type { EventFlow, IEventStoreRepo } from '@schemeless/event-store-types';
 import { SuccessEventObserver } from '@schemeless/event-store-types';
-export declare const makeReplay: (eventFlows: EventFlow[], successEventObservers: SuccessEventObserver<any>[], eventStoreRepo: IEventStoreRepo) => () => Promise<void>;
+export declare const makeReplay: (eventFlows: EventFlow[], successEventObservers: SuccessEventObserver<any>[], eventStoreRepo: IEventStoreRepo) => (startFromId: string | undefined) => Promise<void>;

dist/makeReplay.js

@@ -25,3 +25,3 @@ "use strict";
 const makeObserverQueue_1 = require("./queue/makeObserverQueue");
-const makeReplay = (eventFlows, successEventObservers = [], eventStoreRepo) => () => __awaiter(void 0, void 0, void 0, function* () {
+const makeReplay = (eventFlows, successEventObservers = [], eventStoreRepo) => (startFromId) => __awaiter(void 0, void 0, void 0, function* () {
     var e_1, _a;
@@ -31,3 +31,3 @@ const eventFlowMap = registerEventFlowTypes_1.registerEventFlowTypes({}, eventFlows);
     logger_1.logger.info('replay starting');
-    const eventStoreIterator = yield eventStoreRepo.getAllEvents(pageSize);
+    const eventStoreIterator = yield eventStoreRepo.getAllEvents(pageSize, startFromId);
     const observerQueue = makeObserverQueue_1.makeObserverQueue(successEventObservers);
@@ -34,0 +34,0 @@ const subscription = observerQueue.processed$.subscribe();

package.json

 {
   "name": "@schemeless/event-store",
-  "version": "2.2.3",
+  "version": "2.3.0",
   "typescript:main": "src/index.ts",
@@ -24,3 +24,3 @@ "main": "dist/index.js",
   "dependencies": {
-    "@schemeless/event-store-types": "^2.2.2",
+    "@schemeless/event-store-types": "^2.3.0",
     "better-queue": "^3.8.10",
@@ -35,3 +35,3 @@ "debug": "^4.2.0",
     "@schemeless/event-store-adapter-dynamodb": "^2.2.0-rc.3",
-    "@schemeless/event-store-adapter-typeorm": "^2.2.0-rc.1",
+    "@schemeless/event-store-adapter-typeorm": "^2.3.0",
     "@types/better-queue": "^3.8.2",
@@ -54,3 +54,3 @@ "@types/debug": "^4.1.5",
   },
-  "gitHead": "ee437cc25c7c2e778827c44a67cc0e2cf429f891"
+  "gitHead": "0b9166b4dbfe2733f7a13817f5243ec5c9398050"
 }

No alert changes

Improved metrics

Total package byte prevSize

76725

increased by0.07%

Dependency changes

• Updated@schemeless/event-store-types@^2.3.0