Do not call MailJet functions outside tests where mailjet is tested

config/test.exs

@@ -51,6 +51,10 @@ config :sanbase, Sanbase.EventBus.KafkaExporterSubscriber,
   can_send_after_interval: 0,
   kafka_flush_timeout: 0
 
+config :sanbase, Sanbase.EventBus.MetricRegistrySubscriber,
+  metric_registry_change_handler:
+    {Sanbase.EventBus.MetricRegistrySubscriber, :on_metric_registry_change_test_env}
+
 config :sanbase, Sanbase.ExternalServices.RateLimiting.Server,
   implementation_module: Sanbase.ExternalServices.RateLimiting.TestServer
 

lib/sanbase/event_bus/metric_registry_subscriber.ex

@@ -5,6 +5,7 @@ defmodule Sanbase.EventBus.MetricRegistrySubscriber do
   use GenServer
 
   alias Sanbase.Utils.Config
+
   require Logger
 
   def topics(), do: ["metric_registry_events"]
@@ -51,6 +52,13 @@ defmodule Sanbase.EventBus.MetricRegistrySubscriber do
     :ok
   end
 
+  def on_metric_registry_change_test_env(event_type, metric) do
+    # In test env this is the handler in order to avoid Ecto DBConnection
+    # ownership errors
+    Logger.warning("Metric Registry Change - Event Type: #{event_type}, Metric: #{metric}")
+    :ok
+  end
+
   defp handle_event(
          %{data: %{event_type: event_type, metric: metric}} = event,
          event_shadow,

lib/sanbase/event_bus/user_events_subscriber.ex

@@ -98,7 +98,6 @@ defmodule Sanbase.EventBus.UserEventsSubscriber do
        ) do
     email = Sanbase.Accounts.get_user!(user_id).email
     if email, do: Sanbase.Email.MailjetApi.client().subscribe(:metric_updates, email)
-
     EventBus.mark_as_completed({__MODULE__, event_shadow})
     state
   end

test/sanbase/alerts/trending_words/trigger_trending_words_send_at_predefiend_time_test.exs

@@ -126,9 +126,12 @@ defmodule Sanbase.Alert.TriggerTrendingWordsSendAtPredefiendTimeTest do
       get_currently_trending_words: fn _, _ ->
         {:ok, top_words()}
       end do
-      assert capture_log(fn ->
-               Sanbase.Alert.Scheduler.run_alert(TrendingWordsTriggerSettings)
-             end) =~
+      log =
+        capture_log(fn ->
+          Sanbase.Alert.Scheduler.run_alert(TrendingWordsTriggerSettings)
+        end)
+
+      assert log =~
                "In total 1/1 trending_words alerts were sent successfully"
 
       {:ok, ut} = UserTrigger.by_user_and_id(context.user.id, context.trigger_trending_words.id)

test/sanbase/metric_registry/change_suggestion_test.exs

@@ -4,6 +4,8 @@ defmodule Sanbase.MetricRegisty.ChangeSuggestionTest do
   alias Sanbase.Metric.Registry
   alias Sanbase.Metric.Registry.ChangeSuggestion
 
+  @moduletag capture_log: true
+
   test "creating a change suggestion" do
     assert {:ok, metric} = Sanbase.Metric.Registry.by_name("price_usd_5m", "timeseries")
 

test/sanbase/metric_registry/metric_registry_test.exs

@@ -2,33 +2,7 @@ defmodule Sanbase.MetricRegistyTest do
   use Sanbase.DataCase
   import ExUnit.CaptureLog
 
-  defmodule Handler do
-    require Logger
-
-    def on_metric_registry_change(event_type, metric) do
-      Logger.info("Metric Registry Change - Event Type: #{event_type}, Metric: #{metric}")
-      :ok
-    end
-  end
-
-  setup do
-    env = Application.get_env(:sanbase, Sanbase.EventBus.MetricRegistrySubscriber, [])
-
-    new_env =
-      Keyword.put(env, :metric_registry_change_handler, {Handler, :on_metric_registry_change})
-
-    Application.put_env(:sanbase, Sanbase.EventBus.MetricRegistrySubscriber, new_env)
-
-    on_exit(fn ->
-      Application.put_env(:sanbase, Sanbase.EventBus.MetricRegistrySubscriber, env)
-    end)
-
-    %{}
-  end
-
   test "creating a new metric" do
-    Logger.configure(level: :info)
-
     log =
       capture_log(fn ->
         assert {:ok, result} =
@@ -55,16 +29,12 @@ defmodule Sanbase.MetricRegistyTest do
         Process.sleep(50)
       end)
 
-    Logger.configure(level: :warning)
-
     assert log =~ "Metric Registry Change - Event Type: create_metric_registry, Metric: my_metric"
   end
 
   test "updating a metric" do
     assert {:ok, metric} = Sanbase.Metric.Registry.by_name("price_usd_5m", "timeseries")
 
-    Logger.configure(level: :info)
-
     log =
       capture_log(fn ->
         assert {:ok, updated} =
@@ -82,8 +52,6 @@ defmodule Sanbase.MetricRegistyTest do
         Process.sleep(50)
       end)
 
-    Logger.configure(level: :warning)
-
     assert log =~
              "Metric Registry Change - Event Type: update_metric_registry, Metric: price_usd_5m"
   end

test/sanbase/notifications/notification_actions_test.exs

@@ -8,6 +8,8 @@ defmodule Sanbase.Notifications.NotificationActionsTest do
   alias Sanbase.Repo
 
   setup do
+    Application.put_env(:sanbase, :mailjet_mocked, true)
+    on_exit(fn -> Application.put_env(:sanbase, :mailjet_mocked, false) end)
     create_default_templates()
     :ok
   end

test/sanbase_web/graphql/metric/api_metric_metadata_test.exs

@@ -50,8 +50,7 @@ defmodule SanbaseWeb.Graphql.ApiMetricMetadataTest do
 
       assert Enum.all?(
                metadata["availableSelectors"],
-               &Enum.member?(
-                 [
+               &(&1 in [
                    "ADDRESS",
                    "BLOCKCHAIN_ADDRESS",
                    "BLOCKCHAIN",
@@ -68,9 +67,7 @@ defmodule SanbaseWeb.Graphql.ApiMetricMetadataTest do
                    "SOURCE",
                    "TEXT",
                    "TOKEN_ID"
-                 ],
-                 &1
-               )
+                 ])
              )
 
       assert Enum.all?(