chore: wip

chore: wip

Author: chrisbbreuer

app/Jobs/DummyJob.ts

@@ -8,7 +8,7 @@ export default new Job({
   queue: 'default', // defaults to 'default'
   tries: 3, // defaults to 3, in case of failures
   backoff: 3, // defaults to 3-second delays between retries
-  schedule: Every.FiveSeconds, // '*/5 * * * *' in cron syntax (overwrites the Scheduler's definition)
+  rate: Every.Minute, // '* * * * *' in cron syntax (overwrites the Scheduler's definition)
   handle: () => {
     log.info('This cron job log this message every 5 seconds')
   },

app/Schedule.ts

@@ -1,13 +1,13 @@
-// import run from '@stacksjs/scheduler'
+import run from '@stacksjs/scheduler'
 
-// export default function () {
-//   run.command('bun /home/some/script.js').everySecond()
-//   run.command('bun /home/some/other/script.ts').everyMinute()
-//   run.job('DummyJob.ts').everyTenMinutes() // scans ./app/Jobs/*
-//   // schedule.action('SomeAction.ts').everyFiveMinutes() // you may also trigger an action - scans ./app/Actions/*
-//   run.exec('bun /home/some/script.ts').everyMinute()
-//   run.call(() => {
-//     // eslint-disable-next-line no-console
-//     console.log('a "fancy callback" that runs weekly (Mondays) at 1:00 PM PT')
-//   }).weekly().mondays().at('13:00').timezone('America/Los_Angeles')
-// }
+export default function () {
+  run.command('bun /home/some/script.js').everySecond()
+  run.command('bun /home/some/other/script.ts').everyMinute()
+  run.job('DummyJob.ts').everyTenMinutes() // scans ./app/Jobs/*
+  // schedule.action('SomeAction.ts').everyFiveMinutes() // you may also trigger an action - scans ./app/Actions/*
+  run.exec('bun /home/some/script.ts').everyMinute()
+  run.call(() => {
+    // eslint-disable-next-line no-console
+    console.log('a "fancy callback" that runs weekly (Mondays) at 1:00 PM PT')
+  }).weekly().mondays().at('13:00').timezone('America/Los_Angeles')
+}

bun.lockb

@@ -1,8 +1,9 @@
-import { aws_ec2 as ec2 } from 'aws-cdk-lib'
+import type { Cluster, TaskDefinition } from 'aws-cdk-lib'
+import { CfnOutput as Output, Size, aws_batch as batch, aws_ec2 as ec2, aws_ecs as ecs } from 'aws-cdk-lib'
+import { path as p } from '@stacksjs/path'
+import type { Construct } from 'constructs'
 import { Rule, Schedule } from 'aws-cdk-lib/aws-events'
 import { EcsTask } from 'aws-cdk-lib/aws-events-targets'
-import type { Cluster, TaskDefinition } from 'aws-cdk-lib/aws-ecs'
-import type { Construct } from 'constructs'
 import type { NestedCloudProps } from '../types'
 
 export interface QueueStackProps extends NestedCloudProps {
@@ -12,11 +13,10 @@ export interface QueueStackProps extends NestedCloudProps {
 
 export class QueueStack {
   constructor(scope: Construct, props: QueueStackProps) {
-    const rule = new Rule(scope, 'Rule', {
+    const rule = new Rule(scope, 'QueueRule', {
       // schedule to run every second
       ruleName: `${props.appName}-${props.appEnv}-queue`,
       schedule: Schedule.cron({ minute: '*', hour: '*', month: '*', weekDay: '*', year: '*' }),
-      // schedule: Schedule.cron({ minute: '0', hour: '0' }), // For example, every day at midnight
     })
 
     rule.addTarget(new EcsTask({
@@ -37,9 +37,11 @@ export class QueueStack {
           ],
         },
       ],
+
       retryAttempts: 3,
+
       subnetSelection: {
-        subnetType: ec2.SubnetType.PUBLIC,
+        subnetType: ec2.SubnetType.PUBLIC, // SubnetType.PRIVATE_WITH_EGRESS
       },
     }))
   }

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

@@ -242,6 +242,10 @@ export function eslintPath(path?: string) {
   return lintPath(`eslint/${path || ''}`)
 }
 
+export function jobsPath(path?: string) {
+  return resourcesPath(`jobs/${path || ''}`)
+}
+
 export function loggingPath(path?: string) {
   return corePath(`logging/${path || ''}`)
 }
@@ -490,6 +494,7 @@ export const path = {
   libraryEntryPath,
   lintPath,
   loggingPath,
+  jobsPath,
   modulesPath,
   ormPath,
   objectsPath,

storage/framework/core/path/src/index.ts

@@ -14,7 +14,7 @@ export interface JobOptions {
   timezone?: string
   tries?: number
   backoff?: number | number[]
-  schedule?: string | Every
+  rate?: string | Every
   enabled?: boolean
 }
 
@@ -30,10 +30,10 @@ export type CronJobs = Jobs
 // export type CronJobs = Jobs
 
 export enum Every {
-  Second = '* * * * * *',
-  FiveSeconds = '*/5 * * * * *',
-  TenSeconds = '*/10 * * * * *',
-  ThirtySeconds = '*/30 * * * * *',
+  // Second = '* * * * * *',
+  // FiveSeconds = '*/5 * * * * *',
+  // TenSeconds = '*/10 * * * * *',
+  // ThirtySeconds = '*/30 * * * * *',
   Minute = '* * * * *',
   Hour = '0 * * * *',
   HalfHour = '0,30 * * * *',

storage/framework/core/types/src/cron-jobs.ts

@@ -95,6 +95,7 @@ entrypoints
 envrc
 eventstream
 execa
+fairshare
 Fargate
 filesize
 flareapp
@@ -166,6 +167,7 @@ marvinpinto
 mattpocock
 mdit
 mdsvex
+mebibytes
 meema
 meemalabs
 meilisearch

storage/framework/ide/dictionary.txt

@@ -1,5 +1,16 @@
+import process from 'node:process'
 import type { Server, ServerWebSocket } from 'bun'
 import { serverResponse } from '@stacksjs/router'
+import { path as p } from '@stacksjs/path'
+
+if (process.env.QUEUE_WORKER) {
+  if (!process.env.JOB)
+    throw new Error('Missing JOB environment variable')
+
+  const jobModule = await import(p.jobsPath('DummyJob'))
+  await jobModule.default.handle()
+  process.exit(0)
+}
 
 const server = Bun.serve({
   port: 3000,