Multiple winners in autopilot

crates/autopilot/src/arguments.rs

@@ -227,6 +227,11 @@ pub struct Arguments {
     /// before continuing the run loop.
     #[clap(long, env, default_value = "2s", value_parser = humantime::parse_duration)]
     pub max_run_loop_delay: Duration,
+
+    #[clap(long, env, default_value = "1")]
+    /// The maximum number of winners per auction. Each winner will be allowed
+    /// to settle their winning orders at the same time.
+    pub max_winners_per_auction: usize,
 }
 
 impl std::fmt::Display for Arguments {
@@ -271,6 +276,7 @@ impl std::fmt::Display for Arguments {
             cow_amm_configs,
             run_loop_mode,
             max_run_loop_delay,
+            max_winners_per_auction,
         } = self;
 
         write!(f, "{}", shared)?;
@@ -345,6 +351,7 @@ impl std::fmt::Display for Arguments {
         writeln!(f, "cow_amm_configs: {:?}", cow_amm_configs)?;
         writeln!(f, "run_loop_mode: {:?}", run_loop_mode)?;
         writeln!(f, "max_run_loop_delay: {:?}", max_run_loop_delay)?;
+        writeln!(f, "max_winners_per_auction: {:?}", max_winners_per_auction)?;
         Ok(())
     }
 }

crates/autopilot/src/run.rs

@@ -544,6 +544,7 @@ pub async fn run(args: Arguments) {
         synchronization: args.run_loop_mode,
         max_run_loop_delay: args.max_run_loop_delay,
         maintenance: Arc::new(maintenance),
+        max_winners_per_auction: args.max_winners_per_auction,
     };
     run.run_forever(args.auction_update_interval).await;
     unreachable!("run loop exited");
@@ -618,6 +619,7 @@ async fn shadow_mode(args: Arguments) -> ! {
         liveness.clone(),
         args.run_loop_mode,
         current_block,
+        args.max_winners_per_auction,
     );
     shadow.run_forever().await;
 

crates/autopilot/src/run_loop.rs

@@ -55,6 +55,7 @@ pub struct RunLoop {
     /// allowed to start before it has to re-synchronize to the blockchain
     /// by waiting for the next block to appear.
     pub max_run_loop_delay: Duration,
+    pub max_winners_per_auction: usize,
     /// Maintenance tasks that should run before every runloop to have
     /// the most recent data available.
     pub maintenance: Arc<Maintenance>,

crates/autopilot/src/shadow.rs

@@ -38,9 +38,11 @@ pub struct RunLoop {
     liveness: Arc<Liveness>,
     synchronization: RunLoopMode,
     current_block: CurrentBlockWatcher,
+    _max_winners_per_auction: usize,
 }
 
 impl RunLoop {
+    #[allow(clippy::too_many_arguments)]
     pub fn new(
         orderbook: infra::shadow::Orderbook,
         drivers: Vec<infra::Driver>,
@@ -49,6 +51,7 @@ impl RunLoop {
         liveness: Arc<Liveness>,
         synchronization: RunLoopMode,
         current_block: CurrentBlockWatcher,
+        _max_winners_per_auction: usize,
     ) -> Self {
         Self {
             orderbook,
@@ -60,6 +63,7 @@ impl RunLoop {
             liveness,
             synchronization,
             current_block,
+            _max_winners_per_auction,
         }
     }