chore: wip

Author: glennmichael123

storage/framework/core/actions/src/migrate/database.ts

@@ -1,5 +1,5 @@
 import process from 'node:process'
-import { generateMigrations } from '@stacksjs/database'
+import { generateMigrations, runDatabaseMigration } from '@stacksjs/database'
 import { log } from '@stacksjs/logging'
 
 // this is run and checks whether new created or update migrations need to be generated
@@ -11,12 +11,12 @@ if (result?.isErr()) {
   process.exit(1)
 }
 
-// const result2 = await runDatabaseMigration()
+const result2 = await runDatabaseMigration()
 
-// if (result2.isErr()) {
-//   log.error('runDatabaseMigration failed')
-//   log.error(result2.error)
-//   process.exit(1)
-// }
+if (result2.isErr()) {
+  log.error('runDatabaseMigration failed')
+  log.error(result2.error)
+  process.exit(1)
+}
 
 process.exit(0)

storage/framework/core/actions/src/schedule/run.ts

@@ -4,9 +4,9 @@ import { runScheduler } from '@stacksjs/scheduler'
 
 const result = await runScheduler()
 
-// if (result?.isErr()) {
-//   console.error(result.error)
-//   log.error('Schedule run failed', result.error)
-// }
+if (result?.isErr()) {
+  console.error(result.error)
+  log.error('Schedule run failed', result.error)
+}
 
-// process.exit(0)
+process.exit(0)

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

@@ -3,6 +3,7 @@ import { path } from '@stacksjs/path'
 import type { JobOptions } from '@stacksjs/types'
 import { Every } from '@stacksjs/types'
 import { snakeCase } from '@stacksjs/strings'
+import { err, ok, type Err, type Ok } from '@stacksjs/error-handling'
 
 interface JobSchedule {
   jobName: string
@@ -13,7 +14,7 @@ interface JobSchedule {
 
 const scheduleFile = path.storagePath('framework/core/scheduler/src/schedules/jobSchedule.json')
 
-export async function runScheduler(): Promise<void> {
+export async function runScheduler(): Promise<Ok<string, never> | Err<string, any>> {
   const now = new Date()
   let schedules = loadSchedule()
 
@@ -43,7 +44,7 @@ export async function runScheduler(): Promise<void> {
         }
       }
     } catch (error) {
-      console.error(`Failed to process job file: ${jobFile}`, error)
+      return err(`Scheduler failed execute job: ${jobFile}`)
     }
   }
 
@@ -65,6 +66,8 @@ export async function runScheduler(): Promise<void> {
 
   // Save updated schedules
   saveSchedule(schedules)
+
+  return ok('Schedules ran successfully')
 }
 
 function isDueToRun(nextRunTime: Date, currentDate: Date): boolean {