将ActionCable与服务对象一起使用并响应消息

问题描述

为这个问题取一个标题非常困难，但是从本质上讲，我在Rails应用程序中有一个服务对象，该对象创建了“继续处理”流程。我正在尝试使用ActionCable将前端与后端连接。我当前的操作方式是在控制器中实例化服务对象：

  def create_from_resume
    ...
    ResumeParseService.new(@candidate,current_user)
  end

然后，我的服务首先广播到我的前端以打开相应的模式：

服务：

class ResumeParseService
  attr_reader :user
  attr_reader :employee
  attr_reader :candidate

  def initialize(candidate,user)
    @user = user
    @employee = user.employee
    @candidate = candidate
    @progress = 0

-->    broadcast_begin
  end

  def begin_from_parse_modal
    broadcast_progress(10)

    parsed_resume = get_a_resume_while_hiding_implementation_details
    broadcast_progress(rand(40..60))

    ...

    broadcast_progress(100 - @progress)

    ...
  end

  private


  def broadcast_begin
    ResumeParseChannel.broadcast_and_set_service(self,user,{
      event_name: 'transition_screen',props: {
        to: 'parse',},})
  end

  def broadcast_progress(addition)
    @progress += addition
    ResumeParseChannel.broadcast_to(user,{
      event_name: 'progress',props: {
        progress: @progress,})
  end

  def broadcast_transition_screen(screen_name,body = nil)
    ResumeParseChannel.broadcast_to(user,props: {
        to: screen_name,data: body,})
  end
end

设置频道：

# frozen_string_literal: true
class ResumeParseChannel < ApplicationCable::Channel

  def subscribed
    stream_for(current_user)
  end

  def unsubscribed
    # Any cleanup needed when channel is unsubscribed
  end

  def self.broadcast_and_set_service(service,*args)
    @service = service
    broadcast_to *args
  end

  def screen_transitioned(data)
    case data['screen_name']
    when 'parse'
      pp @service
      @service.begin_from_parse_modal
    else
      # type code here
    end
  end

  private

  def current_user
    if (current_user = env["warden"].user)
      current_user
    else
      reject_unauthorized_connection
    end
  end
end

然后由我的频道负责。稍后，我的频道将发送回“进度更新”，以让我的服务知道该模式已成功打开： JS频道：

consumer.subscriptions.create(
  { channel: "ResumeParseChannel" },{
    connected() {
      document.addEventListener("resume-parse:screen_transitioned",event =>
-->        this.perform("screen_transitioned",event.detail)
      );
    },}
);

现在，我的问题是，一旦该消息发送回我的（红宝石）频道，我就无法想出一种找到我的服务对象的现有实例并使用它的方法。如您所见，我尝试在频道上设置实例var，并在第一次广播中设置了服务对象实例，但是那（以及其他一百万个）不起作用。一旦获得s​​creen_name为“ parse”的“ screen_transitioned”，我需要调用#begin_from_parse_modal。理想情况下，我想尽可能地将广播逻辑和解析逻辑分开。

我知道可以将频道的实例视为实际的订阅，但是我只是不了解该系统的最佳实践，在该系统中，我可以发送“执行此操作”消息，然后执行某些操作一旦收到“已完成”消息。

如果我错过任何说明和/或代码方面的信息，请通知我。还可以随时告诉我下次我是否应该做一些不同的事情！这是我第一次询问stackoverflow，但这大约是我第十亿次寻找答案：）

编辑：对于这种看似常见的情况，我仍然感到震惊。仅将频道用作服务对象可能是最佳实践吗？如果是这样，我们将如何存储状态？我认为以任何形式工作的唯一可能方法是在每个WS消息中发送完整状态。或至少是状态为每条记录的ID，然后在每条消息上查找每条记录。这似乎是不合理的复杂和昂贵。我搜寻了其他问题，甚至还搜索了ActionCable教程，以找到使用服务对象接收消息的任何人，却一无所获。 SOS！

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）