chore(network): add debug logging

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

Author: suchapalaver

src/indexer_client.rs

@@ -55,10 +55,20 @@ impl IndexerClient {
         tracing::debug!(
             url = %deployment_url,
             auth_header = auth_key,
+            auth_value_length = auth_value.len(),
             query_length = query.len(),
             "sending HTTP POST request to indexer"
         );
 
+        // CRITICAL DEBUG: Log if TAP receipt header is being set
+        if auth_key == "tap-receipt" {
+            tracing::warn!(
+                url = %deployment_url,
+                auth_value_preview = &auth_value[..auth_value.len().min(50)],
+                "TAP RECEIPT HEADER BEING SENT TO INDEXER"
+            );
+        }
+
         let result = self
             .client
             .post(deployment_url.clone())

src/network/pre_processing.rs

@@ -142,10 +142,19 @@ pub fn into_internal_deployments_raw_info<'a>(
         .fold(HashMap::new(), |mut acc, deployment_raw_info| {
             let deployment_id = deployment_raw_info.id;
 
+            // Debug logging for deployment processing
+            tracing::debug!(
+                ?deployment_id,
+                subgraphs_count = deployment_raw_info.subgraphs.len(),
+                allocations_count = deployment_raw_info.allocations.len(),
+                "processing deployment in pre_processing pipeline"
+            );
+
             // If the deployment info is not present, insert it
             let deployment = match acc.entry(deployment_id) {
                 Entry::Occupied(entry) => entry.into_mut(),
                 Entry::Vacant(entry) => {
+                    tracing::debug!(?deployment_id, "inserting new deployment into registry");
                     entry.insert(deployment_raw_info.clone());
                     return acc;
                 }

src/network/service.rs

@@ -128,9 +128,24 @@ impl NetworkService {
     ) -> Result<Option<ResolvedSubgraphInfo>, DeploymentError> {
         let network = self.network.borrow();
 
+        // Debug logging for deployment resolution
+        tracing::debug!(
+            ?id,
+            total_deployments = network.deployments.len(),
+            "attempting to resolve deployment ID"
+        );
+
+        // Log first few deployment IDs for comparison
+        for (dep_id, _) in network.deployments.iter().take(3) {
+            tracing::debug!(?dep_id, "available deployment in registry");
+        }
+
         // Resolve the deployment information
         let deployment = match network.deployments.get(id) {
-            None => return Ok(None),
+            None => {
+                tracing::warn!(?id, "deployment ID not found in registry");
+                return Ok(None);
+            }
             Some(Err(err)) => return Err(err.to_owned()),
             Some(Ok(deployment)) => deployment,
         };

src/receipts.rs

@@ -1,5 +1,7 @@
 use std::time::SystemTime;
 
+use base64::{Engine as _, engine::general_purpose};
+use prost::Message;
 use rand::RngCore;
 use serde::Serialize;
 use thegraph_core::{
@@ -28,9 +30,16 @@ impl Receipt {
         self.0.message.collection_id.into()
     }
 
-    /// Serialize the receipt to JSON string
+    /// Serialize the receipt to base64-encoded protobuf format for V2 compatibility
     pub fn serialize(&self) -> String {
-        serde_json::to_string(&self.0).unwrap()
+        // Convert tap_graph::v2::SignedReceipt to protobuf format
+        let protobuf_receipt: tap_aggregator::grpc::v2::SignedReceipt = self.0.clone().into();
+
+        // Encode to protobuf bytes
+        let bytes = protobuf_receipt.encode_to_vec();
+
+        // Base64 encode the bytes
+        general_purpose::STANDARD.encode(&bytes)
     }
 }