Closed cryptomatictrader closed 1 month ago
Important Notice
This PR modifies an in-repo Go module. It is one of:
The dependent Go modules, especially the root one, will have to be updated to reflect the changes. Failing to do so might cause e2e to fail.
Please follow the instructions below:
Please let us know if you need any help.
The pull request introduces significant changes to the OsmosisApp
implementation by integrating a new service for node status checking from the commonservice
module. The nodeStatusChecker
variable is updated to use this new service, and method signatures are adjusted accordingly. Additionally, there are modifications to package names, transitioning from commondomain
to domain
in several files, while maintaining existing logic and functionality. New interfaces and structs are introduced, enhancing the overall structure without altering the core behavior of the application.
File Path | Change Summary |
---|---|
app/app.go |
Updated nodeStatusChecker to use commonservice.NewNodeStatusChecker(rpcAddress) ; modified indexerStreamingService initialization to include nodeStatusChecker . |
ingest/common/domain/errors.go |
Changed package name from domain to commondomain . |
ingest/common/domain/block_pools.go |
Changed package name from commondomain to domain . |
ingest/common/domain/block_process_strategy_manager.go |
Changed package name from commondomain to domain . |
ingest/common/domain/block_process_strategy_manager_test.go |
Changed package name from commondomain_test to domain_test . |
ingest/common/domain/block_update_process_utils.go |
Changed package name from commondomain to domain ; added BlockUpdateProcessUtilsI interface and BlockUpdateProcessUtils struct with methods. |
ingest/common/domain/keepers.go |
Changed package name from commondomain to domain . |
ingest/common/domain/pools.go |
Changed package name from commondomain to domain ; corrected method signature typo in PoolExtractor interface. |
ingest/common/domain/process_strategy.go |
Changed package name from commondomain to domain . |
ingest/indexer/service/blockprocessor/full_indexer_block_process_strategy.go |
Added nodeStatusChecker field; modified ProcessBlock to include synchronization checks. |
ingest/indexer/service/indexer_streaming_service.go |
Added nodeStatusChecker field; modified constructor to include this parameter. |
indexerStreamingService
to include filtering logic for token supply data, which could relate to the changes in how node status is managed in the main PR.OsmosisApp
implementation regarding service integrations in the main PR.indexerStreamingService
in the main PR.OsmosisApp
regarding service integrations in the main PR.Thank you for using CodeRabbit. We offer it for free to the OSS community and would appreciate your support in helping us grow. If you find it useful, would you consider giving us a shout-out on your favorite social media?
Closing this PR to avoid some complicated merge issues and also to make running local test easier. Opened this PR to extend this one.
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: