Как я могу вызвать метод канала в контроллере рельсов?

Получение определенного экземпляра канала из контроллера

Экземпляры Channel связаны с Connection пользователя. Следующее будет работать, чтобы получить хэш Channels для Connection:

conn = ActionCable.server.connections.first { |c| c.current_user == user_id }

# subs is a hash where the keys are json identifiers and the values are Channels
subs = conn.subscriptions.instance_variable_get("@subscriptions")

(Если Connection#current_user не существует, следуйте инструкциям в верхней части раздела 3.1.1 из обзор Rails ActionCable, чтобы добавить его.)

Затем вы можете получить Channel на основе любых критериев, которые вы хотите. Например, вы можете искать по типу, который в вашем случае будет MsgsChannel. Можно также использовать ключ json в subs, но это может быть сложнее.

Получив этот экземпляр, вы можете вызвать для него любой метод (в вашем случае MsgsChannel#subscribe).

Опасения по поводу этого подхода

Channel просто инкапсулирует работу на стороне сервера, которая будет запускаться в ответ на сообщения с клиентской стороны приложения. Вызов сервером метода Channel фактически означает, что сервер делает вид, что потребитель отправил сообщение, которое он не отправлял.

Я бы рекомендовал вместо этого помещать любую логику, которую вы хотите использовать как из Controller, так и из Channel, в метод в общем месте. Затем Controller и Channel могут напрямую вызывать этот метод по мере необходимости.

При этом есть одно болезненное предостережение, которое заключается в том, что вам нужно Channel для вызова stream_from. К сожалению, управление потоками специфично для Channels, хотя по сути это просто обновление информации pubsub для Server.

Я думаю, что управление потоком действительно должно требовать соответствующего соединения и Server с его pubsub. Если бы это было так, вам не нужно было бы беспокоиться о вызове Channel методов со стороны сервера приложения.

Вы сможете эффективно запускать stream_for более непосредственно, если вы получите Channel, любое Channel (вы также можете использовать subs из верхней части этого ответа) и вызовете stream_for на нем.

conn = ActionCable.server.connections.first { |c| c.current_user == user_id }
MsgsChannel.new(conn, "made up id").stream_from "your_stream_name"

Я не пробовал это сам, но похоже, что это должно работать.

Таким образом, вы не должны подписывать пользователя на канал в контроллере при создании. Это должно быть основано на том, когда они посещают страницу. Вы должны изменить, где пользователи подключаются, добавив файл js/coffe, чтобы сделать это за вас в зависимости от того, кто подключен. Хорошим примером/учебником для этого, когда я учился, было это видео здесь.

В видео не упоминается, как подключиться к индивидуальному разговору. Поэтому я боролся с этим и нашел способ получить идентификатор разговора из URL-адреса, возможно, не лучший способ, но он работает. Надеюсь это поможет

conversation_id = parseInt(document.URL.match(new RegExp("conversations/"+ "(.*)"))[1]) # gets the conversation id from the url of the page

App.conversation = App.cable.subscriptions.create { channel: "ConversationChannel", conversation_id: conversation_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) ->
    $('#messages').append data['message']

  speak: (message) ->
    @perform 'speak', message: message