feat: report telemetry logs

Author: dmehala

include/datadog/telemetry/telemetry.h

@@ -29,6 +29,9 @@ class Telemetry {
             std::vector<std::shared_ptr<Metric>> metrics);
 
   ~Telemetry() = default;
+
+  void log_error(std::string message);
+  void log_warning(std::string message);
 };
 
 }  // namespace telemetry

src/datadog/telemetry/telemetry.cpp

@@ -39,5 +39,13 @@ Telemetry::Telemetry(FinalizedConfiguration config,
       std::vector<std::shared_ptr<remote_config::Listener>>{});
 }
 
+void Telemetry::log_error(std::string message) {
+  tracer_telemetry_->log(std::move(message), LogLevel::ERROR);
+}
+
+void Telemetry::log_warning(std::string message) {
+  tracer_telemetry_->log(std::move(message), LogLevel::WARNING);
+}
+
 }  // namespace telemetry
 }  // namespace datadog

src/datadog/tracer_telemetry.cpp

@@ -292,6 +292,27 @@ std::string TracerTelemetry::heartbeat_and_telemetry() {
     batch_payloads.emplace_back(std::move(generate_metrics));
   }
 
+  if (!logs_.empty()) {
+    auto encoded_logs = nlohmann::json::array();
+    for (const auto& log : logs_) {
+      auto encoded =
+          nlohmann::json{{"message", log.message}, {"level", log.level}};
+      encoded_logs.emplace_back(std::move(encoded));
+    }
+
+    assert(!encoded_logs.empty());
+
+    auto logs_payload = nlohmann::json::object({
+        {"request_type", "logs"},
+        {"payload",
+         nlohmann::json{
+             {"logs", encoded_logs},
+         }},
+    });
+
+    batch_payloads.emplace_back(std::move(logs_payload));
+  }
+
   auto telemetry_body = generate_telemetry_body("message-batch");
   telemetry_body["payload"] = batch_payloads;
   auto message_batch_payload = telemetry_body.dump();
@@ -348,6 +369,27 @@ std::string TracerTelemetry::app_closing() {
     batch_payloads.emplace_back(std::move(generate_metrics));
   }
 
+  if (!logs_.empty()) {
+    auto encoded_logs = nlohmann::json::array();
+    for (const auto& log : logs_) {
+      auto encoded =
+          nlohmann::json{{"message", log.message}, {"level", log.level}};
+      encoded_logs.emplace_back(std::move(encoded));
+    }
+
+    assert(!encoded_logs.empty());
+
+    auto logs_payload = nlohmann::json::object({
+        {"request_type", "logs"},
+        {"payload",
+         nlohmann::json{
+             {"logs", encoded_logs},
+         }},
+    });
+
+    batch_payloads.emplace_back(std::move(logs_payload));
+  }
+
   auto telemetry_body = generate_telemetry_body("message-batch");
   telemetry_body["payload"] = batch_payloads;
   auto message_batch_payload = telemetry_body.dump();

src/datadog/tracer_telemetry.h

@@ -38,6 +38,7 @@
 
 #include "json.hpp"
 #include "platform_util.h"
+#include "telemetry/log.h"
 
 namespace datadog {
 namespace tracing {
@@ -47,7 +48,7 @@ struct SpanDefaults;
 
 class TracerTelemetry {
   bool enabled_ = false;
-  bool debug_ = false;
+  bool debug_ = true;
   Clock clock_;
   std::shared_ptr<Logger> logger_;
   HostInfo host_info_;
@@ -120,6 +121,8 @@ class TracerTelemetry {
 
   std::vector<std::shared_ptr<telemetry::Metric>> user_metrics_;
 
+  std::vector<telemetry::LogMessage> logs_;
+
  public:
   TracerTelemetry(
       bool enabled, const Clock& clock, const std::shared_ptr<Logger>& logger,
@@ -151,6 +154,10 @@ class TracerTelemetry {
   std::string app_closing();
   // Construct an `app-client-configuration-change` message.
   std::string configuration_change();
+
+  inline void log(std::string message, telemetry::LogLevel level) {
+    logs_.emplace_back(telemetry::LogMessage{std::move(message), level});
+  }
 };
 
 }  // namespace tracing