chore(core): bump version to 0.1.53 and update @intentjs/hyper-express dependency

- Updated package version to 0.1.53.
- Bumped @intentjs/hyper-express dependency version to 0.0.11.
- Enhanced delay calculation in PayloadBuilder to return both delay and net delay in seconds.
- Updated SqsQueueDriver to use net delay in seconds for message pushing.
- Added netDelayInSeconds property to InternalMessage interface.

Author: vinayak25

packages/core/lib/queue/core/payloadBuilder.ts

@@ -9,17 +9,18 @@ type Complete<T> = {
     : T[P] | undefined;
 };
 
-const calculateDelay = (delay: number | string | Date): number => {
+const calculateDelay = (delay: number | string | Date): [number, number] => {
   const now = Date.now();
   if (delay instanceof Date) {
     const time = delay.getTime();
-    return now > time ? now : time;
+    const netDelayInSeconds = (time - now) / 1000;
+    return now > time ? [now, 0] : [time, netDelayInSeconds];
   }
 
   const delayInMs = typeof delay === 'string' ? ms(delay) : delay * 1000;
   const calculatedDelay = now + delayInMs;
-  if (calculatedDelay < now) return now;
-  return calculatedDelay;
+  if (calculatedDelay < now) return [now, 0];
+  return [calculatedDelay, (calculatedDelay - now) / 1000];
 };
 
 export class PayloadBuilder {
@@ -37,7 +38,9 @@ export class PayloadBuilder {
       ...message,
     } as Complete<InternalMessage>;
 
-    payload.delay = calculateDelay(payload.delay || 0);
+    const [delay, netDelayInSeconds] = calculateDelay(payload.delay || 0);
+    payload.delay = delay;
+    payload.netDelayInSeconds = netDelayInSeconds;
     payload.connection = payload.connection || defaultOptions.connection;
 
     if (!payload.queue) {

packages/core/lib/queue/drivers/redis.ts

@@ -70,11 +70,13 @@ export class RedisQueueDriver implements PollQueueDriver {
   }
 
   async purge(options: Record<string, any>): Promise<void> {
+    await this.initializeModules();
     await this.client.del(this.getQueue(options.queue));
     await this.client.del(this.getDelayedQueue(options.queue));
   }
 
   async count(options: Record<string, any>): Promise<number> {
+    await this.initializeModules();
     return await this.client.llen(this.getQueue(options.queue));
   }
 
@@ -97,6 +99,7 @@ export class RedisQueueDriver implements PollQueueDriver {
   }
 
   async scheduledTask(options: Record<string, any>): Promise<void> {
+    await this.initializeModules();
     await (this.client as any).findDelayedJob(
       this.getDelayedQueue(options.queue),
       this.getQueue(options.queue),

packages/core/lib/queue/drivers/sqs.ts

@@ -11,25 +11,15 @@ export class SqsQueueDriver implements PollQueueDriver {
 
   constructor(private options: Record<string, any>) {
     validateOptions(options, SqsQueueOptionsDto, { cls: SqsQueueDriver.name });
-    this.initializeModules().then(() => {
-      this.client = new this.AWS.SQS({
-        region: options.region,
-        apiVersion: options.apiVersion,
-        credentials: options.credentials || {
-          accessKeyId: options.accessKey,
-          secretAccessKey: options.secretKey,
-        },
-      });
-    });
+    this.initializeModules();
   }
 
-  init(): Promise<void> {
-    throw new Error('Method not implemented.');
-  }
+  async init(): Promise<void> {}
 
   async push(message: string, rawPayload: InternalMessage): Promise<void> {
+    await this.initializeModules();
     const params = {
-      DelaySeconds: rawPayload.delay,
+      DelaySeconds: rawPayload.netDelayInSeconds,
       MessageBody: message,
       QueueUrl: joinUrl(this.options.prefix, rawPayload.queue),
     };
@@ -39,6 +29,7 @@ export class SqsQueueDriver implements PollQueueDriver {
   }
 
   async pull(options: Record<string, any>): Promise<SqsJob[] | null> {
+    await this.initializeModules();
     const params = {
       MaxNumberOfMessages: 10,
       MessageAttributeNames: ['All'],
@@ -53,6 +44,7 @@ export class SqsQueueDriver implements PollQueueDriver {
   }
 
   async remove(job: SqsJob, options: Record<string, any>): Promise<void> {
+    await this.initializeModules();
     const params = {
       QueueUrl: joinUrl(this.options.prefix, options.queue),
       ReceiptHandle: job.data.ReceiptHandle,
@@ -64,6 +56,7 @@ export class SqsQueueDriver implements PollQueueDriver {
   }
 
   async purge(options: Record<string, any>): Promise<void> {
+    await this.initializeModules();
     const params = {
       QueueUrl: joinUrl(this.options.prefix, options.queue),
     };
@@ -74,6 +67,7 @@ export class SqsQueueDriver implements PollQueueDriver {
   }
 
   async count(options: Record<string, any>): Promise<number> {
+    await this.initializeModules();
     const params = {
       QueueUrl: joinUrl(this.options.prefix, options.queue),
       AttributeNames: ['ApproximateNumberOfMessages'],
@@ -84,6 +78,15 @@ export class SqsQueueDriver implements PollQueueDriver {
   }
 
   async initializeModules(): Promise<void> {
+    if (this.AWS && this.client) return Promise.resolve();
     this.AWS = await Package.load('@aws-sdk/client-sqs');
+    this.client = new this.AWS.SQS({
+      region: this.options.region,
+      apiVersion: this.options.apiVersion,
+      credentials: this.options.credentials || {
+        accessKeyId: this.options.accessKey,
+        secretAccessKey: this.options.secretKey,
+      },
+    });
   }
 }

packages/core/lib/queue/strategy/message.ts

@@ -17,4 +17,5 @@ export interface InternalMessage extends Message {
   attemptCount: number;
   id: string;
   delay?: number;
+  netDelayInSeconds?: number;
 }

packages/core/lib/queue/workers/pollQueue.ts

@@ -173,7 +173,7 @@ export class PollQueueWorker extends BaseQueueWorker {
       this.emitEvent(new JobMaxRetriesExceeed(message, job));
       return;
     }
-    await Dispatch(message);
+    await Dispatch({ ...message, delay: message.netDelayInSeconds });
     this.emitEvent(new JobFailed(message, job));
   }
 

packages/core/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@intentjs/core",
-  "version": "0.1.50",
+  "version": "0.1.53",
   "description": "Core module for Intent",
   "repository": {
     "type": "git",
@@ -131,7 +131,7 @@
     "typescript": "^5.5.2"
   },
   "dependencies": {
-    "@intentjs/hyper-express": "^0.0.10",
+    "@intentjs/hyper-express": "^0.0.11",
     "@nestjs/common": "^11.0.12",
     "@nestjs/core": "^11.0.12",
     "@react-email/components": "^0.0.32",

packages/hyper-express/package.json

@@ -1,6 +1,6 @@
 {
     "name": "@intentjs/hyper-express",
-    "version": "0.0.10",
+    "version": "0.0.11",
     "description": "A fork of hyper-express to suit IntentJS requirements. High performance Node.js webserver with a simple-to-use API powered by uWebsockets.js under the hood.",
     "main": "index.js",
     "types": "./types/index.d.ts",

packages/hyper-express/src/shared/uploaded-file.js

@@ -28,11 +28,11 @@ class UploadedFile {
     }
 
     get extension() {
-        return this.filename;
+        return this._filename.split('.').pop();
     }
 
     async toBuffer() {
-        return fs.readFileSync(this.tempPath);
+        return fs.readFileSync(this._tempPath);
     }
 }