update events and jobs syntax

apps/blog-next/package.json

@@ -32,6 +32,7 @@
     "@holo-js/core": "workspace:*",
     "@holo-js/db": "workspace:*",
     "@holo-js/db-sqlite": "workspace:*",
+    "@holo-js/events": "workspace:*",
     "@holo-js/flux": "workspace:*",
     "@holo-js/flux-react": "workspace:*",
     "@holo-js/forms": "workspace:*",

apps/blog-next/server/db/migrations/2026_04_25_044031_create_admins.ts

@@ -1,7 +1,7 @@
-import { defineMigration, type MigrationContext } from '@holo-js/db'
+import { defineMigration } from '@holo-js/db'
 
 export default defineMigration({
-  async up({ schema }: MigrationContext) {
+  async up({ schema }) {
     await schema.createTable('admins', (table) => {
       table.id()
       table.string('name')
@@ -12,7 +12,7 @@ export default defineMigration({
       table.timestamps()
     })
   },
-  async down({ schema }: MigrationContext) {
+  async down({ schema }) {
     await schema.dropTable('admins')
   },
 })

apps/blog-next/server/db/migrations/2026_04_25_044032_create_notifications.ts

@@ -1,7 +1,7 @@
-import { defineMigration, type MigrationContext } from '@holo-js/db'
+import { defineMigration } from '@holo-js/db'
 
 export default defineMigration({
-  async up({ schema }: MigrationContext) {
+  async up({ schema }) {
     await schema.createTable('notifications', (table) => {
       table.string('id').primaryKey()
       table.string('type').nullable()
@@ -15,7 +15,7 @@ export default defineMigration({
       table.index(['read_at'])
     })
   },
-  async down({ schema }: MigrationContext) {
+  async down({ schema }) {
     await schema.dropTable('notifications')
   },
 })

apps/blog-next/server/db/migrations/2026_04_25_044032_create_users.ts

@@ -1,7 +1,7 @@
-import { defineMigration, type MigrationContext } from '@holo-js/db'
+import { defineMigration } from '@holo-js/db'
 
 export default defineMigration({
-  async up({ schema }: MigrationContext) {
+  async up({ schema }) {
     await schema.createTable('users', (table) => {
       table.id()
       table.string('name')
@@ -12,7 +12,7 @@ export default defineMigration({
       table.timestamps()
     })
   },
-  async down({ schema }: MigrationContext) {
+  async down({ schema }) {
     await schema.dropTable('users')
   },
 })

apps/blog-next/server/db/migrations/2026_04_25_044033_create_sessions.ts

@@ -1,7 +1,7 @@
-import { defineMigration, type MigrationContext } from '@holo-js/db'
+import { defineMigration } from '@holo-js/db'
 
 export default defineMigration({
-  async up({ schema }: MigrationContext) {
+  async up({ schema }) {
     await schema.createTable('sessions', (table) => {
       table.string('id').primaryKey()
       table.string('store').default('database')
@@ -14,7 +14,7 @@ export default defineMigration({
       table.index(['expires_at'])
     })
   },
-  async down({ schema }: MigrationContext) {
+  async down({ schema }) {
     await schema.dropTable('sessions')
   },
 })

apps/blog-next/server/db/migrations/2026_04_25_044034_create_auth_identities.ts

@@ -1,7 +1,7 @@
-import { defineMigration, type MigrationContext } from '@holo-js/db'
+import { defineMigration } from '@holo-js/db'
 
 export default defineMigration({
-  async up({ schema }: MigrationContext) {
+  async up({ schema }) {
     await schema.createTable('auth_identities', (table) => {
       table.id()
       table.string('user_id')
@@ -18,7 +18,7 @@ export default defineMigration({
       table.unique(['provider', 'provider_user_id'], 'auth_identities_provider_user_unique')
     })
   },
-  async down({ schema }: MigrationContext) {
+  async down({ schema }) {
     await schema.dropTable('auth_identities')
   },
 })

apps/blog-next/server/db/migrations/2026_04_25_044035_create_personal_access_tokens.ts

@@ -1,7 +1,7 @@
-import { defineMigration, type MigrationContext } from '@holo-js/db'
+import { defineMigration } from '@holo-js/db'
 
 export default defineMigration({
-  async up({ schema }: MigrationContext) {
+  async up({ schema }) {
     await schema.createTable('personal_access_tokens', (table) => {
       table.uuid('id').primaryKey()
       table.string('provider').default('users')
@@ -16,7 +16,7 @@ export default defineMigration({
       table.index(['user_id'])
     })
   },
-  async down({ schema }: MigrationContext) {
+  async down({ schema }) {
     await schema.dropTable('personal_access_tokens')
   },
 })

apps/blog-next/server/db/migrations/2026_04_25_044036_create_password_reset_tokens.ts

@@ -1,7 +1,7 @@
-import { defineMigration, type MigrationContext } from '@holo-js/db'
+import { defineMigration } from '@holo-js/db'
 
 export default defineMigration({
-  async up({ schema }: MigrationContext) {
+  async up({ schema }) {
     await schema.createTable('password_reset_tokens', (table) => {
       table.uuid('id').primaryKey()
       table.string('provider').default('users')
@@ -14,7 +14,7 @@ export default defineMigration({
       table.index(['email'])
     })
   },
-  async down({ schema }: MigrationContext) {
+  async down({ schema }) {
     await schema.dropTable('password_reset_tokens')
   },
 })

apps/blog-next/server/db/migrations/2026_04_25_044037_create_email_verification_tokens.ts

@@ -1,7 +1,7 @@
-import { defineMigration, type MigrationContext } from '@holo-js/db'
+import { defineMigration } from '@holo-js/db'
 
 export default defineMigration({
-  async up({ schema }: MigrationContext) {
+  async up({ schema }) {
     await schema.createTable('email_verification_tokens', (table) => {
       table.uuid('id').primaryKey()
       table.string('provider').default('users')
@@ -16,7 +16,7 @@ export default defineMigration({
       table.index(['email'])
     })
   },
-  async down({ schema }: MigrationContext) {
+  async down({ schema }) {
     await schema.dropTable('email_verification_tokens')
   },
 })

apps/blog-next/server/db/migrations/2026_05_02_115334_create_comments_table.ts

@@ -1,7 +1,7 @@
-import { defineMigration, type MigrationContext } from '@holo-js/db'
+import { defineMigration } from '@holo-js/db'
 
 export default defineMigration({
-  async up({ schema }: MigrationContext) {
+  async up({ schema }) {
     await schema.createTable('comments', (table) => {
       table.id()
       table.integer('post_id')
@@ -13,7 +13,7 @@ export default defineMigration({
       table.timestamps()
     })
   },
-  async down({ schema }: MigrationContext) {
+  async down({ schema }) {
     await schema.dropTable('comments')
   },
 })

apps/blog-next/server/db/migrations/2026_05_25_063242_create_cache_cache_table.ts

@@ -1,7 +1,7 @@
-import { defineMigration, type MigrationContext } from '@holo-js/db'
+import { defineMigration } from '@holo-js/db'
 
 export default defineMigration({
-  async up({ schema }: MigrationContext) {
+  async up({ schema }) {
     await schema.createTable('cache', (table) => {
       table.string('key').primaryKey()
       table.text('payload')
@@ -15,7 +15,7 @@ export default defineMigration({
       table.index(['expires_at'], 'cache_locks_expires_at_index')
     })
   },
-  async down({ schema }: MigrationContext) {
+  async down({ schema }) {
     await schema.dropTable('cache_locks')
     await schema.dropTable('cache')
   },

apps/blog-next/server/db/migrations/2026_06_19_202222_create_failed_jobs_table.ts

@@ -0,0 +1,21 @@
+import { defineMigration } from '@holo-js/db'
+
+export default defineMigration({
+  async up({ schema }) {
+    await schema.createTable('failed_jobs', (table) => {
+      table.string('id').primaryKey()
+      table.string('job_id')
+      table.string('job')
+      table.string('connection')
+      table.string('queue')
+      table.text('payload')
+      table.text('exception')
+      table.bigInteger('failed_at')
+      table.index(['job_id'], 'failed_jobs_job_id_index')
+      table.index(['failed_at'], 'failed_jobs_failed_at_index')
+    })
+  },
+  async down({ schema }) {
+    await schema.dropTable('failed_jobs')
+  },
+})

apps/blog-next/server/db/migrations/2026_06_19_202222_create_jobs_table.ts

@@ -0,0 +1,25 @@
+import { defineMigration } from '@holo-js/db'
+
+export default defineMigration({
+  async up({ schema }) {
+    await schema.createTable('jobs', (table) => {
+      table.string('id').primaryKey()
+      table.string('job')
+      table.string('connection')
+      table.string('queue')
+      table.text('payload')
+      table.integer('attempts').default(0)
+      table.integer('max_attempts').default(1)
+      table.bigInteger('available_at')
+      table.bigInteger('reserved_at').nullable()
+      table.string('reservation_id').nullable()
+      table.bigInteger('created_at')
+      table.index(['queue', 'available_at'], 'jobs_queue_available_at_index')
+      table.index(['queue', 'reserved_at'], 'jobs_queue_reserved_at_index')
+      table.index(['reservation_id'], 'jobs_reservation_id_index')
+    })
+  },
+  async down({ schema }) {
+    await schema.dropTable('jobs')
+  },
+})

apps/blog-next/server/events/blog/post-saved.ts

@@ -0,0 +1,13 @@
+import { defineEvent } from '@holo-js/events'
+
+export const BlogPostSaved = defineEvent<{
+  action: 'created' | 'updated' | 'deleted'
+  postId: number
+  title: string
+  status: string
+  slug: string
+}>({
+  name: 'blog.post.saved',
+})
+
+export default BlogPostSaved

apps/blog-next/server/jobs/blog/index-post.ts

@@ -0,0 +1,22 @@
+import { defineJob } from '@holo-js/queue'
+
+import Post from '../../models/Post'
+
+export const IndexBlogPost = defineJob<{
+  action: 'created' | 'updated' | 'deleted'
+  postId: number
+}>({
+  queue: 'default',
+  async handle(payload) {
+    const post = await Post.find(payload.postId)
+
+    return {
+      action: payload.action,
+      postId: payload.postId,
+      indexed: post !== undefined,
+      title: post?.title ?? null,
+    }
+  },
+})
+
+export default IndexBlogPost

apps/blog-next/server/lib/blog.ts

@@ -4,6 +4,7 @@ import { DB, uniqueSlug } from '@holo-js/db'
 import { ValidationException } from '@holo-js/forms'
 
 import { blogPostChanged } from '../broadcast/blog-post-changed'
+import BlogPostSaved from '../events/blog/post-saved'
 import Category from '../models/Category'
 import Post from '../models/Post'
 import Tag from '../models/Tag'
@@ -253,6 +254,13 @@ export async function createPost(input: { title: string, excerpt?: string, body:
   }
 
   await broadcast(blogPostChanged('created', post.id, post.title, post.status, post.slug))
+  await BlogPostSaved.dispatch({
+    action: 'created',
+    postId: post.id,
+    title: post.title,
+    status: post.status,
+    slug: post.slug,
+  })
 
   return post
 }
@@ -289,6 +297,13 @@ export async function updatePost(id: number, input: { title: string, excerpt?: s
   }
 
   await broadcast(blogPostChanged('updated', post.id, post.title, post.status, post.slug))
+  await BlogPostSaved.dispatch({
+    action: 'updated',
+    postId: post.id,
+    title: post.title,
+    status: post.status,
+    slug: post.slug,
+  })
 
   return post
 }
@@ -298,5 +313,12 @@ export async function deletePost(id: number) {
   await Post.delete(id)
   if (post) {
     await broadcast(blogPostChanged('deleted', post.id, post.title, post.status, post.slug))
+    await BlogPostSaved.dispatch({
+      action: 'deleted',
+      postId: post.id,
+      title: post.title,
+      status: post.status,
+      slug: post.slug,
+    })
   }
 }

apps/blog-next/server/listeners/blog/index-saved-post.ts

@@ -0,0 +1,14 @@
+import { defineListener } from '@holo-js/events'
+
+import BlogPostSaved from '../../events/blog/post-saved'
+import IndexBlogPost from '../../jobs/blog/index-post'
+
+export default defineListener({
+  listensTo: [BlogPostSaved],
+  async handle(event) {
+    await IndexBlogPost.dispatch({
+      action: event.payload.action,
+      postId: event.payload.postId,
+    })
+  },
+})

apps/blog-next/tests/blog-logic.mjs

@@ -61,6 +61,10 @@ async function getRegisteredCacheKeys() {
   return [...(await getCacheRuntimeBindings()?.dependencyIndex?.listRegisteredKeys() ?? [])]
 }
 
+async function countQueuedBlogIndexJobs() {
+  return await DB.table('jobs').where('job', 'blog.index-post').count()
+}
+
 function resolveDriverCacheKey(indexedKey) {
   const delimiterIndex = indexedKey.indexOf('\u0000')
   return delimiterIndex === -1 ? indexedKey : indexedKey.slice(delimiterIndex + 1)
@@ -286,6 +290,8 @@ try {
   assert.ok(frameworkTag)
   assert.ok(releaseTag)
 
+  const queuedJobsBeforePostLifecycle = await countQueuedBlogIndexJobs()
+
   await createPost({
     title: 'Logic Coverage Post',
     excerpt: 'Logic excerpt',
@@ -294,6 +300,7 @@ try {
     categoryId: String(updatedCategory.id),
     tagIds: String(frameworkTag.id),
   })
+  assert.equal(await countQueuedBlogIndexJobs(), queuedJobsBeforePostLifecycle + 1)
   assert.equal(await countRegisteredCacheKeys(), 0)
   assert.ok((await getPublishedPosts()).some(post => post.slug === 'logic-coverage-post'))
 
@@ -369,6 +376,7 @@ try {
     categoryId: '',
     tagIds: String(releaseTag.id),
   })
+  assert.equal(await countQueuedBlogIndexJobs(), queuedJobsBeforePostLifecycle + 2)
   assert.equal(await countRegisteredCacheKeys(), 0)
 
   logicPost = await Post.with('category', 'tags').where('id', logicPost.id).first()
@@ -397,6 +405,7 @@ try {
   assert.equal(await Category.find(updatedCategory.id), undefined)
 
   await deletePost(logicPost.id)
+  assert.equal(await countQueuedBlogIndexJobs(), queuedJobsBeforePostLifecycle + 4)
   await deletePost(cleanupPost.id)
   if (mediaFailurePost) {
     await deletePost(mediaFailurePost.id)

apps/blog-nuxt/package.json

@@ -33,6 +33,7 @@
     "@holo-js/core": "workspace:*",
     "@holo-js/db": "workspace:*",
     "@holo-js/db-sqlite": "workspace:*",
+    "@holo-js/events": "workspace:*",
     "@holo-js/flux": "workspace:*",
     "@holo-js/flux-vue": "workspace:*",
     "@holo-js/forms": "workspace:*",