Added scheduler correction with timezone

anoopkarnik · Aug 21, 2024 · 4ac37e3 · 4ac37e3
1 parent 577467d
commit 4ac37e3
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/apps/dashboard-app/routes.ts b/apps/dashboard-app/routes.ts
@@ -1,6 +1,6 @@
 
 export const publicRoutes = [
-    "/landing","/auth/new-verification",'/api'
+    "/landing","/auth/new-verification",'/api/hooks/catch'
 ]
 
 export const authRoutes =[

diff --git a/apps/scheduler/src/index.ts b/apps/scheduler/src/index.ts
@@ -34,20 +34,20 @@ async function main() {
             if (workflow.trigger?.type.name === 'Cron'){
                 logger.info(`Processing cron workflow ${workflow.id}`);
                 const metadata:any = workflow.trigger?.metadata;
-                const startDate = new Date(metadata?.startDate);
-                const now = new Date();
                 const timezone = metadata?.timezone;
+                const startDate = moment(metadata?.startDate).tz(timezone).toDate();
+                const now =  moment().tz(timezone).toDate();
                 const cronExpression = metadata?.cronExpression;
                 let lastRun;
                 if (workflow.lastRun){
-                    lastRun = new Date(workflow.lastRun);
+                    lastRun = moment(workflow.lastRun).tz(timezone).toDate();
                 }
                 else{
-                    lastRun = new Date(metadata.startDate);
+                    lastRun = moment(metadata.startDate).tz(timezone).toDate();
                 }
                 const interval = cronParser.parseExpression(cronExpression,{currentDate: lastRun, tz: timezone});
-                let nextRun:Date = interval.next().toDate ();
-                const local_time = moment(new Date())
+                let nextRun:Date = interval.next().toDate();
+                const local_time = moment().tz(timezone);
                 let eventMetadata = {
                     trigger: {
                         result:{