commit 6fde95fad082fa7d6fc54f2ef8584e06fb116d42
author Ed Tanous <edtanous@google.com> Thu Jun 01 07:33:34 2023 -0700
committer Ed Tanous <ed@tanous.net> Thu Jun 01 20:43:11 2023 +0000
tree 31865ca598fcb00af96d5d33824cf53ae1df4f36
parent 88ada3bc05ea247b6c8a24db49ebfdd268c17f4d

Server-sent-event fixes

This makes several changes to server-sent events to allow it to merge
to master.  The routing system has been removed in leiu of using
content-type eventstream detection.  Timers have been added to the
sse connections, and sse connections now rely on async_wait, rather
than a full read.

Tested: WIP

Signed-off-by: Ed Tanous <edtanous@google.com>
Change-Id: Id0ff0ebc2b3a795b3dba008e440556a9fdd882c2

http/http_connection.hpp

diff --git a/http/http_connection.hpp b/http/http_connection.hpp
index 1b85c6b..7ae22e9 100644
--- a/http/http_connection.hpp
+++ b/http/http_connection.hpp
@@ -243,12 +243,14 @@
             [self(shared_from_this())](crow::Response& thisRes) {
             self->completeRequest(thisRes);
         });
-
+        bool isSse =
+            isContentTypeAllowed(req->getHeaderValue("Accept"),
+                                 http_helpers::ContentType::EventStream, false);
         if ((thisReq.isUpgrade() &&
              boost::iequals(
                  thisReq.getHeaderValue(boost::beast::http::field::upgrade),
                  "websocket")) ||
-            (Handler::isSseRoute(*req)))
+            isSse)
         {
             asyncResp->res.setCompleteRequestHandler(
                 [self(shared_from_this())](crow::Response& thisRes) {