refactor: remove dead code

The dispatcher doesn't use the history foldable because this code was
reimplemented in the authority-claimer service.

offchain/dispatcher/src/dispatcher.rs

@@ -4,9 +4,10 @@
 use eth_state_client_lib::StateServer;
 use eth_state_fold_types::{Block, BlockStreamItem};
 use rollups_events::DAppMetadata;
+use std::sync::Arc;
 use tokio_stream::StreamExt;
 use tracing::{error, instrument, trace, warn};
-use types::foldables::authority::rollups::{RollupsInitialState, RollupsState};
+use types::foldables::{InputBox, InputBoxInitialState};
 
 use crate::{
     config::DispatcherConfig,
@@ -57,19 +58,15 @@ pub async fn start(
             .into(),
     );
 
-    let initial_state = RollupsInitialState {
-        history_address: config
-            .blockchain_config
-            .history_address
-            .clone()
-            .into_inner()
-            .into(),
-        input_box_address: config
-            .blockchain_config
-            .input_box_address
-            .clone()
-            .into_inner()
-            .into(),
+    let initial_state = InputBoxInitialState {
+        input_box_address: Arc::new(
+            config
+                .blockchain_config
+                .input_box_address
+                .clone()
+                .into_inner()
+                .into(),
+        ),
     };
 
     trace!("Creating context");
@@ -136,10 +133,10 @@ async fn process_block(
     block: &Block,
 
     state_server: &impl StateServer<
-        InitialState = RollupsInitialState,
-        State = RollupsState,
+        InitialState = InputBoxInitialState,
+        State = InputBox,
     >,
-    initial_state: &RollupsInitialState,
+    initial_state: &InputBoxInitialState,
 
     context: &mut Context,
     machine_driver: &mut MachineDriver,
@@ -155,7 +152,7 @@ async fn process_block(
     // Drive machine
     trace!("Reacting to state with `machine_driver`");
     machine_driver
-        .react(context, &state.block, &state.state.input_box, broker)
+        .react(context, &state.block, &state.state, broker)
         .await
         .context(BrokerSnafu)?;
 

offchain/dispatcher/src/drivers/context.rs

@@ -7,7 +7,7 @@ use crate::{
 };
 
 use rollups_events::DAppMetadata;
-use types::foldables::input_box::Input;
+use types::foldables::Input;
 
 #[derive(Debug)]
 pub struct Context {

offchain/dispatcher/src/drivers/machine.rs

@@ -6,7 +6,7 @@ use super::Context;
 use crate::machine::{rollups_broker::BrokerFacadeError, BrokerSend};
 
 use eth_state_fold_types::{ethereum_types::Address, Block};
-use types::foldables::input_box::{DAppInputBox, Input, InputBox};
+use types::foldables::{DAppInputBox, Input, InputBox};
 
 use tracing::{debug, instrument, trace};
 
@@ -234,7 +234,7 @@ mod tests {
             rollup_status,
         );
         let machine_driver = MachineDriver::new(H160::random());
-        let dapp_input_box = types::foldables::input_box::DAppInputBox {
+        let dapp_input_box = types::foldables::DAppInputBox {
             inputs: input_timestamps
                 .iter()
                 .map(|timestamp| Arc::new(mock::new_input(*timestamp)))

offchain/dispatcher/src/drivers/mock.rs

@@ -14,7 +14,7 @@ use std::{
     ops::{Deref, DerefMut},
     sync::{Arc, Mutex},
 };
-use types::foldables::input_box::{DAppInputBox, Input, InputBox};
+use types::foldables::{DAppInputBox, Input, InputBox};
 
 use crate::machine::{
     rollups_broker::BrokerFacadeError, BrokerSend, BrokerStatus, RollupStatus,

offchain/dispatcher/src/machine/mod.rs

@@ -3,7 +3,7 @@
 
 pub mod rollups_broker;
 
-use types::foldables::input_box::Input;
+use types::foldables::Input;
 
 use async_trait::async_trait;
 

offchain/dispatcher/src/machine/rollups_broker.rs

@@ -10,7 +10,7 @@ use rollups_events::{
     RollupsAdvanceStateInput, RollupsData, RollupsInput, RollupsInputsStream,
     INITIAL_ID,
 };
-use types::foldables::input_box::Input;
+use types::foldables::Input;
 
 use super::{BrokerSend, BrokerStatus, RollupStatus};
 
@@ -290,7 +290,7 @@ mod broker_facade_tests {
     };
     use test_fixtures::broker::BrokerFixture;
     use testcontainers::clients::Cli;
-    use types::foldables::input_box::Input;
+    use types::foldables::Input;
 
     use crate::machine::{
         rollups_broker::BrokerFacadeError, BrokerSend, BrokerStatus,

offchain/dispatcher/src/setup.rs

@@ -10,7 +10,7 @@ use rollups_events::DAppMetadata;
 use snafu::{ensure, ResultExt};
 use tokio_stream::{Stream, StreamExt};
 use tonic::transport::Channel;
-use types::foldables::authority::{RollupsInitialState, RollupsState};
+use types::foldables::{InputBox, InputBoxInitialState};
 
 use crate::{
     config::DispatcherConfig,
@@ -28,7 +28,7 @@ const BUFFER_LEN: usize = 256;
 pub async fn create_state_server(
     config: &SCConfig,
 ) -> Result<
-    impl StateServer<InitialState = RollupsInitialState, State = RollupsState>
+    impl StateServer<InitialState = InputBoxInitialState, State = InputBox>
         + BlockServer,
     DispatcherError,
 > {

offchain/state-server/src/main.rs

@@ -2,7 +2,7 @@
 // SPDX-License-Identifier: Apache-2.0 (see LICENSE)
 mod config;
 use config::Config;
-use types::foldables::authority::rollups::RollupsState;
+use types::foldables::InputBox;
 
 #[tokio::main]
 async fn main() -> Result<(), Box<dyn std::error::Error>> {
@@ -12,7 +12,7 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
 
     log::log_service_start(&config, "State Server");
 
-    state_server::run_server::<RollupsState>(config.state_server_config)
+    state_server::run_server::<InputBox>(config.state_server_config)
         .await
         .map_err(|e| e.into())
 }