Merge pull request #105 from windingtree/feat/level-queue-test

Feat/level queue test

Author: kostysh

packages/storage/test/levelQueue.memory.spec.ts renamed to examples/e2e-tests/test/levelQueue.memory.spec.ts

@@ -1,8 +1,8 @@
 import { describe, expect, it } from 'vitest';
-import { GenericStorageOptions } from '../src/index.js';
-import { createInitializer } from '../src/level.js';
 import { JobHandler, Queue } from '@windingtree/sdk-queue';
 import { DateTime } from 'luxon';
+import { GenericStorageOptions } from '@windingtree/sdk-storage';
+import { createInitializer } from '@windingtree/sdk-storage/level';
 
 describe('Level Queue Test', () => {
   const createJobHandler =

packages/queue/src/index.ts

@@ -704,7 +704,7 @@ export class Queue extends EventEmitter<QueueEvents> {
     }
 
     this.jobs.push(job);
-    logger.trace('Job added:', job);
+    logger.trace('Job added:', JSON.stringify(job, null, 2));
     void this.storageUpdate(job.id, job);
     void this.start();
     return job.id;

packages/storage/package.json

@@ -57,11 +57,6 @@
   "publishConfig": {
     "access": "public"
   },
-  "devDependencies": {
-    "@types/luxon": "^3.3.5",
-    "@windingtree/sdk-queue": "workspace:*",
-    "luxon": "^1.23.0"
-  },
   "dependencies": {
     "@windingtree/sdk-logger": "workspace:*",
     "buffer": "^6.0.3",

pnpm-lock.yaml

@@ -14,6 +14,7 @@ export default defineWorkspace([
       name: 'e2e',
       environment: 'node',
       include: ['./examples/e2e-tests/**/*.spec.ts'],
+      testTimeout: 10000,
     },
   },
 ]);