use signet-sdk

- align to alloy @ 0.12.6
- transfer off of zenith-rs and use signet-sdk instead

Author: dylanlott

Cargo.toml

@@ -22,11 +22,21 @@ name = "transaction-submitter"
 path = "bin/submit_transaction.rs"
 
 [dependencies]
-init4-bin-base = "0.1.0"
-
-zenith-types = "0.15"
-
-alloy = { version = "=0.11.1", features = ["full", "json-rpc", "signer-aws", "rpc-types-mev", "rlp", "node-bindings"] }
+init4-bin-base = { path = "../bin-base" }
+
+signet-bundle = { git = "https://github.com/init4tech/signet-sdk", branch = "prestwich/update-trevm" }
+signet-types = { git = "https://github.com/init4tech/signet-sdk", branch = "prestwich/update-trevm" }
+signet-zenith = { git = "https://github.com/init4tech/signet-sdk", branch = "prestwich/update-trevm" }
+
+alloy = { version = "0.12.6", features = [
+    "full",
+    "json-rpc",
+    "signer-aws",
+    "rpc-types-mev",
+    "rlp",
+    "node-bindings",
+    "serde",
+] }
 
 aws-config = "1.1.7"
 aws-sdk-kms = "1.15.0"

bin/submit_transaction.rs

