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

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>;