1.4.8 upgrade

lib/archethic/account/mem_tables/state_ledger.ex

@@ -10,7 +10,7 @@ defmodule Archethic.Account.MemTables.StateLedger do
   alias Archethic.TransactionChain.Transaction.ValidationStamp.LedgerOperations.VersionedUnspentOutput
 
   use GenServer
-  @vsn 1
+  @vsn 2
 
   require Logger
 
@@ -88,4 +88,20 @@ defmodule Archethic.Account.MemTables.StateLedger do
     :ets.new(@ledger_table, [:set, :named_table, :public, read_concurrency: true])
     {:ok, :no_state}
   end
+
+  # add timestamp in the ETS table
+  def code_change(1, state, _extra) do
+    elements =
+      :ets.tab2list(@ledger_table)
+      |> Enum.map(fn {address, encoded_payload, protocol_version} ->
+        {address, encoded_payload, nil, protocol_version}
+      end)
+
+    # since it's a set it will override them
+    :ets.insert(@ledger_table, elements)
+
+    {:ok, state}
+  end
+
+  def code_change(_version, state, _extra), do: {:ok, state}
 end

lib/archethic/beacon_chain/subset.ex

@@ -37,7 +37,7 @@ defmodule Archethic.BeaconChain.Subset do
   alias Archethic.Utils
 
   use GenServer
-  @vsn 1
+  @vsn 2
 
   require Logger
 
@@ -99,6 +99,28 @@ defmodule Archethic.BeaconChain.Subset do
      }}
   end
 
+  # update the TransactionSummary in memory
+  def code_change(1, state, _extra) do
+    state =
+      update_in(
+        state,
+        [Access.key!(:current_slot), Access.key!(:transaction_attestations)],
+        fn attestations ->
+          Enum.map(
+            attestations,
+            fn attestation = %ReplicationAttestation{transaction_summary: summary} ->
+              %ReplicationAttestation{
+                attestation
+                | transaction_summary: Map.put(summary, :genesis_address, nil)
+              }
+            end
+          )
+        end
+      )
+
+    {:ok, state}
+  end
+
   def code_change(_, state, _extra), do: {:ok, state}
 
   def handle_call(:get_current_slot, _from, state = %{current_slot: current_slot}) do

lib/archethic/beacon_chain/subset/summary_cache.ex

@@ -6,6 +6,7 @@ defmodule Archethic.BeaconChain.Subset.SummaryCache do
   alias Archethic.BeaconChain
   alias Archethic.BeaconChain.Slot
   alias Archethic.BeaconChain.SummaryTimer
+  alias Archethic.BeaconChain.ReplicationAttestation
   alias Archethic.Crypto
 
   alias Archethic.PubSub
@@ -14,7 +15,7 @@ defmodule Archethic.BeaconChain.Subset.SummaryCache do
   alias Archethic.Utils.VarInt
 
   use GenServer
-  @vsn 1
+  @vsn 2
 
   @table_name :archethic_summary_cache
 
@@ -39,6 +40,38 @@ defmodule Archethic.BeaconChain.Subset.SummaryCache do
     {:ok, %{}}
   end
 
+  # update the TransactionSummary in memory
+  def code_change(1, state, _extra) do
+    # credo:disable-for-lines:26
+    elements =
+      :ets.tab2list(@table_name)
+      |> Enum.map(fn {subset, {slot, node_public_key}} ->
+        slot =
+          Map.update!(
+            slot,
+            :transaction_attestations,
+            fn attestations ->
+              Enum.map(
+                attestations,
+                fn attestation = %ReplicationAttestation{transaction_summary: summary} ->
+                  %ReplicationAttestation{
+                    attestation
+                    | transaction_summary: Map.put(summary, :genesis_address, nil)
+                  }
+                end
+              )
+            end
+          )
+
+        {subset, {slot, node_public_key}}
+      end)
+
+    :ets.delete_all_objects(@table_name)
+    :ets.insert(@table_name, elements)
+
+    {:ok, state}
+  end
+
   def code_change(_version, state, _extra), do: {:ok, state}
 
   def handle_info(:self_repair_sync, state) do

lib/archethic/self_repair/repair_worker.ex

@@ -7,7 +7,7 @@ defmodule Archethic.SelfRepair.RepairWorker do
   alias Archethic.SelfRepair.NotifierSupervisor
 
   use GenServer, restart: :transient
-  @vsn 1
+  @vsn 2
 
   require Logger
 
@@ -102,6 +102,15 @@ defmodule Archethic.SelfRepair.RepairWorker do
 
   def handle_info(_, data), do: {:noreply, data}
 
+  # add the genesis_address to the state
+  def code_change(1, state, _extra) do
+    [genesis_address] = Registry.keys(RepairRegistry, self())
+    state = Map.put(state, :genesis_address, genesis_address)
+    {:ok, state}
+  end
+
+  def code_change(_version, state, _extra), do: {:ok, state}
+
   defp start_repair(
          data = %{
            storage_addresses: [],

mix.exs

@@ -4,7 +4,7 @@ defmodule Archethic.MixProject do
   def project do
     [
       app: :archethic,
-      version: "1.4.7",
+      version: "1.4.8-rc1",
       build_path: "_build",
       config_path: "config/config.exs",
       deps_path: "deps",

priv/migration_tasks/prod/1.4.8@aeip_21-1.exs

@@ -75,11 +75,12 @@ defmodule Migration_1_4_8 do
             do: fetch_transaction(last_chain_address, authorized_nodes),
             else: nil
 
-        unless TransactionChain.transaction_exists?(last_chain_address) do
-          Replication.sync_transaction_chain(last_transaction, genesis_address, authorized_nodes,
-            self_repair: true
-          )
-        end
+          if not is_nil(last_transaction) && not TransactionChain.transaction_exists?(last_chain_address) do
+            Replication.sync_transaction_chain(last_transaction, genesis_address, authorized_nodes,
+              self_repair: true
+            )
+          end
+
 
         inputs = fetch_transaction_inputs(last_chain_address, authorized_nodes)
 

rel/appups/archethic/1.0.7_to_1.1.0.appup

@@ -631,7 +631,7 @@
                   'Elixir.Archethic.SelfRepair',
                   'Elixir.Archethic.SharedSecrets',
                   'Elixir.Archethic.TransactionChain']},
-    
+
     {load_module,'Elixir.Archethic.DB.EmbeddedImpl',brutal_purge,soft_purge,
                  ['Elixir.Archethic.DB.EmbeddedImpl.BootstrapInfo',
                   'Elixir.Archethic.DB.EmbeddedImpl.ChainIndex',
@@ -2075,5 +2075,3 @@
     {add_module,'Elixir.Archethic.Contracts.Interpreter.TransactionStatements'},
     {add_module,'Elixir.Archethic.Contracts.Interpreter.Utils'},
     {add_module,'Elixir.Archethic.P2P.Message.ReplicateTransactionChain'}]}]}.
-
-