feat(config): enable horizon

Author: suchapalaver

crates/config/default_values.toml

@@ -34,4 +34,4 @@ max_receipts_per_request = 10000
 0xDD6a6f76eb36B873C1C184e8b9b9e762FE216490 = "https://tap-aggregator-arbitrum-one.graphops.xyz"
 
 [horizon]
-enabled = false
+enabled = true

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,8 @@ deployment_id = "Qmaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa"
 # Refreshing interval for the Escrow contracts information from the Escrow subgraph.
 syncing_interval_secs = 60
 
+# NOTE: V2 escrow accounts are now in the network subgraph, not a separate escrow_v2 subgraph
+
 [blockchain]
 # The chain ID of the network that the graph network is running on
 chain_id = 1337
@@ -170,4 +172,9 @@ hardhat = "100"
 "eip155:1337" = "hardhat"
 
 [horizon]
-enabled = false
+# Enable Horizon migration support and detection
+# When enabled: Check if Horizon contracts are active in the network
+#   - If Horizon contracts detected: Hybrid migration mode (new V2 receipts only, process existing V1 receipts)
+#   - If Horizon contracts not detected: Remain in legacy mode (V1 receipts only)
+# When disabled: Pure legacy mode, no Horizon detection performed
+enabled = true

crates/config/minimal-config-example.toml

@@ -42,8 +42,8 @@ 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
@@ -63,3 +63,11 @@ 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]
+# Enable Horizon migration support and detection
+# When enabled: Check if Horizon contracts are active in the network
+#   - If Horizon contracts detected: Hybrid migration mode (new V2 receipts only, process existing V1 receipts)
+#   - If Horizon contracts not detected: Remain in legacy mode (V1 receipts only)
+# When disabled: Pure legacy mode, no Horizon detection performed
+enabled = true

crates/config/src/config.rs

@@ -303,6 +303,7 @@ impl MetricsConfig {
 pub struct SubgraphsConfig {
     pub network: NetworkSubgraphConfig,
     pub escrow: EscrowSubgraphConfig,
+    // Note: V2 escrow accounts are in the network subgraph, not a separate escrow_v2 subgraph
 }
 
 #[serde_as]
@@ -446,12 +447,24 @@ pub struct RavRequestConfig {
     pub max_receipts_per_request: u64,
 }
 
-/// Configuration for the horizon
-/// standard
+/// Configuration for the horizon migration
 #[derive(Debug, Default, Deserialize)]
 #[cfg_attr(test, derive(PartialEq))]
 pub struct HorizonConfig {
-    /// Whether the horizon is enabled or not
+    /// Enable Horizon migration support and detection
+    ///
+    /// When enabled (true):
+    /// - System will check if Horizon contracts are active in the network
+    /// - If Horizon contracts are detected: Enable hybrid migration mode
+    ///   * Accept new V2 TAP receipts only  
+    ///   * Continue processing existing V1 receipts for RAV generation
+    ///   * Reject new V1 receipt submissions
+    /// - If Horizon contracts are not detected: Remain in legacy mode
+    ///
+    /// When disabled (false):
+    /// - Pure legacy mode, no Horizon detection performed
+    /// - Only V1 TAP receipts are supported
+    #[serde(default)]
     pub enabled: bool,
 }
 

crates/tap-agent/src/agent.rs

@@ -176,10 +176,8 @@ pub async fn start_agent() -> (ActorRef<SenderAccountsManagerMessage>, JoinHandl
 
     let config = Box::leak(Box::new({
         let mut config = SenderAccountConfig::from_config(&CONFIG);
-        // FIXME: This is a temporary measure to disable
-        // Horizon, even if enabled through our configuration file.
-        // Force disable Horizon support
-        config.horizon_enabled = false;
+        // Enable Horizon support
+        config.horizon_enabled = true;
         // Add a warning log so operators know their setting was ignore
         if CONFIG.horizon.enabled {
             tracing::warn!(