Skip to content

Commit

Permalink
Don't remove expired quotes after every auction
Browse files Browse the repository at this point in the history
  • Loading branch information
MartinquaXD committed Jan 23, 2025
1 parent a6b8f42 commit 77224d2
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 17 deletions.
21 changes: 5 additions & 16 deletions crates/autopilot/src/maintenance.rs
Original file line number Diff line number Diff line change
@@ -1,13 +1,10 @@
use {
crate::{
boundary::events::settlement::{GPv2SettlementContract, Indexer},
database::{
onchain_order_events::{
ethflow_events::{EthFlowData, EthFlowDataForDb},
event_retriever::CoWSwapOnchainOrdersContract,
OnchainOrderParser,
},
Postgres,
database::onchain_order_events::{
ethflow_events::{EthFlowData, EthFlowDataForDb},
event_retriever::CoWSwapOnchainOrdersContract,
OnchainOrderParser,
},
event_updater::EventUpdater,
},
Expand All @@ -31,23 +28,16 @@ pub struct Maintenance {
settlement_indexer: EventUpdater<Indexer, GPv2SettlementContract>,
/// Indexes ethflow orders (orders selling native ETH).
ethflow_indexer: Option<EthflowIndexer>,
/// Used for periodic cleanup tasks to not have the DB overflow with old
/// data.
db_cleanup: Postgres,
/// All indexing tasks to keep cow amms up to date.
cow_amm_indexer: Vec<Arc<dyn Maintaining>>,
/// On which block we last ran an update successfully.
last_processed: Mutex<BlockInfo>,
}

impl Maintenance {
pub fn new(
settlement_indexer: EventUpdater<Indexer, GPv2SettlementContract>,
db_cleanup: Postgres,
) -> Self {
pub fn new(settlement_indexer: EventUpdater<Indexer, GPv2SettlementContract>) -> Self {
Self {
settlement_indexer,
db_cleanup,
cow_amm_indexer: Default::default(),
ethflow_indexer: None,
last_processed: Default::default(),
Expand Down Expand Up @@ -88,7 +78,6 @@ impl Maintenance {
"settlement_indexer",
self.settlement_indexer.run_maintenance()
),
Self::timed_future("db_cleanup", self.db_cleanup.run_maintenance()),
Self::timed_future("ethflow_indexer", self.index_ethflow_orders()),
)?;

Expand Down
2 changes: 1 addition & 1 deletion crates/autopilot/src/run.rs
Original file line number Diff line number Diff line change
Expand Up @@ -473,7 +473,7 @@ pub async fn run(args: Arguments) {
let trusted_tokens =
AutoUpdatingTokenList::from_configuration(market_makable_token_list_configuration).await;

let mut maintenance = Maintenance::new(settlement_event_indexer, db.clone());
let mut maintenance = Maintenance::new(settlement_event_indexer);
maintenance.with_cow_amms(&cow_amm_registry);

if let Some(ethflow_contract) = args.ethflow_contract {
Expand Down

0 comments on commit 77224d2

Please sign in to comment.