refactor: configure system for transition mode

Signed-off-by: Joseph Livesey <[email protected]>

Author: suchapalaver

contrib/indexer-service/config.toml

@@ -46,4 +46,8 @@ trigger_value_divisor = 500_000
 "ACCOUNT0_ADDRESS_PLACEHOLDER" = "http://tap-aggregator:7610"
 
 [horizon]
-enabled = true
+# Horizon migration mode: legacy | transition | full
+# - legacy: Only v1 TAP receipts supported (pre-migration)
+# - transition: Both v1 and v2 TAP receipts supported (during migration)  
+# - full: Only v2 TAP receipts supported (post-migration)
+mode = "transition"

contrib/tap-agent/config.toml

@@ -46,4 +46,8 @@ trigger_value_divisor = 500_000
 "ACCOUNT0_ADDRESS_PLACEHOLDER" = "http://tap-aggregator:7610"
 
 [horizon]
-enabled = true
+# Horizon migration mode: legacy | transition | full
+# - legacy: Only v1 TAP receipts supported (pre-migration)
+# - transition: Both v1 and v2 TAP receipts supported (during migration)  
+# - full: Only v2 TAP receipts supported (post-migration)
+mode = "transition"

crates/config/maximal-config-example.toml

@@ -67,8 +67,8 @@ recently_closed_allocation_buffer_secs = 3600
 
 [subgraphs.escrow]
 # NOTE: It is heavily recomended to use both `query_url` and `deployment_id`,
-# Query URL for the Escrow subgraph.
-query_url = "http://example.com/network-subgraph"
+# Query URL for the Escrow subgraph (v1).
+query_url = "http://example.com/escrow-subgraph"
 # Optional, Auth token will used a "bearer auth"
 # query_auth_token = "super-secret"
 
@@ -78,6 +78,14 @@ deployment_id = "Qmaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
 # Refreshing interval for the Escrow contracts information from the Escrow subgraph.
 syncing_interval_secs = 60
 
+[subgraphs.escrow_v2]
+# Query URL for the Escrow v2 subgraph (Horizon).
+query_url = "http://example.com/escrow-v2-subgraph"
+# Optional, Auth token will used a "bearer auth"
+# query_auth_token = "super-secret"
+# Refreshing interval for the Escrow v2 contracts information.
+syncing_interval_secs = 30
+
 [blockchain]
 # The chain ID of the network that the graph network is running on
 chain_id = 1337
@@ -170,4 +178,4 @@ hardhat = "100"
 "eip155:1337" = "hardhat"
 
 [horizon]
-enabled = false
+mode = "transition"

crates/config/minimal-config-example.toml

@@ -42,13 +42,18 @@ query_url = "http://example.com/network-subgraph"
 deployment_id = "Qmaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
 
 [subgraphs.escrow]
-# Query URL for the Escrow subgraph.
-query_url = "http://example.com/network-subgraph"
+# Query URL for the Escrow subgraph (v1).
+query_url = "http://example.com/escrow-subgraph"
 # Optional, deployment to look for in the local `graph-node`, if locally indexed.
 # Locally indexing the subgraph is recommended.
 # NOTE: Use `query_url` or `deployment_id` only
 deployment_id = "Qmaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
 
+[subgraphs.escrow_v2]
+# Query URL for the Escrow v2 subgraph (Horizon).
+query_url = "http://example.com/escrow-v2-subgraph"
+syncing_interval_secs = 30
+
 [blockchain]
 # The chain ID of the network that the graph network is running on
 chain_id = 1337
@@ -63,3 +68,6 @@ receipts_verifier_address = "0x2222222222222222222222222222222222222222"
 # Key-Value of all senders and their aggregator endpoints
 0xDDE4cfFd3D9052A9cb618fC05a1Cd02be1f2F467 = "https://tap-aggregator.network.thegraph.com"
 0xDD6a6f76eb36B873C1C184e8b9b9e762FE216490 = "https://tap-aggregator-arbitrum-one.graphops.xyz"
+
+[horizon]
+mode = "transition"

crates/config/src/config.rs

@@ -303,6 +303,7 @@ impl MetricsConfig {
 pub struct SubgraphsConfig {
     pub network: NetworkSubgraphConfig,
     pub escrow: EscrowSubgraphConfig,
+    pub escrow_v2: Option<EscrowSubgraphConfig>,
 }
 
 #[serde_as]
@@ -446,13 +447,26 @@ pub struct RavRequestConfig {
     pub max_receipts_per_request: u64,
 }
 
+/// Horizon upgrade mode configuration
+#[derive(Debug, Clone, Deserialize, PartialEq, Default)]
+#[serde(rename_all = "lowercase")]
+pub enum HorizonMode {
+    /// Legacy mode: Only v1 TAP receipts supported
+    #[default]
+    Legacy,
+    /// Transition mode: Both v1 and v2 TAP receipts supported (for migration)
+    Transition,
+    /// Full mode: Only v2 TAP receipts supported (post-migration)
+    Full,
+}
+
 /// Configuration for the horizon
 /// standard
 #[derive(Debug, Default, Deserialize)]
 #[cfg_attr(test, derive(PartialEq))]
 pub struct HorizonConfig {
-    /// Whether the horizon is enabled or not
-    pub enabled: bool,
+    /// Horizon upgrade mode
+    pub mode: HorizonMode,
 }
 
 #[cfg(test)]