From 8defd5e48a4e1f31d02384bcc6d40772984b7d6f Mon Sep 17 00:00:00 2001
From: Neylix <julien.leclerc05@protonmail.com>
Date: Tue, 13 Feb 2024 17:41:16 +0100
Subject: [PATCH] Fix origin genesis addresses

---
 lib/archethic.ex                           |  5 ++---
 lib/archethic/self_repair/network_chain.ex | 18 ++++++++----------
 2 files changed, 10 insertions(+), 13 deletions(-)

diff --git a/lib/archethic.ex b/lib/archethic.ex
index 1690e790a..c6e257382 100644
--- a/lib/archethic.ex
+++ b/lib/archethic.ex
@@ -25,7 +25,6 @@ defmodule Archethic do
   alias Archethic.SelfRepair
   alias Archethic.SelfRepair.NetworkChain
   alias Archethic.SelfRepair.NetworkView
-  alias Archethic.SharedSecrets
   alias Archethic.TaskSupervisor
   alias Archethic.TransactionChain
   alias Archethic.TransactionChain.Transaction
@@ -99,8 +98,8 @@ defmodule Archethic do
       :ok ->
         true
 
-      {:error, addresses} ->
-        SharedSecrets.genesis_address(:node_shared_secrets) |> SelfRepair.resync(addresses, [])
+      {:error, [{genesis_address, address}]} ->
+        SelfRepair.resync(genesis_address, [address], [])
         false
 
       :error ->
diff --git a/lib/archethic/self_repair/network_chain.ex b/lib/archethic/self_repair/network_chain.ex
index 226d93f35..da08af7c1 100644
--- a/lib/archethic/self_repair/network_chain.ex
+++ b/lib/archethic/self_repair/network_chain.ex
@@ -78,14 +78,14 @@ defmodule Archethic.SelfRepair.NetworkChain do
   def synchronous_resync(type) do
     :telemetry.execute([:archethic, :self_repair, :resync], %{count: 1}, %{network_chain: type})
 
-    genesis_address = get_genesis_address(type)
-
     case verify_synchronization(type) do
       {:error, addresses} when is_list(addresses) ->
         Task.Supervisor.async_stream_nolink(
           Archethic.TaskSupervisor,
           addresses,
-          &SelfRepair.replicate_transaction(&1, genesis_address),
+          fn {genesis_address, address} ->
+            SelfRepair.replicate_transaction(address, genesis_address)
+          end,
           ordered: false,
           on_timeout: :kill_task
         )
@@ -99,7 +99,10 @@ defmodule Archethic.SelfRepair.NetworkChain do
   @doc """
   Verify if the last stored transaction is the last one on the network
   """
-  @spec verify_synchronization(atom()) :: :ok | :error | {:error, list(Crypto.prepended_hash())}
+  @spec verify_synchronization(atom()) ::
+          :ok
+          | :error
+          | {:error, list({Crypto.prepended_hash(), Crypto.prepended_hash()})}
   def verify_synchronization(:origin) do
     genesis_addresses = SharedSecrets.genesis_address(:origin)
 
@@ -129,11 +132,6 @@ defmodule Archethic.SelfRepair.NetworkChain do
     do_verify_synchronization(genesis_address, last_schedule_date)
   end
 
-  defp get_genesis_address(:oracle), do: OracleChain.genesis_address()
-
-  defp get_genesis_address(type) when type in [:origin, :node_shared_secrets],
-    do: SharedSecrets.genesis_address(type)
-
   defp do_verify_synchronization(nil, _), do: :ok
 
   defp do_verify_synchronization(genesis_address, last_schedule_date) do
@@ -167,7 +165,7 @@ defmodule Archethic.SelfRepair.NetworkChain do
            acceptance_resolver: &(&1.timestamp > local_last_address_timestamp)
          ) do
       {:ok, remote_last_address} ->
-        {:error, [remote_last_address]}
+        {:error, [{genesis_address, remote_last_address}]}
 
       {:error, :acceptance_failed} ->
         :ok