feat: udf for graphd added

docs/ngdi_API_Gateway.md

@@ -28,7 +28,15 @@ pdm run ngdi-api
 
 See https://github.com/wey-gu/nebula/tree/ngdi_udf
 
-- Build binary `ngdi.so` file
+### Build binary `ngdi.so` file
+
+Clone the `nebula` repo and checkout the hash of your existing nebulagraph cluster(check with `SHOW HOSTS GRAPH`)
+
+```bash
+git clone https://github.com/vesoft-inc/nebula && cd nebula
+```
+
+Prepare nebula_dev docker container for building UDF.
 
 ```bash
 export TAG=ubuntu2004
@@ -44,6 +52,9 @@ docker run -ti \
 mkdir build && cd build
 cmake -DCMAKE_CXX_COMPILER=$TOOLSET_CLANG_DIR/bin/g++ -DCMAKE_C_COMPILER=$TOOLSET_CLANG_DIR/bin/gcc -DENABLE_WERROR=OFF -DCMAKE_BUILD_TYPE=Release -DENABLE_TESTING=OFF ..
 
+Build the `ngdi.so` file.
+
+```bash
 cd ../udf
 make UDF=ngdi
 ```

udf/Makefile

@@ -0,0 +1,33 @@
+# Copyright (c) 2023 vesoft inc. All rights reserved.
+#
+# This source code is licensed under Apache 2.0 License.
+#
+
+ifneq ($(wildcard ../build/third-party/install),)
+  3PP_PATH := ../build/third-party/install
+else ifneq ($(wildcard /opt/vesoft/third-party/3.3),)
+  3PP_PATH := /opt/vesoft/third-party/3.3
+else ifneq ($(wildcard /opt/vesoft/third-party/3.0),)
+  3PP_PATH := /opt/vesoft/third-party/3.0
+else
+  $(error "Cannot find the third-party installation directory")
+endif
+
+CXX := g++
+CXX_FLAGS := -std=c++17 -c -I ../src/ -I $(3PP_PATH)/include/ -fPIC -static-libstdc++
+LIBS := -L$(3PP_PATH)/lib -static-libstdc++ -lglog -lgflags -Wl,-rpath=$(3PP_PATH)/lib -lcurl
+UDF ?= ngdi
+
+all: $(UDF).cpp
+	$(CXX) $(CXX_FLAGS) $(UDF).cpp -o $(UDF).o
+	$(CXX) -shared $(UDF).o $(LIBS) -o $(UDF).so
+
+
+clean:
+	rm ./*.o
+	rm ./*.so
+
+.PHONY: help
+help:
+	@echo "Usage: make UDF=<udf_name>"
+	@echo "Example: make UDF=ngdi"

udf/README.md

@@ -0,0 +1,3 @@
+This is the User Defined Function (UDF) to enable calling ngdi from nGQL.
+
+See [docs](https://github.com/wey-gu/nebulagraph-di/blob/main/docs/ngdi_API_Gateway.md)

udf/http_client.h

@@ -0,0 +1,60 @@
+/* Copyright (c) 2023 vesoft inc. All rights reserved.
+ *
+ * This source code is licensed under Apache 2.0 License.
+ */
+
+#ifndef UDF_HTTP_CLIENT
+#define UDF_HTTP_CLIENT
+
+#include <curl/curl.h>
+
+#include <cctype>
+#include <iomanip>
+#include <iostream>
+#include <sstream>
+#include <string>
+
+#include "../src/common/datatypes/List.h"
+#include "../src/common/datatypes/Map.h"
+
+size_t write_callback(char* ptr, size_t size, size_t nmemb, void* userdata) {
+  std::string* response = static_cast<std::string*>(userdata);
+  response->append(ptr, size * nmemb);
+  return size * nmemb;
+}
+
+std::string do_post(const std::string& url,
+                    const std::vector<std::string>& headers,
+                    const std::string& body) {
+  std::cout << "url=" << url << std::endl;
+  std::cout << "body=" << body << std::endl;
+  CURL* curl = curl_easy_init();  // 初始化curl
+  if (curl) {
+    curl_easy_setopt(curl, CURLOPT_URL, url.c_str());    // 设置请求URL
+    curl_easy_setopt(curl, CURLOPT_FOLLOWLOCATION, 1L);  // 支持重定向
+    curl_easy_setopt(curl, CURLOPT_WRITEFUNCTION,
+                     write_callback);  // 设置回调函数
+    std::string response;
+    curl_easy_setopt(curl, CURLOPT_WRITEDATA,
+                     &response);                               // 设置回调函数参数
+    curl_easy_setopt(curl, CURLOPT_POST, 1L);                  // 设置为POST请求
+    curl_easy_setopt(curl, CURLOPT_POSTFIELDS, body.c_str());  // 设置请求体
+    struct curl_slist* header_list = nullptr;
+    for (auto& header : headers) {
+      header_list = curl_slist_append(header_list, header.c_str());
+    }
+    curl_easy_setopt(curl, CURLOPT_HTTPHEADER, header_list);
+    CURLcode result_code = curl_easy_perform(curl);  // 执行请求
+    std::cout << "result code=" << result_code << std::endl;
+    if (result_code != CURLE_OK) {
+      return curl_easy_strerror(result_code);
+    } else {
+      std::cout << "response=" << response << std::endl;
+      return response;
+    }
+    curl_easy_cleanup(curl);  // 释放curl资源
+  }
+  return "ERROR: curl init fail.";
+}
+
+#endif