implement read timeout capability in contract tests

Author: cwaldren-ld

contract-tests/sse-contract-tests/src/entity_manager.cpp

@@ -35,6 +35,11 @@ std::optional<std::string> EntityManager::create(ConfigParams const& params) {
             std::chrono::milliseconds(*params.readTimeoutMs));
     }
 
+    if (params.initialDelayMs) {
+        client_builder.initial_reconnect_delay(
+            std::chrono::milliseconds(*params.initialDelayMs));
+    }
+
     client_builder.logger([this](std::string msg) {
         LD_LOG(logger_, LogLevel::kDebug) << std::move(msg);
     });

contract-tests/sse-contract-tests/src/event_outbox.cpp

@@ -93,6 +93,8 @@ EventOutbox::RequestType EventOutbox::build_request(
                         break;
                     case Error::UnrecoverableClientError:
                         msg.comment = "unrecoverable client error";
+                    case Error::ReadTimeout:
+                        msg.comment = "read timeout";
                     default:
                         msg.comment = "unspecified error";
                 }

contract-tests/sse-contract-tests/src/main.cpp

@@ -20,7 +20,7 @@ int main(int argc, char* argv[]) {
     launchdarkly::Logger logger{
         std::make_unique<ConsoleBackend>("sse-contract-tests")};
 
-    const std::string default_port = "8123";
+    std::string const default_port = "8123";
     std::string port = default_port;
     if (argc == 2) {
         port =
@@ -38,6 +38,7 @@ int main(int argc, char* argv[]) {
         srv.add_capability("report");
         srv.add_capability("post");
         srv.add_capability("reconnection");
+        srv.add_capability("read-timeout");
 
         net::signal_set signals{ioc, SIGINT, SIGTERM};
 

libs/server-sent-events/include/launchdarkly/sse/error.hpp

@@ -6,5 +6,6 @@ enum class Error {
     NoContent = 1,
     InvalidRedirectLocation = 2,
     UnrecoverableClientError = 3,
+    ReadTimeout = 4,
 };
 }

libs/server-sent-events/src/client.cpp

@@ -309,6 +309,7 @@ class FoxyClient : public Client,
             if (shutting_down_) {
                 return;
             }
+            errors_(Error::ReadTimeout);
             return do_backoff(
                 "aborting read of response body (timeout/shutdown)");
         }