@arque/core - npm Package Compare versions

Comparing version 1.0.0-alpha.10 to 1.0.0-alpha.13

build/index.js

@@ -10,3 +10,3 @@ "use strict";
 var __exportStar = (this && this.__exportStar) || function(m, exports) {
-    for (var p in m) if (p !== "default" && !exports.hasOwnProperty(p)) __createBinding(exports, m, p);
+    for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);
 };
@@ -13,0 +13,0 @@ Object.defineProperty(exports, "__esModule", { value: true });

build/lib/aggregate/index.js

 "use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.BaseAggregate = void 0;
 var base_1 = require("./base");
-Object.defineProperty(exports, "BaseAggregate", { enumerable: true, get: function () { return base_1.default; } });
+Object.defineProperty(exports, "BaseAggregate", { enumerable: true, get: function () { return __importDefault(base_1).default; } });
 //# sourceMappingURL=index.js.map

build/lib/connection/index.d.ts

 export { default as LocalConnection } from './local';
-export { default as ActiveMQConnection } from './activemq';
 //# sourceMappingURL=index.d.ts.map

build/lib/connection/index.js

 "use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.LocalConnection = void 0;
 var local_1 = require("./local");
-Object.defineProperty(exports, "LocalConnection", { enumerable: true, get: function () { return local_1.default; } });
-var activemq_1 = require("./activemq");
-Object.defineProperty(exports, "ActiveMQConnection", { enumerable: true, get: function () { return activemq_1.default; } });
+Object.defineProperty(exports, "LocalConnection", { enumerable: true, get: function () { return __importDefault(local_1).default; } });
 //# sourceMappingURL=index.js.map

build/lib/decorators/index.js

 "use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.ProjectionEventHandler = exports.Projection = exports.AggregateEventHandler = exports.Aggregate = void 0;
 var aggregate_1 = require("./aggregate");
-Object.defineProperty(exports, "Aggregate", { enumerable: true, get: function () { return aggregate_1.default; } });
+Object.defineProperty(exports, "Aggregate", { enumerable: true, get: function () { return __importDefault(aggregate_1).default; } });
 var aggregate_event_handler_1 = require("./aggregate-event-handler");
-Object.defineProperty(exports, "AggregateEventHandler", { enumerable: true, get: function () { return aggregate_event_handler_1.default; } });
+Object.defineProperty(exports, "AggregateEventHandler", { enumerable: true, get: function () { return __importDefault(aggregate_event_handler_1).default; } });
 var projection_1 = require("./projection");
-Object.defineProperty(exports, "Projection", { enumerable: true, get: function () { return projection_1.default; } });
+Object.defineProperty(exports, "Projection", { enumerable: true, get: function () { return __importDefault(projection_1).default; } });
 var projection_event_handler_1 = require("./projection-event-handler");
-Object.defineProperty(exports, "ProjectionEventHandler", { enumerable: true, get: function () { return projection_event_handler_1.default; } });
+Object.defineProperty(exports, "ProjectionEventHandler", { enumerable: true, get: function () { return __importDefault(projection_event_handler_1).default; } });
 //# sourceMappingURL=index.js.map

build/lib/event-store/database/index.js

 "use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.MongoDBEventStoreDatabase = exports.MemoryEventStoreDatabase = void 0;
 var memory_1 = require("./memory");
-Object.defineProperty(exports, "MemoryEventStoreDatabase", { enumerable: true, get: function () { return memory_1.default; } });
+Object.defineProperty(exports, "MemoryEventStoreDatabase", { enumerable: true, get: function () { return __importDefault(memory_1).default; } });
 var mongodb_1 = require("./mongodb");
-Object.defineProperty(exports, "MongoDBEventStoreDatabase", { enumerable: true, get: function () { return mongodb_1.default; } });
+Object.defineProperty(exports, "MongoDBEventStoreDatabase", { enumerable: true, get: function () { return __importDefault(mongodb_1).default; } });
 //# sourceMappingURL=index.js.map

build/lib/event-store/database/memory.js

@@ -17,3 +17,3 @@ "use strict";
     var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
+    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
     __setModuleDefault(result, mod);
@@ -20,0 +20,0 @@ return result;

build/lib/event-store/database/mongodb.js

@@ -17,3 +17,3 @@ "use strict";
     var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
+    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
     __setModuleDefault(result, mod);
@@ -20,0 +20,0 @@ return result;

build/lib/event-store/distributed/index.js

 "use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.DistributedEventStoreServer = exports.DistributedEventStore = void 0;
 var client_1 = require("./client");
-Object.defineProperty(exports, "DistributedEventStore", { enumerable: true, get: function () { return client_1.default; } });
+Object.defineProperty(exports, "DistributedEventStore", { enumerable: true, get: function () { return __importDefault(client_1).default; } });
 var server_1 = require("./server");
-Object.defineProperty(exports, "DistributedEventStoreServer", { enumerable: true, get: function () { return server_1.default; } });
+Object.defineProperty(exports, "DistributedEventStoreServer", { enumerable: true, get: function () { return __importDefault(server_1).default; } });
 //# sourceMappingURL=index.js.map

build/lib/event-store/index.js

@@ -10,9 +10,13 @@ "use strict";
 var __exportStar = (this && this.__exportStar) || function(m, exports) {
-    for (var p in m) if (p !== "default" && !exports.hasOwnProperty(p)) __createBinding(exports, m, p);
+    for (var p in m) if (p !== "default" && !Object.prototype.hasOwnProperty.call(exports, p)) __createBinding(exports, m, p);
 };
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.MemoryEventStore = void 0;
 var memory_1 = require("./memory");
