Promotes the node status checker from sqs level to common level, so that it is used by both sqs and indexer ingesters.
Modifies the fullIndexerBlockProcessStrategy in indexer such that it delays the publishing of token supplies and pool pair data until the node sync finishes (i.e., when catch up is false).
Adds test cases for the full_indexer_block_process_strategy::ProcessBlock function:
When the node has caught up and is no longer syncing:
Publishes the correct number of token supplies and offsets.
Publishes the correct number of pool pairs, along with the expected number of pools with creation data.
Returns an error if it fails to verify the node's syncing status.
When the node is still syncing:
Returns an error, and no data should be published.
This commit:
sqs
level tocommon
level, so that it is used by bothsqs
andindexer
ingesters.fullIndexerBlockProcessStrategy
in indexer such that it delays the publishing of token supplies and pool pair data until the node sync finishes (i.e., whencatch up
is false).full_indexer_block_process_strategy::ProcessBlock
function: