chore: wip

Author: glennmichael123

app/Jobs/ExampleJob.ts

@@ -1,4 +1,3 @@
-import { log } from '@stacksjs/cli'
 import { Job } from '@stacksjs/queue'
 import { Every } from '@stacksjs/types'
 
@@ -9,7 +8,7 @@ export default new Job({
   backoff: 3, // optional, defaults to 3-second delays between retries
   rate: Every.Minute, // optional, '* * * * *' in cron syntax
   handle: () => {
-    log.info('This message logs every minute') // unless triggered via a route.job() call, in which case it logs once
+    // console.log('hello world') // unless triggered via a route.job() call, in which case it logs once
   },
   // action: 'SendWelcomeEmail', // instead of handle, you may target an action or `action: () => {`
 })

database/migrations/1736175792802-create-jobs-table.ts

@@ -8,6 +8,6 @@ export async function up(db: Database<any>) {
     .addColumn('email', 'varchar(255)', col => col.unique())
     .addColumn('created_at', 'timestamp', col => col.notNull().defaultTo(sql`CURRENT_TIMESTAMP`))
     .addColumn('updated_at', 'timestamp')
-    .addColumn('deleted_at', 'text')
+    .addColumn('deleted_at', 'timestamp')
     .execute()
 }

database/migrations/1734960728767-create-projects-table.ts renamed to database/migrations/1736240733668-create-projects-table.ts

