fix content view (#568)

Author: qicosmos

include/cinatra/coro_http_connection.hpp

@@ -204,7 +204,7 @@ class coro_http_connection
         }
         else {
           if (default_handler_) {
-            default_handler_(request_, response_);
+            co_await default_handler_(request_, response_);
           }
           else {
             bool is_exist = false;
@@ -409,7 +409,8 @@ class coro_http_connection
   void set_multi_buf(bool r) { multi_buf_ = r; }
 
   void set_default_handler(
-      std::function<void(coro_http_request &, coro_http_response &)> &handler) {
+      std::function<async_simple::coro::Lazy<void>(
+          coro_http_request &, coro_http_response &)> &handler) {
     default_handler_ = handler;
   }
 
@@ -904,7 +905,8 @@ class coro_http_connection
 #endif
   bool need_shrink_every_time_ = false;
   bool multi_buf_ = true;
-  std::function<void(coro_http_request &, coro_http_response &)>
+  std::function<async_simple::coro::Lazy<void>(coro_http_request &,
+                                               coro_http_response &)>
       default_handler_ = nullptr;
   std::string chunk_size_str_;
   std::string remote_addr_;

include/cinatra/coro_http_response.hpp

@@ -173,21 +173,19 @@ class coro_http_response {
                 : resp_str.append(CONN_CLOSE_SV);
     }
 
-    if (content_view_.empty()) {
-      resp_str.append(content_);
-    }
-    else {
-      resp_str.append(content_view_);
-    }
-
     append_header_str(resp_str, resp_headers_);
 
     if (!resp_header_span_.empty()) {
       append_header_str(resp_str, resp_header_span_);
     }
 
     resp_str.append(CRCF);
-    resp_str.append(content_);
+    if (content_view_.empty()) {
+      resp_str.append(content_);
+    }
+    else {
+      resp_str.append(content_view_);
+    }
   }
 
   void append_header_str(auto &resp_str, auto &resp_headers) {

include/cinatra/coro_http_server.hpp

@@ -550,8 +550,9 @@ class coro_http_server {
 
   void set_shrink_to_fit(bool r) { need_shrink_every_time_ = r; }
 
-  void set_default_handler(
-      std::function<void(coro_http_request &, coro_http_response &)> handler) {
+  void set_default_handler(std::function<async_simple::coro::Lazy<void>(
+                               coro_http_request &, coro_http_response &)>
+                               handler) {
     default_handler_ = std::move(handler);
   }
 
@@ -923,7 +924,8 @@ class coro_http_server {
 #endif
   coro_http_router router_;
   bool need_shrink_every_time_ = false;
-  std::function<void(coro_http_request &, coro_http_response &)>
+  std::function<async_simple::coro::Lazy<void>(coro_http_request &,
+                                               coro_http_response &)>
       default_handler_ = nullptr;
 };
 

tests/test_cinatra.cpp

@@ -399,10 +399,22 @@ async_simple::coro::Lazy<void> test_collect_all() {
 
 TEST_CASE("test default http handler") {
   coro_http_server server(1, 9001);
-  server.set_default_handler([](coro_http_request &req,
-                                coro_http_response &resp) {
-    resp.set_status_and_content(status_type::ok, "It is from default handler");
-  });
+  server.set_default_handler(
+      [](coro_http_request &req,
+         coro_http_response &resp) -> async_simple::coro::Lazy<void> {
+        resp.set_status_and_content(status_type::ok,
+                                    "It is from default handler");
+        co_return;
+      });
+  server.set_http_handler<POST>(
+      "/view",
+      [](coro_http_request &req,
+         coro_http_response &resp) -> async_simple::coro::Lazy<void> {
+        resp.set_delay(true);
+        resp.set_status_and_content_view(status_type::ok,
+                                         req.get_body());  // no copy
+        co_await resp.get_conn()->reply();
+      });
   server.async_start();
 
   for (int i = 0; i < 5; i++) {
@@ -414,6 +426,10 @@ TEST_CASE("test default http handler") {
     CHECK(data.resp_body == "It is from default handler");
     data = client.get("/any");
     CHECK(data.resp_body == "It is from default handler");
+    data = async_simple::coro::syncAwait(
+        client.async_post("/view", "post string", req_content_type::string));
+    CHECK(data.status == 200);
+    CHECK(data.resp_body == "post string");
   }
 }
 
@@ -562,6 +578,7 @@ TEST_CASE("test head put and some other request") {
         std::string result = ec ? "delete failed" : "delete ok";
         resp.set_status_and_content(status_type::ok, result);
       });
+
   server.async_start();
   std::this_thread::sleep_for(300ms);