diff --git a/sql/proof_chain_mbase_result.sql b/sql/proof_chain_mbase_result.sql index bae225b..684a39b 100644 --- a/sql/proof_chain_mbase_result.sql +++ b/sql/proof_chain_mbase_result.sql @@ -11,7 +11,7 @@ session_started_events AS ( JOIN chain_moonbeam_moonbase_alpha.block_transactions trx ON (trx.block_id = session_started.block_id AND trx.tx_offset = session_started.tx_offset) WHERE - session_started.sender = '\xeFD84B6F1C04Ad9A7D666E21C9608a2ea2FE4B83'::bytea + session_started.sender = '\x06A38f70c8e245e1cfe1b7d5ACa1B7cd29380343'::bytea AND session_started.topics @> ARRAY[ '\x8b1f889addbfa41db5227bae3b091bd5c8b9a9122f874dfe54ba2f75aabe1f4c'::bytea ] @@ -28,7 +28,7 @@ result_reward_awarded_events AS ( JOIN chain_moonbeam_moonbase_alpha.block_transactions trx_1 ON (trx_1.block_id = fin.block_id AND trx_1.tx_offset = fin.tx_offset) WHERE - fin.sender = '\xeFD84B6F1C04Ad9A7D666E21C9608a2ea2FE4B83'::bytea + fin.sender = '\x06A38f70c8e245e1cfe1b7d5ACa1B7cd29380343'::bytea AND fin.topics @> ARRAY['\x93dcf9329a330cb95723152c05719560f2fbd50e215c542854b27acc80c9108d'::bytea] AND trx_1.successful = TRUE AND fin.block_id >= '1910104892088990000'::bigint @@ -43,7 +43,7 @@ result_quorum_not_reached_events AS ( JOIN chain_moonbeam_moonbase_alpha.block_transactions trx_1 ON (trx_1.block_id = fin.block_id AND trx_1.tx_offset = fin.tx_offset) WHERE - fin.sender = '\xeFD84B6F1C04Ad9A7D666E21C9608a2ea2FE4B83'::bytea + fin.sender = '\x06A38f70c8e245e1cfe1b7d5ACa1B7cd29380343'::bytea AND fin.topics @> ARRAY['\x31d16d882c6405d327fa305ecf0d52b45154868e0828822533fd2547f4b21a75'::bytea] AND trx_1.successful = TRUE AND fin.block_id >= '1910104892088990000'::bigint @@ -67,6 +67,6 @@ LEFT JOIN all_finalization_events afe ON ( sse.origin_chain_id = afe.origin_chain_id AND sse.origin_chain_block_height = afe.origin_chain_block_height ) -WHERE sse.origin_chain_block_height > 17374020::numeric +WHERE sse.origin_chain_block_height > 17635725::numeric ORDER BY sse.observer_chain_block_id ASC, sse.observer_chain_tx_offset ASC ; diff --git a/src/dbmanresult.py b/src/dbmanresult.py index 43f344e..c8efc74 100644 --- a/src/dbmanresult.py +++ b/src/dbmanresult.py @@ -80,7 +80,7 @@ def __main_loop(self): # we are catching up. So we only need to grab what we need to attempt for finalizing if self.chain_table == "chain_moonbeam_moonbase_alpha": cur.execute( - r'SELECT * FROM chain_moonbeam_moonbase_alpha."_proof_chain_result_events" WHERE observer_chain_session_start_block_id > %s AND observer_chain_finalization_tx_hash IS NULL AND origin_chain_block_height > 17388735;', + r'SELECT * FROM chain_moonbeam_moonbase_alpha."_proof_chain_result_events" WHERE observer_chain_session_start_block_id > %s AND observer_chain_finalization_tx_hash IS NULL AND origin_chain_block_height > 17635725;', (self.last_block_id,), ) else: @@ -103,7 +103,7 @@ def __main_loop(self): # we need everything after last max block number if self.chain_table == "chain_moonbeam_moonbase_alpha": cur.execute( - r'SELECT * FROM chain_moonbeam_moonbase_alpha."_proof_chain_result_events" WHERE observer_chain_session_start_block_id > %s AND origin_chain_block_height > 17388735;', + r'SELECT * FROM chain_moonbeam_moonbase_alpha."_proof_chain_result_events" WHERE observer_chain_session_start_block_id > %s AND origin_chain_block_height > 17635725;', (self.last_block_id,), ) else: