package client

import (
	"encoding/json"

	corev2 "github.com/sensu/sensu-go/api/core/v2"
	"github.com/sensu/sensu-go/types"
)

var filtersPath = createNSBasePath(coreAPIGroup, coreAPIVersion, "filters")

// CreateFilter creates a new filter on configured Sensu instance
func (client *RestClient) CreateFilter(filter *types.EventFilter) (err error) {
	bytes, err := json.Marshal(filter)
	if err != nil {
		return err
	}

	path := filtersPath(client.config.Namespace())
	res, err := client.R().SetBody(bytes).Post(path)
	if err != nil {
		return err
	}

	if res.StatusCode() >= 400 {
		return UnmarshalError(res)
	}

	return nil
}

// DeleteFilter deletes a filter from configured Sensu instance
func (client *RestClient) DeleteFilter(namespace, name string) error {
	return client.Delete(filtersPath(namespace, name))
}

// FetchFilter fetches a specific check
func (client *RestClient) FetchFilter(name string) (*types.EventFilter, error) {
	var filter *types.EventFilter

	path := filtersPath(client.config.Namespace(), name)
	res, err := client.R().Get(path)
	if err != nil {
		return nil, err
	}

	if res.StatusCode() >= 400 {
		return nil, UnmarshalError(res)
	}

	err = json.Unmarshal(res.Body(), &filter)
	return filter, err
}

// ListFilters fetches all filters from configured Sensu instance
func (client *RestClient) ListFilters(namespace string, options *ListOptions) ([]corev2.EventFilter, error) {
	var filters []corev2.EventFilter

	if err := client.List(filtersPath(namespace), &filters, options); err != nil {
		return filters, err
	}

	return filters, nil
}

// UpdateFilter updates an existing filter with fields from a new one.
func (client *RestClient) UpdateFilter(f *types.EventFilter) error {
	b, err := json.Marshal(f)
	if err != nil {
		return err
	}

	path := filtersPath(f.Namespace, f.Name)
	resp, err := client.R().SetBody(b).Put(path)
	if err != nil {
		return err
	}

	if resp.StatusCode() >= 400 {
		return UnmarshalError(resp)
	}

	return err
}