Add system tests for transport API (#216)

offa · Feb 1, 2024 · da572db · da572db
1 parent f849556
commit da572db
Show file tree

Hide file tree

Showing 2 changed files with 28 additions and 2 deletions.
diff --git a/test/system/InfluxDBST.cxx b/test/system/InfluxDBST.cxx
@@ -21,6 +21,7 @@
 // SOFTWARE.
 
 #include "SystemTest.h"
+#include "InfluxDBBuilder.h"
 
 namespace influxdb::test
 {
@@ -38,6 +39,27 @@ namespace influxdb::test
  }
  }
 
+ TEST_CASE("Connection configuration", "[InfluxDBST]")
+ {
+ using namespace Catch::Matchers;
+
+ SECTION("Connect through factory")
+ {
+ auto db = InfluxDBFactory::Get("http://" + getHostFromEnv() + ":8086?db=ignore");
+ const auto response = db->execute("show databases");
+ CHECK(response.empty() == false);
+ }
+
+ SECTION("Connect through builder")
+ {
+ auto db = InfluxDBBuilder::http("http://" + getHostFromEnv() + ":8086?db=ignore")
+ .setTimeout(std::chrono::seconds{5})
+ .connect();
+ const auto response = db->execute("show databases");
+ CHECK(response.empty() == false);
+ }
+ }
+
  TEST_CASE("InfluxDB system test", "[InfluxDBST]")
  {
  using namespace Catch::Matchers;

diff --git a/test/system/SystemTest.h b/test/system/SystemTest.h
@@ -61,10 +61,14 @@ namespace influxdb::test
  return {*user, *pass};
  }
 
+ inline std::string getHostFromEnv()
+ {
+ return getEnv("INFLUXDBCXX_SYSTEMTEST_HOST").value_or("localhost");
+ }
+
  inline std::unique_ptr<InfluxDB> configure(const std::string& db, std::optional<User> user = {})
  {
- const auto host = getEnv("INFLUXDBCXX_SYSTEMTEST_HOST").value_or("localhost");
  const std::string authString{user ? (user->name + ":" + user->pass + "@") : ""};
- return InfluxDBFactory::Get("http://" + authString + host + ":8086?db=" + db);
+ return InfluxDBFactory::Get("http://" + authString + getHostFromEnv() + ":8086?db=" + db);
  }
 }