class SupportMailbox < ApplicationMailbox
def process
ticket = Ticket.find_or_create_by!(message_id: mail.message_id) do |t|
t.subject = mail.subject
t.from_email = mail.from&.first
t.body = mail.decoded
t.account = Account.find_by!(inbound_address: mail.to&.first)
end
ticket.broadcast_prepend_later_to(
[ticket.account, :tickets],
target: 'ticket_feed'
)
end
end
<%= turbo_stream_from [Current.account, :tickets] %>
<div id="ticket_feed">
<%= render @tickets %>
</div>
<div id="<%= dom_id(ticket) %>" class="border-b py-3">
<div class="font-medium"><%= ticket.subject %></div>
<div class="text-sm text-gray-600"><%= ticket.from_email %></div>
</div>
For apps that ingest emails (support inbox, replies), Action Mailbox is a natural fit. When a message arrives, I create a record and broadcast it into a Turbo Stream feed so the UI updates in realtime. This is essentially “email as an event source”. The mailbox extracts metadata (from, subject, body), persists it, and then broadcasts a prepend to the appropriate stream (scoped to the account/team). The UI subscribes with turbo_stream_from and renders the message partial. The benefit is that operators can watch incoming mail live without polling. The key considerations are deduplication (Message-ID), security (only authorized users subscribe), and sanitization (render email body safely). Hotwire keeps it simple: rendered partials, no bespoke websocket protocol.
Related snips
class CommentsController < ApplicationController
before_action :set_post
def create
@comment = @post.comments.build(comment_params)
System test: asserting Turbo Stream responses
class Post < ApplicationRecord
belongs_to :author, class_name: 'User'
has_many :comments, dependent: :destroy
scope :published, -> { where.not(published_at: nil).where('published_at <= ?', Time.current) }
scope :draft, -> { where(published_at: nil) }
ActiveRecord scopes for reusable query logic
module Api
module V1
class UsersController < BaseController
def show
user = User.includes(:profile).find(params[:id])
ETags for conditional requests and caching
class PostsController < ApplicationController
def index
@posts = Post.includes(:author)
.order(created_at: :desc)
.page(params[:page])
.per(10)
Turbo Frames: infinite scroll with lazy-loading frame
require "csv"
class PeopleCsvStream
include Enumerable
HEADERS = %w[id full_name email signed_up_at plan].freeze
Resilient CSV Export as a Streamed Response
<form data-controller="query-sync" data-action="change->query-sync#apply">
<select name="status" class="rounded border p-2">
<option value="">Any</option>
<option value="open">Open</option>
<option value="closed">Closed</option>
</select>
Filter UI that syncs query params via Stimulus (no front-end router)
Share this code
Here's the card — post it anywhere.