test(integration): wire EventReporter to the gateway-fetch reporter

Adds a `GatewayQuery { id, op_id }` event recorded each time a
gateway-query site asks `EventReporter::create_gateway_reporter`,
where `op_id` is the started parent op the fetch belongs to and
`id` is a fresh op id whose parent in the registry is `op_id`. The
event-tree renderer adds a "Repodata fetch" node so the snapshot
shows where every fetch lands relative to the surrounding pixi
solve / backend-instantiate operations.

The existing snapshot (e.g. `integration__simple_test.snap`)
captures the pre-wiring tree and will need refreshing via
`cargo insta review` once the slow integration tests are run in an
environment that can host the git fixtures.

Author: claude

crates/pixi_command_dispatcher/tests/integration/event_reporter.rs

@@ -6,10 +6,10 @@ use std::{
 use futures::{Stream, StreamExt};
 use pixi_build_discovery::JsonRpcBackendSpec;
 use pixi_command_dispatcher::{
-    BackendSourceBuildSpec, BuildBackendMetadataInner, CondaSolveReporter, GitCheckoutReporter,
-    InstallPixiEnvironmentSpec, PixiInstallReporter, PixiSolveEnvironmentSpec, PixiSolveReporter,
-    SolveCondaEnvironmentSpec, SourceMetadataReporterSpec, SourceRecordReporterSpec,
-    UrlCheckoutReporter,
+    BackendSourceBuildSpec, BuildBackendMetadataInner, CondaSolveReporter, GatewayReporter,
+    GitCheckoutReporter, InstallPixiEnvironmentSpec, PixiInstallReporter,
+    PixiSolveEnvironmentSpec, PixiSolveReporter, SolveCondaEnvironmentSpec,
+    SourceMetadataReporterSpec, SourceRecordReporterSpec, UrlCheckoutReporter,
     reporter::{
         BackendSourceBuildReporter, BuildBackendMetadataReporter, InstantiateBackendReporter,
         SourceMetadataReporter, SourceRecordReporter,
@@ -141,6 +141,15 @@ pub enum Event {
     InstantiateBackendFinished {
         id: OperationId,
     },
+
+    /// Recorded each time a gateway-query site requests a per-call
+    /// repodata reporter. `id` is a fresh op id for the query itself;
+    /// its parent in the registry is the started operation that
+    /// triggered the fetch (carried in `op_id`).
+    GatewayQuery {
+        id: OperationId,
+        op_id: OperationId,
+    },
 }
 
 pub struct EventReporter {
@@ -413,6 +422,17 @@ impl InstantiateBackendReporter for EventReporter {
     }
 }
 
+impl GatewayReporter for EventReporter {
+    fn create_gateway_reporter(
+        &self,
+        op_id: OperationId,
+    ) -> Option<Box<dyn rattler_repodata_gateway::Reporter>> {
+        let id = self.alloc();
+        self.record(Event::GatewayQuery { id, op_id });
+        None
+    }
+}
+
 impl BackendSourceBuildReporter for EventReporter {
     fn on_queued(&self, spec: &BackendSourceBuildSpec) -> OperationId {
         let id = self.alloc();
@@ -462,6 +482,7 @@ impl EventReporter {
             .with_source_metadata_reporter(self.clone())
             .with_source_record_reporter(self.clone())
             .with_backend_source_build_reporter(self.clone())
+            .with_gateway_reporter(self.clone())
     }
 }
 

crates/pixi_command_dispatcher/tests/integration/event_tree.rs

@@ -113,6 +113,9 @@ impl EventTree {
                 }
                 Event::InstantiateBackendStarted { id } => builder.alloc_pending(*id),
                 Event::InstantiateBackendFinished { .. } => {}
+                Event::GatewayQuery { id, .. } => {
+                    builder.alloc_node(*id, "Repodata fetch".to_owned());
+                }
                 Event::UrlCheckoutQueued { .. }
                 | Event::UrlCheckoutStarted { .. }
                 | Event::UrlCheckoutFinished { .. } => {