@@ -65,10 +65,6 @@ function getUnitPrice(lineData: LineItem[]) {
 function getLastDigits(paymentIntent: any) {
   return paymentIntent.payment_method.card.last4
 }
-
-function getBrand(paymentIntent: any) {
-  return 'visa'
-}
 </script>
 
 <template>

database/migrations/1734960728770-create-subscriber_emails-table.ts renamed to database/migrations/1736240733671-create-subscriber_emails-table.ts

@@ -69,7 +69,7 @@ export function make(buddy: CLI): void {
 
       if (make) {
         options.name = buddy.args[1]
-        
+
         switch (make) {
           case 'action':
             await makeAction(options)

database/migrations/1734960728772-create-personal_access_tokens-table.ts renamed to database/migrations/1736240733674-create-personal_access_tokens-table.ts

@@ -35,7 +35,8 @@ export async function createJobsMigration(): Promise<Result<MigrationResult[] |
         await Bun.write(migrationFilePath, migrationContent) // Ensure the write operation is awaited
 
         log.success('Created jobs migration')
-      } else {
+      }
+      else {
         log.success('Jobs migration already created')
       }
     }

database/migrations/1734960728775-create-personal_access_token_teams-table.ts renamed to database/migrations/1736240733675-create-personal_access_token_teams-table.ts

@@ -48,8 +48,8 @@ export async function hasMigrationBeenCreated(tableName: string): Promise<boolea
   log.debug(`hasTableBeenMigrated for table: ${tableName}`)
 
   const migrations = globSync([path.userMigrationsPath('*.ts')], { absolute: true })
-  
-  return migrations.some(path => path.includes("create-jobs-"))
+
+  return migrations.some(path => path.includes('create-jobs-'))
 }
 
 export async function getExecutedMigrations(): Promise<{ name: string }[]> {

database/migrations/1734960728775-create-team_users-table.ts renamed to database/migrations/1736240733676-create-team_users-table.ts

@@ -257,7 +257,7 @@ async function createTableMigration(modelPath: string) {
   }
 
   if (useSoftDeletes)
-    migrationContent += `    .addColumn('deleted_at', 'text')\n`
+    migrationContent += `    .addColumn('deleted_at', 'timestamp')\n`
 
   migrationContent += `    .execute()\n`
   migrationContent += `}\n`

database/migrations/1734960728776-create-teams-table.ts renamed to database/migrations/1736240733676-create-teams-table.ts

@@ -1 +1 @@
-export type ModelNames = 'Project' | 'SubscriberEmail' | 'AccessToken' | 'Team' | 'Subscriber' | 'Deployment' | 'Release' | 'User' | 'Post' | 'Product' | 'PaymentMethod' | 'Transaction' | 'Subscription' | 'Error'
+export type ModelNames = 'Project' | 'SubscriberEmail' | 'AccessToken' | 'Team' | 'Subscriber' | 'Deployment' | 'Release' | 'User' | 'Post' | 'Product' | 'PaymentMethod' | 'Transaction' | 'Job' | 'Subscription' | 'Error'

database/migrations/1734960728778-create-subscribers-table.ts renamed to database/migrations/1736240733679-create-subscribers-table.ts

@@ -1 +1 @@
-export type TableNames = 'projects' | 'subscriber_emails' | 'personal_access_tokens' | 'personal_access_token_teams' | 'team_users' | 'teams' | 'subscribers' | 'deployments' | 'releases' | 'team_users' | 'users' | 'posts' | 'products' | 'payment_methods' | 'transactions' | 'subscriptions' | 'errors'
+export type TableNames = 'projects' | 'subscriber_emails' | 'personal_access_tokens' | 'personal_access_token_teams' | 'team_users' | 'teams' | 'subscribers' | 'deployments' | 'releases' | 'team_users' | 'users' | 'posts' | 'products' | 'payment_methods' | 'transactions' | 'jobs' | 'subscriptions' | 'errors'

database/migrations/1734960728781-create-deployments-table.ts renamed to database/migrations/1736240733681-create-deployments-table.ts

@@ -1,5 +1,6 @@
 import type { Model } from '@stacksjs/types'
 import { faker } from '@stacksjs/faker'
+import { schema } from '@stacksjs/validation'
 
 export default {
   name: 'Error',
@@ -14,17 +15,22 @@ export default {
   attributes: {
     type: {
       required: true,
-      order: 1,
       fillable: true,
-
-      factory: () => faker.system.fileType(),
+      validation: {
+        rule: schema.string().maxLength(255),
+        message: {
+          maxLength: 'Queue must have a maximum characters of 255',
+        },
+      },
+      factory: () => 'default',
     },
 
-    message: {
+    payload: {
       required: true,
-      order: 2,
       fillable: true,
-
+      validation: {
+        rule: schema.string(),
+      },
       factory: () => faker.lorem.sentence(),
     },
 

database/migrations/1734960728783-create-releases-table.ts renamed to database/migrations/1736240733685-create-releases-table.ts

@@ -0,0 +1,58 @@
+import type { Model } from '@stacksjs/types'
+import { faker } from '@stacksjs/faker'
+import { schema } from '@stacksjs/validation'
+
+export default {
+  name: 'Job',
+  table: 'jobs',
+  primaryKey: 'id',
+  autoIncrement: true,
+
+  traits: {
+    useTimestamps: true,
+  },
+
+  attributes: {
+    queue: {
+      required: true,
+      fillable: true,
+      validation: {
+        rule: schema.string().maxLength(255),
+        message: {
+          maxLength: 'Queue must have a maximum of 255 characters',
+        },
+      },
+      factory: () => 'default',
+    },
+
+    payload: {
+      required: true,
+      fillable: true,
+      validation: {
+        rule: schema.string(),
+      },
+      factory: () => faker.lorem.sentence(),
+    },
+
+    attempts: {
+      fillable: true,
+      validation: {
+        rule: schema.number(),
+        message: {
+          number: 'attempts must be a number',
+        },
+      },
+      factory: () => faker.number.int({ min: 0, max: 10 }),
+    },
+
+    reserved_at: {
+      required: true,
+      order: 4,
+      fillable: true,
+      validation: {
+        rule: schema.date(),
+      },
+      factory: () => '2024-12-23 13:32:19',
+    },
+  },
+} satisfies Model

database/migrations/1734960728786-create-passkeys-table.ts renamed to database/migrations/1736240733687-create-passkeys-table.ts

@@ -5,8 +5,8 @@ import { HttpError } from '@stacksjs/error-handling'
 
 export interface ErrorsTable {
   id?: number
-  type?: undefined
-  message?: undefined
+  type?: string
+  payload?: string
   stack?: undefined
   status?: undefined
   user_id?: undefined
@@ -48,16 +48,16 @@ interface QueryOptions {
 
 export class ErrorModel {
   private hidden = []
-  private fillable = ['type', 'message', 'stack', 'status', 'user_id', 'additional_info', 'uuid']
+  private fillable = ['type', 'payload', 'stack', 'status', 'user_id', 'additional_info', 'uuid']
   private softDeletes = false
   protected selectFromQuery: any
   protected withRelations: string[]
   protected updateFromQuery: any
   protected deleteFromQuery: any
   protected hasSelect: boolean
   public id: number
-  public type: undefined | undefined
-  public message: undefined | undefined
+  public type: string | undefined
+  public payload: string | undefined
   public stack: undefined | undefined
   public status: undefined | undefined
   public user_id: undefined | undefined
@@ -69,7 +69,7 @@ export class ErrorModel {
   constructor(error: Partial<ErrorType> | null) {
     this.id = error?.id || 1
     this.type = error?.type
-    this.message = error?.message
+    this.payload = error?.payload
     this.stack = error?.stack
     this.status = error?.status
     this.user_id = error?.user_id
@@ -460,10 +460,10 @@ export class ErrorModel {
     return instance
   }
 
-  static whereMessage(value: string): ErrorModel {
+  static wherePayload(value: string): ErrorModel {
     const instance = new ErrorModel(null)
 
-    instance.selectFromQuery = instance.selectFromQuery.where('message', '=', value)
+    instance.selectFromQuery = instance.selectFromQuery.where('payload', '=', value)
 
     return instance
   }
@@ -740,7 +740,7 @@ export class ErrorModel {
 
       id: this.id,
       type: this.type,
-      message: this.message,
+      payload: this.payload,
       stack: this.stack,
       status: this.status,
       user_id: this.user_id,
@@ -801,15 +801,15 @@ export async function remove(id: number): Promise<void> {
     .execute()
 }
 
-export async function whereType(value: undefined): Promise<ErrorModel[]> {
+export async function whereType(value: string): Promise<ErrorModel[]> {
   const query = db.selectFrom('errors').where('type', '=', value)
   const results = await query.execute()
 
   return results.map(modelItem => new ErrorModel(modelItem))
 }
 
-export async function whereMessage(value: undefined): Promise<ErrorModel[]> {
-  const query = db.selectFrom('errors').where('message', '=', value)
+export async function wherePayload(value: string): Promise<ErrorModel[]> {
+  const query = db.selectFrom('errors').where('payload', '=', value)
   const results = await query.execute()
 
   return results.map(modelItem => new ErrorModel(modelItem))