Hardcode agent url

Author: gyuheon0h

datadog-crashtracker/src/crash_info/telemetry.rs

@@ -239,23 +239,35 @@ impl TelemetryCrashUploader {
         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");
+        // 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")
+                .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;
+            });
         }
 
         telemetry_result
     }
 
     pub async fn upload_to_telemetry(&self, crash_info: &CrashInfo) -> anyhow::Result<()> {
-        panic!("{}", format!("upload_to_telemetry: {:?}", crash_info));
         let metadata = &self.metadata;
 
         let message = serde_json::to_string(crash_info)?;
@@ -296,15 +308,29 @@ impl TelemetryCrashUploader {
         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");
+        // 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")
+                .body(serde_json::to_string(&payload)?.into())
+                .unwrap();
+
+            // Fire-and-forget notification; ignore errors.
+            let _ = tokio::spawn(async move {
+                let _ = client.request(req).await;
+            });
         }
-
         telemetry_result
     }