feat: embedded validation responses on keeper

Author: jcabrero

crates/erc-8004-contract-clients/src/validation_registry.rs

@@ -19,11 +19,40 @@ sol! {
             bytes32 requestHash,
             uint64 snapshotId
         ) external;
+
+        function validationResponse(
+            bytes32 requestHash,
+            uint8 response,
+            string calldata responseURI,
+            bytes32 responseHash,
+            string calldata tag
+        ) external;
+
+        event ValidationRequest(
+            address indexed validatorAddress,
+            uint256 indexed agentId,
+            string requestURI,
+            bytes32 indexed requestHash
+        );
+
+        event ValidationResponse(
+            address indexed validatorAddress,
+            uint256 indexed agentId,
+            bytes32 indexed requestHash,
+            uint8 response,
+            string responseURI,
+            bytes32 responseHash,
+            string tag
+        );
     }
 }
 
 use ValidationRegistryUpgradeable::ValidationRegistryUpgradeableInstance;
 
+// Event type re-exports
+pub type ValidationRequestEvent = ValidationRegistryUpgradeable::ValidationRequest;
+pub type ValidationResponseEvent = ValidationRegistryUpgradeable::ValidationResponse;
+
 /// Client for interacting with the ValidationRegistryUpgradeable contract.
 #[derive(Clone)]
 pub struct ValidationRegistryClient<P: Provider + Clone> {
@@ -82,4 +111,30 @@ impl<P: Provider + Clone> ValidationRegistryClient<P> {
         );
         self.submitter.invoke("validationRequest", call).await
     }
+
+    /// Submit a validation response.
+    ///
+    /// # Arguments
+    /// * `request_hash` - The request hash identifying the validation request
+    /// * `response` - Response value 0-100 (0=invalid, 100=valid)
+    /// * `response_uri` - Optional URI pointing to response details
+    /// * `response_hash` - Hash of the response data (can be zero)
+    /// * `tag` - Tag identifying the response source (e.g., "heartbeat")
+    pub async fn validation_response(
+        &self,
+        request_hash: B256,
+        response: u8,
+        response_uri: String,
+        response_hash: B256,
+        tag: String,
+    ) -> Result<B256> {
+        let call = self.contract.validationResponse(
+            request_hash,
+            response,
+            response_uri,
+            response_hash,
+            tag,
+        );
+        self.submitter.invoke("validationResponse", call).await
+    }
 }

docker-compose.yml

@@ -35,6 +35,10 @@ services:
       - L2_HEARTBEAT_MANAGER_ADDRESS=0x5FC8d32690cc91D4c39d9d3abcBD16989F875707
       - L2_JAILING_POLICY_ADDRESS=0x2279B7A0a67DB372996a5FaB50D91eAA73d2eBe6
       - L1_EMISSIONS_CONTROLLER_ADDRESS=0x0165878A594ca255338adfa4d48449f69242Eb8F
+      # ERC-8004 Keeper configuration
+      - ENABLE_ERC8004_KEEPER=true
+      - L2_VALIDATION_REGISTRY_ADDRESS=0x3Aa5ebB10DC797CAC828524e59A333d0A371443c
+      - RUST_LOG=info
 
   # NilCC Simulator - Submits HTXs to the contract
   simulator:
@@ -97,7 +101,7 @@ services:
       - PRIVATE_KEY=0x47e179ec197488593b187f80a00eb0da91f1b9d0b13f8733639f19c30a34926a
       - IDENTITY_REGISTRY_CONTRACT_ADDRESS=0x959922bE3CAee4b8Cd9a407cc3ac1C251C2007B1
       - VALIDATION_REGISTRY_CONTRACT_ADDRESS=0x3Aa5ebB10DC797CAC828524e59A333d0A371443c
-      - HEARTBEAT_MANAGER_ADDRESS=0x5FC8d32690cc91D4c39d9d3abcBD16989F875707
+      - VALIDATOR_ADDRESS=0x90F79bf6EB2c4f870365E785982E1f101E93b906
       - AGENT_URI=https://api.nilai.nillion.network/v1/health/
       - RUST_LOG=info
     networks:

keeper/Cargo.toml

@@ -16,3 +16,4 @@ tracing = "0.1"
 tracing-subscriber = { version = "0.3", features = ["env-filter", "fmt"] }
 
 blacklight-contract-clients = { path = "../crates/blacklight-contract-clients" }
+erc-8004-contract-clients = { path = "../crates/erc-8004-contract-clients" }