UPD | some improvements

Author: xiadnoring

CMakeLists.txt

@@ -694,6 +694,8 @@ set(MANAPIHTTP_HTTP_FILES
         include/ext/pq/AsyncPostgreValue.hpp
         include/ext/pq/AsyncPostgreValueTypes.hpp
         include/ext/pq/AsyncPostgreNotification.hpp
+        include/ext/pq/AsyncPostgrePool.hpp
+        include/ext/pq/AsyncPostgreImpl.ipp
         include/std/ManapiAsyncParallelRun.hpp
         include/ManapiFetch2.hpp
         include/ManapiTimerObject.hpp
@@ -916,7 +918,7 @@ if (MANAPIHTTP_BUILD_TYPE STREQUAL "exe" OR MANAPIHTTP_BUILD_TYPE STREQUAL "test
     endif ()
 
     target_compile_definitions(${PROJECT_NAME} PRIVATE MANAPIHTTP_HTTP_AS_EXECUTABLE)
-    target_sources(${PROJECT_NAME} PRIVATE main.cpp handlers.hpp handlers.cpp ${MANAPIHTTP_HTTP_FILES} ${PROTO_SRCS} ${PROTO_HDRS})
+    target_sources(${PROJECT_NAME} PRIVATE main.cpp impl.cpp handlers.hpp handlers.cpp ${MANAPIHTTP_HTTP_FILES} ${PROTO_SRCS} ${PROTO_HDRS})
 
     #    target_sources(${PROJECT_NAME} PUBLIC
     #            FILE_SET CXX_MODULES

README.md

@@ -297,8 +297,8 @@ public:
 
     // Assembles the client's payload, sends it and presents the response back
     // from the server.
-    manapi::future<manapi::error::status_or<std::string>> SayHello(const std::string& user) {
-        using promise = manapi::async::promise_sync<manapi::error::status_or<std::string>>;
+    manapi::future<manapi::status_or<std::string>> SayHello(const std::string& user) {
+        using promise = manapi::async::promise_sync<manapi::status_or<std::string>>;
         // Data we are sending to the server.
         helloworld::HelloRequest request;
         request.set_name(user);
@@ -321,7 +321,7 @@ public:
 
                         auto msg = status.error_message();
                         manapi_log_debug("grpc client failed due to %s", msg.data());
-                        resolve(manapi::error::status_internal("grpc client: something gets wrong"));
+                        resolve(manapi::status_internal("grpc client: something gets wrong"));
                     }
                     else {
                         ctx->event_loop()->custom_callback([resolve = std::move(resolve), &reply, status = std::move(status)] (manapi::event_loop *ev) -> void {
@@ -332,14 +332,14 @@ public:
 
                             auto msg = status.error_message();
                             manapi_log_debug("grpc client failed due to %s", msg.data());
-                            resolve(manapi::error::status_internal("grpc client: something gets wrong"));
+                            resolve(manapi::status_internal("grpc client: something gets wrong"));
                         }).unwrap();
                     }
               });
             }
             catch (std::exception const &e) {
                 manapi_log_error(e.what());
-               resolve(manapi::error::status_internal("sayhello failed"));
+               resolve(manapi::status_internal("sayhello failed"));
            }
         });
 }
@@ -377,9 +377,9 @@ int main () {
                 res.log();
                 res.unwrap();
 
-                res = co_await grpc_server.start([&] (grpc::ServerBuilder &builder) -> manapi::error::status {
+                res = co_await grpc_server.start([&] (grpc::ServerBuilder &builder) -> manapi::status {
                     builder.RegisterService(service.get());
-                    return manapi::error::status_ok();
+                    return manapi::status_ok();
                 });
                 
                 res.log();

impl.cpp

@@ -0,0 +1,2 @@
+
+#include "ext/pq/AsyncPostgreImpl.ipp"