Добрый день

Elixir-новичкам помогают тут?


Имею на erlang+cowboy рабочее приложение подменяющее асинхронное взаимодействие синхронным:

1. принял запрос с фронт устройства/браузера X в cowboy
2. отправил http-запрос во внешнюю систему Y, получил в ответе ref
3. сохранил PID-коннекта с X и ref от Y в ETS-таблице {ref_from_y, pid_from_x}
4. через cowboy_loop handler вывешиваю соединение(=процесс X) для ожидания ответа от внешней системы Y

5. Внешняя система Y шлет в cowboy http-запрос с ref
6. В ETS по ref ищу  PID-процесса который держит коннект с устройством X
7. шлю сообщение в указанный процесс PID ! {some_msg_fromY} на фронт/устройство

Есть задача перейти на Elixir/Phoenix.

Вопрос: какой инструмент/модуль Elixir/Phonenix использовать для построения такого взаимодействия?

Почитал про Task/Agent/Job/Flow  - ни один не подходит. Все равно приходится ETS + Process.send использовать как в erlang ... В какую сторону копать?

в фениксе(и plug в целом) всё очень печально с асинхронными хэндлерами.
если не вдаваться в подробности, я бы рекомендовал либо использовать голый ковбой, либо запатчить plug на проброс и обработку implementation-specific возвратов из хэндлера, позволяющих даунгрейд до голого ковбоя.

Добрый день

Elixir-новичкам помогают тут?


Имею на erlang+cowboy рабочее приложение подменяющее асинхронное взаимодействие синхронным:

1. принял запрос с фронт устройства/браузера X в cowboy
2. отправил http-запрос во внешнюю систему Y, получил в ответе ref
3. сохранил PID-коннекта с X и ref от Y в ETS-таблице {ref_from_y, pid_from_x}
4. через cowboy_loop handler вывешиваю соединение(=процесс X) для ожидания ответа от внешней системы Y

5. Внешняя система Y шлет в cowboy http-запрос с ref
6. В ETS по ref ищу  PID-процесса который держит коннект с устройством X
7. шлю сообщение в указанный процесс PID ! {some_msg_fromY} на фронт/устройство

Есть задача перейти на Elixir/Phoenix.

Вопрос: какой инструмент/модуль Elixir/Phonenix использовать для построения такого взаимодействия?

Почитал про Task/Agent/Job/Flow  - ни один не подходит. Все равно приходится ETS + Process.send использовать как в erlang ... В какую сторону копать?

в next_fun - как я уже сказал, receive.

def get(url) do
    Stream.resource(

      #start_fun
      fn -> 
        HTTPoison.get!(
           url,  %{}, 
           [stream_to: self(), async: :once]
        ) 
      end,
      #---------------------
      #next_fun

      fn %HTTPoison.AsyncResponse{id: id}=resp ->
    receive do
      %HTTPoison.AsyncStatus{id: ^id, code: code}->
        IO.inspect(code, label: "Status code: ")
        {:halt, resp}
    after
      5_000 -> raise "receive timeout"
    end,

     end_fun #todo

    )
  end
end

вот пример.  но тут синхронный ответ от внешнего апи просто передается в next_fn

а в моем случае взаимодействие с внешней системой асинхронное. то есть после start_fun я лишь получаю ref. А позже внешняя система по этому ref сделает callback request на мое приложение. То есть pid полученный в start_fn никак не связан с next_fn (

когда ExtAPI сделает callback request в мое приложение то непонятно как это попадет в блок receive? по ref_from_ext_api полученному ранее...

для оборачивания кода можно использовать тройные апострофы

для оборачивания кода можно использовать тройные апострофы

Бэктики, не знаю как по русски

Добрый день

Elixir-новичкам помогают тут?


Имею на erlang+cowboy рабочее приложение подменяющее асинхронное взаимодействие синхронным:

1. принял запрос с фронт устройства/браузера X в cowboy
2. отправил http-запрос во внешнюю систему Y, получил в ответе ref
3. сохранил PID-коннекта с X и ref от Y в ETS-таблице {ref_from_y, pid_from_x}
4. через cowboy_loop handler вывешиваю соединение(=процесс X) для ожидания ответа от внешней системы Y

5. Внешняя система Y шлет в cowboy http-запрос с ref
6. В ETS по ref ищу  PID-процесса который держит коннект с устройством X
7. шлю сообщение в указанный процесс PID ! {some_msg_fromY} на фронт/устройство

Есть задача перейти на Elixir/Phoenix.

Вопрос: какой инструмент/модуль Elixir/Phonenix использовать для построения такого взаимодействия?

Почитал про Task/Agent/Job/Flow  - ни один не подходит. Все равно приходится ETS + Process.send использовать как в erlang ... В какую сторону копать?