Initial commit

.gitignore

@@ -0,0 +1,2 @@
+.DS_Store
+.env

.vscode/launch.json

@@ -0,0 +1,15 @@
+{
+    "version": "0.2.0",
+    "configurations": [
+        {
+            "name": "Deno",
+            "type": "node",
+            "request": "launch",
+            "cwd": "${workspaceFolder}",
+            "runtimeExecutable": "deno",
+            "runtimeArgs": ["run", "--inspect-brk", "-A", "${file}"],
+            "port": 9229,
+            "outputCapture": "std"
+        }
+    ]
+}

.vscode/settings.json

@@ -0,0 +1,3 @@
+{
+    "deno.enable": true
+}

examples/getHost.ts

@@ -0,0 +1,21 @@
+import { Zabbix } from "../mod.ts";
+
+const zabbix: Zabbix = new Zabbix({
+  url: "http://127.0.0.1/api_jsonrpc.php",
+  user: "Admin",
+  password: "zabbix",
+});
+
+const main = async () => {
+  try {
+    await zabbix.login();
+    const hosts = await zabbix.request("host.get", {
+      limit: 1,
+    });
+    console.log(JSON.stringify(hosts, null, 2));
+    zabbix.logout();
+  } catch (error) {
+    console.error(error);
+  }
+};
+main()

mod.ts

@@ -0,0 +1 @@
+export { Zabbix } from "./src/zabbix.ts";

src/fetch.ts

@@ -0,0 +1,41 @@
+export interface IPostConfigBodyParams {
+  user?: string;
+  password?: string;
+  // deno-lint-ignore no-explicit-any
+  [propName: string]: any;
+}
+
+interface IPostConfig {
+  url: string;
+  auth: string | null;
+  method: string;
+  params: IPostConfigBodyParams;
+  options?: RequestInit;
+}
+
+export async function Post(config: IPostConfig) {
+  try {
+    const url = config.url;
+    const auth = config.auth;
+    const method = config.method;
+    const params = config.params;
+    const options = config.options;
+
+    const configInit: RequestInit = Object.assign({
+      method: "POST",
+      headers: { "Content-Type": "application/json" },
+      body: JSON.stringify({
+        jsonrpc: "2.0",
+        method: method,
+        params: params,
+        id: String(Math.random()),
+        auth: auth,
+      }),
+    }, options);
+
+    const response = await fetch(url, configInit);
+    return response.json();
+  } catch (error) {
+    throw error;
+  }
+}

src/zabbix.ts

@@ -0,0 +1,69 @@
+import { Post, IPostConfigBodyParams } from "./fetch.ts";
+
+interface IZabbixConfig {
+  url: string;
+  user: string;
+  password: string;
+  options?: RequestInit;
+}
+
+export class Zabbix {
+  private url: string;
+  private user: string;
+  private password: string;
+  private options?: RequestInit;
+  private auth: string | null;
+
+  constructor(config: IZabbixConfig) {
+    this.url = config.url;
+    this.user = config.user;
+    this.password = config.password;
+    this.options = config.options || {};
+    this.auth = null;
+  }
+
+  async request(method: string, params: IPostConfigBodyParams) {
+    try {
+      const response = await Post({
+        url: this.url,
+        method: method,
+        params: params,
+        auth: this.auth,
+        options: this.options,
+      });
+
+      if (response.result) {
+        return response.result;
+      } else {
+        throw JSON.stringify(response);
+      }
+    } catch (error) {
+      throw error;
+    }
+  }
+
+  async login() {
+    try {
+      const result = await this.request("user.login", {
+        user: this.user,
+        password: this.password,
+      });
+      this.auth = result;
+      return result;
+    } catch (error) {
+      throw error;
+    }
+  }
+
+  async logout() {
+    try {
+      const result = await this.request("user.logout", []);
+      this.auth = null;
+      return result;
+    } catch (error) {
+      throw error;
+    } finally {
+      this.auth = null;
+    }
+  }
+}