fix(avail-client): add GasRelay timeout and Referer header (#4588)

## What ❔

Fixes some of the Avail issues that occurred recently. 

The only issue that remains unresolved by this PR is when the Avail
Bridge API returns inclusion data for a certain blob, but the
L1AvailBridge doesn't have the state root containing this blob. In
theory, this shouldn't happen, but Avail services had this type of race
condition before.
The proper fix would require fetching L1 DA validator from the
DiamondProxy, then fetching the bridge address from the L1DAValidator,
and making sure that the underlying call to the bridge would succeed.
The upcoming upgrade that switches to enum of L1 DA validators makes the
process more comples, so I decided to not include it to limit the amout
of effort spent here.

## Why ❔

To handle some corner cases with Avail client. 

## Is this a breaking change?
- [ ] Yes
- [x] No

## Operational changes
<!-- Any config changes? Any new flags? Any changes to any scripts? -->
<!-- Please add anything that non-Matter Labs entities running their own
ZK Chain may need to know -->

## Checklist

<!-- Check your PR fulfills the following items. -->
<!-- For draft PRs check the boxes as you complete them. -->

- [ ] PR title corresponds to the body of PR (we generate changelog
entries from PRs).
- [ ] Tests for the changes have been added / updated.
- [ ] Documentation comments have been added / updated.
- [ ] Code has been formatted via `zkstack dev fmt` and `zkstack dev
lint`.

Author: dimazhornyk

core/lib/config/src/configs/da_client/avail.rs

@@ -38,6 +38,10 @@ pub struct AvailGasRelayConfig {
     pub gas_relay_api_url: String,
     #[config(default_t = 5)]
     pub max_retries: usize,
+    #[config(default_t = "zksync".to_string())]
+    pub referer_header: String,
+    #[config(default_t = 3 * TimeUnit::Minutes)]
+    pub dispatch_timeout: Duration,
 }
 
 #[derive(Clone, Debug, DescribeConfig, DeserializeConfig)]

core/lib/config/src/configs/da_client/mod.rs

@@ -156,6 +156,8 @@ mod tests {
           avail_client_type: GasRelay
           gas_relay_api_url: https://lens-turbo-api.availproject.org
           max_retries: 4
+          referer_header: zksync
+          dispatch_timeout: 2s
         "#;
         let yaml = Yaml::new("test.yml", serde_yaml::from_str(yaml).unwrap()).unwrap();
 
@@ -177,6 +179,8 @@ mod tests {
             "https://lens-turbo-api.availproject.org"
         );
         assert_eq!(client.max_retries, 4);
+        assert_eq!(client.referer_header, "zksync");
+        assert_eq!(client.dispatch_timeout, Duration::from_secs(2));
     }
 
     #[test]
@@ -188,6 +192,8 @@ mod tests {
             gas_relay:
               gas_relay_api_url: https://lens-turbo-api.availproject.org
               max_retries: 4
+              referer_header: zksync
+              dispatch_timeout: 2s
         "#;
         let yaml = Yaml::new("test.yml", serde_yaml::from_str(yaml).unwrap()).unwrap();
 

core/node/da_clients/src/avail/client.rs

@@ -139,6 +139,7 @@ impl AvailClient {
                     &conf.gas_relay_api_url,
                     gas_relay_api_key.0.expose_secret(),
                     conf.max_retries,
+                    &conf.referer_header,
                     Arc::clone(&api_client),
                 )
                 .await?;
@@ -254,6 +255,23 @@ impl DataAvailabilityClient for AvailClient {
                     })
             }
             AvailClientMode::GasRelay(client) => {
+                let config = match &self.config.config {
+                    AvailClientConfig::GasRelay(conf) => conf,
+                    _ => unreachable!(), // validated in protobuf config
+                };
+
+                if Utc::now()
+                    .signed_duration_since(dispatched_at)
+                    .to_std()
+                    .map_err(to_retriable_da_error)?
+                    > config.dispatch_timeout
+                {
+                    return Err(DAError {
+                        error: anyhow!("Dispatch timeout exceeded"),
+                        is_retriable: false,
+                    });
+                }
+
                 let Some((block_hash, extrinsic_index)) = client
                     .check_finality(dispatch_request_id)
                     .await

core/node/da_clients/src/avail/sdk.rs

@@ -453,6 +453,7 @@ pub(crate) struct GasRelayClient {
     api_url: String,
     api_key: String,
     max_retries: usize,
+    referer_header: String,
     api_client: Arc<reqwest::Client>,
 }
 
@@ -478,12 +479,14 @@ impl GasRelayClient {
         api_url: &str,
         api_key: &str,
         max_retries: usize,
+        referer_header: &str,
         api_client: Arc<reqwest::Client>,
     ) -> anyhow::Result<Self> {
         Ok(Self {
             api_url: api_url.to_owned(),
             api_key: api_key.to_owned(),
             max_retries,
+            referer_header: referer_header.to_owned(),
             api_client,
         })
     }
@@ -496,6 +499,7 @@ impl GasRelayClient {
             .post(&submit_url)
             .body(Bytes::from(data))
             .header("Content-Type", "application/octet-stream")
+            .header("Referer", &self.referer_header)
             .header("x-api-key", &self.api_key)
             .send()
             .await