feat: events for ng

Cargo.toml

@@ -217,7 +217,7 @@ zstd = "=0.12.4"
 
 opentelemetry = "0.27.0"
 opentelemetry-http = "0.27.0"
-opentelemetry-otlp = { version = "0.27.0", features = ["logs", "http-proto", "http-json"] }
+opentelemetry-otlp = { version = "0.27.0", features = ["logs", "http-proto", "http-json", "populate-logs-event-name"] }
 opentelemetry-semantic-conventions = { version = "0.27.0", features = ["semconv_experimental"] }
 opentelemetry_sdk = "0.27.0"
 

cli/tools/run/mod.rs

@@ -77,9 +77,14 @@ pub async fn run_script(
   let worker_factory = factory.create_cli_main_worker_factory().await?;
   let mut worker = worker_factory
     .create_main_worker(mode, main_module.clone())
-    .await?;
-
-  let exit_code = worker.run().await?;
+    .await
+    .inspect_err(|e| {
+      deno_telemetry::report_event("boot_failure", e)
+    })?;
+
+  let exit_code = worker.run().await.inspect_err(|e| {
+    deno_telemetry::report_event("uncaught_exception", e)
+  })?;
   Ok(exit_code)
 }
 

ext/telemetry/lib.rs

@@ -790,6 +790,25 @@ fn op_otel_log(
   logs.emit(&mut log_record, instrumentation_scope);
 }
 
+pub fn report_event(name: &'static str, data: impl std::fmt::Display) {
+  let Some(Processors { logs, .. }) = OTEL_PROCESSORS.get() else {
+    return;
+  };
+  let Some(instrumentation_scope) = BUILT_IN_INSTRUMENTATION_SCOPE.get() else {
+    return;
+  };
+
+  let mut log_record = LogRecord::default();
+
+  log_record.set_observed_timestamp(SystemTime::now());
+  log_record.set_event_name(name);
+  log_record.set_severity_number(Severity::Trace);
+  log_record.set_severity_text(Severity::Trace.name());
+  log_record.set_body(format!("{data}").into());
+
+  logs.emit(&mut log_record, instrumentation_scope);
+}
+
 fn owned_string<'s>(
   scope: &mut v8::HandleScope<'s>,
   string: v8::Local<'s, v8::String>,