terraform-provider/internal/client/secret_import.go

package kmsclient

import (
	"github.com/hanzokms/terraform-provider/internal/errors"
	"net/http"
)

const (
	operationGetSecretImport     = "CallGetSecretImport"
	operationGetSecretImportByID = "CallGetSecretImportByID"
	operationGetSecretImportList = "CallGetSecretImportList"
	operationCreateSecretImport  = "CallCreateSecretImport"
	operationUpdateSecretImport  = "CallUpdateSecretImport"
	operationDeleteSecretImport  = "CallDeleteSecretImport"
)

// Workaround to getSecretImportById API call.
func findSecretImportByID(secretImports []SecretImport, id string) (GetSecretImportResponse, error) {
	for _, secretImport := range secretImports {
		if secretImport.ID == id {
			return GetSecretImportResponse{SecretImport: secretImport}, nil
		}
	}

	return GetSecretImportResponse{}, NewNotFoundError("SecretImport", id)
}

func (client Client) GetSecretImport(request GetSecretImportRequest) (GetSecretImportResponse, error) {
	var body ListSecretImportResponse

	httpRequest := client.Config.HttpClient.
		R().
		SetResult(&body).
		SetHeader("User-Agent", USER_AGENT).
		SetQueryParam("workspaceId", request.ProjectID).
		SetQueryParam("environment", request.Environment).
		SetQueryParam("path", request.SecretPath)

	response, err := httpRequest.Get("api/v1/secret-imports")

	if err != nil {
		return GetSecretImportResponse{}, errors.NewGenericRequestError(operationGetSecretImport, err)
	}

	if response.IsError() {
		return GetSecretImportResponse{}, errors.NewAPIErrorWithResponse(operationGetSecretImport, response, nil)
	}

	return findSecretImportByID(body.SecretImports, request.ID)

}

func (client Client) GetSecretImportByID(request GetSecretImportByIDRequest) (GetSecretImportByIDResponse, error) {
	var body GetSecretImportByIDResponse

	httpRequest := client.Config.HttpClient.
		R().
		SetResult(&body).
		SetHeader("User-Agent", USER_AGENT)

	response, err := httpRequest.Get("api/v1/secret-imports/" + request.ID)

	if err != nil {
		return GetSecretImportByIDResponse{}, errors.NewGenericRequestError(operationGetSecretImportByID, err)
	}

	if response.IsError() {
		if response.StatusCode() == http.StatusNotFound {
			return GetSecretImportByIDResponse{}, ErrNotFound
		}
		return GetSecretImportByIDResponse{}, errors.NewAPIErrorWithResponse(operationGetSecretImportByID, response, nil)
	}

	return body, nil
}

func (client Client) GetSecretImportList(request ListSecretImportRequest) (ListSecretImportResponse, error) {
	var body ListSecretImportResponse

	httpRequest := client.Config.HttpClient.
		R().
		SetResult(&body).
		SetHeader("User-Agent", USER_AGENT).
		SetQueryParam("workspaceId", request.ProjectID).
		SetQueryParam("environment", request.Environment).
		SetQueryParam("path", request.SecretPath)

	response, err := httpRequest.Get("api/v1/secret-imports")

	if err != nil {
		return ListSecretImportResponse{}, errors.NewGenericRequestError(operationGetSecretImportList, err)
	}

	if response.IsError() {
		return ListSecretImportResponse{}, errors.NewAPIErrorWithResponse(operationGetSecretImportList, response, nil)
	}

	return body, nil
}

func (client Client) CreateSecretImport(request CreateSecretImportRequest) (CreateSecretImportResponse, error) {
	var body CreateSecretImportResponse
	response, err := client.Config.HttpClient.
		R().
		SetResult(&body).
		SetHeader("User-Agent", USER_AGENT).
		SetBody(request).
		Post("api/v1/secret-imports")

	if err != nil {
		return CreateSecretImportResponse{}, errors.NewGenericRequestError(operationCreateSecretImport, err)
	}

	if response.IsError() {
		return CreateSecretImportResponse{}, errors.NewAPIErrorWithResponse(operationCreateSecretImport, response, nil)
	}

	return body, nil
}

func (client Client) UpdateSecretImport(request UpdateSecretImportRequest) (UpdateSecretImportResponse, error) {
	var body UpdateSecretImportResponse
	response, err := client.Config.HttpClient.
		R().
		SetResult(&body).
		SetHeader("User-Agent", USER_AGENT).
		SetBody(request).
		Patch("api/v1/secret-imports/" + request.ID)

	if err != nil {
		return UpdateSecretImportResponse{}, errors.NewGenericRequestError(operationUpdateSecretImport, err)
	}

	if response.IsError() {
		if response.StatusCode() == http.StatusNotFound {
			return UpdateSecretImportResponse{}, NewNotFoundError("SecretImport", request.SecretPath)
		}

		return UpdateSecretImportResponse{}, errors.NewAPIErrorWithResponse(operationUpdateSecretImport, response, nil)
	}

	return body, nil
}

func (client Client) DeleteSecretImport(request DeleteSecretImportRequest) (DeleteSecretImportResponse, error) {
	var body DeleteSecretImportResponse
	response, err := client.Config.HttpClient.
		R().
		SetResult(&body).
		SetHeader("User-Agent", USER_AGENT).
		SetBody(request).
		Delete("api/v1/secret-imports/" + request.ID)

	if err != nil {
		return DeleteSecretImportResponse{}, errors.NewGenericRequestError(operationDeleteSecretImport, err)
	}

	if response.IsError() {
		if response.StatusCode() == http.StatusNotFound {
			return DeleteSecretImportResponse{}, NewNotFoundError("SecretImport", request.SecretPath)
		}

		return DeleteSecretImportResponse{}, errors.NewAPIErrorWithResponse(operationDeleteSecretImport, response, nil)
	}

	return body, nil
}