rails_actioncable_chat_channel_with_user_auth.rb

1# 1. Define the Channel (app/channels/chat_channel.rb)
2class ChatChannel < ApplicationCable::Channel
3  def subscribed
4    stream_from "chat_#{params[:room]}"
5  end
6
7  def receive(data)
8    ActionCable.server.broadcast("chat_#{params[:room]}", data)
9  end
10end
11
12# 2. Connection Logic (app/channels/application_cable/connection.rb)
13module ApplicationCable
14  class Connection < ActionCable::Connection::Base
15    identified_by :current_user
16
17    def connect
18      self.current_user = find_verified_user
19    end
20
21    private
22      def find_verified_user
23        if verified_user = User.find_by(id: cookies.encrypted[:user_id])
24          verified_user
25        else
26          reject_unauthorized_connection
27        end
28      end
29  end
30end
31
32# 3. Broadcasting from a Controller or Job
33# ActionCable.server.broadcast("chat_general", { message: "Hello World" })