chore: wip

storage/framework/core/buddy/src/cli.ts

@@ -65,6 +65,7 @@ async function main() {
   cmd.make(buddy)
   cmd.migrate(buddy)
   cmd.outdated(buddy)
+  cmd.queue(buddy)
   cmd.release(buddy)
   cmd.route(buddy)
   cmd.saas(buddy)

storage/framework/core/queue/src/job.ts

@@ -40,8 +40,6 @@ export interface JobOptions {
 }
 
 export async function runJob(name: string, options: JobOptions = {}): Promise<void> {
-  log.info(`Running job: ${name}`)
-
   try {
     const jobModule = await import(appPath(`Jobs/${name}.ts`))
     const job = jobModule.default as JobConfig

storage/framework/core/queue/src/process.ts

@@ -1,9 +1,40 @@
-import { Job } from "../../../orm/src/models/Job";
+import { log } from '@stacksjs/logging'
+import { Job } from "../../../orm/src/models/Job"
+import { runJob } from "./job"
+
+interface QueuePayload  {
+  displayName: string,
+  name: string,
+  maxTries: number,
+  timeOut: number | null,
+  timeOutAt: Date | null
+}
 
 export async function processJobs(): Promise<void> {
   const jobs = await Job.all()
 
   for (const job of jobs) {
-    console.log(job)
+    if (job.payload) {
+      const payload: QueuePayload = JSON.parse(job.payload)
+      const currentAttempts = job.attempts || 0
+      log.info(`Running ${payload.displayName}`)
+
+      job.update({attempts: currentAttempts + 1 })
+
+      try {
+        await runJob(payload.name, {
+          queue: job.queue,
+          payload: {},
+          context: '',
+          maxTries: payload.maxTries,
+          timeout: 60,
+        })
+      } catch (error) {
+        log.info(`${payload.displayName} failed`)
+        log.error(error)
+      }
+
+      log.info(`Successfully ran ${payload.displayName}`)
+    }
   }
-}
+}

storage/framework/core/queue/src/utils.ts

@@ -1,10 +1,10 @@
 import type { JobOptions } from "./job"
-import process from 'node:process'
 import Job from "../../../orm/src/models/Job"
 
 export async function storeJob(name: string, options: JobOptions): Promise<void> {
   const payloadJson = JSON.stringify({
     displayName: `app/Jobs/${name}.ts`,
+    name,
     maxTries: options.tries || 1,
     timeout: null,
     timeoutAt: null