. /src /json /json_body.cpp
0.00% Lines (0/6) 0.00% Functions (0/2)
[ ] prev/next file n p prev/next uncovered line
TLA Baseline Branch
Line Hits Code Line Hits Code
1   // 1   //
2   // Copyright (c) 2025 Vinnie Falco (vinnie.falco@gmail.com) 2   // Copyright (c) 2025 Vinnie Falco (vinnie.falco@gmail.com)
3   // 3   //
4   // Distributed under the Boost Software License, Version 1.0. (See accompanying 4   // Distributed under the Boost Software License, Version 1.0. (See accompanying
5   // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt) 5   // file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
6   // 6   //
7   // Official repository: https://github.com/cppalliance/http 7   // Official repository: https://github.com/cppalliance/http
8   // 8   //
9   9  
10   #include <boost/http/json/json_body.hpp> 10   #include <boost/http/json/json_body.hpp>
11   #include <boost/http/json/json_sink.hpp> 11   #include <boost/http/json/json_sink.hpp>
12   #include <boost/http/field.hpp> 12   #include <boost/http/field.hpp>
13   #include <boost/http/method.hpp> 13   #include <boost/http/method.hpp>
14   #include <boost/capy/io/push_to.hpp> 14   #include <boost/capy/io/push_to.hpp>
15   #include <boost/json/value.hpp> 15   #include <boost/json/value.hpp>
16   16  
17   namespace boost { 17   namespace boost {
18   namespace http { 18   namespace http {
19   19  
MISUBC 20   ✗ json_body:: 20   ✗ json_body::
MISUBC 21   ✗ json_body(json_body_options options) noexcept 21   ✗ json_body(json_body_options options) noexcept
MISUBC 22   ✗ : options_(std::move(options)) 22   ✗ : options_(std::move(options))
23   { 23   {
MISUBC 24   ✗ } 24   ✗ }
25   25  
26   route_task 26   route_task
MISUBC 27   ✗ json_body:: 27   ✗ json_body::
28   operator()(route_params& p) const 28   operator()(route_params& p) const
29   { 29   {
30   if( ! p.is_method(method::post) || 30   if( ! p.is_method(method::post) ||
31   ! p.req.value_or( 31   ! p.req.value_or(
32   field::content_type, "") 32   field::content_type, "")
33   .starts_with("application/json")) 33   .starts_with("application/json"))
34   co_return route_next; 34   co_return route_next;
35   35  
36   json_sink sink( 36   json_sink sink(
37   options_.storage, options_.parse_opts); 37   options_.storage, options_.parse_opts);
38   auto [ec, n] = co_await capy::push_to( 38   auto [ec, n] = co_await capy::push_to(
39   p.req_body, sink); 39   p.req_body, sink);
40   if(ec) 40   if(ec)
41   co_return route_error(ec); 41   co_return route_error(ec);
42   42  
43   p.route_data.emplace<json::value>( 43   p.route_data.emplace<json::value>(
44   sink.release()); 44   sink.release());
45   45  
46   co_return route_next; 46   co_return route_next;
MISUBC 47   ✗ } 47   ✗ }
48   48  
49   } // namespace http 49   } // namespace http
50   } // namespace boost 50   } // namespace boost