Realtime and Notifications

This chapter broadcasts post changes, dispatches events, and sends notifications from the blog workflow.

What you will build

• a post-changed broadcast payload
• a private admin broadcast channel
• a post-saved event
• a listener that reacts after the post write
• notification-ready auth mail flows

Files you will create

server/broadcast/blog-post-changed.ts
server/channels/blog-admin.ts
server/events/blog/post-saved.ts
server/listeners/blog/index-saved-post.ts
server/jobs/blog/index-post.ts
server/notifications/auth/email-verification.ts
server/notifications/auth/password-reset.ts
server/realtime/posts.ts
app/admin/broadcast-feed.tsx

The finished example uses those same files under apps/blog-next.

Broadcast after writes

await broadcast(blogPostChanged('created', post.id, post.title, post.status, post.slug))

Dispatch domain events

await BlogPostSaved.dispatch({
  action: 'created',
  postId: post.id,
  title: post.title,
  status: post.status,
  slug: post.slug,
})

Use cases

• update an admin dashboard when a post changes
• queue indexing work after a post is saved
• notify users about auth lifecycle events
• keep realtime subscribers in sync

Checkpoint

Blog writes now produce side effects outside the request path, while the write itself stays focused on data consistency.

Related reference

• Events
• Broadcast
• Realtime
• Notifications
• Queue