replication_errors.go

package replication

import (
	"net/http"

	"github.com/go-openapi/runtime"

	replicationapi "github.com/mittwald/goharbor-client/v5/apiv2/internal/api/client/replication"
	"github.com/mittwald/goharbor-client/v5/apiv2/pkg/errors"
)

const (
	// ErrReplicationIllegalIDFormatMsg describes an illegal request format
	ErrReplicationIllegalIDFormatMsg = "illegal format of provided ID value"

	// ErrReplicationUnauthorizedMsg describes an unauthorized request
	ErrReplicationUnauthorizedMsg = "unauthorized"

	// ErrReplicationInternalErrorsMsg describes server-side internal errors
	ErrReplicationInternalErrorsMsg = "unexpected internal errors"

	// ErrReplicationNoPermissionMsg describes a request error without permission
	ErrReplicationNoPermissionMsg = "user does not have permission to the replication"

	// ErrReplicationIDNotExistsMsg describes an error
	// when no proper replication ID is found
	ErrReplicationIDNotExistsMsg = "replication ID does not exist"

	// ErrReplicationNameAlreadyExistsMsg describes a duplicate replication name error
	ErrReplicationNameAlreadyExistsMsg = "replication name already exists"

	// ErrReplicationMismatchMsg describes a failed lookup
	// of a replication with name/id pair
	ErrReplicationMismatchMsg = "id/name pair not found on server side"

	// ErrReplicationNotFoundMsg describes an error
	// when a specific replication is not found
	ErrReplicationNotFoundMsg = "replication not found on server side"

	// ErrReplicationNotProvidedMsg describes an error
	// caused by a missing replication object
	ErrReplicationNotProvidedMsg = "no replication provided"

	// ErrReplicationExecutionNotProvidedMsg describes an error
	// caused by a missing replication execution object
	ErrReplicationExecutionNotProvidedMsg = "no replication execution provided"

	// ErrReplicationExecutionReplicationIDMismatchMsg describes an error
	// caused by an ID mismatch of the desired replication execution and an existing replication
	ErrReplicationExecutionReplicationIDMismatchMsg = "received replication execution id doesn't match"

	// ErrReplicationDisabledMsg describes an error when actions cannot be performed
	// because the underlying replication is currently disabled.
	ErrReplicationDisabledMsg = "the underlying replication is disabled"
)

// ErrReplicationIllegalIDFormat describes an illegal request format.
type ErrReplicationIllegalIDFormat struct{}

// Error returns the error message.
func (e *ErrReplicationIllegalIDFormat) Error() string {
	return ErrReplicationIllegalIDFormatMsg
}

// ErrReplicationUnauthorized describes an unauthorized request.
type ErrReplicationUnauthorized struct{}

// Error returns the error message.
func (e *ErrReplicationUnauthorized) Error() string {
	return ErrReplicationUnauthorizedMsg
}

// ErrReplicationInternalErrors describes server-side internal errors.
type ErrReplicationInternalErrors struct{}

// Error returns the error message.
func (e *ErrReplicationInternalErrors) Error() string {
	return ErrReplicationInternalErrorsMsg
}

// ErrReplicationNoPermission describes a request error without permission.
type ErrReplicationNoPermission struct{}

// Error returns the error message.
func (e *ErrReplicationNoPermission) Error() string {
	return ErrReplicationNoPermissionMsg
}

// ErrReplicationIDNotExists describes an error
// when no proper replication ID is found.
type ErrReplicationIDNotExists struct{}

// Error returns the error message.
func (e *ErrReplicationIDNotExists) Error() string {
	return ErrReplicationIDNotExistsMsg
}

// ErrReplicationNameAlreadyExists describes a duplicate replication name error.
type ErrReplicationNameAlreadyExists struct{}

// Error returns the error message.
func (e *ErrReplicationNameAlreadyExists) Error() string {
	return ErrReplicationNameAlreadyExistsMsg
}

// ErrReplicationMismatch describes a failed lookup
// of a replication with name/id pair.
type ErrReplicationMismatch struct{}

// Error returns the error message.
func (e *ErrReplicationMismatch) Error() string {
	return ErrReplicationMismatchMsg
}

// ErrReplicationNotFound describes an error
// when a specific replication is not found.
type ErrReplicationNotFound struct{}

// Error returns the error message.
func (e *ErrReplicationNotFound) Error() string {
	return ErrReplicationNotFoundMsg
}

type ErrReplicationNotProvided struct{}

// Error returns the error message.
func (e *ErrReplicationNotProvided) Error() string {
	return ErrReplicationNotProvidedMsg
}

type ErrReplicationExecutionNotProvided struct{}

// Error returns the error message.
func (e *ErrReplicationExecutionNotProvided) Error() string {
	return ErrReplicationExecutionNotProvidedMsg
}

type ErrReplicationExecutionReplicationIDMismatch struct{}

// Error returns the error message.
func (e *ErrReplicationExecutionReplicationIDMismatch) Error() string {
	return ErrReplicationExecutionReplicationIDMismatchMsg
}

// ErrReplicationDisabled describes an error that the underlying replication is disabled.
type ErrReplicationDisabled struct{}

// Error returns the error message.
func (e *ErrReplicationDisabled) Error() string {
	return ErrReplicationDisabledMsg
}

// handleSwaggerReplicationErrors takes a swagger generated error as input,
// which usually does not contain any form of error message,
// and outputs a new error with a proper message.
func handleSwaggerReplicationErrors(in error) error {
	t, ok := in.(*runtime.APIError)
	if ok {
		switch t.Code {
		case http.StatusBadRequest:
			return &ErrReplicationIllegalIDFormat{}
		case http.StatusUnauthorized:
			return &ErrReplicationUnauthorized{}
		case http.StatusForbidden:
			return &ErrReplicationNoPermission{}
		case http.StatusNotFound:
			return &errors.ErrNotFound{}
		case http.StatusInternalServerError:
			return &ErrReplicationInternalErrors{}
		case http.StatusPreconditionFailed:
			return &ErrReplicationDisabled{}
		}
	}

	switch in.(type) {
	case *replicationapi.DeleteReplicationPolicyNotFound:
		return &ErrReplicationIDNotExists{}
	case *replicationapi.UpdateReplicationPolicyNotFound:
		return &ErrReplicationIDNotExists{}
	case *replicationapi.CreateReplicationPolicyConflict:
		return &ErrReplicationNameAlreadyExists{}
	default:
		return in
	}
}