fix CI dependency issues and Phoenix.PubSub configuration

Author: InvalidPathException

.github/workflows/ci.yml

@@ -38,20 +38,22 @@ jobs:
         elixir-version: ${{ env.ELIXIR_VERSION }}
         otp-version: ${{ env.OTP_VERSION }}
 
-    - name: Restore dependencies cache
-      uses: actions/cache@v4
-      with:
-        path: |
-          deps
-          _build
-        key: ${{ runner.os }}-mix-otp28-${{ hashFiles('**/mix.lock') }}
-        restore-keys: ${{ runner.os }}-mix-otp28-
-    
+    # Temporarily disabled cache to ensure clean builds
+    # - name: Restore dependencies cache
+    #   uses: actions/cache@v4
+    #   with:
+    #     path: |
+    #       deps
+    #       _build
+    #     key: ${{ runner.os }}-mix-otp28-${{ hashFiles('**/mix.lock') }}
+    #     restore-keys: ${{ runner.os }}-mix-otp28-
+
     - name: Install dependencies
       run: |
         mix local.hex --force
         mix local.rebar --force
         mix deps.get
+        mix deps.compile
     
     - name: Check formatting
       run: mix format --check-formatted

apps/kafkaesque_core/lib/kafkaesque/core/application.ex

@@ -8,7 +8,7 @@ defmodule Kafkaesque.Core.Application do
     children = [
       {Registry, keys: :unique, name: Kafkaesque.TopicRegistry},
       {DynamicSupervisor, name: Kafkaesque.TopicSupervisor, strategy: :one_for_one},
-      {Phoenix.PubSub, name: Kafkaesque.PubSub},
+      {Phoenix.PubSub, name: Kafkaesque.PubSub, adapter: Phoenix.PubSub.PG2},
       Kafkaesque.Telemetry.Supervisor
     ]
 

apps/kafkaesque_core/test/pipeline/produce_broadway_test.exs

@@ -45,15 +45,21 @@ defmodule Kafkaesque.Pipeline.ProduceBroadwayTest do
           max_queue_size: 100
         )
 
-      assert {:ok, pid} =
-               ProduceBroadway.start_link(
-                 topic: @test_topic,
-                 partition: @test_partition,
-                 batch_size: 10,
-                 batch_timeout: 1
-               )
+      result =
+        ProduceBroadway.start_link(
+          topic: @test_topic,
+          partition: @test_partition,
+          batch_size: 10,
+          batch_timeout: 1
+        )
 
-      assert Process.alive?(pid)
+      case result do
+        {:ok, pid} ->
+          assert Process.alive?(pid)
+
+        {:error, {:already_started, pid}} ->
+          assert Process.alive?(pid)
+      end
     end
   end
 

apps/kafkaesque_core/test/support/test_case.ex

@@ -48,7 +48,7 @@ defmodule Kafkaesque.TestCase do
       nil ->
         # Not running, start it
         children = [
-          {Phoenix.PubSub, name: Kafkaesque.PubSub}
+          {Phoenix.PubSub, name: Kafkaesque.PubSub, adapter: Phoenix.PubSub.PG2}
         ]
 
         case Supervisor.start_link(children, strategy: :one_for_one, name: KafkaesqueTestPubSub) do