plugin_requests.go

package se2

import (
	"context"
	"encoding/json"
	"fmt"
	"net/http"

	"github.com/pkg/errors"
)

const pathPlugins = pathTenantByName + "/plugins"

type Plugin struct {
	Name       string `json:"name"`
	Namespace  string `json:"namespace"`
	Lang       string `json:"lang"`
	Ref        string `json:"ref"`
	APIVersion string `json:"apiVersion"`
	FQMN       string `json:"fqmn"`
	URI        string `json:"uri"`
}

type PluginResponse struct {
	Plugins []Plugin `json:"plugins"`
}

func (c *Client) GetPlugins(ctx context.Context, tenantName string) (PluginResponse, error) {
	if tenantName == emptyString {
		return PluginResponse{}, errors.New("client.GetPlugins: tenant name cannot be blank")
	}

	req, err := http.NewRequestWithContext(ctx, http.MethodGet, fmt.Sprintf(c.host+pathPlugins, tenantName), nil)
	if err != nil {
		return PluginResponse{}, errors.Wrap(err, "client.GetPlugins: http.NewRequest")
	}

	res, err := c.do(req)
	if err != nil {
		return PluginResponse{}, errors.Wrap(err, "client.GetPlugins: c.do")
	}

	defer func() {
		_ = res.Body.Close()
	}()

	if res.StatusCode != http.StatusOK {
		return PluginResponse{}, fmt.Errorf(httpResponseCodeErrorFormat, "client.GetPlugins", http.StatusOK, res.StatusCode)
	}

	var t PluginResponse

	dec := json.NewDecoder(res.Body)
	dec.DisallowUnknownFields()

	err = dec.Decode(&t)
	if err != nil {
		return PluginResponse{}, errors.Wrap(err, "client.GetPlugins: dec.Decode")
	}

	return t, nil
}