rails6 ActionCableでchat機能は付けられましたが非同期処理内で送信者と受信者でviewの見え方を変えたい

Question

前提・実現したいこと

rails6でactioncableとbroadcastでLineのグループ機能のようなものを作っています
現段階ではチャット機能はできていて
非同期処理の中でifを使ってメッセージの送信者と見ている人のidを比較し、送信者と見ている人でメッセージの見え方を変えたいです

発生している問題・エラーメッセージ

broadcast(非同期)内で'gem devise'のヘルパーメソッドのcurrent_userで値を取りたいのですがうまくいきません

<div class="message">
 <% if message.user_id == #current_user.id# %>
  ...
 <% else %>
  ...
 <% end %>
</div>

該当のソースコード

class MessageBroadcastJob < ApplicationJob
  queue_as :default

  def perform(message)
    ActionCable.server.broadcast "room_channel_#{message.room_id}", message: render_message(message)
  end
  
  private

    def render_message(message)
      ApplicationController.renderer.render partial: 'messages/message', locals: { message: message }
    end
end

class RoomChannel < ApplicationCable::Channel
  def subscribed
     stream_from "room_channel_#{params['room']}"
  end

  def unsubscribed
    # Any cleanup needed when channel is unsubscribed
  end
  
  def speak(data)
    Message.create!(content: data['message'], user_id: current_user.id, room_id: params['room'])
  end
end

import consumer from "./consumer"

$(function() {
  const chatChannel = consumer.subscriptions.create({ channel: 'RoomChannel', room: $('#messages').data('room_id') }, {
    connected() {
      // Called when the subscription is ready for use on the server
    },

    disconnected() {
      // Called when the subscription has been terminated by the server
    },

    received: function(data) {
      return $('#messages').append(data['message']);
    },

    speak: function(message) {
      return this.perform('speak', {
        message: message
      });
    }
  });

  $(document).on('keypress', '[data-behavior~=room_speaker]', function(event) {
    if (event.keyCode === 13) {
      chatChannel.speak(event.target.value);
      event.target.value = '';
      return event.preventDefault();
    }
  });
});

試したこと

current_userの値を非同期で取れないか試行錯誤しています

補足情報（FW/ツールのバージョンなど）

cloud9 ubuntu
rails6
ruby 2.6.3
devise 4.7.1

Answer 1

WebSocket側からdeviseのcurrent_userを直接扱うことはできません。
app/channels/application_cable/connection.rb
で別途current_userを用意してください。