···1313use tracing_opentelemetry::OpenTelemetrySpanExt;
14141515use crate::dns::{DnsProvider, TxtResolver};
1616-use crate::well_known::WellKnownResolver;
1716use crate::routes::claim_codes::claim_codes;
1817use crate::routes::create_account::create_account;
1918use crate::routes::create_did::create_did_handler;
···2423use crate::routes::health::health;
2524use crate::routes::register_device::register_device;
2625use crate::routes::resolve_handle::resolve_handle_handler;
2626+use crate::well_known::WellKnownResolver;
27272828/// Wraps an `axum::http::HeaderMap` as an OTel text-map [`Extractor`] so that
2929/// the W3C `traceparent` and `tracestate` headers can be read by the global propagator.
+3-2
crates/relay/src/main.rs
···119119 }
120120 };
121121122122- let well_known_resolver: Option<Arc<dyn well_known::WellKnownResolver>> =
123123- Some(Arc::new(well_known::HttpWellKnownResolver::new(http_client.clone())));
122122+ let well_known_resolver: Option<Arc<dyn well_known::WellKnownResolver>> = Some(Arc::new(
123123+ well_known::HttpWellKnownResolver::new(http_client.clone()),
124124+ ));
124125125126 let state = app::AppState {
126127 config: Arc::new(config),
+10-2
crates/relay/src/routes/resolve_handle.rs
···78787979#[cfg(test)]
8080mod tests {
8181- use std::{future::Future, pin::Pin, sync::{Arc, Mutex}};
8181+ use std::{
8282+ future::Future,
8383+ pin::Pin,
8484+ sync::{Arc, Mutex},
8585+ };
82868387 use axum::{
8488 body::Body,
···305309 .await
306310 .unwrap();
307311308308- let name = captured.lock().unwrap().clone().expect("txt_lookup not called");
312312+ let name = captured
313313+ .lock()
314314+ .unwrap()
315315+ .clone()
316316+ .expect("txt_lookup not called");
309317 assert_eq!(name, "_atproto.alice.example.com");
310318 }
311319