Assemble data for user, team and permission sync in backend plugin

grafana-plugin/pkg/plugin/permissions.go

@@ -0,0 +1,95 @@
+package plugin
+
+import (
+	"encoding/json"
+	"fmt"
+	"io"
+	"net/http"
+	"net/url"
+	"strings"
+)
+
+type OnCallPermission struct {
+	Action string `json:"action"`
+}
+
+func (a *App) GetPermissions(settings *OnCallPluginSettings, onCallUser *OnCallUser) ([]OnCallPermission, error) {
+	reqURL, err := url.JoinPath(settings.GrafanaURL, fmt.Sprintf("api/access-control/users/%d/permissions", onCallUser.ID))
+	if err != nil {
+		return nil, fmt.Errorf("error creating URL: %+v", err)
+	}
+
+	req, err := http.NewRequest("GET", reqURL, nil)
+	if err != nil {
+		return nil, fmt.Errorf("error creating creating new request: %+v", err)
+	}
+	req.Header.Set("Authorization", fmt.Sprintf("Bearer %s", settings.GrafanaToken))
+
+	res, err := a.httpClient.Do(req)
+	if err != nil {
+		return nil, fmt.Errorf("error making request: %+v", err)
+	}
+	defer res.Body.Close()
+
+	body, err := io.ReadAll(res.Body)
+	if err != nil {
+		return nil, fmt.Errorf("error reading response: %+v", err)
+	}
+
+	var permissions []OnCallPermission
+	err = json.Unmarshal(body, &permissions)
+	if err != nil {
+		return nil, fmt.Errorf("failed to parse JSON response: %v", err)
+	}
+
+	if res.StatusCode == 200 {
+		var filtered []OnCallPermission
+		for _, permission := range permissions {
+			if strings.HasPrefix(permission.Action, "grafana-oncall-app") {
+				filtered = append(filtered, permission)
+			}
+		}
+		return filtered, nil
+	}
+	return nil, fmt.Errorf("no permissions for %s, http status %s", onCallUser.Login, res.Status)
+}
+
+func (a *App) GetAllPermissions(settings *OnCallPluginSettings) (map[string]map[string]interface{}, error) {
+	reqURL, err := url.Parse(settings.GrafanaURL)
+	if err != nil {
+		return nil, fmt.Errorf("error parsing URL: %+v", err)
+	}
+
+	reqURL.Path += "api/access-control/users/permissions/search"
+	q := reqURL.Query()
+	q.Set("actionPrefix", "grafana-oncall-app")
+	reqURL.RawQuery = q.Encode()
+
+	req, err := http.NewRequest("GET", reqURL.String(), nil)
+	if err != nil {
+		return nil, fmt.Errorf("error creating creating new request: %+v", err)
+	}
+	req.Header.Set("Authorization", fmt.Sprintf("Bearer %s", settings.GrafanaToken))
+
+	res, err := a.httpClient.Do(req)
+	if err != nil {
+		return nil, fmt.Errorf("error making request: %+v", err)
+	}
+	defer res.Body.Close()
+
+	body, err := io.ReadAll(res.Body)
+	if err != nil {
+		return nil, fmt.Errorf("error reading response: %+v", err)
+	}
+
+	var permissions map[string]map[string]interface{}
+	err = json.Unmarshal(body, &permissions)
+	if err != nil {
+		return nil, fmt.Errorf("failed to parse JSON response: %v", err)
+	}
+
+	if res.StatusCode == 200 {
+		return permissions, nil
+	}
+	return nil, fmt.Errorf("no permissions available, http status %s", res.Status)
+}