Skip to content

Commit df5c16e

Browse files
committed
use runtime cfg for desktop otel
1 parent 730e160 commit df5c16e

File tree

2 files changed

+17
-27
lines changed

2 files changed

+17
-27
lines changed

apps/desktop/src-tauri/src/lib.rs

Lines changed: 1 addition & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -1887,23 +1887,11 @@ async fn update_auth_plan(app: AppHandle) {
18871887
AuthStore::update_auth_plan(&app).await.ok();
18881888
}
18891889

1890-
type FilteredRegistryInner = tracing_subscriber::layer::Layered<
1890+
type FilteredRegistry = tracing_subscriber::layer::Layered<
18911891
tracing_subscriber::filter::FilterFn<fn(m: &tracing::Metadata) -> bool>,
18921892
tracing_subscriber::Registry,
18931893
>;
18941894

1895-
#[cfg(debug_assertions)]
1896-
pub type FilteredRegistry = tracing_subscriber::layer::Layered<
1897-
tracing_opentelemetry::OpenTelemetryLayer<
1898-
// FilteredRegistryInner,
1899-
tracing_subscriber::filter::FilterFn<fn(m: &tracing::Metadata) -> bool>,
1900-
opentelemetry_sdk::trace::SdkTracerProvider,
1901-
>,
1902-
tracing_subscriber::Registry,
1903-
>;
1904-
#[cfg(not(debug_assertions))]
1905-
pub type FilteredRegistry = FilteredRegistryInner;
1906-
19071895
pub type DynLoggingLayer = Box<dyn tracing_subscriber::Layer<FilteredRegistry> + Send + Sync>;
19081896
type LoggingHandle = tracing_subscriber::reload::Handle<Option<DynLoggingLayer>, FilteredRegistry>;
19091897

apps/desktop/src-tauri/src/main.rs

Lines changed: 16 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -47,7 +47,7 @@ fn main() {
4747
(sentry_client, _guard)
4848
});
4949

50-
let (layer, handle) = tracing_subscriber::reload::Layer::new(None::<DynLoggingLayer>);
50+
let (reload_layer, handle) = tracing_subscriber::reload::Layer::new(None::<DynLoggingLayer>);
5151

5252
let logs_dir = {
5353
#[cfg(target_os = "macos")]
@@ -73,12 +73,7 @@ fn main() {
7373
let file_appender = tracing_appender::rolling::daily(&logs_dir, "cap-desktop.log");
7474
let (non_blocking, _logger_guard) = tracing_appender::non_blocking(file_appender);
7575

76-
let registry = tracing_subscriber::registry().with(tracing_subscriber::filter::filter_fn(
77-
(|v| v.target().starts_with("cap_")) as fn(&tracing::Metadata) -> bool,
78-
));
79-
80-
// #[cfg(debug_assertions)]
81-
let (registry, _tracer) = {
76+
let (otel_layer, _tracer) = if cfg!(debug_assertions) {
8277
use opentelemetry::trace::TracerProvider;
8378
use opentelemetry_otlp::WithExportConfig;
8479
use tracing_subscriber::Layer;
@@ -93,15 +88,22 @@ fn main() {
9388
)
9489
.build();
9590

91+
let layer = tracing_opentelemetry::layer()
92+
.with_tracer(tracer.tracer("cap-desktop"))
93+
.boxed();
94+
9695
opentelemetry::global::set_tracer_provider(tracer.clone());
97-
(
98-
registry.with(tracing_opentelemetry::layer().with_tracer(tracer.tracer("cap-desktop"))),
99-
tracer,
100-
)
96+
(Some(layer), Some(tracer))
97+
} else {
98+
(None, None)
10199
};
102100

103-
registry
104-
.with(layer)
101+
tracing_subscriber::registry()
102+
.with(tracing_subscriber::filter::filter_fn(
103+
(|v| v.target().starts_with("cap_")) as fn(&tracing::Metadata) -> bool,
104+
))
105+
.with(reload_layer)
106+
.with(otel_layer)
105107
.with(
106108
tracing_subscriber::fmt::layer()
107109
.with_ansi(true)
@@ -127,5 +129,5 @@ fn main() {
127129
.enable_all()
128130
.build()
129131
.expect("Failed to build multi threaded tokio runtime")
130-
.block_on(cap_desktop_lib::run(handle.boxed()));
132+
.block_on(cap_desktop_lib::run(handle));
131133
}

0 commit comments

Comments
 (0)