для того, чтобы ловить события не попадающие в текущую стадию

делаю вызов TaskFsm.sendInfo(id, [task: "reset", msg: nil])

но в handle_event процесс не попадает

а пытается найти соответсвующую вызову finish

которой нет

и падает

потому что у тебя должен быть определен catch-all finish/3, который вызывает handle_event

о_О

http://erlang.org/doc/design_principles/statem.html#id73802

а если у меня там 10 шагов? мне 10 таких определять?

ну, да

Со state_functions - так, поэтому handle_event_function появился.

можешь макрос запилить

шляпа...

типа, catch_all_states [:finish, :start, :pause], который генерит тебе форварды в handle_event/3

хотя проще, конечно, их руками написать

и если у тебя fsm на 10 стейтов, я тебе искренне сочувствую

Такую фичу лучше сразу на уровне контрибьюта в библиотеку делать.

с макросами у меня не очень, но придётся видать освоить, так как переписывать все на handle_event долго и как-то не очень

Хотя event_function удобнее уже тем, что можно на разные состояния мэтчить, если одно и тоже действие для нескольких стейтов нужно сделать.

угу, следующие на нём запилю, останется что-то придумать с текущими...

Я домой вернусь, попробую кое-что.

Сделать с макросами.

Ребят, вопрос: Кто-нибудь прикручивал в Elixir справочник адресов ФИАС или КЛАДР? есть готовое решение?

@midster хотелось бы уточнить, что вставить в else: def check_exchanges_connections() do current_time = :os.system_time(:milli_seconds) :ets.tab2list(:trade_timestamps) |> Enum.each(fn trade_timestamp -> {stream_name, last_data_timestamp} = trade_timestamp if current_time - last_data_timestamp > 60_000 do Nadia.send_message(Application.get_env(:nadia, :chat_id), "Stream #{stream_name} - last data recieved #{current_time - last_data_timestamp} ms ago") end end) {:ok} end

def check_exchanges_connections() do current_timestamp = :os.system_time(:milli_seconds) :ets.tab2list(:trade_timestamps) |> Enum.each(fn {stream_name, last_timestamp} -> case (current_timestamp - last_timestamp) do diff when diff > 60_000 -> Nadia.send_message(Application.get_env(:nadia, :chat_id), "Stream #{stream_name} - last data recieved #{diff} ms ago") _ -> {:error, {:too_early, stream_name}} end end) {:ok} end

def check_exchanges_connections() do current_timestamp = :os.system_time(:milli_seconds) :ets.tab2list(:trade_timestamps) |> Enum.each(fn {stream_name, last_timestamp} -> case (current_timestamp - last_timestamp) do diff when diff > 60_000 -> Nadia.send_message(Application.get_env(:nadia, :chat_id), "Stream #{stream_name} - last data recieved #{diff} ms ago") _ -> {:error, {:too_early, stream_name}} end end) {:ok} end

Результаты enum.each не сохраняются и никуда не передаются

Результаты enum.each не сохраняются и никуда не передаются

это пока

да и вообще это не важно

сохраняются они или нет

и {:ok} тоже надо убрать

Что за бред? Supervisor.start_link( [ worker(Cachex, [ :my_cache, [] ]) ] ) Насколько я понимаю, это устаревший вариант запуска дочернего воркера. А как по-современному это переписать?

{Cachex, [ :my_cache, []]} - это если Cachex имплементирует child_spec-callback.

В мастере не поддерживает, так что пока не получится.

{Cachex, [ :my_cache, []]} - это если Cachex имплементирует child_spec-callback.

нихрена он не имплементирует, в итоге юзается некий дефолтный и в start_link так прямо и пихается [ :my_cache, []]. а start_link ожидает два аргумента: имя кеша и список опций.

и как эту жопу обойти?

вручную, короче сделать чайлд спек и пихнуть супервизору

идиотизм

да и вообще это не важно

Как не важно, важно. В данном случае обработка отлично от интересующего результата высосана из пальца

То есть ты дописал код в котором нет ценности

Он не делает ничего полезного

Наоборот он заставляет думать что что-то в случае элс произойдет

А это не так

То есть помимо своей бесполезности он еще и вводит в заблуждение

То есть помимо своей бесполезности он еще и вводит в заблуждение

да какие вопросы не пиши так и все! никто же не заставляет ?

че пристали с этим else

идиотизм

Вы слишком много кушали!

Вы слишком много кушали!

