The Complete Production SOP: How to Deploy and Run Ruby on Rails Action Cable Real-Time WebSockets in Autonomous AI Agents

---
name: "rails-action-cable-websockets"
description: "Integrate full-duplex WebSocket communication into Rails applications using Action Cable."
triggers:
  - "setup action cable channel"
  - "stream_for action cable"
  - "broadcast from model rails"
permissions:
  fs_read: true
  fs_write: "workspace"
  shell_exec: false
  net_access: false
---

module ApplicationCable
  class Connection < ActionCable::Connection::Base
    identified_by :current_user

    def connect
      self.current_user = find_verified_user
    end

    private

    def find_verified_user
      if verified_user = User.find_by(id: cookies.encrypted[:user_id])
        verified_user
      else
        reject_unauthorized_connection
      end
    end
  end
end

class ChatChannel < ApplicationCable::Channel
  def subscribed
    room = Room.find_by(id: params[:room_id])
    if room && current_user.can_access?(room)
      stream_for room
    else
      reject
    end
  end

  def unsubscribed
    stop_all_streams
  end

  def speak(data)
    room = Room.find_by(id: params[:room_id])
    return unless room && current_user.can_access?(room)

    message = room.messages.create!(
      user: current_user,
      content: data["message"]
    )
    ChatChannel.broadcast_to(room, {
      id: message.id,
      content: message.content,
      user: current_user.name,
      created_at: message.created_at.iso8601
    })
  end
end

require "test_helper"

class ChatChannelTest < ActionCable::Channel::TestCase
  setup do
    @user = users(:alex)
    @room = rooms(:general)
    stub_connection current_user: @user
  end

  test "subscribes to specific room stream" do
    subscribe room_id: @room.id
    assert subscription.confirmed?
    assert_has_stream_for @room
  end

  test "rejects unauthorized room" do
    private_room = rooms(:confidential)
    subscribe room_id: private_room.id
    assert subscription.rejected?
  end
end