Revert

Author: gyuheon0h

datadog-crashtracker/src/crash_info/telemetry.rs

@@ -238,31 +238,16 @@ impl TelemetryCrashUploader {
         // Send to both telemetry and errors intake
         let telemetry_result = self.send_telemetry_payload(&payload).await;
 
-        // Also send crash ping to errors intake if available
-        // if let Some(errors_uploader) = &self.errors_intake_uploader {
-        //     let crash_metadata = self.telemetry_metadata_to_crashtracker_metadata();
-        //     if let Err(e) = errors_uploader
-        //         .send_crash_ping(crash_uuid, sig_info, &crash_metadata)
-        //         .await
-        //     {
-        //         eprintln!("Failed to send crash ping to errors intake: {e}");
-        //     }
-        // } else {
-        //     eprintln!("DEBUG: No errors intake uploader available for crash ping");
-        // }
-        {
-            let client = ddtelemetry::worker::http_client::from_config(&self.cfg);
-            let req = http::Request::builder()
-                .method(http::Method::POST)
-                .uri("http://localhost:9126/evp_proxy/v2/api/v2/errorsintake")
-                .header("X-Datadog-EVP-Subdomain", "event-platform-intake")
-                .body(serde_json::to_string(&crash_ping_msg)?.into())
-                .unwrap();
-
-            // Fire-and-forget notification; ignore errors.
-            let _ = tokio::spawn(async move {
-                let _ = client.request(req).await;
-            });
+        if let Some(errors_uploader) = &self.errors_intake_uploader {
+            let crash_metadata = self.telemetry_metadata_to_crashtracker_metadata();
+            let errors_intake_result = errors_uploader
+                .send_crash_ping(crash_uuid, sig_info, &crash_metadata)
+                .await;
+            if let Err(e) = errors_intake_result {
+                eprintln!("Failed to send crash report to errors intake: {e}");
+            }
+        } else {
+            eprintln!("No errors intake uploader available for crash report");
         }
 
         telemetry_result
@@ -308,30 +293,13 @@ impl TelemetryCrashUploader {
         // Send to both telemetry and errors intake
         let telemetry_result = self.send_telemetry_payload(&payload).await;
 
-        // Also send crash report to errors intake if available
-        // if let Some(errors_uploader) = &self.errors_intake_uploader {
-        //     eprintln!("DEBUG: Attempting to send crash report to errors intake");
-        //     if let Err(e) = errors_uploader.upload_to_errors_intake(crash_info).await {
-        //         eprintln!("Failed to send crash report to errors intake: {e}");
-        //     }
-        // } else {
-        //     eprintln!("DEBUG: No errors intake uploader available for crash report");
-        // }
-        // Send an HTTP request to http://localhost:9126/
-        // This is a fire-and-forget notification; ignore errors.
-        {
-            let client = ddtelemetry::worker::http_client::from_config(&self.cfg);
-            let req = http::Request::builder()
-                .method(http::Method::POST)
-                .uri("http://localhost:9126/evp_proxy/v2/api/v2/errorsintake")
-                .header("X-Datadog-EVP-Subdomain", "event-platform-intake")
-                .body(serde_json::to_string(&payload)?.into())
-                .unwrap();
-
-            // Fire-and-forget notification; ignore errors.
-            let _ = tokio::spawn(async move {
-                let _ = client.request(req).await;
-            });
+        if let Some(errors_uploader) = &self.errors_intake_uploader {
+            let errors_intake_result = errors_uploader.upload_to_errors_intake(crash_info).await;
+            if let Err(e) = errors_intake_result {
+                eprintln!("Failed to send crash report to errors intake: {e}");
+            }
+        } else {
+            eprintln!("No errors intake uploader available for crash report");
         }
         telemetry_result
     }