如何解决将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,并在第一次广播中设置了服务对象实例,但是那(以及其他一百万个)不起作用。一旦获得screen_name为“ parse”的“ screen_transitioned”,我需要调用#begin_from_parse_modal。理想情况下,我想尽可能地将广播逻辑和解析逻辑分开。
我知道可以将频道的实例视为实际的订阅,但是我只是不了解该系统的最佳实践,在该系统中,我可以发送“执行此操作”消息,然后执行某些操作一旦收到“已完成”消息。
如果我错过任何说明和/或代码方面的信息,请通知我。还可以随时告诉我下次我是否应该做一些不同的事情!这是我第一次询问stackoverflow,但这大约是我第十亿次寻找答案:)
编辑:对于这种看似常见的情况,我仍然感到震惊。仅将频道用作服务对象可能是最佳实践吗?如果是这样,我们将如何存储状态?我认为以任何形式工作的唯一可能方法是在每个WS消息中发送完整状态。或至少是状态为每条记录的ID,然后在每条消息上查找每条记录。这似乎是不合理的复杂和昂贵。我搜寻了其他问题,甚至还搜索了ActionCable教程,以找到使用服务对象接收消息的任何人,却一无所获。 SOS!
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。