add max fee for first tx

committer/src/config.rs

@@ -70,6 +70,7 @@ pub struct Eth {
     /// This is a workaround to get pending transactions unstuck until the tx manager task is
     /// complete.
     pub max_fee_per_gas_for_first_tx: Option<u64>,
+    pub max_priority_fee_per_gas_for_first_tx: Option<u64>,
 }
 
 fn parse_url<'de, D>(deserializer: D) -> Result<Url, D::Error>

committer/src/setup.rs

@@ -199,6 +199,10 @@ pub async fn l1_adapter(
         internal_config.eth_errors_before_unhealthy,
         aws_client,
         config.eth.max_fee_per_gas_for_first_tx.map(Into::into),
+        config
+            .eth
+            .max_priority_fee_per_gas_for_first_tx
+            .map(Into::into),
     )
     .await?;
 

e2e/src/eth_node/state_contract.rs

@@ -27,7 +27,7 @@ impl DeployedContract {
         let aws_client = AwsClient::new(AwsConfig::for_testing(key.url).await).await;
 
         let chain_state_contract =
-            WebsocketClient::connect(url, address, key.id, blob_wallet, 5, aws_client, None)
+            WebsocketClient::connect(url, address, key.id, blob_wallet, 5, aws_client, None, None)
                 .await?;
 
         Ok(Self {

packages/eth/src/websocket.rs

@@ -33,6 +33,7 @@ impl WebsocketClient {
         unhealthy_after_n_errors: usize,
         aws_client: AwsClient,
         max_fee_per_gas_for_first_tx: Option<u128>,
+        max_priority_fee_per_gas_for_first_tx: Option<u128>,
     ) -> ports::l1::Result<Self> {
         let blob_signer = if let Some(key_arn) = blob_pool_key_arn {
             Some(aws_client.make_signer(key_arn).await?)
@@ -48,6 +49,7 @@ impl WebsocketClient {
             main_signer,
             blob_signer,
             max_fee_per_gas_for_first_tx,
+            max_priority_fee_per_gas_for_first_tx,
         )
         .await?;
 

packages/eth/src/websocket/connection.rs

@@ -72,6 +72,7 @@ sol!(
 pub struct WsConnection {
     provider: WsProvider,
     max_fee_per_blob_gas_for_first_tx: Option<u128>,
+    max_priority_fee_per_blob_gas_for_first_tx: Option<u128>,
     first_blob_tx_sent: Arc<AtomicBool>,
     blob_provider: Option<WsProvider>,
     address: Address,
@@ -198,12 +199,14 @@ impl EthApi for WsConnection {
         let blob_tx = match (
             self.first_blob_tx_sent.load(Ordering::Relaxed),
             self.max_fee_per_blob_gas_for_first_tx,
+            self.max_priority_fee_per_blob_gas_for_first_tx,
         ) {
-            (true, _) | (false, None) => TransactionRequest::default()
+            (true, _, _) | (false, None, _) | (false, _, None) => TransactionRequest::default()
                 .with_blob_sidecar(sidecar)
                 .with_to(*blob_signer_address),
-            (false, Some(max_fee)) => TransactionRequest::default()
+            (false, Some(max_fee), Some(max_priority_fee)) => TransactionRequest::default()
                 .with_max_fee_per_blob_gas(max_fee)
+                .with_max_priority_fee_per_gas(max_priority_fee)
                 .with_blob_sidecar(sidecar)
                 .with_to(*blob_signer_address),
         };
@@ -252,6 +255,7 @@ impl WsConnection {
         main_signer: AwsSigner,
         blob_signer: Option<AwsSigner>,
         max_fee_per_blob_gas_for_first_tx: Option<u128>,
+        max_priority_fee_per_blob_gas_for_first_tx: Option<u128>,
     ) -> Result<Self> {
         let address = main_signer.address();
 
@@ -289,6 +293,7 @@ impl WsConnection {
             metrics: Default::default(),
             first_blob_tx_sent: Arc::new(AtomicBool::new(false)),
             max_fee_per_blob_gas_for_first_tx,
+            max_priority_fee_per_blob_gas_for_first_tx,
         })
     }