fix: remote config polling parsing

dmehala · dmehala · commit de92b216c714 · 2024-05-22T21:46:18.000+02:00
According to the Remote Configuration specification,
`DD_REMOTE_CONFIG_POLL_INTERVAL_SECONDS` support floating point input
and can be set to `0`.
diff --git a/src/datadog/datadog_agent_config.cpp b/src/datadog/datadog_agent_config.cpp
@@ -21,7 +21,7 @@ Expected<DatadogAgentConfig> load_datadog_agent_env_config() {
 
   if (auto raw_rc_poll_interval_value =
           lookup(environment::DD_REMOTE_CONFIG_POLL_INTERVAL_SECONDS)) {
-    auto res = parse_int(*raw_rc_poll_interval_value, 10);
+    auto res = parse_double(*raw_rc_poll_interval_value);
     if (auto error = res.if_error()) {
       return error->with_prefix(
           "DatadogAgent: Remote Configuration poll interval error ");
@@ -114,12 +114,13 @@ Expected<FinalizedDatadogAgentConfig> finalize_config(
                  "milliseconds."};
   }
 
-  if (int rc_poll_interval_seconds =
+  if (double rc_poll_interval_seconds =
           value_or(env_config->remote_configuration_poll_interval_seconds,
-                   user_config.remote_configuration_poll_interval_seconds, 5);
-      rc_poll_interval_seconds > 0) {
+                   user_config.remote_configuration_poll_interval_seconds, 5.0);
+      rc_poll_interval_seconds >= 0.0) {
     result.remote_configuration_poll_interval =
-        std::chrono::seconds(rc_poll_interval_seconds);
+        std::chrono::duration_cast<std::chrono::milliseconds>(
+            std::chrono::duration<double>(rc_poll_interval_seconds));
   } else {
     return Error{Error::DATADOG_AGENT_INVALID_REMOTE_CONFIG_POLL_INTERVAL,
                  "DatadogAgent: Remote Configuration poll interval must be a "
diff --git a/src/datadog/datadog_agent_config.h b/src/datadog/datadog_agent_config.h
@@ -61,7 +61,7 @@ struct DatadogAgentConfig {
   Optional<bool> remote_configuration_enabled;
   // How often, in seconds, to query the Datadog Agent for remote configuration
   // updates.
-  Optional<int> remote_configuration_poll_interval_seconds;
+  Optional<double> remote_configuration_poll_interval_seconds;
 
   static Expected<HTTPClient::URL> parse(StringView);
 };
diff --git a/test/test_tracer_config.cpp b/test/test_tracer_config.cpp
@@ -446,14 +446,6 @@ TEST_CASE("TracerConfig::agent") {
   }
 
   SECTION("remote configuration poll interval") {
-    SECTION("cannot be zero") {
-      config.agent.remote_configuration_poll_interval_seconds = 0;
-      auto finalized = finalize_config(config);
-      REQUIRE(!finalized);
-      REQUIRE(finalized.error().code ==
-              Error::DATADOG_AGENT_INVALID_REMOTE_CONFIG_POLL_INTERVAL);
-    }
-
     SECTION("cannot be negative") {
       config.agent.remote_configuration_poll_interval_seconds = -1337;
       auto finalized = finalize_config(config);
@@ -491,7 +483,7 @@ TEST_CASE("TracerConfig::agent") {
                                  "ddog"};
         auto finalized = finalize_config(config);
         REQUIRE(!finalized);
-        REQUIRE(finalized.error().code == Error::INVALID_INTEGER);
+        REQUIRE(finalized.error().code == Error::INVALID_DOUBLE);
       }
     }
   }

Original file line number	Diff line number	Diff line change
`@@ -446,14 +446,6 @@ TEST_CASE("TracerConfig::agent") {`
`446`	`446`	`}`
`447`	`447`
`448`	`448`	`SECTION("remote configuration poll interval") {`
`449`		`- SECTION("cannot be zero") {`
`450`		`- config.agent.remote_configuration_poll_interval_seconds = 0;`
`451`		`- auto finalized = finalize_config(config);`
`452`		`- REQUIRE(!finalized);`
`453`		`- REQUIRE(finalized.error().code ==`
`454`		`- Error::DATADOG_AGENT_INVALID_REMOTE_CONFIG_POLL_INTERVAL);`
`455`		`- }`
`456`		`-`
`457`	`449`	`SECTION("cannot be negative") {`
`458`	`450`	`config.agent.remote_configuration_poll_interval_seconds = -1337;`
`459`	`451`	`auto finalized = finalize_config(config);`
`@@ -491,7 +483,7 @@ TEST_CASE("TracerConfig::agent") {`
`491`	`483`	`"ddog"};`
`492`	`484`	`auto finalized = finalize_config(config);`
`493`	`485`	`REQUIRE(!finalized);`
`494`		`- REQUIRE(finalized.error().code == Error::INVALID_INTEGER);`
	`486`	`+ REQUIRE(finalized.error().code == Error::INVALID_DOUBLE);`
`495`	`487`	`}`
`496`	`488`	`}`
`497`	`489`	`}`