feat: Added static Asia/Kolkata as the timezone for AutoImports (#1097)

Author: thisismayuresh

apps/api/src/app/auto-import-jobs-schedular/usecase/auto-import-jobs-schedular.ts

@@ -48,6 +48,7 @@ export class AutoImportJobsSchedular {
 
       const interval = parser.parseExpression(cronExpression.trim(), {
         currentDate: currentNextRun,
+        tz: 'Asia/Kolkata',
       });
 
       const nextRun = interval.next().toDate();

apps/api/src/app/import-jobs/usecase/create-userjob/create-userjob.usecase.ts

@@ -73,17 +73,19 @@ export class CreateUserJob {
         return dayjs().add(5, 'minutes').toDate();
       }
 
+      const interval = parser.parseExpression(cronExpression.trim(), {
+        tz: 'Asia/Kolkata',
+      });
+      const nextCronTime = dayjs(interval.next().toDate());
       const now = dayjs();
-      const fiveMinutesFromNow = now.add(5, 'minutes');
 
-      const interval = parser.parseExpression(cronExpression.trim());
-      const nextCronTime = dayjs(interval.next().toDate());
+      if (nextCronTime.isBefore(now.add(1, 'minute'))) {
+        const nextOccurrence = dayjs(interval.next().toDate());
 
-      if (nextCronTime.isAfter(fiveMinutesFromNow)) {
-        return fiveMinutesFromNow.toDate();
-      } else {
-        return nextCronTime.toDate();
+        return nextOccurrence.toDate();
       }
+
+      return nextCronTime.toDate();
     } catch (error) {
       return dayjs().add(5, 'minutes').toDate();
     }

apps/queue-manager/src/consumers/get-auto-import-job-data.consumer.ts

@@ -8,7 +8,7 @@ import {
 } from '@impler/shared';
 
 import { SendImportJobDataConsumer } from './send-import-job-data.consumer';
-import { JobMappingRepository, ColumnRepository, UploadRepository, UserJobEntity } from '@impler/dal';
+import { JobMappingRepository, ColumnRepository, UserJobEntity } from '@impler/dal';
 
 interface IValidationResult {
   hasInvalidRecords: boolean;
@@ -24,7 +24,6 @@ export class SendAutoImportJobDataConsumer extends SendImportJobDataConsumer {
   private columnRepo: ColumnRepository = new ColumnRepository();
   private rssXmlService: RSSXMLService = new RSSXMLService();
   private paymentAPIService: PaymentAPIService = new PaymentAPIService();
-  private uploadRepository: UploadRepository = new UploadRepository();
 
   async message(message: { content: string }) {
     const data = JSON.parse(message.content) as { _jobId: string };