From e2a2c0f575f665986f963aebb43e776897f830fa Mon Sep 17 00:00:00 2001 From: Chase Pursley Date: Wed, 10 Jan 2024 13:23:00 -0500 Subject: [PATCH] Change supervisor strategy. Other improvements. --- lib/walex/config/registry.ex | 2 +- lib/walex/decoder/decoder.ex | 2 +- lib/walex/destinations/supervisor.ex | 2 +- lib/walex/replication/supervisor.ex | 2 +- mix.exs | 1 - 5 files changed, 4 insertions(+), 5 deletions(-) diff --git a/lib/walex/config/registry.ex b/lib/walex/config/registry.ex index e4f1ca9..5dbd681 100644 --- a/lib/walex/config/registry.ex +++ b/lib/walex/config/registry.ex @@ -22,6 +22,6 @@ defmodule WalEx.Config.Registry do defp set_name(module, app_name), do: {:via, Registry, {@walex_registry, {module, app_name}}} def get_state(:get_agent, module, app_name) do - Agent.get({:via, Registry, {:walex_registry, {module, app_name}}}, & &1) + Agent.get({:via, Registry, {@walex_registry, {module, app_name}}}, & &1) end end diff --git a/lib/walex/decoder/decoder.ex b/lib/walex/decoder/decoder.ex index 289b7b5..9a599f6 100755 --- a/lib/walex/decoder/decoder.ex +++ b/lib/walex/decoder/decoder.ex @@ -204,7 +204,7 @@ defmodule WalEx.Decoder do defp decode_message_impl(<<"Y", data_type_id::integer-32, namespace_and_name::binary>>) do [namespace, name_with_null] = :binary.split(namespace_and_name, <<0>>) - name = String.slice(name_with_null, 0..-2) + name = String.slice(name_with_null, 0..-2//1) %Type{ id: data_type_id, diff --git a/lib/walex/destinations/supervisor.ex b/lib/walex/destinations/supervisor.ex index 439de18..0cc91c2 100644 --- a/lib/walex/destinations/supervisor.ex +++ b/lib/walex/destinations/supervisor.ex @@ -27,7 +27,7 @@ defmodule WalEx.Destinations.Supervisor do |> maybe_webhooks(app_name) |> maybe_event_relay(app_name) - Supervisor.init(children, strategy: :one_for_all) + Supervisor.init(children, strategy: :one_for_one, max_restarts: 10) end defp maybe_event_modules(children, app_name) do diff --git a/lib/walex/replication/supervisor.ex b/lib/walex/replication/supervisor.ex index b39a7f7..e31e805 100755 --- a/lib/walex/replication/supervisor.ex +++ b/lib/walex/replication/supervisor.ex @@ -24,6 +24,6 @@ defmodule WalEx.Replication.Supervisor do {Server, app_name: app_name} ] - Supervisor.init(children, strategy: :one_for_all) + Supervisor.init(children, strategy: :one_for_one, max_restarts: 10) end end diff --git a/mix.exs b/mix.exs index b2d606c..1112272 100644 --- a/mix.exs +++ b/mix.exs @@ -33,7 +33,6 @@ defmodule WalEx.MixProject do {:decimal, "~> 2.1.1"}, {:ex_doc, "~> 0.31.0", only: :dev, runtime: false}, {:jason, "~> 1.4"}, - {:retry, "~> 0.18.0"}, {:timex, "~> 3.7"}, {:req, "~> 0.4.8"}, {:uniq, "~> 0.6.1"},