From d6c7461351a27eff2544b4c0eb34c994ae22f1c0 Mon Sep 17 00:00:00 2001
From: Tan Chee Keong <tanck@sigmaprime.io>
Date: Mon, 10 Mar 2025 17:22:08 +0800
Subject: [PATCH] Add timeout for aggregator

---
 common/eth2/src/lib.rs      | 4 +++-
 validator_client/src/lib.rs | 2 ++
 2 files changed, 5 insertions(+), 1 deletion(-)

diff --git a/common/eth2/src/lib.rs b/common/eth2/src/lib.rs
index 39d2260dbc..065fedf1b8 100644
--- a/common/eth2/src/lib.rs
+++ b/common/eth2/src/lib.rs
@@ -144,6 +144,7 @@ pub struct Timeouts {
     pub get_debug_beacon_states: Duration,
     pub get_deposit_snapshot: Duration,
     pub get_validator_block: Duration,
+    pub aggregator_duties: Duration,
 }
 
 impl Timeouts {
@@ -161,6 +162,7 @@ impl Timeouts {
             get_debug_beacon_states: timeout,
             get_deposit_snapshot: timeout,
             get_validator_block: timeout,
+            aggregator_duties: timeout,
         }
     }
 }
@@ -2677,7 +2679,7 @@ impl BeaconNodeHttpClient {
             .push("validator")
             .push("beacon_committee_selections");
 
-        self.post_with_timeout_and_response(path, &selections, self.timeouts.attester_duties)
+        self.post_with_timeout_and_response(path, &selections, self.timeouts.aggregator_duties)
             .await
     }
 }
diff --git a/validator_client/src/lib.rs b/validator_client/src/lib.rs
index 70236d6a3c..82cd95cfd2 100644
--- a/validator_client/src/lib.rs
+++ b/validator_client/src/lib.rs
@@ -69,6 +69,7 @@ const HTTP_GET_BEACON_BLOCK_SSZ_TIMEOUT_QUOTIENT: u32 = 4;
 const HTTP_GET_DEBUG_BEACON_STATE_QUOTIENT: u32 = 4;
 const HTTP_GET_DEPOSIT_SNAPSHOT_QUOTIENT: u32 = 4;
 const HTTP_GET_VALIDATOR_BLOCK_TIMEOUT_QUOTIENT: u32 = 4;
+const HTTP_AGGREGATOR_DUTIES_TIMEOUT_QUOTIENT: u32 = 1;
 
 const DOPPELGANGER_SERVICE_NAME: &str = "doppelganger";
 
@@ -323,6 +324,7 @@ impl<E: EthSpec> ProductionValidatorClient<E> {
                     get_debug_beacon_states: slot_duration / HTTP_GET_DEBUG_BEACON_STATE_QUOTIENT,
                     get_deposit_snapshot: slot_duration / HTTP_GET_DEPOSIT_SNAPSHOT_QUOTIENT,
                     get_validator_block: slot_duration / HTTP_GET_VALIDATOR_BLOCK_TIMEOUT_QUOTIENT,
+                    aggregator_duties: slot_duration / HTTP_AGGREGATOR_DUTIES_TIMEOUT_QUOTIENT,
                 }
             } else {
                 Timeouts::set_all(slot_duration)