chore: wip

Author: glennmichael123

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

@@ -0,0 +1,15 @@
+import type { Database } from '@stacksjs/database'
+import { sql } from '@stacksjs/database'
+
+export async function up(db: Database<any>) {
+  await db.schema
+    .createTable('jobs')
+    .addColumn('id', 'integer', col => col.primaryKey().autoIncrement())
+    .addColumn('queue', 'varchar(255)', col => col.notNull())
+    .addColumn('payload', 'text', col => col.notNull())
+    .addColumn('attempts', 'integer', col => col.notNull().defaultTo(0))
+    .addColumn('reserved_at', 'timestamp')
+    .addColumn('created_at', 'timestamp', col => col.notNull().defaultTo(sql.raw('CURRENT_TIMESTAMP')))
+    .addColumn('updated_at', 'timestamp')
+    .execute()
+}

storage/framework/core/database/src/custom/jobs.ts

@@ -3,14 +3,14 @@ import { log } from '@stacksjs/cli'
 import { database } from '@stacksjs/config'
 import { err, handleError, ok, type Result } from '@stacksjs/error-handling'
 import { path } from '@stacksjs/path'
-import { hasTableBeenMigrated } from '../drivers'
+import { hasMigrationBeenCreated } from '../drivers'
 
 const driver = database.default || ''
 
 export async function createJobsMigration(): Promise<Result<MigrationResult[] | string, Error>> {
   try {
     if (['sqlite', 'mysql'].includes(driver)) {
-      const hasBeenMigrated = await hasTableBeenMigrated('jobs')
+      const hasBeenMigrated = await hasMigrationBeenCreated('jobs')
 
       if (!hasBeenMigrated) {
         let migrationContent = `import type { Database } from '@stacksjs/database'\nimport { sql } from '@stacksjs/database'\n\n`
@@ -35,6 +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 {
+        log.success('Jobs migration already created')
       }
     }
 

storage/framework/core/database/src/drivers/index.ts

@@ -44,6 +44,14 @@ export async function hasTableBeenMigrated(tableName: string): Promise<boolean>
   return results.some(migration => migration.name.includes(tableName))
 }
 
+export async function hasMigrationBeenCreated(tableName: string): Promise<boolean> {
+  log.debug(`hasTableBeenMigrated for table: ${tableName}`)
+
+  const migrations = globSync([path.userMigrationsPath('*.ts')], { absolute: true })
+  
+  return migrations.some(path => path.includes("create-jobs-"))
+}
+
 export async function getExecutedMigrations(): Promise<{ name: string }[]> {
   try {
     return await db.selectFrom('migrations').select('name').execute()