@@ -83,7 +83,7 @@ async fn connect_from_config() -> (Provider, Address, u64) {
 
     let provider = ProviderBuilder::new()
         .wallet(EthereumWallet::from(signer))
-        .on_builtin(&rpc_url)
+        .connect(&rpc_url)
         .await
         .unwrap();
 

src/config.rs

@@ -12,7 +12,7 @@ use alloy::{
 };
 use std::{borrow::Cow, env, num, str::FromStr};
 
-use zenith_types::Zenith;
+use signet_zenith::Zenith;
 
 // Keys for .env variables that need to be set to configure the builder.
 const HOST_CHAIN_ID: &str = "HOST_CHAIN_ID";
@@ -207,7 +207,7 @@ impl BuilderConfig {
     /// Connect to the Rollup rpc provider.
     pub async fn connect_ru_provider(&self) -> Result<WalletlessProvider, ConfigError> {
         let provider = ProviderBuilder::new()
-            .on_builtin(&self.ru_rpc_url)
+            .connect(&self.ru_rpc_url)
             .await
             .map_err(ConfigError::Provider)?;
 
@@ -219,7 +219,7 @@ impl BuilderConfig {
         let builder_signer = self.connect_builder_signer().await?;
         let provider = ProviderBuilder::new()
             .wallet(EthereumWallet::from(builder_signer))
-            .on_builtin(&self.host_rpc_url)
+            .connect(&self.host_rpc_url)
             .await
             .map_err(ConfigError::Provider)?;
 
@@ -234,7 +234,7 @@ impl BuilderConfig {
             Vec::with_capacity(self.tx_broadcast_urls.len());
         for url in self.tx_broadcast_urls.iter() {
             let provider =
-                ProviderBuilder::new().on_builtin(url).await.map_err(ConfigError::Provider)?;
+                ProviderBuilder::new().connect(url).await.map_err(ConfigError::Provider)?;
 
             providers.push(provider);
         }

src/tasks/block.rs

@@ -3,7 +3,7 @@ use super::oauth::Authenticator;
 use super::tx_poller::TxPoller;
 use crate::config::{BuilderConfig, WalletlessProvider};
 use alloy::{
-    consensus::{SidecarBuilder, SidecarCoder, TxEnvelope},
+    consensus::{SidecarBuilder, SidecarCoder, transaction::TxEnvelope},
     eips::eip2718::Decodable2718,
     primitives::{B256, Bytes, keccak256},
     providers::Provider as _,
@@ -13,7 +13,8 @@ use std::time::{SystemTime, UNIX_EPOCH};
 use std::{sync::OnceLock, time::Duration};
 use tokio::{sync::mpsc, task::JoinHandle};
 use tracing::{Instrument, debug, error, info, trace};
-use zenith_types::{Alloy2718Coder, ZenithEthBundle, encode_txns};
+use signet_zenith::{Alloy2718Coder, encode_txns};
+use signet_bundle::SignetEthBundle;
 
 /// Ethereum's slot time in seconds.
 pub const ETHEREUM_SLOT_TIME: u64 = 12;
@@ -183,7 +184,7 @@ impl BlockBuilder {
     }
 
     /// Simulates a Zenith bundle against the rollup state
-    async fn simulate_bundle(&mut self, bundle: &ZenithEthBundle) -> eyre::Result<()> {
+    async fn simulate_bundle(&mut self, bundle: &SignetEthBundle) -> eyre::Result<()> {
         // TODO: Simulate bundles with the Simulation Engine
         // [ENG-672](https://linear.app/initiates/issue/ENG-672/add-support-for-bundles)
         debug!(hash = ?bundle.bundle.bundle_hash(), block_number = ?bundle.block_number(), "bundle simulations is not implemented yet - skipping simulation");
@@ -269,7 +270,7 @@ mod tests {
         rpc::types::{TransactionRequest, mev::EthSendBundle},
         signers::local::PrivateKeySigner,
     };
-    use zenith_types::ZenithEthBundle;
+    use signet_bundle::SignetEthBundle;
 
     /// Create a mock bundle for testing with a single transaction
     async fn create_mock_bundle(wallet: &EthereumWallet) -> Bundle {
@@ -294,7 +295,7 @@ mod tests {
             replacement_uuid: Some("replacement_uuid".to_owned()),
         };
 
-        let zenith_bundle = ZenithEthBundle { bundle: eth_bundle, host_fills: None };
+        let zenith_bundle = SignetEthBundle { bundle: eth_bundle, host_fills: None };
 
         Bundle { id: "mock_bundle".to_owned(), bundle: zenith_bundle }
     }

src/tasks/bundler.rs

@@ -6,15 +6,15 @@ use reqwest::Url;
 use serde::{Deserialize, Serialize};
 use tokio::sync::mpsc::{UnboundedReceiver, unbounded_channel};
 use tokio::task::JoinHandle;
-use zenith_types::ZenithEthBundle;
+use signet_bundle::SignetEthBundle;
 
 /// Holds a bundle from the cache with a unique ID and a Zenith bundle.
 #[derive(Debug, Clone, Serialize, Deserialize)]
 pub struct Bundle {
     /// Cache identifier for the bundle
     pub id: String,
     /// The Zenith bundle for this bundle
-    pub bundle: ZenithEthBundle,
+    pub bundle: SignetEthBundle,
 }
 
 /// Response from the tx-pool containing a list of bundles.

src/tasks/submit.rs

@@ -18,14 +18,14 @@ use alloy::{
 use eyre::{bail, eyre};
 use init4_bin_base::deps::metrics::{counter, histogram};
 use oauth2::TokenResponse;
+use signet_types::{SignRequest, SignResponse};
+use signet_zenith::{
+    BundleHelper::{self, BlockHeader, FillPermit2, submitCall},
+    Zenith::IncorrectHostBlock,
+};
 use std::time::Instant;
 use tokio::{sync::mpsc, task::JoinHandle};
 use tracing::{debug, error, instrument, trace};
-use zenith_types::{
-    BundleHelper::{self, FillPermit2},
-    SignRequest, SignResponse,
-    Zenith::IncorrectHostBlock,
-};
 
 macro_rules! spawn_provider_send {
     ($provider:expr, $tx:expr) => {
@@ -127,7 +127,7 @@ impl SubmitTask {
         s: FixedBytes<32>,
         in_progress: &InProgressBlock,
     ) -> eyre::Result<TransactionRequest> {
-        let data = zenith_types::BundleHelper::submitCall { fills, header, v, r, s }.abi_encode();
+        let data = submitCall { fills, header, v, r, s }.abi_encode();
 
         let sidecar = in_progress.encode_blob::<SimpleCoder>().build()?;
         Ok(TransactionRequest::default()
@@ -151,7 +151,7 @@ impl SubmitTask {
     ) -> eyre::Result<ControlFlow> {
         let (v, r, s) = extract_signature_components(&resp.sig);
 
-        let header = zenith_types::BundleHelper::BlockHeader {
+        let header = BlockHeader {
             hostBlockNumber: resp.req.host_block_number,
             rollupChainId: U256::from(self.config.ru_chain_id),
             gasLimit: resp.req.gas_limit,
@@ -167,7 +167,7 @@ impl SubmitTask {
             .with_gas_limit(1_000_000);
 
         if let Err(TransportError::ErrorResp(e)) =
-            self.host_provider.call(&tx).block(BlockNumberOrTag::Pending.into()).await
+            self.host_provider.call(tx.clone()).block(BlockNumberOrTag::Pending.into()).await
         {
             error!(
                 code = e.code,