railsのActionCableを使ったチャットアプリでエラー ActionView::Template::Error (Devise could not find the `Warden::Pro

Question

rails 6.0.3
ruby 2.6.5
Mysql

railsでActionCableを使ったチャットアプリを作成しています。

しかしメッセージを送信したところで、

[ActiveJob] [MessageBroadcastJob] [b9536de0-7add-448c-8a4e-464fa65b1229] Error performing MessageBroadcastJob (Job ID: b9536de0-7add-448c-8a4e-464fa65b1229) from Async(default) in 10.09ms: ActionView::Template::Error (Devise could not find the `Warden::Proxy` instance on your request environment.
Make sure that your application is loading Devise and Warden as expected and that the `Warden::Manager` middleware is present in your middleware stack.
If you are seeing this on one of your tests, ensure that your tests are either executing the Rails middleware stack or that your tests are using the `Devise::Test::ControllerHelpers` module to inject the `request.env['warden']` object for you.):

このようなエラーが出てしまいます。
ちなみに、メッセージ自体は保存することができます。
個人的にはjob関係がなにか悪いところがあるかと思いました。

コードを載せておきます。

_message.html.erb

<div class="message" id="message-<%= message.id %>">
	<div class="usernameAndTimeBox">
		<% unless message.user_id.nil? %>
			<%= link_to message.username, user_path(message.user_id),class: "message_username" %>
		<% else %>
			<p class="message_username"><%= message.username %></p>
		<% end %>
		<p class="agomessage"><%= time_ago_in_words(message.created_at) + "前" %></p>
	</div>
	<% if user_signed_in? %>
		<% if message.login == true %>
			<%# if message.user_id == current_user.id %>
				<button id="<%= message.id %>" class="delete_btn">削除</button>
			<%# end %>
		<% end %>
	<% end %>
	<%= raw Rinku.auto_link simple_format h(message.content), class: "message_content" %>
	<% unless message.youtube_id.nil? %>
		<% iframe = content_tag(
			:iframe,
			'',
			width: 560,
			height: 315,
			src: "https://www.YouTube.com/embed/#{message.youtube_id}",
			frameborder: 0,
			allowfullscreen: true,
			class: "youtube-container"
		) %>
		<%= content_tag(:div, iframe, class: "youtube-container2") %>
	<% end %>
	<% if message.image? %>
		<%= image_tag message.image.url %>
	<% end %>
<!-- 	<div class="editBox">
		<div class="formchat">
			<%#= form_with model: message, url: message_path(message)  do |f| %>
				<%#= f.rich_text_area :content %>
				<%#= f.submit %>
			<%# end %>
		</div>
	</div> -->
</div>

message_broadcast_job.rb

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

room_channel.js

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(data) {
          // 0.01秒たったら下に移動。
          setTimeout(function(){
            var submitscroll = $('#bottomGO').offset().top;
            $('html, body').scrollTop(submitscroll);
          },10);
          return $('#messages').append(data['message']);

          // Called when there's incoming data on the websocket for this channel
        },

        speak: function(message) {
          return this.perform('speak', {
            message: message
          });
        }
      });
      $(document).on('keypress submit click', '[data-behavior~=room_speaker]', function(event){

          console.log(event.target.value);
          function chatgo(){
               chatChannel.speak(event.target.value);
               event.target.value = '';
               return event.preventDefault();
           }
          if(event.shiftKey){
             if(event.keyCode === 13){
                if(event.target.value != ''){
                  chatgo();
                }else if(event.target.value == '' || event.target.length <= 1000){
                  event.preventDefault();
                  event.target.value = event.target.value;
                }
             }
           }
         $('#submit').click(function(){
            if(event.target.value != ''){
              chatgo();
            }else if(event.target.value == '' || event.target.length <= 1000){
              event.preventDefault();
            }
         });
      });  
  });

message.rb

class Message < ApplicationRecord
	belongs_to :user, optional: true
	belongs_to :room
	# has_rich_text :content
	validates :content, length: {maximum: 1000 }
	after_create_commit { MessageBroadcastJob.perform_later self }
	mount_uploader :image, ImageUploader

	validate :image_size

	private

	def image_size
		if image.size > 5.megabytes
			errors.add(:image, "容量が大きすぎます。5MB未満のファイルにしてください。")
		end
	end
end

次はメッセージを削除するところです。

room_delete_channel.js

import consumer from "./consumer"
$(function(){
    const deleteChannel = consumer.subscriptions.create({channel: "RoomDeleteChannel", 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(data) {
          $('#message-' + data['id']).remove();
          // Called when there's incoming data on the websocket for this channel
      },

      delete: function(id) {
        console.log("idGOGOGO")
        return this.perform('delete', {
          id: id
        });
      }
    });
    $(document).on('click', '.delete_btn', function(event){
        deleteChannel.delete(event.target.id)
        // return event.preventDefault();
    });
});

room_delete_channel.rb

class RoomDeleteChannel < ApplicationCable::Channel
  def subscribed
    stream_from "room_delete_channel"
  end

  def unsubscribed
    # Any cleanup needed when channel is unsubscribed
  end

  def delete(data)
    	ActionCable.server.broadcast 'room_delete_channel', id: data['id']
    	message = Message.find_by(id: data['id'], room_id: params['room'],user_id: current_user.id,login: true)
    	message.destroy
  end
end

current_userとipを扱うためのファイル
connection.rb

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

   　　attr_accessor :ip_addr
  	def connect
  		self.current_user = find_verified_user
     　　　@ip_addr = request.ip
  	end

  	private

  	def find_verified_user
  		session_key = cookies.encrypted[Rails.application.config.session_options[:key]]
  		if session_key['warden.user.user.key'].present?
  			verified_id = session_key['warden.user.user.key'][0][0]
  			verified_user = User.find_by(id: verified_id)
  			return reject_unauthorized_connection unless verified_user
  			verified_user
  		else
  			return false
  		end
  	end
  end
end

追記

ActionCableで、メッセージを保存して、
ActionJobで、再度
ApplicationController.renderer.render

を使って、読み込むのですが、
読み込んだ先のファイルで
user_signed_in?　と　current_userなどの　deiviseが用意しているヘルパーメソッドがエラーで使えなくなりました。

調べたらApplicationController.renderer.renderはenvに直接アクセスすることができないみたいです。

https://www.stefanwienert.de/blog/2016/04/05/using-rails-5-new-renderer-with-authentication-gems-like-clearance-or-devise/

このサイトを参考にして、やってみましたが、うまくいかず

 ActionView::MissingTemplate (Missing template messages/message with {:locale=>[:ja], :formats=>[:html, :text, :js, :css, :ics, :csv, :vcf, :vtt, :png, :jpeg, :gif, :bmp, :tiff, :svg, :mpeg, :mp3, :ogg, :m4a, :webm, :mp4, :otf, :ttf, :woff, :woff2, :xml, :rss, :atom, :yaml, :multipart_form, :url_encoded_form, :json, :pdf, :zip, :gzip], :variants=>[], :handlers=>[:raw, :erb, :html, :builder, :ruby, :jbuilder]}. Searched in:
  * "/home/vagrant/chatapp/app/views"
  * "/home/vagrant/.rbenv/versions/2.6.5/lib/ruby/gems/2.6.0/gems/devise-4.7.1/app/views"
  * 
"/home/vagrant/.rbenv/versions/2.6.5/lib/ruby/gems/2.6.0/gems/actiontext-6.0.3/app/views"
  * "/home/vagrant/.rbenv/versions/2.6.5/lib/ruby/gems/2.6.0/gems/actionmailbox-6.0.3/app/views"
):

が出てしまいました。。。

修正してみたファイルを記述します。
message_broadcast_job.rb

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 })
	   ApplicationController.render_with_signed_in_user(message.user_id, 'messages/message', locals: { message: message })
  end

end

application.controller.rb

    ...
	def self.render_with_signed_in_user(user, *args)
	   ActionController::Renderer::RACK_KEY_TRANSLATION['warden'] ||= 'warden'
	   proxy = Warden::Proxy.new({}, Warden::Manager.new({})).tap{|i| i.set_user(user, scope: :user) }
	   renderer = self.renderer.new('warden' => proxy)
	   puts "====================" + renderer.to_s
	   renderer.render(*args)
	 end
end

Answer 1

application.controller.rbに

	def self.render_with_signed_in_user(user, *args)
	   ActionController::Renderer::RACK_KEY_TRANSLATION['warden'] ||= 'warden'
	   proxy = Warden::Proxy.new({}, Warden::Manager.new({})).tap{|i| i.set_user(user, scope: :user) }
	   renderer = self.renderer.new('warden' => proxy)
	   renderer.render(*args)
	 end

を追加して、
message_broadcast_job.rbに

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 })
     ApplicationController.render_with_signed_in_user(message.user, partial: 'messages/message', locals: { message: message })
    
  end

end

とすることで解決しました。

jobだと、envにアクセスできないので、　application_controller.rbでアクセスできるようにします。

以下参考
https://www.stefanwienert.de/blog/2016/04/05/using-rails-5-new-renderer-with-authentication-gems-like-clearance-or-devise/