This are the minimum changes to reproduce the invalid signature error

Author: rodrigo-o

lib/lambda_ethereum_consensus/beacon/clock.ex

@@ -18,9 +18,6 @@ defmodule LambdaEthereumConsensus.Beacon.Clock do
     GenServer.start_link(__MODULE__, opts, name: __MODULE__)
   end
 
-  @spec get_current_time() :: Types.uint64()
-  def get_current_time(), do: GenServer.call(__MODULE__, :get_current_time)
-
   ##########################
   ### GenServer Callbacks
   ##########################
@@ -38,11 +35,6 @@ defmodule LambdaEthereumConsensus.Beacon.Clock do
      }}
   end
 
-  @impl true
-  def handle_call(:get_current_time, _from, %{time: time} = state) do
-    {:reply, time, state}
-  end
-
   @impl true
   def handle_info(:on_tick, state) do
     schedule_next_tick()

lib/lambda_ethereum_consensus/fork_choice/fork_choice.ex

@@ -119,7 +119,7 @@ defmodule LambdaEthereumConsensus.ForkChoice do
 
   @spec get_current_chain_slot() :: Types.slot()
   def get_current_chain_slot() do
-    time = Clock.get_current_time()
+    time = :os.system_time(:second)
     genesis_time = StoreDb.fetch_genesis_time!()
     compute_current_slot(time, genesis_time)
   end

lib/lambda_ethereum_consensus/validator/validator.ex

@@ -255,7 +255,7 @@ defmodule LambdaEthereumConsensus.Validator do
     log_debug(validator.index, "publishing attestation", log_md)
 
     Gossip.Attestation.publish(subnet_id, attestation)
-    |> log_debug_result(validator.index, "published attestation", log_md)
+    |> log_info_result(validator.index, "published attestation", log_md)
 
     if current_duty.should_aggregate? do
       log_debug(validator.index, "collecting for future aggregation", log_md)

lib/lambda_ethereum_consensus/validator/validator_manager.ex

@@ -59,14 +59,20 @@ defmodule LambdaEthereumConsensus.Validator.ValidatorManager do
 
   # TODO: The use of a Genserver and cast is still needed to avoid locking at the clock level.
   # This is a temporary solution and will be taken off in a future PR.
-  defp notify_validators(msg), do: GenServer.cast(__MODULE__, {:notify_all, msg})
+  defp notify_validators(msg), do: GenServer.call(__MODULE__, {:notify_all, msg})
 
   def handle_cast({:notify_all, msg}, validators) do
     validators = notify_all(validators, msg)
 
     {:noreply, validators}
   end
 
+  def handle_call({:notify_all, msg}, _from, validators) do
+    validators = notify_all(validators, msg)
+
+    {:reply, :ok, validators}
+  end
+
   defp notify_all(validators, msg) do
     start_time = System.monotonic_time(:millisecond)
 

lib/libp2p_port.ex

@@ -226,7 +226,7 @@ defmodule LambdaEthereumConsensus.Libp2pPort do
       direction: "elixir->"
     })
 
-    call_command(pid, {:publish, %Publish{topic: topic_name, message: message}})
+    cast_command(pid, {:publish, %Publish{topic: topic_name, message: message}})
   end
 
   @doc """
@@ -243,7 +243,7 @@ defmodule LambdaEthereumConsensus.Libp2pPort do
 
     GenServer.cast(pid, {:new_subscriber, topic_name, module})
 
-    call_command(pid, {:subscribe, %SubscribeToTopic{name: topic_name}})
+    cast_command(pid, {:subscribe, %SubscribeToTopic{name: topic_name}})
   end
 
   @doc """

network_params.yaml

@@ -2,11 +2,11 @@ participants:
   - el_type: geth
     cl_type: lighthouse
     count: 2
-    validator_count: 32
+    validator_count: 27
   - el_type: geth
     cl_type: lambda
     cl_image: lambda_ethereum_consensus:latest
     use_separate_vc: false
     count: 1
-    validator_count: 32
+    validator_count: 10
     cl_max_mem: 4096