controllers/blobstore/chain/crete_file_blobstore.go

package chain

import (
	"context"
	"fmt"

	"github.com/datadrivers/go-nexus-client/nexus3/schema/blobstore"
	ctrl "sigs.k8s.io/controller-runtime"

	nexusApi "github.com/epam/edp-nexus-operator/api/v1alpha1"
	"github.com/epam/edp-nexus-operator/pkg/client/nexus"
)

type CreateFileBlobStore struct {
	nexusFileBlobStoreApiClient nexus.FileBlobStore
}

func NewCreateFileBlobStore(nexusFileBlobStoreApiClient nexus.FileBlobStore) *CreateFileBlobStore {
	return &CreateFileBlobStore{nexusFileBlobStoreApiClient: nexusFileBlobStoreApiClient}
}

func (c *CreateFileBlobStore) ServeRequest(ctx context.Context, blobStore *nexusApi.NexusBlobStore) error {
	if blobStore.Spec.File == nil {
		return nil
	}

	log := ctrl.LoggerFrom(ctx).WithValues("blobstore_name", blobStore.Spec.Name)
	log.Info("Start creating file blobstore")

	nexusBlobStore, err := c.nexusFileBlobStoreApiClient.Get(blobStore.Spec.Name)
	if err != nil {
		if !nexus.IsErrNotFound(err) {
			return fmt.Errorf("failed to get blobstore: %w", err)
		}

		log.Info("Blobstore doesn't exist, creating new one")

		if err = c.nexusFileBlobStoreApiClient.Create(specToFileBlobstore(&blobStore.Spec)); err != nil {
			return fmt.Errorf("failed to create blobstore: %w", err)
		}

		log.Info("Blobstore has been created")

		return nil
	}

	newNexusBlobStore := specToFileBlobstore(&blobStore.Spec)

	if fileBlobstoreChanged(newNexusBlobStore, nexusBlobStore) {
		log.Info("Updating blobstore")

		if err = c.nexusFileBlobStoreApiClient.Update(blobStore.Spec.Name, newNexusBlobStore); err != nil {
			return fmt.Errorf("failed to update blobstore: %w", err)
		}

		log.Info("Blobstore has been updated")
	}

	return nil
}

func specToFileBlobstore(spec *nexusApi.NexusBlobStoreSpec) *blobstore.File {
	f := &blobstore.File{
		Name: spec.Name,
		Path: spec.File.Path,
	}

	if spec.SoftQuota != nil {
		f.SoftQuota = &blobstore.SoftQuota{
			Limit: spec.SoftQuota.Limit,
			Type:  spec.SoftQuota.Type,
		}
	}

	return f
}

func fileBlobstoreChanged(newNexusBlobStore, nexusBlobStore *blobstore.File) bool {
	if newNexusBlobStore.Path != nexusBlobStore.Path {
		return true
	}

	if newNexusBlobStore.SoftQuota != nil && nexusBlobStore.SoftQuota != nil {
		return newNexusBlobStore.SoftQuota.Limit != nexusBlobStore.SoftQuota.Limit ||
			newNexusBlobStore.SoftQuota.Type != nexusBlobStore.SoftQuota.Type
	}

	return (newNexusBlobStore.SoftQuota != nil && nexusBlobStore.SoftQuota == nil) ||
		(newNexusBlobStore.SoftQuota == nil && nexusBlobStore.SoftQuota != nil)
}