fix(telemetry): include dependencies and integrations in app-extended-heartbeat

Per the instrumentation-telemetry-api-docs schema, app-extended-heartbeat
must carry the full state — configuration, dependencies, and integrations —
so the agent can reconstruct application records on data loss. dd-trace-go
and dd-trace-dotnet both ship the full triple. The Rust worker, however,
defines AppStarted as a configuration-only struct and reuses it for
app-extended-heartbeat, so dependencies and integrations are not included
in the heartbeat payload.

The ExtendedHeartbeat handler does call unflush_stored() on all three
collectors, evidently with the intent of re-emitting the full state.
Because the heartbeat payload omits the re-queued dependencies and
integrations and app_started_sent_success only pops configurations from
unflushed, the re-queued items remain in unflushed and are sent on the
next FlushData as a duplicate app-integrations-change /
app-dependencies-loaded.

Updating the shared AppStarted struct, build_app_started, and
app_started_sent_success addresses both Lifecycle(Start) and
Lifecycle(ExtendedHeartbeat) call sites.

Co-Authored-By: Claude Opus 4.7 (1M context) <noreply@anthropic.com>

Author: cataphract

Cargo.lock

@@ -50,7 +50,7 @@ chrono = {version = "0.4", default-features = false, features = ["std", "clock",
 cxx = { version = "1.0", optional = true }
 errno = "0.3"
 libdd-common = { version = "4.0.0", path = "../libdd-common" }
-libdd-telemetry = { version = "4.0.0", path = "../libdd-telemetry" }
+libdd-telemetry = { version = "5.0.0", path = "../libdd-telemetry" }
 http = "1.1"
 libc = "0.2"
 nix = { version = "0.29", features = ["poll", "signal", "socket"] }

libdd-crashtracker/Cargo.toml

@@ -34,7 +34,7 @@ tokio-util = "0.7.11"
 libdd-capabilities = { path = "../libdd-capabilities", version = "1.0.0" }
 libdd-common = { version = "4.0.0", path = "../libdd-common", default-features = false }
 libdd-shared-runtime = { version = "0.1.0", path = "../libdd-shared-runtime" }
-libdd-telemetry = { version = "4.0.0", path = "../libdd-telemetry", default-features = false, optional = true}
+libdd-telemetry = { version = "5.0.0", path = "../libdd-telemetry", default-features = false, optional = true}
 libdd-trace-protobuf = { version = "3.0.1", path = "../libdd-trace-protobuf" }
 libdd-trace-stats = { version = "2.0.0", path = "../libdd-trace-stats", default-features = false }
 libdd-trace-utils = { version = "3.0.1", path = "../libdd-trace-utils", default-features = false }

libdd-data-pipeline/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "libdd-telemetry"
-version= "4.0.0"
+version= "5.0.0"
 description = "Telemetry client allowing to send data as described in https://docs.datadoghq.com/tracing/configure_data_security/?tab=net#telemetry-collection"
 homepage = "https://github.com/DataDog/libdatadog/tree/main/libdd-telemetry"
 repository = "https://github.com/DataDog/libdatadog/tree/main/libdd-telemetry"

libdd-telemetry/Cargo.toml

@@ -17,6 +17,8 @@ use libdd_telemetry::{
 fn build_app_started_payload() -> AppStarted {
     AppStarted {
         configuration: Vec::new(),
+        dependencies: Vec::new(),
+        integrations: Vec::new(),
     }
 }
 

libdd-telemetry/examples/tm-ping.rs

@@ -66,6 +66,8 @@ mod tests {
                     seq_id: None,
                 },
             ],
+            dependencies: Vec::new(),
+            integrations: Vec::new(),
         });
 
         let serialized = serde_json::to_value(&payload).unwrap();
@@ -88,7 +90,9 @@ mod tests {
                         "config_id": null,
                         "seq_id": null
                     }
-                ]
+                ],
+                "dependencies": [],
+                "integrations": []
             }
         });
 
@@ -490,6 +494,8 @@ mod tests {
                 config_id: None,
                 seq_id: None,
             }],
+            dependencies: Vec::new(),
+            integrations: Vec::new(),
         });
 
         let serialized = serde_json::to_value(&payload).unwrap();
@@ -505,7 +511,9 @@ mod tests {
                         "config_id": null,
                         "seq_id": null
                     }
-                ]
+                ],
+                "dependencies": [],
+                "integrations": []
             }
         });
 

libdd-telemetry/src/data/payload.rs

@@ -48,6 +48,8 @@ pub enum ConfigurationOrigin {
 #[derive(Serialize, Debug)]
 pub struct AppStarted {
     pub configuration: Vec<Configuration>,
+    pub dependencies: Vec<Dependency>,
+    pub integrations: Vec<Integration>,
 }
 
 #[derive(Serialize, Debug)]

libdd-telemetry/src/data/payloads.rs

@@ -673,13 +673,17 @@ impl TelemetryWorker {
     fn build_app_started(&mut self) -> data::AppStarted {
         data::AppStarted {
             configuration: self.data.configurations.unflushed().cloned().collect(),
+            dependencies: self.data.dependencies.unflushed().cloned().collect(),
+            integrations: self.data.integrations.unflushed().cloned().collect(),
         }
     }
 
     fn app_started_sent_success(&mut self, p: &data::AppStarted) {
         self.data
             .configurations
             .removed_flushed(p.configuration.len());
+        self.data.dependencies.removed_flushed(p.dependencies.len());
+        self.data.integrations.removed_flushed(p.integrations.len());
     }
 
     fn payload_sent_success(&mut self, payload: &data::Payload) {