@spinajs/queue - npm Package Compare versions

Comparing version 2.0.180 to 2.0.181

lib/cjs/BlackHoleQueueClient.d.ts

@@ -0,0 +0,0 @@ import { Constructor } from '@spinajs/di';

lib/cjs/BlackHoleQueueClient.js

@@ -25,7 +25,7 @@ "use strict";
 };
-BlackHoleQueueClient = __decorate([
+exports.BlackHoleQueueClient = BlackHoleQueueClient;
+exports.BlackHoleQueueClient = BlackHoleQueueClient = __decorate([
     (0, di_1.NewInstance)(),
     (0, di_1.Injectable)(interfaces_js_1.QueueClient)
 ], BlackHoleQueueClient);
-exports.BlackHoleQueueClient = BlackHoleQueueClient;
 //# sourceMappingURL=BlackHoleQueueClient.js.map

lib/cjs/config/queue.d.ts

@@ -0,0 +0,0 @@ declare const queue: {

lib/cjs/config/queue.js

@@ -0,0 +0,0 @@ "use strict";

lib/cjs/decorators.d.ts

@@ -0,0 +0,0 @@ export interface IEventOption {

lib/cjs/decorators.js

@@ -0,0 +0,0 @@ "use strict";

lib/cjs/index.d.ts

@@ -0,0 +0,0 @@ import { Constructor } from '@spinajs/di';

lib/cjs/index.js

@@ -156,2 +156,3 @@ "use strict";
 };
+exports.DefaultQueueService = DefaultQueueService;
 __decorate([
@@ -165,6 +166,5 @@ (0, log_1.Logger)('queue'),
 ], DefaultQueueService.prototype, "Connections", void 0);
-DefaultQueueService = __decorate([
+exports.DefaultQueueService = DefaultQueueService = __decorate([
     (0, di_1.Injectable)(interfaces_js_1.QueueService)
 ], DefaultQueueService);
-exports.DefaultQueueService = DefaultQueueService;
 //# sourceMappingURL=index.js.map

lib/cjs/interfaces.d.ts

@@ -0,0 +0,0 @@ import { AsyncService, Constructor, IInstanceCheck, IMappableService } from '@spinajs/di';

lib/cjs/interfaces.js

@@ -25,3 +25,3 @@ "use strict";
     QueueMessageType["Event"] = "EVENT";
-})(QueueMessageType = exports.QueueMessageType || (exports.QueueMessageType = {}));
+})(QueueMessageType || (exports.QueueMessageType = QueueMessageType = {}));
 class QueueService extends di_1.AsyncService {
@@ -45,2 +45,3 @@ getConnectionsForMessage(event) {
 }
+exports.QueueService = QueueService;
 __decorate([
@@ -50,3 +51,2 @@ (0, configuration_1.Config)('queue'),
 ], QueueService.prototype, "Configuration", void 0);
-exports.QueueService = QueueService;
 function isJob(event) {
@@ -163,2 +163,3 @@ return event.Type === QueueMessageType.Job;
 }
+exports.QueueClient = QueueClient;
 __decorate([
@@ -172,3 +173,2 @@ (0, log_1.Logger)('queue'),
 ], QueueClient.prototype, "Routing", void 0);
-exports.QueueClient = QueueClient;
 //# sourceMappingURL=interfaces.js.map

lib/cjs/migrations/Queue_2022_10_18_01_13_00.d.ts

@@ -0,0 +0,0 @@ import { OrmMigration, OrmDriver } from '@spinajs/orm';

lib/cjs/migrations/Queue_2022_10_18_01_13_00.js

@@ -32,6 +32,6 @@ "use strict";
 };
-Queue_2022_10_18_01_13_00 = __decorate([
+exports.Queue_2022_10_18_01_13_00 = Queue_2022_10_18_01_13_00;
+exports.Queue_2022_10_18_01_13_00 = Queue_2022_10_18_01_13_00 = __decorate([
     (0, orm_1.Migration)('queue')
 ], Queue_2022_10_18_01_13_00);
-exports.Queue_2022_10_18_01_13_00 = Queue_2022_10_18_01_13_00;
 //# sourceMappingURL=Queue_2022_10_18_01_13_00.js.map

lib/cjs/models/JobModel.d.ts

@@ -0,0 +0,0 @@ import { DateTime } from 'luxon';

lib/cjs/models/JobModel.js

@@ -22,2 +22,3 @@ "use strict";
 };
+exports.JobModel = JobModel;
 __decorate([
@@ -43,7 +44,6 @@ (0, orm_1.Primary)(),
 ], JobModel.prototype, "FinishedAt", void 0);
-JobModel = __decorate([
+exports.JobModel = JobModel = __decorate([
     (0, orm_1.Connection)('queue'),
     (0, orm_1.Model)('queue_jobs')
 ], JobModel);
-exports.JobModel = JobModel;
 //# sourceMappingURL=JobModel.js.map

lib/mjs/BlackHoleQueueClient.d.ts

@@ -0,0 +0,0 @@ import { Constructor } from '@spinajs/di';

lib/mjs/BlackHoleQueueClient.js

@@ -0,0 +0,0 @@ var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {

lib/mjs/config/queue.d.ts

@@ -0,0 +0,0 @@ declare const queue: {

lib/mjs/config/queue.js

@@ -0,0 +0,0 @@ const queue = {

lib/mjs/decorators.d.ts

@@ -0,0 +0,0 @@ export interface IEventOption {

lib/mjs/decorators.js

@@ -0,0 +0,0 @@ /**

lib/mjs/index.d.ts

@@ -0,0 +0,0 @@ import { Constructor } from '@spinajs/di';

lib/mjs/index.js

@@ -0,0 +0,0 @@ var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {

lib/mjs/interfaces.d.ts

@@ -0,0 +0,0 @@ import { AsyncService, Constructor, IInstanceCheck, IMappableService } from '@spinajs/di';

lib/mjs/interfaces.js

@@ -19,3 +19,3 @@ var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {
     QueueMessageType["Event"] = "EVENT";
-})(QueueMessageType = QueueMessageType || (QueueMessageType = {}));
+})(QueueMessageType || (QueueMessageType = {}));
 export class QueueService extends AsyncService {
@@ -22,0 +22,0 @@ getConnectionsForMessage(event) {

lib/mjs/migrations/Queue_2022_10_18_01_13_00.d.ts

@@ -0,0 +0,0 @@ import { OrmMigration, OrmDriver } from '@spinajs/orm';

lib/mjs/migrations/Queue_2022_10_18_01_13_00.js

@@ -0,0 +0,0 @@ var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {

lib/mjs/models/JobModel.d.ts

@@ -0,0 +0,0 @@ import { DateTime } from 'luxon';

lib/mjs/models/JobModel.js

@@ -0,0 +0,0 @@ var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) {

package.json

 {
   "name": "@spinajs/queue",
-  "version": "2.0.180",
+  "version": "2.0.181",
   "description": "queue sending & pulling made easy",
@@ -57,7 +57,7 @@
   "dependencies": {
-    "@spinajs/configuration": "^2.0.180",
-    "@spinajs/di": "^2.0.180",
-    "@spinajs/exceptions": "^2.0.180",
-    "@spinajs/log": "^2.0.180",
-    "@spinajs/orm": "^2.0.180",
+    "@spinajs/configuration": "^2.0.181",
+    "@spinajs/di": "^2.0.181",
+    "@spinajs/exceptions": "^2.0.181",
+    "@spinajs/log": "^2.0.181",
+    "@spinajs/orm": "^2.0.181",
     "luxon": "^3.2.1"
@@ -64,0 +64,0 @@ },

No alert changes

Improved metrics

Total package byte prevSize

250360

0.82%

Dependency changes

• + Added

  @spinajs/configuration@2.0.327
  (transitive)

• + Added

  @spinajs/di@2.0.327
  (transitive)

• + Added

  @spinajs/exceptions@2.0.327
  (transitive)

• + Added

  @spinajs/internal-logger@2.0.327
  (transitive)

• + Added

  @spinajs/log@2.0.327
  (transitive)

• + Added

  @spinajs/util@2.0.327
  (transitive)

• + Added

  uuid@9.0.1
  (transitive)

• - Removed

  @spinajs/configuration@2.0.328
  (transitive)

• - Removed

  @spinajs/di@2.0.328
  (transitive)

• - Removed

  @spinajs/exceptions@2.0.328
  (transitive)

• - Removed

  @spinajs/log@2.0.328
  (transitive)

• Updated

  @spinajs/configuration@^2.0.181

• Updated

  @spinajs/di@^2.0.181

• Updated

  @spinajs/exceptions@^2.0.181

• Updated

  @spinajs/log@^2.0.181

• Updated

  @spinajs/orm@^2.0.181