Write transaction to specific genesis address

lib/archethic/db.ex

@@ -16,7 +16,9 @@ defmodule Archethic.DB do
               opts :: [paging_state: nil | binary(), after: DateTime.t()]
             ) :: Enumerable.t()
   @callback write_transaction(Transaction.t()) :: :ok
+  @callback write_transaction_at(Transaction.t(), binary()) :: :ok
   @callback write_transaction_chain(Enumerable.t()) :: :ok
+  @callback write_transaction(Transaction.t()) :: :ok
   @callback list_transactions(fields :: list()) :: Enumerable.t()
   @callback add_last_transaction_address(binary(), binary(), DateTime.t()) :: :ok
   @callback list_last_transaction_addresses() :: Enumerable.t()

lib/archethic/db/embedded_impl.ex

@@ -78,6 +78,15 @@ defmodule Archethic.DB.EmbeddedImpl do
     end
   end
 
+  @doc """
+  Write a transaction if a specific genesis address
+  """
+  @spec write_transaction_at(Transaction.t(), binary()) :: :ok
+  def write_transaction_at(tx = %Transaction{}, genesis_address)
+      when is_binary(genesis_address) do
+    ChainWriter.append_transaction(genesis_address, tx)
+  end
+
   @doc """
   Determine if the transaction exists or not
   """

lib/archethic/transaction_chain.ex

@@ -126,6 +126,20 @@ defmodule Archethic.TransactionChain do
     )
   end
 
+  @doc """
+  Write the transaction in a specific genesis address
+  """
+  @spec writer_transaction_at(Transaction.t(), binary()) :: :ok
+  def write_transaction_at(tx = %Transaction{address: address, type: type}, genesis_address) do
+    DB.write_transaction_at(tx, genesis_address)
+    KOLedger.remove_transaction(address)
+
+    Logger.info("Transaction stored",
+      transaction_address: Base.encode16(address),
+      transaction_type: type
+    )
+  end
+
   @doc """
   Persist a new transaction chain
   """