???

типа культурное "зажрались"?

ну на самом деле устарело это хз когда, но никто так и не удосужился сделать нормальный child_spec

я бы сам сделал, но недостаточно компетентен

ГенСерверу при инициализации можно задать значение, которое будет константным между вызовами?

можно пример, а то не очень понятен вопрос в принципе?

ребят подскажите нормальный HTTP client, чет httpoison со своим hackney прям боль

ГенСерверу при инициализации можно задать значение, которое будет константным между вызовами?

в супервизор же в чилдспеке принимает MFA, почему бы там не передать константу, а потом положить её в стейт?

ребят подскажите нормальный HTTP client, чет httpoison со своим hackney прям боль

а чем плох то?

во, стейт кажется то что нужно

только я понимаю как он задается при старте, а как его потом доставать?

только я понимаю как он задается при старте, а как его потом доставать?

прочитай про genserver в принципе, там всё довольно просто

https://hexdocs.pm/elixir/GenServer.html#module-example

принципиально доку не читаем, да? вроде этот пример же про то что надо

при старте инициализируем, в хендлере вынимаем

спасибо

а чем плох то?

отказываеться работать собака )

отказываеться работать собака )

может сталкивался 14:22:31.973 [error] Task #PID<6862.2283.0> started from #PID<6862.2282.0> terminating ** (FunctionClauseError) no function clause matching in :hackney_url.transport_scheme/1 /var/www/app/edeliver_builds/deps/hackney/src/hackney_url.erl:109: :hackney_url.transport_scheme(:hackney_http_connect) /var/www/app/edeliver_builds/deps/hackney/src/hackney.erl:859: :hackney.absolute_url/2 /var/www/app/edeliver_builds/deps/hackney/src/hackney.erl:712: :hackney.maybe_redirect/2 /var/www/app/edeliver_builds/deps/hackney/src/hackney.erl:362: :hackney.send_request/2 lib/httpoison/base.ex:439: HTTPoison.Base.request/9 lib/movie_web/release_tasks.ex:703: MovieWeb.ReleaseTasks.request/2 lib/movie_web/release_tasks.ex:142: anonymous fn/2 in MovieWeb.ReleaseTasks.import_movies/0 lib/ecto/adapters/sql.ex:576: anonymous fn/3 in Ecto.Adapters.SQL.do_transaction/3

отказываеться работать собака )

а как испульзуешь то его?

а как испульзуешь то его?

дергаю html страницу через прокси

дергаю html страницу через прокси

не сочти меня грубым, но ты код пишешь то?

гист скинь

чтобы было понятно, как ты его используешь

я использовал hackney и он работал

я использовал hackney и он работал

да походу вот моя трабла https://github.com/benoitc/hackney/issues/376

я у себя follow_redirect: false ставил, и руками смотрел есть ли редирект в ответе

я у себя follow_redirect: false ставил, и руками смотрел есть ли редирект в ответе

а как-то поймать можно если ест ьредирект?

урлов просто много) руками смотреть каждый не вариант

а как-то поймать можно если ест ьредирект?

case HTTPoison.request(:get, String.to_charlist(url), "", header, options) do {:ok, %HTTPoison.Response{headers: resp_header, status_code: status_code}} when status_code > 300 and status_code < 400 -> тут вытаскивает из хидеров location и идем по нему

как то так у меня

как то так у меня

у меня значит чет не то case HTTPoison.get(url, ["User-Agent": Enum.random(@user_agents)], [proxy: proxy, follow_redirect: true, ssl: [{:versions, [:'tlsv1.2']}] ])

follow_redirect: true же у тебя

попробую переписать, чтобы ловить редиректы, как в твоем примере

спасибо

Я раньше тоже httpoison использовал, потом понял что юнит-тестить его сложновато и перешёл на tesla

Я раньше тоже httpoison использовал, потом понял что юнит-тестить его сложновато и перешёл на tesla

а чем сложно?

есть какбы отдельные клиент и сервер, общающиеся по джсон-апи, нужно было юнит-тестить клиент, я сделал сервер-заглушку на плаге, но такое решение было забраковано тим-лидом, потому что слушает tcp-порт, а на тесле получилось просто и без головной боли

В любом случае ты что-то мокаешь

В httpoison есть exvcr

Которым все пользуются и не имеют проблем

Самое крутое, что можно раз в неделю подкинуть реальный ключ и обновить кассеты

Даже если api связано с бабками