From 9a4133cd296e4b1f3669368716ffeb9736d6f66e Mon Sep 17 00:00:00 2001
From: Wangjunqi123 <wangjunqi@kylinos.cn>
Date: Wed, 5 Jun 2024 14:40:53 +0800
Subject: [PATCH] elk/kibanaclient(v7): wrap API of get package info

---
 elk/kibanaClient/7_17_16/clientFleetAPI+.go | 26 +++++++++++++++++++++
 elk/kibanaClient/7_17_16/meta/extraPath.go  |  5 ++++
 2 files changed, 31 insertions(+)
 create mode 100644 elk/kibanaClient/7_17_16/clientFleetAPI+.go
 create mode 100644 elk/kibanaClient/7_17_16/meta/extraPath.go

diff --git a/elk/kibanaClient/7_17_16/clientFleetAPI+.go b/elk/kibanaClient/7_17_16/clientFleetAPI+.go
new file mode 100644
index 00000000..ee85b6a8
--- /dev/null
+++ b/elk/kibanaClient/7_17_16/clientFleetAPI+.go
@@ -0,0 +1,26 @@
+package kibanaClient
+
+import (
+	"context"
+	"fmt"
+	"io"
+	"net/http"
+
+	"gitee.com/openeuler/PilotGo-plugin-elk/kibanaClient/7_17_16/meta"
+)
+
+func (client *KibanaClient_v7) GetPackageInfo(ctx context.Context, pkgname string) (*meta.PackageInfo_p, error) {
+	apiURL := fmt.Sprintf(meta.FleetPackageInfoAPI, pkgname)
+	resp, err := client.Client.Connection.SendWithContext(ctx, http.MethodGet, apiURL, nil, nil, nil)
+	if err != nil {
+		return nil, fmt.Errorf("error calling %s API: %w", meta.FleetPackageInfoAPI, err)
+	}
+	defer resp.Body.Close()
+	bytes, err := io.ReadAll(resp.Body)
+	if err != nil {
+		return nil, fmt.Errorf("error reading response body: %w", err)
+	}
+
+	pinfo := Gjson_GetPackageInfo(bytes, "response.name", "response.policy_templates", "response.data_streams", "response.version", "response.title")
+	return pinfo, nil
+}
diff --git a/elk/kibanaClient/7_17_16/meta/extraPath.go b/elk/kibanaClient/7_17_16/meta/extraPath.go
new file mode 100644
index 00000000..f22d69ef
--- /dev/null
+++ b/elk/kibanaClient/7_17_16/meta/extraPath.go
@@ -0,0 +1,5 @@
+package meta
+
+const (
+	FleetPackageInfoAPI     = "/api/fleet/epm/packages/%s"
+)
-- 
Gitee