feat: send query request to value check

Signed-off-by: Gustavo Inacio <[email protected]>

Author: gusinacio

common/src/indexer_service/http/request_handler.rs

@@ -14,7 +14,9 @@ use reqwest::StatusCode;
 use thegraph_core::DeploymentId;
 use tracing::trace;
 
-use crate::indexer_service::http::IndexerServiceResponse;
+use serde_json::value::RawValue;
+
+use crate::{indexer_service::http::IndexerServiceResponse, tap::AgoraQuery};
 
 use super::{
     indexer_service::{AttestationOutput, IndexerServiceError, IndexerServiceState},
@@ -41,14 +43,38 @@ where
         .with_label_values(&[&manifest_id.to_string()])
         .inc();
 
+    #[derive(Debug, serde::Deserialize)]
+    pub struct QueryBody {
+        pub query: String,
+        pub variables: Option<Box<RawValue>>,
+    }
+
     let request =
         serde_json::from_slice(&body).map_err(|e| IndexerServiceError::InvalidRequest(e.into()))?;
 
     let attestation_signer = if let Some(receipt) = receipt.into_signed_receipt() {
         let allocation_id = receipt.message.allocation_id;
+        let signature = receipt.signature;
+
+        let request: QueryBody = serde_json::from_slice(&body)
+            .map_err(|e| IndexerServiceError::InvalidRequest(e.into()))?;
+        let variables = request
+            .variables
+            .as_ref()
+            .map(ToString::to_string)
+            .unwrap_or_default();
+        let _ = state
+            .value_check_sender
+            .tx_query
+            .send(AgoraQuery {
+                signature,
+                deployment_id: manifest_id,
+                query: request.query.clone(),
+                variables,
+            })
+            .await;
 
         // Verify the receipt and store it in the database
-        // TODO update checks
         state
             .tap_manager
             .verify_and_store_receipt(receipt)

common/src/tap.rs

@@ -25,7 +25,7 @@ mod checks;
 mod receipt_store;
 
 pub use checks::value_check::{
-    create_value_check, CostModelSource, ValueCheckReceiver, ValueCheckSender,
+    create_value_check, AgoraQuery, CostModelSource, ValueCheckReceiver, ValueCheckSender,
 };
 
 #[derive(Clone)]

common/src/tap/checks/value_check.rs

@@ -201,10 +201,10 @@ fn compile_cost_model(src: CostModelSource) -> anyhow::Result<CostModel> {
 }
 
 pub struct AgoraQuery {
-    signature: Signature,
-    deployment_id: DeploymentId,
-    query: String,
-    variables: String,
+    pub signature: Signature,
+    pub deployment_id: DeploymentId,
+    pub query: String,
+    pub variables: String,
 }
 
 #[derive(Clone, Eq, Hash, PartialEq)]