Regist storage.

.github/workflows/pull_request.yml

@@ -133,6 +133,8 @@ jobs:
           ASAN_OPTIONS: fast_unwind_on_malloc=1
         run: |
           pushd build
+          # register storage to meta
+          ./bin/regist_host --host=127.0.0.1:9779
           ctest -j $(nproc) -E '\w*_ssl_test' --timeout 10000 --output-on-failure
           make install
           popd

src/client/tests/CMakeLists.txt

@@ -44,6 +44,19 @@ nebula_add_test(
         ${NEBULA_THIRD_PARTY_LIBRARIES}
 )
 
+nebula_add_test(
+    NAME
+        regist_host
+    SOURCES
+        RegistHost.cpp
+    OBJECTS
+        ${NEBULA_CLIENT_OBJS}
+        $<TARGET_OBJECTS:nebula_common_obj>
+        $<TARGET_OBJECTS:nebula_graph_client_obj>
+    LIBRARIES
+        ${NEBULA_THIRD_PARTY_LIBRARIES}
+)
+
 nebula_add_test(
     NAME
         session_ssl_test

src/client/tests/RegistHost.cpp

@@ -0,0 +1,36 @@
+/* Copyright (c) 2021 vesoft inc. All rights reserved.
+ *
+ * This source code is licensed under Apache 2.0 License.
+ */
+
+#include <common/Init.h>
+#include <folly/Format.h>
+#include <glog/logging.h>
+#include <nebula/client/Config.h>
+#include <nebula/client/ConnectionPool.h>
+#include <nebula/client/Session.h>
+
+#include <atomic>
+#include <chrono>
+#include <thread>
+
+// Require a nebula server could access
+
+DEFINE_string(host, "", "Register host address.");
+DEFINE_string(server, "127.0.0.1:9669", "Nebula server address.");
+
+int main(int argc, char** argv) {
+  nebula::init(&argc, &argv);
+  google::SetStderrLogging(google::INFO);
+
+  nebula::ConnectionPool pool;
+  nebula::Config c{10, 0, 300, 0, "", false};
+  pool.init({FLAGS_server}, c);
+  auto session = pool.getSession("root", "nebula");
+  CHECK(session.valid());
+
+  auto resp =
+      session.execute(folly::format("ADD HOSTS {} INTO NEW ZONE 'default_zone'", FLAGS_host).str());
+  CHECK_EQ(resp.errorCode, nebula::ErrorCode::SUCCEEDED) << *resp.errorMsg;
+  return 0;
+}