Feat: auto migration

.env.test

@@ -1,10 +1,10 @@
 # Test environment configuration for Docker PostgreSQL
 TEST_DB_HOST=localhost
-TEST_DB_PORT=5432
+TEST_DB_PORT=5433
 TEST_DB_NAME=que_test
 TEST_DB_USER=que_user
 TEST_DB_PASSWORD=que_password
 TEST_DB_SSL=false
 
 # Connection string format (alternative to individual fields)
-TEST_DATABASE_URL=postgresql://que_user:que_password@localhost:5432/que_test
+TEST_DATABASE_URL=postgresql://que_user:que_password@localhost:5433/que_test

.eslintrc.js

@@ -1,21 +1,18 @@
 module.exports = {
-  parser: '@typescript-eslint/parser',
+  parser: "@typescript-eslint/parser",
   parserOptions: {
     ecmaVersion: 2020,
-    sourceType: 'module',
+    sourceType: "module",
   },
-  extends: [
-    'eslint:recommended',
-    '@typescript-eslint/recommended',
-  ],
+  extends: ["eslint:recommended", "plugin:@typescript-eslint/recommended"],
   rules: {
-    '@typescript-eslint/no-unused-vars': 'error',
-    '@typescript-eslint/explicit-function-return-type': 'warn',
-    '@typescript-eslint/no-explicit-any': 'warn',
-    '@typescript-eslint/no-non-null-assertion': 'warn',
+    "@typescript-eslint/no-unused-vars": "error",
+    "@typescript-eslint/explicit-function-return-type": "warn",
+    "@typescript-eslint/no-explicit-any": "warn",
+    "@typescript-eslint/no-non-null-assertion": "warn",
   },
   env: {
     node: true,
     jest: true,
   },
-};
+};

dist/client.d.ts

@@ -1,8 +1,10 @@
-import { PoolClient } from 'pg';
-import { Job, EnqueueOptions, ClientConfig, JSONArray } from './types';
+import { PoolClient } from "pg";
+import { Job, EnqueueOptions, ClientConfig, JSONArray } from "./types";
 export declare class Client {
     private pool;
+    private migrationPromise;
     constructor(config?: ClientConfig);
+    private ensureMigrations;
     enqueue(jobClass: string, args?: JSONArray, options?: EnqueueOptions): Promise<Job>;
     enqueueInTx(client: PoolClient, jobClass: string, args?: JSONArray, options?: EnqueueOptions): Promise<Job>;
     lockJob(queue?: string): Promise<Job | null>;

dist/types.d.ts

@@ -42,6 +42,7 @@ export interface WorkerOptions {
     queue?: string;
     interval?: number;
     maxAttempts?: number;
+    concurrency?: number;
 }
 export interface JobRow {
     priority: number;

dist/utils.d.ts

@@ -1,6 +1,8 @@
-import { JSONArray } from './types';
+import { JSONArray } from "./types";
+import { Pool } from "pg";
 export declare function intPow(base: number, exponent: number): number;
 export declare function calculateRetryDelay(errorCount: number): number;
 export declare function formatJobArgs(args: JSONArray): string;
 export declare function parseJobArgs(args: JSONArray): JSONArray;
+export declare function runMigrations(client: Pool): Promise<void>;
 //# sourceMappingURL=utils.d.ts.map

dist/worker.d.ts

@@ -7,6 +7,7 @@ export declare class Worker {
     private running;
     private shutdownPromise;
     private timeoutId;
+    private timeoutResolve;
     constructor(clientConfig?: ClientConfig, options?: WorkerOptions);
     register(jobClass: string, workFunc: WorkFunction): void;
     work(): Promise<void>;