test(integration-tests): update test middleware for v2

Author: suchapalaver

Cargo.lock

@@ -25,3 +25,6 @@ rand.workspace = true
 indexer-receipt = { path = "../crates/indexer-receipt" }
 num_cpus = "1.16.0"
 clap = { version = "4.0", features = ["derive"] }
+base64 = { workspace = true }
+prost = { workspace = true }
+tap_aggregator = { workspace = true }

integration-tests/Cargo.toml

@@ -14,7 +14,10 @@ use crate::{
         ACCOUNT0_SECRET, CHAIN_ID, GRAPH_URL, INDEXER_URL, MAX_RECEIPT_VALUE, SUBGRAPH_ID,
         TAP_VERIFIER_CONTRACT,
     },
-    utils::{create_request, create_tap_receipt, create_tap_receipt_v2, find_allocation},
+    utils::{
+        create_request, create_tap_receipt, create_tap_receipt_v2, encode_v2_receipt,
+        find_allocation,
+    },
 };
 
 // Function to test indexer service component
@@ -233,11 +236,11 @@ async fn create_and_send_receipts_v2(
         &service_provider,
     )?;
 
-    let receipt_json = serde_json::to_string(&receipt).unwrap();
+    let receipt_encoded = encode_v2_receipt(&receipt)?;
     let response = create_request(
         &http_client,
         format!("{}/subgraphs/id/{}", INDEXER_URL, SUBGRAPH_ID).as_str(),
-        &receipt_json,
+        &receipt_encoded,
         &json!({
             "query": "{ _meta { block { number } } }"
         }),

integration-tests/src/load_test.rs

@@ -13,7 +13,10 @@ use crate::{
         ACCOUNT0_SECRET, CHAIN_ID, GATEWAY_API_KEY, GATEWAY_URL, GRAPH_URL, INDEXER_URL,
         MAX_RECEIPT_VALUE, SUBGRAPH_ID, TAP_AGENT_METRICS_URL, TAP_VERIFIER_CONTRACT,
     },
-    utils::{create_request, create_tap_receipt, create_tap_receipt_v2, find_allocation},
+    utils::{
+        create_request, create_tap_receipt, create_tap_receipt_v2, encode_v2_receipt,
+        find_allocation,
+    },
     MetricsChecker,
 };
 
@@ -266,12 +269,12 @@ pub async fn test_tap_rav_v2() -> Result<()> {
                 &service_provider,
             )?;
 
-            let receipt_json = serde_json::to_string(&receipt)?;
+            let receipt_encoded = encode_v2_receipt(&receipt)?;
 
             let response = create_request(
                 &http_client,
                 &format!("{}/subgraphs/id/{}", INDEXER_URL, SUBGRAPH_ID),
-                &receipt_json,
+                &receipt_encoded,
                 &json!({
                     "query": "{ _meta { block { number } } }"
                 }),
@@ -330,12 +333,12 @@ pub async fn test_tap_rav_v2() -> Result<()> {
             &service_provider,
         )?;
 
-        let receipt_json = serde_json::to_string(&receipt)?;
+        let receipt_encoded = encode_v2_receipt(&receipt)?;
 
         let response = create_request(
             &http_client,
             &format!("{}/subgraphs/id/{}", INDEXER_URL, SUBGRAPH_ID),
-            &receipt_json,
+            &receipt_encoded,
             &json!({
                 "query": "{ _meta { block { number } } }"
             }),

integration-tests/src/rav_tests.rs

@@ -8,9 +8,12 @@ use std::{
 };
 
 use anyhow::Result;
+use base64::prelude::*;
+use prost::Message;
 use rand::{rng, Rng};
 use reqwest::Client;
 use serde_json::json;
+use tap_aggregator::grpc;
 use tap_core::{signed_message::Eip712SignedMessage, tap_eip712_domain};
 use tap_graph::Receipt;
 use thegraph_core::alloy::{primitives::Address, signers::local::PrivateKeySigner};
@@ -94,6 +97,13 @@ pub fn create_tap_receipt_v2(
     Ok(receipt)
 }
 
+pub fn encode_v2_receipt(receipt: &Eip712SignedMessage<tap_graph::v2::Receipt>) -> Result<String> {
+    let protobuf_receipt = grpc::v2::SignedReceipt::from(receipt.clone());
+    let encoded = protobuf_receipt.encode_to_vec();
+    let base64_encoded = BASE64_STANDARD.encode(encoded);
+    Ok(base64_encoded)
+}
+
 // Function to create a configured request
 pub fn create_request(
     client: &reqwest::Client,