fix Phoenix.PubSub test setup and update Elixir to 1.18

Author: InvalidPathException

apps/kafkaesque_client/mix.exs

@@ -9,7 +9,7 @@ defmodule KafkaesqueClient.MixProject do
       config_path: "../../config/config.exs",
       deps_path: "../../deps",
       lockfile: "../../mix.lock",
-      elixir: "~> 1.17",
+      elixir: "~> 1.18",
       elixirc_paths: elixirc_paths(Mix.env()),
       start_permanent: Mix.env() == :prod,
       aliases: aliases(),

apps/kafkaesque_core/mix.exs

@@ -9,7 +9,7 @@ defmodule KafkaesqueCore.MixProject do
       config_path: "../../config/config.exs",
       deps_path: "../../deps",
       lockfile: "../../mix.lock",
-      elixir: "~> 1.17",
+      elixir: "~> 1.18",
       elixirc_paths: elixirc_paths(Mix.env()),
       start_permanent: Mix.env() == :prod,
       aliases: aliases(),

apps/kafkaesque_core/test/pipeline/produce_broadway_test.exs

@@ -67,13 +67,15 @@ defmodule Kafkaesque.Pipeline.ProduceBroadwayTest do
           max_queue_size: 100
         )
 
-      {:ok, _pid} =
-        ProduceBroadway.start_link(
-          topic: @test_topic,
-          partition: @test_partition,
-          batch_size: 5,
-          batch_timeout: 1
-        )
+      case ProduceBroadway.start_link(
+             topic: @test_topic,
+             partition: @test_partition,
+             batch_size: 5,
+             batch_timeout: 1
+           ) do
+        {:ok, _pid} -> :ok
+        {:error, {:already_started, _pid}} -> :ok
+      end
 
       :ok
     end
@@ -266,13 +268,15 @@ defmodule Kafkaesque.Pipeline.ProduceBroadwayTest do
           max_queue_size: 100
         )
 
-      {:ok, _pid} =
-        ProduceBroadway.start_link(
-          topic: @test_topic,
-          partition: @test_partition,
-          batch_size: 5,
-          batch_timeout: 1
-        )
+      case ProduceBroadway.start_link(
+             topic: @test_topic,
+             partition: @test_partition,
+             batch_size: 5,
+             batch_timeout: 1
+           ) do
+        {:ok, _pid} -> :ok
+        {:error, {:already_started, _pid}} -> :ok
+      end
 
       :ok
     end

apps/kafkaesque_core/test/support/test_case.ex

@@ -20,7 +20,10 @@ defmodule Kafkaesque.TestCase do
   setup do
     # Start required registries and services
     ensure_registry_started()
-    ensure_pubsub_started()
+    # Only start PubSub if the application isn't already managing it
+    unless Application.started_applications() |> Enum.any?(fn {app, _, _} -> app == :kafkaesque_core end) do
+      ensure_pubsub_started()
+    end
     ensure_telemetry_started()
 
     :ok
@@ -40,12 +43,23 @@ defmodule Kafkaesque.TestCase do
   Ensures PubSub is started.
   """
   def ensure_pubsub_started do
-    case Phoenix.PubSub.Supervisor.start_link(
-           name: Kafkaesque.PubSub,
-           adapter: Phoenix.PubSub.PG2
-         ) do
-      {:ok, _} -> :ok
-      {:error, {:already_started, _}} -> :ok
+    # Check if PubSub is already running
+    case Process.whereis(Kafkaesque.PubSub) do
+      nil ->
+        # Not running, start it
+        children = [
+          {Phoenix.PubSub, name: Kafkaesque.PubSub}
+        ]
+
+        case Supervisor.start_link(children, strategy: :one_for_one, name: KafkaesqueTestPubSub) do
+          {:ok, _} -> :ok
+          {:error, {:already_started, _}} -> :ok
+          {:error, {:shutdown, {:failed_to_start_child, Phoenix.PubSub, {:already_started, _}}}} -> :ok
+        end
+
+      _pid ->
+        # Already running
+        :ok
     end
   end
 

apps/kafkaesque_core/test/topic/supervisor_test.exs

@@ -14,9 +14,14 @@ defmodule Kafkaesque.Topic.SupervisorTest do
     Application.put_env(:kafkaesque_core, :offsets_dir, Path.join(test_dir, "offsets"))
 
     # Start the topic supervisor if not already started
-    case TopicSupervisor.start_link([]) do
-      {:ok, pid} -> {:ok, pid}
-      {:error, {:already_started, pid}} -> {:ok, pid}
+    case Process.whereis(TopicSupervisor) do
+      nil ->
+        case TopicSupervisor.start_link([]) do
+          {:ok, pid} -> {:ok, pid}
+          {:error, {:already_started, pid}} -> {:ok, pid}
+        end
+      pid ->
+        {:ok, pid}
     end
 
     on_exit(fn ->

apps/kafkaesque_dashboard/mix.exs

@@ -9,7 +9,7 @@ defmodule KafkaesqueDashboard.MixProject do
       config_path: "../../config/config.exs",
       deps_path: "../../deps",
       lockfile: "../../mix.lock",
-      elixir: "~> 1.17",
+      elixir: "~> 1.18",
       elixirc_paths: elixirc_paths(Mix.env()),
       start_permanent: Mix.env() == :prod,
       aliases: aliases(),

apps/kafkaesque_server/mix.exs

@@ -9,7 +9,7 @@ defmodule KafkaesqueServer.MixProject do
       config_path: "../../config/config.exs",
       deps_path: "../../deps",
       lockfile: "../../mix.lock",
-      elixir: "~> 1.17",
+      elixir: "~> 1.18",
       elixirc_paths: elixirc_paths(Mix.env()),
       start_permanent: Mix.env() == :prod,
       aliases: aliases(),