Как обрабатывать сообщения от другого процесса, чтобы они отправлялись по каналу Elixir Phoenix

У меня есть каналы, отлично работающие на основе документов, и мое приложение получает и ретранслировать сообщения, как ожидалось:

введите описание изображения здесь

Вот код, который обрабатывает канал:

defmodule HelloWeb.RoomChannel do
  use Phoenix.Channel

  def join("room:lobby", _message, socket) do
    {:ok, socket}
  end
  def join("room:" <> _private_room_id, _params, _socket) do
    {:error, %{reason: "unauthorized"}}
  end

  def handle_in("new_msg", %{"body" => body}, socket) do
    broadcast!(socket, "new_msg", %{body: body})
    {:noreply, socket}
  end
end

Однако на самом деле я действительно хочу отправлять сообщения по этому каналу Phoenix, которые поступают из другого процесса Elixir (который, как правило, подписывается на сторонний API через веб-сокеты). Поэтому всякий раз, когда я получаю сообщение веб-сокета от процесса стороннего обработчика, я хочу отправить это сообщение в этот RoomChannel модуль и заставить его отправить сообщение по каналу в браузер.

Как мне это сделать? Есть ли обработчик handle_info в стиле GenServer, который я могу написать, который будет прослушивать входящие сообщения в RoomChannel и отправлять их по каналу Phoenix?

Или мне как-то нужно отправить сокет Phoenix на другой GenServer, чтобы обработать его там?


person Thomas Browne    schedule 08.03.2021    source источник


Ответы (1)


Phoenix.Channel не является GenServer сам по себе, он использует _ 3_ внизу, но имитирует поведение GenServer. Это не показано в основной документации учебника, но вы можете найти его, просмотрев ссылку:

Phoenix.Channel.handle_info/2.

person Aleksei Matiushkin    schedule 08.03.2021