Refactor HTTP examples and tests to use updated SSE endpoint; normalize CRLF in SSE chunk parsing

Co-authored-by: Copilot <copilot@github.com>

Author: kzhdev

CHANGELOG.md

@@ -1,8 +1,12 @@
-# [v2.0.1] - 2026-04-27
+# [v2.0.1] - 2026-04-29
+
+## Chaged
+- updated SSE endpoint in excamples and tests
 
 ## Fixed
 - WebSocket `co_spawn` completion handler now guards `on_error_()` with a `run_` check, suppressing spurious error callbacks after shutdown.
 - Fixed use-after-free in WebSocket tests where `[&]` lambda captures referenced destroyed stack variables when async callbacks fired via IOCP after the test function returned. Affected tests (`ConnectToEchoServer`, `InvalidHostnameError`, `MultipleErrorCallbacks`, `ReconnectAfterError`, `PlainWebsocket_UrlParsing`) now use `shared_ptr` captures to extend captured variable lifetimes.
+- normalize CRLF in SSE chunk parsing
 
 ## Tests
 - Added 10 comprehensive `Reconnect_*` tests verifying correct behavior when reconnecting by creating a new `Websocket` instance during normal operation (service thread always running):

examples/http_awaitable_client.cpp

@@ -1,7 +1,7 @@
+#include <slick/logger.hpp>
 #include <slick/net/http.hpp>
 #include <slick/net/logging.hpp>
 #include <nlohmann/json.hpp>
-#include <slick/logger.hpp>
 #include <boost/asio.hpp>
 
 using namespace slick::net;

examples/http_stream_client.cpp

@@ -39,7 +39,7 @@ int main()
     // Create HTTP stream connection
     // This example uses a test SSE endpoint that sends time updates
     auto stream = std::make_shared<HttpStream>(
-        "https://sse.dev/test",
+        "https://stream.wikimedia.org/v2/stream/recentchange",
         []() {
             LOG_INFO("Stream connected");
         },

src/http_stream.cpp

@@ -421,6 +421,20 @@ void HttpStream::parse_sse_chunk(const char* data, size_t size) {
     // Append new data to buffer
     sse_buffer_.append(data, size);
 
+    // Normalize CRLF and bare CR to LF so event/line splitting is uniform
+    for (size_t i = 0; i < sse_buffer_.size(); ) {
+        if (sse_buffer_[i] == '\r') {
+            if (i + 1 < sse_buffer_.size() && sse_buffer_[i + 1] == '\n') {
+                sse_buffer_.erase(i, 1); // remove \r, keep \n
+            } else {
+                sse_buffer_[i] = '\n'; // bare \r -> \n
+                ++i;
+            }
+        } else {
+            ++i;
+        }
+    }
+
     // Process complete events (separated by double newline)
     size_t pos = 0;
     while ((pos = sse_buffer_.find("\n\n")) != std::string::npos) {

tests/http_tests.cpp

@@ -251,9 +251,12 @@ TEST_F(HttpTest, SyncDelete_WithBody) {
 
     EXPECT_TRUE(response.is_ok()) << "Status: " << response.result_code << ", Response: " << response.result_text;
     EXPECT_EQ(response.result_code, 200);
+    EXPECT_FALSE(response.result_text.empty());
 
-        EXPECT_TRUE(response.is_ok());
-    EXPECT_EQ(response.result_code, 200);
+    EXPECT_NO_THROW({
+        auto json = nlohmann::json::parse(response.result_text);
+        EXPECT_TRUE(json.contains("json") || json.contains("data"));
+    });
 }
 
 // ======================== Asynchronous GET Tests ========================
@@ -530,7 +533,7 @@ TEST_F(HttpTest, HttpStream_BasicConnection) {
     std::string last_error;
 
     auto stream = std::make_shared<HttpStream>(
-        "https://sse.dev/test",
+        "https://stream.wikimedia.org/v2/stream/recentchange",
         [&]() {
             connected.store(true);
         },
@@ -573,7 +576,7 @@ TEST_F(HttpTest, HttpStream_CustomHeaders) {
 
     std::vector<std::pair<std::string, std::string>> headers = {{"X-Custom-Header", "test"}};
     auto stream = std::make_shared<HttpStream>(
-        "https://sse.dev/test",
+        "https://stream.wikimedia.org/v2/stream/recentchange",
         [&]() { connected.store(true); },
         [&]() { disconnected.store(true); },
         [&](const char* data, size_t size) {
@@ -637,7 +640,7 @@ TEST_F(HttpTest, HttpStream_MultipleStreams) {
     // Create 3 concurrent streams
     for (int i = 0; i < 3; ++i) {
         auto stream = std::make_shared<HttpStream>(
-            "https://sse.dev/test",
+            "https://stream.wikimedia.org/v2/stream/recentchange",
             [&]() { connected_count++; },
             [&]() { disconnected_count++; },
             [&](const char*, size_t) { data_count++; },
@@ -671,7 +674,7 @@ TEST_F(HttpTest, HttpStream_StatusCheck) {
     std::atomic<bool> disconnected{false};
 
     auto stream = std::make_shared<HttpStream>(
-        "https://sse.dev/test",
+        "https://stream.wikimedia.org/v2/stream/recentchange",
         [&]() { connected.store(true); },
         [&]() { disconnected.store(true); },
         [](const char*, size_t) {},