chore: wip

chore: wip

Author: chrisbbreuer

app/Scheduler.ts

@@ -9,8 +9,9 @@ import { schedule } from '@stacksjs/scheduler'
  * questions, feel free to reach out via Discord or GitHub Discussions.
  */
 export default function () {
-  schedule.job('name').everyFiveMinutes()
+  schedule.job('name').everyMinute()
   schedule.action('name').everyFiveMinutes()
+  schedule.command('echo "Hello, world!"').daily()
 }
 
 process.on('SIGINT', () => {

storage/framework/core/scheduler/src/schedule.ts

@@ -22,6 +22,9 @@ export class Schedule {
 
   constructor(task: () => void) {
     this.task = task
+    // Start job automatically when constructor is called
+    // We need to use setTimeout to ensure all chain methods are called first
+    setTimeout(() => this.start(), 0)
   }
 
   everySecond(): Schedule {
@@ -149,28 +152,34 @@ export class Schedule {
     return this
   }
 
-  start(): Cron {
+  private start(): Cron {
     const job = new Cron(
       this.cronPattern,
-      this.options,
+      {
+        ...this.options,
+        timezone: this.timezone,
+      } as CronOptions,
       this.task,
     )
 
+    if (this.options.name) {
+      Schedule.jobs.set(this.options.name, job)
+    }
+
     log.info(`Scheduled task with pattern: ${this.cronPattern} in timezone: ${this.timezone}`)
     return job
   }
 
   // job and action methods need to be added and they accept a path string param
   static job(name: string): Schedule {
-    // Here we create a task that will run the job by name
     return new Schedule(async () => {
       log.info(`Running job: ${name}`)
       try {
-        // Here you'd implement the actual job running logic
         await runCommand(`node path/to/jobs/${name}.js`)
       }
       catch (error) {
         log.error(`Job ${name} failed:`, error)
+        throw error // This will be caught by the error handler if one is set
       }
     }).withName(name)
   }
@@ -179,34 +188,33 @@ export class Schedule {
     return new Schedule(async () => {
       log.info(`Running action: ${name}`)
       try {
-        // Here you'd implement the actual action running logic
         await runCommand(`node path/to/actions/${name}.js`)
       }
       catch (error) {
         log.error(`Action ${name} failed:`, error)
+        throw error
       }
     }).withName(name)
   }
 
   static command(cmd: string): Schedule {
-    log.info(`Executing command: ${cmd}`)
     return new Schedule(async () => {
       try {
         log.info(`Executing command: ${cmd}`)
         const result = await runCommand(cmd)
 
         if (result.isErr()) {
           log.error(result.error)
-          return
+          throw result.error
         }
 
         log.info(result.value)
       }
       catch (error) {
         log.error(`Command execution failed: ${error}`)
-        throw error // This will be caught by the error handler if one is set
+        throw error
       }
-    })
+    }).withName(`command-${cmd}`)
   }
 
   /**
@@ -227,7 +235,6 @@ export class Schedule {
 
     const shutdownPromises = []
 
-    // Stop all running jobs
     for (const [name, job] of Schedule.jobs) {
       log.info(`Stopping job: ${name}`)
       shutdownPromises.push(
@@ -238,7 +245,6 @@ export class Schedule {
       )
     }
 
-    // Clear the jobs map
     await Promise.all(shutdownPromises)
     Schedule.jobs.clear()