From 0876cc624d6ea5733acb1a4a0d1307a364dfde44 Mon Sep 17 00:00:00 2001 From: Samuel Date: Fri, 25 Feb 2022 16:35:36 +0100 Subject: [PATCH] Fix notification of new transaction --- lib/archethic/pub_sub.ex | 15 --------------- lib/archethic_web/live/chains/beacon_live.ex | 2 +- 2 files changed, 1 insertion(+), 16 deletions(-) diff --git a/lib/archethic/pub_sub.ex b/lib/archethic/pub_sub.ex index 0c1576091..92d893328 100644 --- a/lib/archethic/pub_sub.ex +++ b/lib/archethic/pub_sub.ex @@ -15,7 +15,6 @@ defmodule ArchEthic.PubSub do alias ArchEthic.PubSubRegistry alias ArchEthic.TransactionChain.Transaction - alias ArchEthic.TransactionChain.TransactionSummary @doc """ Notify the registered processes than a new transaction has been validated @@ -73,13 +72,6 @@ defmodule ArchEthic.PubSub do dispatch(:next_summary_time, {:next_summary_time, date}) end - @doc """ - Notify added new transaction summary in subset to the subscribers - """ - def notify_added_new_transaction_summary(tx_summary = %TransactionSummary{}) do - dispatch(:added_new_transaction_summary, {:added_new_transaction_summary, tx_summary}) - end - @doc """ Notify next epoch of slot time """ @@ -162,13 +154,6 @@ defmodule ArchEthic.PubSub do Registry.register(PubSubRegistry, :next_summary_time, []) end - @doc """ - Register a process to added new transaction summary to beacon chain slot - """ - def register_to_added_new_transaction_summary do - Registry.register(PubSubRegistry, :added_new_transaction_summary, []) - end - @doc """ Register a process to sent current epoch of slot time """ diff --git a/lib/archethic_web/live/chains/beacon_live.ex b/lib/archethic_web/live/chains/beacon_live.ex index eca453491..074a45be9 100644 --- a/lib/archethic_web/live/chains/beacon_live.ex +++ b/lib/archethic_web/live/chains/beacon_live.ex @@ -36,8 +36,8 @@ defmodule ArchEthicWeb.BeaconChainLive do if connected?(socket) do PubSub.register_to_next_summary_time() # register for client to able to get the current added transaction to the beacon pool - PubSub.register_to_added_new_transaction_summary() PubSub.register_to_current_epoch_of_slot_time() + PubSub.register_to_new_replication_attestations() end beacon_dates =