🚧 wip: adding elasticsearch

Signed-off-by: Muhammed Hussein Karimi <info@karimi.dev>

package-lock.json

@@ -9,6 +9,7 @@
             "version": "1.22.0-beta.0",
             "license": "MIT",
             "dependencies": {
+                "@elastic/elasticsearch": "^8.8.1",
                 "@grpc/grpc-js": "~1.7.3",
                 "@louislam/ping": "~0.4.4-mod.0",
                 "@louislam/sqlite3": "15.1.6",
@@ -3308,6 +3309,39 @@
                 "ms": "^2.1.1"
             }
         },
+        "node_modules/@elastic/elasticsearch": {
+            "version": "8.8.1",
+            "resolved": "https://registry.npmjs.org/@elastic/elasticsearch/-/elasticsearch-8.8.1.tgz",
+            "integrity": "sha512-ibArPKHEmak3jao7xts2gROATiwPQo9aOrWWdix5mJcX1gnjm/UeJBVO901ROmaxFVPKxVnjC9Op3gJYkqagjg==",
+            "dependencies": {
+                "@elastic/transport": "^8.3.2",
+                "tslib": "^2.4.0"
+            },
+            "engines": {
+                "node": ">=14"
+            }
+        },
+        "node_modules/@elastic/transport": {
+            "version": "8.3.2",
+            "resolved": "https://registry.npmjs.org/@elastic/transport/-/transport-8.3.2.tgz",
+            "integrity": "sha512-ZiBYRVPj6pwYW99fueyNU4notDf7ZPs7Ix+4T1btIJsKJmeaORIItIfs+0O7KV4vV+DcvyMhkY1FXQx7kQOODw==",
+            "dependencies": {
+                "debug": "^4.3.4",
+                "hpagent": "^1.0.0",
+                "ms": "^2.1.3",
+                "secure-json-parse": "^2.4.0",
+                "tslib": "^2.4.0",
+                "undici": "^5.22.1"
+            },
+            "engines": {
+                "node": ">=14"
+            }
+        },
+        "node_modules/@elastic/transport/node_modules/ms": {
+            "version": "2.1.3",
+            "resolved": "https://registry.npmjs.org/ms/-/ms-2.1.3.tgz",
+            "integrity": "sha512-6FlzubTLZG3J2a/NVCAleEhjzq5oxgHyaCU9yYXvcLsvoVaHJq/s5xXI6/XXP6tz7R9xAOtHnSO/tXtF3WRTlA=="
+        },
         "node_modules/@esbuild/android-arm": {
             "version": "0.15.18",
             "resolved": "https://registry.npmjs.org/@esbuild/android-arm/-/android-arm-0.15.18.tgz",
@@ -6420,6 +6454,17 @@
                 "readable-stream": "^3.1.1"
             }
         },
+        "node_modules/busboy": {
+            "version": "1.6.0",
+            "resolved": "https://registry.npmjs.org/busboy/-/busboy-1.6.0.tgz",
+            "integrity": "sha512-8SFQbg/0hQ9xy3UNTB0YEnsNBbWfhf7RtnzpL7TkBiTBRfrQ9Fxcnz7VJsleJpyp6rVLvXiuORqjlHi5q+PYuA==",
+            "dependencies": {
+                "streamsearch": "^1.1.0"
+            },
+            "engines": {
+                "node": ">=10.16.0"
+            }
+        },
         "node_modules/bytes": {
             "version": "3.0.0",
             "resolved": "https://registry.npmjs.org/bytes/-/bytes-3.0.0.tgz",
@@ -10414,6 +10459,14 @@
             "integrity": "sha512-3wdGidZyq5PB084XLES5TpOSRA3wjXAlIWMhum2kRcv/41Sn2emQ0dycQW4uZXLejwKvg6EsvbdlVL+FYEct7A==",
             "dev": true
         },
+        "node_modules/hpagent": {
+            "version": "1.2.0",
+            "resolved": "https://registry.npmjs.org/hpagent/-/hpagent-1.2.0.tgz",
+            "integrity": "sha512-A91dYTeIB6NoXG+PxTQpCCDDnfHsW9kc06Lvpu1TEe9gnd6ZFeiBoRO9JvzEv6xK7EX97/dUE8g/vBMTqTS3CA==",
+            "engines": {
+                "node": ">=14"
+            }
+        },
         "node_modules/html-encoding-sniffer": {
             "version": "2.0.1",
             "resolved": "https://registry.npmjs.org/html-encoding-sniffer/-/html-encoding-sniffer-2.0.1.tgz",
@@ -16624,6 +16677,11 @@
                 "node": ">= 8"
             }
         },
