resolve-eventstore-base - npm Package Compare versions

Comparing version 0.24.7 to 0.24.8

es/concurrent-error.js

 function ConcurrentError(aggregateId) {
   Error.call(this);
-  this.code = 409;
   this.name = 'ConcurrentError';
@@ -5,0 +4,0 @@ this.message = `Can not save the event because aggregate '${aggregateId}' is not actual at the moment. Please retry later.`;

es/create-adapter.js

@@ -0,1 +1,2 @@
+import getLog from './get-log';
 import getSecretsManagerFallback from './get-secrets-manager-fallback';
@@ -33,2 +34,3 @@
 }, options) => {
+  const log = getLog(`createAdapter`);
   const config = { ...options
@@ -41,2 +43,14 @@ };
   };
+  let bucketSize = 100;
+  const {
+    snapshotBucketSize
+  } = config;
+
+  if (Number.isSafeInteger(snapshotBucketSize) && snapshotBucketSize > 0) {
+    bucketSize = snapshotBucketSize;
+    log.debug(`snapshot bucket size explicitly set to ${bucketSize}`);
+  } else {
+    log.debug(`snapshot bucket size defaulted to ${bucketSize}`);
+  }
+
   let connectPromiseResolve;
@@ -57,3 +71,4 @@ const connectPromise = new Promise(resolve => {
     shapeEvent,
-    counters: new Map()
+    counters: new Map(),
+    bucketSize
   });
@@ -60,0 +75,0 @@ const adapter = {

es/index.js

@@ -15,2 +15,3 @@ import createAdapter from './create-adapter';
 import throwBadCursor from './throw-bad-cursor';
+import snapshotTrigger from './snapshot-trigger';
 const wrappedCreateAdapter = createAdapter.bind(null, {
@@ -28,3 +29,3 @@ importStream,
 export default wrappedCreateAdapter;
-export { ResourceAlreadyExistError as EventstoreResourceAlreadyExistError, ResourceNotExistError as EventstoreResourceNotExistError, ConcurrentError, MAINTENANCE_MODE_AUTO, MAINTENANCE_MODE_MANUAL, throwBadCursor, getNextCursor };
+export { ResourceAlreadyExistError as EventstoreResourceAlreadyExistError, ResourceNotExistError as EventstoreResourceNotExistError, ConcurrentError, MAINTENANCE_MODE_AUTO, MAINTENANCE_MODE_MANUAL, throwBadCursor, getNextCursor, snapshotTrigger };
 //# sourceMappingURL=index.js.map

lib/concurrent-error.js

@@ -10,3 +10,2 @@ "use strict";
   Error.call(this);
-  this.code = 409;
   this.name = 'ConcurrentError';
@@ -13,0 +12,0 @@ this.message = `Can not save the event because aggregate '${aggregateId}' is not actual at the moment. Please retry later.`;

lib/create-adapter.js

@@ -8,2 +8,4 @@ "use strict";
 
+var _getLog = _interopRequireDefault(require("./get-log"));
+
 var _getSecretsManagerFallback = _interopRequireDefault(require("./get-secrets-manager-fallback"));
@@ -43,2 +45,3 @@
 }, options) => {
+  const log = (0, _getLog.default)(`createAdapter`);
   const config = { ...options
@@ -51,2 +54,14 @@ };
   };
+  let bucketSize = 100;
+  const {
+    snapshotBucketSize
+  } = config;
+
+  if (Number.isSafeInteger(snapshotBucketSize) && snapshotBucketSize > 0) {
+    bucketSize = snapshotBucketSize;
+    log.debug(`snapshot bucket size explicitly set to ${bucketSize}`);
+  } else {
+    log.debug(`snapshot bucket size defaulted to ${bucketSize}`);
+  }
+
   let connectPromiseResolve;
@@ -67,3 +82,4 @@ const connectPromise = new Promise(resolve => {
     shapeEvent,
-    counters: new Map()
+    counters: new Map(),
+    bucketSize
   });
@@ -70,0 +86,0 @@ const adapter = {

lib/index.js

@@ -48,2 +48,8 @@ "use strict";
 });
+Object.defineProperty(exports, "snapshotTrigger", {
+  enumerable: true,
+  get: function () {
+    return _snapshotTrigger.default;
+  }
+});
 exports.default = void 0;
@@ -79,2 +85,4 @@
 
+var _snapshotTrigger = _interopRequireDefault(require("./snapshot-trigger"));
+
 function _interopRequireDefault(obj) { return obj && obj.__esModule ? obj : { default: obj }; }
@@ -81,0 +89,0 @@

package.json

 {
   "name": "resolve-eventstore-base",
-  "version": "0.24.7",
+  "version": "0.24.8",
   "description": "A base for reSolve eventstore adapters",
@@ -29,3 +29,4 @@ "engines": {
   "dependencies": {
-    "@babel/runtime": "7.9.6"
+    "@babel/runtime": "7.9.6",
+    "resolve-debug-levels": "0.24.8"
   },
@@ -32,0 +33,0 @@ "devDependencies": {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

148854

increased by8.74%

Number of package files

75

increased by11.94%

Lines of code

1374

increased by9.05%

Worsened metrics

Dependency count

2

increased by100%

Dependency changes

• + Addedresolve-debug-levels@0.24.8

• + Addeddebug@4.1.1(transitive)

• + Addedms@2.1.3(transitive)

• + Addedresolve-debug-levels@0.24.8(transitive)