Added HTTP Client and Server Example

Author: cinemast

.circleci/config.yml

@@ -22,6 +22,9 @@ jobs:
           command: lcov --directory . --capture --output-file coverage.info && lcov --remove coverage.info '/usr/*' --output-file coverage.info
       - codecov/upload:
           file: coverage.info
+      - run:
+          name: Run example
+          command: ./example-warehouse
   "build-linux-clang":
     docker:
       - image: "debian:buster"
@@ -35,8 +38,11 @@ jobs:
           name: Build
           command: cmake -DCOMPILE_TESTS=ON -DCOMPILE_EXAMPLES=ON . && cmake --build .
       - run:
-          nmae: Run tests
+          name: Run tests
           command: ./jsonrpccpp-test -s
+      - run:
+          name: Run example
+          command: ./example-warehouse
   "build-osx-clang":
     macos:
       xcode: "10.2.1"
@@ -50,8 +56,11 @@ jobs:
           name: Build
           command: cmake -DCOMPILE_TESTS=ON -DCOMPILE_EXAMPLES=ON . && cmake --build .
       - run:
-          nmae: Run tests
+          name: Run tests
           command: ./jsonrpccpp-test -s
+      - run:
+          name: Run example
+          command: ./example-warehouse
 workflows:
   version: 2
   build:

CMakeLists.txt

@@ -29,9 +29,11 @@ if (COMPILE_TESTS)
 endif ()
 
 if (COMPILE_EXAMPLES)
+    find_package(Threads)
     add_executable(example-warehouse examples/warehouse/main.cpp examples/warehouse/warehouseapp.cpp examples/warehouse/types.h examples/inmemoryconnector.hpp)
-    target_link_libraries(example-warehouse json-rpc-cxx)
+    target_link_libraries(example-warehouse json-rpc-cxx Threads::Threads)
     target_include_directories(example-warehouse PRIVATE vendor examples)
+    add_test(NAME example COMMAND example-warehouse)
 endif ()
 
 

appveyor.yml

@@ -6,3 +6,4 @@ build_script:
   - cmake -DCOMPILE_TESTS=ON -DCOMPILE_EXAMPLES=ON .
   - cmake --build .
   - Debug\jsonrpccpp-test.exe -s
+  - Debug\example-warehouse.exe

examples/cpphttplibconnector.hpp

@@ -0,0 +1,52 @@
+#pragma once
+
+#include <cpp-httplib/httplib.h>
+#include <jsonrpccxx/iclientconnector.hpp>
+#include <jsonrpccxx/server.hpp>
+#include <string>
+
+class CppHttpLibClientConnector : public jsonrpccxx::IClientConnector {
+public:
+  explicit CppHttpLibClientConnector(const std::string &host, int port) : httpClient(host.c_str(), port) {}
+  std::string Send(const std::string &request) override {
+    auto res = httpClient.Post("/jsonrpc", request, "application/json");
+    if (!res || res->status != 200) {
+      throw jsonrpccxx::JsonRpcException(-32003, "client connector error, received status != 200");
+    }
+    return res->body;
+  }
+
+private:
+  httplib::Client httpClient;
+};
+
+class CppHttpLibServerConnector {
+public:
+  explicit CppHttpLibServerConnector(jsonrpccxx::JsonRpcServer &server, int port) : server(server), port(port) {
+    httpServer.Post("/jsonrpc", [&](const httplib::Request &req, httplib::Response &res) {
+      res.status = 200;
+      res.set_content(server.HandleRequest(req.body), "application/json");
+    });
+  }
+  virtual ~CppHttpLibServerConnector() { StopListening(); }
+
+  bool StartListening() {
+    if (httpServer.is_running())
+      return false;
+    this->thread = std::thread([this]() { this->httpServer.listen("localhost", port); });
+    return true;
+  }
+
+  void StopListening() {
+    if (httpServer.is_running()) {
+      httpServer.stop();
+      this->thread.join();
+    }
+  }
+
+private:
+  std::thread thread;
+  jsonrpccxx::JsonRpcServer &server;
+  httplib::Server httpServer;
+  int port;
+};

examples/inmemoryconnector.hpp

@@ -2,6 +2,7 @@
 #include <jsonrpccxx/iclientconnector.hpp>
 #include <jsonrpccxx/server.hpp>
 
+//This class is server and client connector at the same time.
 class InMemoryConnector : public jsonrpccxx::IClientConnector {
 public:
   explicit InMemoryConnector(jsonrpccxx::JsonRpcServer &server) : server(server) {}

examples/warehouse/main.cpp

@@ -1,4 +1,5 @@
 #include "inmemoryconnector.hpp"
+#include "cpphttplibconnector.hpp"
 #include "warehouseapp.hpp"
 
 #include <iostream>
@@ -18,17 +19,9 @@ class WareHouseClient {
   JsonRpcClient &client;
 };
 
-int main() {
-  JsonRpc2Server rpcServer;
-  InMemoryConnector connector(rpcServer);
-  JsonRpcClient client(connector, version::v2);
-
-  // Bindings
+void doWarehouseStuff(IClientConnector &clientConnector) {
+  JsonRpcClient client(clientConnector, version::v2);
   WareHouseClient appClient(client);
-  WarehouseServer app;
-  rpcServer.Add("GetProduct", GetHandle(&WarehouseServer::GetProduct, app), {"id"});
-  rpcServer.Add("AddProduct", GetHandle(&WarehouseServer::AddProduct, app), {"product"});
-
   Product p = {"0xff", 22.4, "Product 1", category::cash_carry};
   cout << "Adding product: " << std::boolalpha << appClient.AddProduct(p) << "\n";
 
@@ -38,7 +31,27 @@ int main() {
     appClient.GetProduct("0xff2");
   } catch (JsonRpcException &e) {
     cerr << "Error finding product: " << e.what() << "\n";
-    return 1;
   }
+}
+
+int main() {
+  JsonRpc2Server rpcServer;
+
+  // Bindings
+  WarehouseServer app;
+  rpcServer.Add("GetProduct", GetHandle(&WarehouseServer::GetProduct, app), {"id"});
+  rpcServer.Add("AddProduct", GetHandle(&WarehouseServer::AddProduct, app), {"product"});
+
+  cout << "Running in-memory example" << "\n";
+  InMemoryConnector inMemoryConnector(rpcServer);
+  doWarehouseStuff(inMemoryConnector);
+
+  cout << "Running http example" << "\n";
+  CppHttpLibServerConnector httpServer(rpcServer, 8484);
+  cout << "Starting http server: " << std::boolalpha << httpServer.StartListening() << "\n";
+  CppHttpLibClientConnector httpClient("localhost", 8484);
+  std::this_thread::sleep_for(0.5s);
+  doWarehouseStuff(httpClient);
+
   return 0;
 }

vendor/cpp-httplib/LICENSE

@@ -0,0 +1,21 @@
+The MIT License (MIT)
+
+Copyright (c) 2017 yhirose
+
+Permission is hereby granted, free of charge, to any person obtaining a copy
+of this software and associated documentation files (the "Software"), to deal
+in the Software without restriction, including without limitation the rights
+to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
+copies of the Software, and to permit persons to whom the Software is
+furnished to do so, subject to the following conditions:
+
+The above copyright notice and this permission notice shall be included in all
+copies or substantial portions of the Software.
+
+THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
+FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
+AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
+LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
+OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
+SOFTWARE.