Drop HTTP transport (#124)

* Drop HTTP transport

* Use Ubunty xenial in travis

Author: awegrzyn

.travis.yml

@@ -1,6 +1,5 @@
 sudo: required
 language: cpp
-dist: trusty
 matrix:
   allow_failures:
     - os: linux
@@ -15,6 +14,7 @@ matrix:
       osx_image: xcode10
       env: TOOL=test
     - os: linux
+      dist: xenial
       env: TOOL=test
       addons:
         apt:
@@ -24,11 +24,12 @@ matrix:
             - gcc-8
             - g++-8
             - cmake
-            - libboost-system1.55-dev
-            - libboost-filesystem1.55-dev
-            - libboost-test1.55-dev
-            - libboost-program-options1.55-dev
+            - libboost-system1.58-dev
+            - libboost-filesystem1.58-dev
+            - libboost-test1.58-dev
+            - libboost-program-options1.58-dev
     - os: linux
+      dist: xenial
       env: TOOL=coverage
       addons:
         apt:
@@ -44,10 +45,10 @@ matrix:
             - doxygen-latex
             - doxygen-gui
             - graphviz
-            - libboost-system1.55-dev
-            - libboost-filesystem1.55-dev
-            - libboost-test1.55-dev
-            - libboost-program-options1.55-dev
+            - libboost-system1.58-dev
+            - libboost-filesystem1.58-dev
+            - libboost-test1.58-dev
+            - libboost-program-options1.58-dev
       branches:
         only:
           - dev

CMakeLists.txt

@@ -53,7 +53,6 @@ list(APPEND CMAKE_MODULE_PATH "${CMAKE_CURRENT_LIST_DIR}/cmake")
 find_package(Boost REQUIRED COMPONENTS unit_test_framework program_options system filesystem)
 find_package(Git QUIET)
 find_package(ApMon MODULE)
-find_package(CURL REQUIRED MODULE)
 
 
 ####################################
@@ -77,7 +76,6 @@ set(SRCS
   src/MonitoringFactory.cxx
   src/Transports/UDP.cxx
   src/Transports/TCP.cxx
-  src/Transports/HTTP.cxx
   src/Transports/Unix.cxx
   src/Exceptions/MonitoringException.cxx
 )
@@ -86,7 +84,7 @@ set(SRCS
 message(STATUS "Backends")
 message(STATUS "  Compiling StdCout backend")
 message(STATUS "  Compiling Flume UDP/JSON backend")
-message(STATUS "  Compiling InfluxDB HTTP and UDP backend")
+message(STATUS "  Compiling InfluxDB backend with Unix socket and UDP transport")
 
 # Create library
 add_library(Monitoring SHARED ${SRCS} $<$<BOOL:${ApMon_FOUND}>:src/Backends/ApMonBackend.cxx>)
@@ -104,7 +102,6 @@ target_link_libraries(Monitoring
     Boost::boost
   PRIVATE
     Boost::system
-    CURL::CURL
     $<$<BOOL:${ApMon_FOUND}>:ApMon::ApMon>
 )
 

README.md

@@ -67,11 +67,11 @@ See table below to find out how to create `URI` for each backend:
 
 | Backend name | Transport   | URI backend[-protocol] | URI query  | Default verbosity |
 | ------------ |:-----------:|:----------------------:|:----------:| -----------------:|
-| InfluxDB     | HTTP        | `influxdb-http`        | `?db=<db>` | `info`            |
+| No-op        | -           | `no-op`                |            | -                 |
 | InfluxDB     | UDP         | `influxdb-udp`         | -          | `info`            |
 | InfluxDB     | Unix socket | `influxdb-unix`        | -          | `info`            |
 | ApMon        | UDP         | `apmon`                | -          | `info`            |
-| StdOut       | -           | `stdout`, `infologger` | -          | `debug`           |
+| StdOut       | -           | `stdout`, `infologger` | [Prefix]   | `debug`           |
 | Flume        | UDP         | `flume`                | -          | `info`            |
 
 ##### StdCout output format

cmake/FindCURL.cmake

@@ -7,7 +7,6 @@
 #include <boost/lexical_cast.hpp>
 #include <string>
 #include "../Transports/UDP.h"
-#include "../Transports/HTTP.h"
 #include "../Transports/Unix.h"
 #include "../Exceptions/MonitoringException.h"
 
@@ -27,15 +26,6 @@ InfluxDB::InfluxDB(const std::string& host, unsigned int port) :
                    << " ("<< host << ":" << port << ")" << MonLogger::End();
 }
 
-InfluxDB::InfluxDB(const std::string& host, unsigned int port, const std::string& search)
-{
-  mTransport = std::make_unique<transports::HTTP>(
-    "http://" + host + ":" + std::to_string(port) + "/write?" + search
-  );
-  MonLogger::Get() << "InfluxDB/HTTP backend initialized" << " (" << "http://" << host
-                   << ":" <<  std::to_string(port) << "/write?" << search << ")" << MonLogger::End();
-}
-
 InfluxDB::InfluxDB(const std::string& socketPath) :
   mTransport(std::make_unique<transports::Unix>(socketPath))
 {

src/Backends/InfluxDB.cxx

@@ -32,12 +32,7 @@ class InfluxDB final : public Backend
     /// \param port      InfluxDB UDP endpoint port number
     InfluxDB(const std::string& host, unsigned int port);
 
-    /// Constructor for HTTP transport
-    /// \param host      InfluxDB HTTP endpoint hostname
-    /// \param port      InfluxDB HTTP endpoint port number
-    /// \param path	 Query search providing database name
-    InfluxDB(const std::string& host, unsigned int port, const std::string& search);
-
+    /// Constructor for Unix socket transport
     InfluxDB(const std::string& socketPath);
 
     /// Default destructor

src/Backends/InfluxDB.h

@@ -49,9 +49,6 @@ std::unique_ptr<Backend> getInfluxDb(http::url uri) {
   if (uri.protocol == "udp") {
     return std::make_unique<backends::InfluxDB>(uri.host, uri.port);
   }
-  if (uri.protocol == "http") {
-    return std::make_unique<backends::InfluxDB>(uri.host, uri.port, uri.search);
-  }
   if (uri.protocol == "unix") {
     std::string path = uri.path;;
     auto found = std::find_if(begin(verbosities), end(verbosities),
@@ -99,7 +96,6 @@ std::unique_ptr<Backend> MonitoringFactory::GetBackend(std::string& url) {
     {"infologger", getStdOut},
     {"stdout", getStdOut},
     {"influxdb-udp", getInfluxDb},
-    {"influxdb-http", getInfluxDb},
     {"influxdb-unix", getInfluxDb},
     {"apmon", getApMon},
     {"flume", getFlume},

src/MonitoringFactory.cxx

@@ -28,8 +28,8 @@ BOOST_AUTO_TEST_CASE(verbosity)
    auto influxDebug = Monitoring::GetBackend(influxDebugUrl);
    BOOST_CHECK_EQUAL(static_cast<std::underlying_type<Verbosity>::type>(influxDebug->getVerbosity()), 2);
 
-   std::string influxHttpUrl = "influxdb-http://127.0.0.1:1234/?db=test";
-   auto influxHttp = Monitoring::GetBackend(influxHttpUrl);
+   std::string influxUnixUrl = "influxdb-unix://127.0.0.1:1234/?db=test";
+   auto influxHttp = Monitoring::GetBackend(influxUnixUrl);
 
    std::string ilProdUrl = "stdout:///info";
    auto ilProd = Monitoring::GetBackend(ilProdUrl);