Add debug logging

Author: kinyoklion

libs/networking/src/curl_multi_manager.cpp

@@ -196,7 +196,7 @@ void CurlMultiManager::check_multi_info() {
             // Invoke completion callback
             if (callback) {
                 boost::asio::post(executor_, [callback = std::move(callback),
-                                      easy, result, handle]() {
+                                      result, handle]() {
                                       callback(handle, result);
                                   });
             }

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

@@ -326,6 +326,7 @@ int CurlClient::ProgressCallback(void* clientp,
                 now - context->last_progress_time);
 
             if (elapsed > *context->read_timeout) {
+                context->log_message("Read timeout, aborting curl transfer.");
                 return kCurlTransferAbort;
             }
         }

libs/server-sent-events/tests/curl_client_test.cpp

@@ -640,22 +640,28 @@ TEST(CurlClientTest, RespectsReadTimeout) {
 
     auto client = Builder(runner.context().get_executor(), "http://localhost:" + std::to_string(port))
         .receiver([&](Event e) { collector.add_event(std::move(e)); })
-        .errors([&](Error e) { collector.add_error(std::move(e)); })
+        .errors([&](Error e) {
+            std::cerr << "Error" << e.index() << std::endl;
+            collector.add_error(std::move(e));
+        })
+        .logger([&](const std::string& message) {
+            std::cerr << "log_message" << message << std::endl;
+        })
         .read_timeout(500ms)  // Short timeout for test
         .initial_reconnect_delay(50ms)
         .build();
 
     client->async_connect();
 
     // Should receive the first event
-    ASSERT_TRUE(collector.wait_for_events(1, 2000ms));
+    ASSERT_TRUE(collector.wait_for_events(1, 100ms));
 
     // Then should get a timeout error
-    ASSERT_TRUE(collector.wait_for_errors(1, 3000ms));
+    ASSERT_TRUE(collector.wait_for_errors(1, 1000ms));
 
     SimpleLatch shutdown_latch(1);
     client->async_shutdown([&] { shutdown_latch.count_down(); });
-    EXPECT_TRUE(shutdown_latch.wait_for(5000ms));
+    EXPECT_TRUE(shutdown_latch.wait_for(100ms));
 }
 
 // Resource management tests