Add direct Tinybird auction telemetry (#818)

Author: ChristianPavilonis

crates/trusted-server-adapter-fastly/src/app.rs

@@ -94,6 +94,7 @@ use edgezero_core::http::{
 use edgezero_core::router::RouterService;
 use error_stack::Report;
 use trusted_server_core::auction::endpoints::handle_auction;
+use trusted_server_core::auction::AuctionTelemetrySink;
 use trusted_server_core::auction::{build_orchestrator, AuctionOrchestrator};
 use trusted_server_core::constants::{COOKIE_SHAREDID, COOKIE_TS_EIDS};
 use trusted_server_core::ec::batch_sync::handle_batch_sync;
@@ -147,6 +148,7 @@ pub(crate) struct AppState {
     pub(crate) orchestrator: Arc<AuctionOrchestrator>,
     pub(crate) registry: Arc<IntegrationRegistry>,
     pub(crate) default_kv_store: Arc<dyn PlatformKvStore>,
+    pub(crate) auction_telemetry_sink: Arc<dyn AuctionTelemetrySink>,
 }
 
 /// Build the application state, loading settings and constructing all per-application components.
@@ -173,13 +175,15 @@ pub(crate) fn build_state_from_settings(
     let orchestrator = build_orchestrator(&settings)?;
     let registry = IntegrationRegistry::new(&settings)?;
 
+    let auction_telemetry_sink = crate::tinybird::auction_sink_from_settings(&settings);
     let default_kv_store = Arc::new(UnavailableKvStore) as Arc<dyn PlatformKvStore>;
 
     Ok(Arc::new(AppState {
         settings: Arc::new(settings),
         orchestrator: Arc::new(orchestrator),
         registry: Arc::new(registry),
         default_kv_store,
+        auction_telemetry_sink,
     }))
 }
 
@@ -254,6 +258,7 @@ fn build_per_request_services(state: &AppState, ctx: &RequestContext) -> Runtime
         .backend(Arc::new(FastlyPlatformBackend))
         .http_client(Arc::new(FastlyPlatformHttpClient))
         .geo(Arc::new(FastlyPlatformGeo))
+        .auction_telemetry_sink(Arc::clone(&state.auction_telemetry_sink))
         .client_info(client_info)
         .build()
 }
@@ -1352,6 +1357,9 @@ mod tests {
         let default_kv_store =
             Arc::new(crate::platform::UnavailableKvStore) as Arc<dyn super::PlatformKvStore>;
         let state = Arc::new(super::AppState {
+            auction_telemetry_sink: Arc::new(
+                trusted_server_core::auction::NoopAuctionTelemetrySink,
+            ),
             settings: Arc::new(settings),
             orchestrator: Arc::new(orchestrator),
             registry: Arc::new(registry),

crates/trusted-server-adapter-fastly/src/main.rs

@@ -34,6 +34,7 @@ mod management_api;
 mod middleware;
 mod platform;
 mod rate_limiter;
+mod tinybird;
 
 use crate::app::{load_settings_from_config_store, EcFinalizeState, TrustedServerApp};
 use crate::ec_kv::FastlyEcKvStore;