-Object.defineProperty(exports, "MemoryEventStore", { enumerable: true, get: function () { return memory_1.default; } });
+Object.defineProperty(exports, "MemoryEventStore", { enumerable: true, get: function () { return __importDefault(memory_1).default; } });
 __exportStar(require("./distributed"), exports);
 __exportStar(require("./database"), exports);
 //# sourceMappingURL=index.js.map

build/lib/projection-store/index.js

 "use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.MongoDBProjectionStore = exports.MemoryProjectionStore = void 0;
 var memory_1 = require("./memory");
-Object.defineProperty(exports, "MemoryProjectionStore", { enumerable: true, get: function () { return memory_1.default; } });
+Object.defineProperty(exports, "MemoryProjectionStore", { enumerable: true, get: function () { return __importDefault(memory_1).default; } });
 var mongodb_1 = require("./mongodb");
-Object.defineProperty(exports, "MongoDBProjectionStore", { enumerable: true, get: function () { return mongodb_1.default; } });
+Object.defineProperty(exports, "MongoDBProjectionStore", { enumerable: true, get: function () { return __importDefault(mongodb_1).default; } });
 //# sourceMappingURL=index.js.map

build/lib/projection-store/memory.js

@@ -17,3 +17,3 @@ "use strict";
     var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
+    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
     __setModuleDefault(result, mod);
@@ -20,0 +20,0 @@ return result;

build/lib/projection-store/mongodb.js

@@ -17,3 +17,3 @@ "use strict";
     var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
+    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
     __setModuleDefault(result, mod);
@@ -20,0 +20,0 @@ return result;

build/lib/projection/index.js

 "use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.BaseProjection = void 0;
 var base_1 = require("./base");
-Object.defineProperty(exports, "BaseProjection", { enumerable: true, get: function () { return base_1.default; } });
+Object.defineProperty(exports, "BaseProjection", { enumerable: true, get: function () { return __importDefault(base_1).default; } });
 //# sourceMappingURL=index.js.map

build/lib/snapshot-store/index.js

 "use strict";
+var __importDefault = (this && this.__importDefault) || function (mod) {
+    return (mod && mod.__esModule) ? mod : { "default": mod };
+};
 Object.defineProperty(exports, "__esModule", { value: true });
+exports.MongoDBSnapshotStore = exports.MemorySnapshotStore = void 0;
 var memory_1 = require("./memory");
-Object.defineProperty(exports, "MemorySnapshotStore", { enumerable: true, get: function () { return memory_1.default; } });
+Object.defineProperty(exports, "MemorySnapshotStore", { enumerable: true, get: function () { return __importDefault(memory_1).default; } });
 var mongodb_1 = require("./mongodb");
-Object.defineProperty(exports, "MongoDBSnapshotStore", { enumerable: true, get: function () { return mongodb_1.default; } });
+Object.defineProperty(exports, "MongoDBSnapshotStore", { enumerable: true, get: function () { return __importDefault(mongodb_1).default; } });
 //# sourceMappingURL=index.js.map

build/lib/snapshot-store/memory.js

@@ -17,3 +17,3 @@ "use strict";
     var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
+    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
     __setModuleDefault(result, mod);
@@ -20,0 +20,0 @@ return result;

build/lib/snapshot-store/mongodb.js

@@ -17,3 +17,3 @@ "use strict";
     var result = {};
-    if (mod != null) for (var k in mod) if (k !== "default" && Object.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
+    if (mod != null) for (var k in mod) if (k !== "default" && Object.prototype.hasOwnProperty.call(mod, k)) __createBinding(result, mod, k);
     __setModuleDefault(result, mod);
@@ -20,0 +20,0 @@ return result;

package.json

 {
   "name": "@arque/core",
-  "version": "1.0.0-alpha.10",
+  "version": "1.0.0-alpha.13",
   "description": "Core for `arque`",
@@ -43,3 +43,3 @@ "keywords": [
     "@types/p-queue": "^3.2.1",
-    "@types/ramda": "^0.27.11",
+    "@types/ramda": "^0.27.14",
     "@types/serialize-error": "^4.0.1",
@@ -53,3 +53,3 @@ "backoff": "^2.5.0",
     "p-queue": "^6.6.0",
-    "ramda": "^0.27.0",
+    "ramda": "^0.27.1",
     "reflect-metadata": "^0.1.13",
@@ -71,4 +71,4 @@ "serialize-error": "^7.0.1"
     "sinon": "^9.0.2",
-    "ts-node": "^8.9.1",
-    "typescript": "^3.9.7"
+    "ts-node": "^9.0.0",
+    "typescript": "^4.0.2"
   },
@@ -78,3 +78,3 @@ "publishConfig": {
   },
-  "gitHead": "d503600ad08b28382eb6a92a68d89381367fcef1"
+  "gitHead": "551fd9b36cc7391c8854bee8b0082f6c48fccb28"
 }

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

New author

Supply chain risk

A new npm collaborator published a version of the package for the first time. New collaborators are usually benign additions to a project, but do indicate a change to the security surface area of a package.

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

Worsened metrics

Total package byte prevSize

147400

decreased by-2.02%

Number of package files

155

decreased by-2.52%

Lines of code

2034

decreased by-1.6%

Number of medium supply chain risk alerts

1

increased byInfinity%

Dependency changes

• Updated@types/ramda@^0.27.14

• Updatedramda@^0.27.1