+        "node_modules/secure-json-parse": {
+            "version": "2.7.0",
+            "resolved": "https://registry.npmjs.org/secure-json-parse/-/secure-json-parse-2.7.0.tgz",
+            "integrity": "sha512-6aU+Rwsezw7VR8/nyvKTx8QpWH9FrcYiXXlqC4z5d5XQBDRqtbfsRjnwGyqbi3gddNtWHuEk9OANUotL26qKUw=="
+        },
         "node_modules/semver": {
             "version": "6.3.0",
             "resolved": "https://registry.npmjs.org/semver/-/semver-6.3.0.tgz",
@@ -17139,6 +17197,14 @@
             "resolved": "https://registry.npmjs.org/stream-shift/-/stream-shift-1.0.1.tgz",
             "integrity": "sha512-AiisoFqQ0vbGcZgQPY1cdP2I76glaVA/RauYR4G4thNFgkTqr90yXTo4LYX60Jl+sIlPNHHdGSwo01AvbKUSVQ=="
         },
+        "node_modules/streamsearch": {
+            "version": "1.1.0",
+            "resolved": "https://registry.npmjs.org/streamsearch/-/streamsearch-1.1.0.tgz",
+            "integrity": "sha512-Mcc5wHehp9aXz1ax6bZUyY5afg9u2rv5cqQI3mRrYkGC8rW2hM02jWuwjtL++LS5qinSyhj2QfLyNsuc+VsExg==",
+            "engines": {
+                "node": ">=10.0.0"
+            }
+        },
         "node_modules/string_decoder": {
             "version": "1.3.0",
             "resolved": "https://registry.npmjs.org/string_decoder/-/string_decoder-1.3.0.tgz",
@@ -18042,6 +18108,17 @@
                 "url": "https://github.com/sponsors/ljharb"
             }
         },
+        "node_modules/undici": {
+            "version": "5.22.1",
+            "resolved": "https://registry.npmjs.org/undici/-/undici-5.22.1.tgz",
+            "integrity": "sha512-Ji2IJhFXZY0x/0tVBXeQwgPlLWw13GVzpsWPQ3rV50IFMMof2I55PZZxtm4P6iNq+L5znYN9nSTAq0ZyE6lSJw==",
+            "dependencies": {
+                "busboy": "^1.6.0"
+            },
+            "engines": {
+                "node": ">=14.0"
+            }
+        },
         "node_modules/unicode-canonical-property-names-ecmascript": {
             "version": "2.0.0",
             "resolved": "https://registry.npmjs.org/unicode-canonical-property-names-ecmascript/-/unicode-canonical-property-names-ecmascript-2.0.0.tgz",

package.json

@@ -68,6 +68,7 @@
         "sort-contributors": "node extra/sort-contributors.js"
     },
     "dependencies": {
+        "@elastic/elasticsearch": "^8.8.1",
         "@grpc/grpc-js": "~1.7.3",
         "@louislam/ping": "~0.4.4-mod.0",
         "@louislam/sqlite3": "15.1.6",

server/util-server.js

@@ -16,6 +16,7 @@ const postgresConParse = require("pg-connection-string").parse;
 const mysql = require("mysql2");
 const { MongoClient } = require("mongodb");
 const { NtlmClient } = require("axios-ntlm");
+const { esClient } = require("@elastic/elasticsearch");
 const { Settings } = require("./settings");
 const grpc = require("@grpc/grpc-js");
 const protojs = require("protobufjs");
@@ -129,6 +130,14 @@ exports.pingAsync = function (hostname, ipv6 = false, size = 56) {
     });
 };
 
+exports.elasticSearchQueryAsync = function () {
+    return new Promise((resolve, reject) => {
+        const client = new esClient({
+
+        });
+    });
+};
+
 /**
  * MQTT Monitor
  * @param {string} hostname Hostname / address of machine to test