jsonrpc: use json::stream_parser for responses

Author: ashtum

example/client/jsonrpc/cpp11.cpp

@@ -254,8 +254,7 @@ main(int, char*[])
         }
 
         // Install serializer service with default configuration
-        http_proto::serializer::config cfg;
-        http_proto::install_serializer_service(rts_ctx, cfg);
+        http_proto::install_serializer_service(rts_ctx, {});
 
         // Root certificates used for verification
         ssl_ctx.set_default_verify_paths();

example/client/jsonrpc/cpp20.cpp

@@ -166,8 +166,7 @@ main(int, char*[])
         }
 
         // Install serializer service with default configuration
-        http_proto::serializer::config cfg;
-        http_proto::install_serializer_service(rts_ctx, cfg);
+        http_proto::install_serializer_service(rts_ctx, {});
 
         // Root certificates used for verification
         ssl_ctx.set_default_verify_paths();

example/client/jsonrpc/jsonrpc/client.cpp

@@ -223,6 +223,33 @@ class stream_impl : public any_stream
     };
 };
 
+class json_sink : public http_proto::sink
+{
+    json::stream_parser& jpr_;
+
+public:
+    json_sink(json::stream_parser& jpr)
+        : jpr_(jpr)
+    {
+    }
+
+private:
+    results
+    on_write(
+        buffers::const_buffer b,
+        bool more) override
+    {
+        results ret;
+        ret.bytes = jpr_.write(
+            static_cast<const char*>(b.data()),
+            b.size(),
+            ret.ec);
+        if(!ret.ec && !more)
+            jpr_.finish(ret.ec);
+        return ret;
+    }
+};
+
 } //namespace
 
 // ----------------------------------------------
@@ -287,12 +314,13 @@ class client::request_op
             http_io::async_read_header(
                 *c_.stream_, c_.pr_, std::move(self));
 
+            c_.pr_.set_body<json_sink>(c_.jpr_);
             BOOST_ASIO_CORO_YIELD
             http_io::async_read(
                 *c_.stream_, c_.pr_, std::move(self));
 
             {
-                auto body = json::parse(c_.pr_.body(), ec);
+                auto body = c_.jpr_.release();
                 if(ec || !body.is_object())
                     return self.complete({ errc::invalid_response }, {});
                 auto& obj = body.get_object();

example/client/jsonrpc/jsonrpc/client.hpp

@@ -22,6 +22,7 @@
 #include <boost/http_proto/request.hpp>
 #include <boost/http_proto/response_parser.hpp>
 #include <boost/http_proto/serializer.hpp>
+#include <boost/json/stream_parser.hpp>
 #include <boost/json/value_to.hpp>
 #include <boost/rts/context_fwd.hpp>
 #include <boost/url/url.hpp>
@@ -36,6 +37,7 @@ class client
     boost::http_proto::serializer sr_;
     boost::http_proto::response_parser pr_;
     boost::http_proto::request req_;
+    boost::json::stream_parser jpr_;
     std::uint64_t id_ = 0;
 
 public: