fix initJobBuilder

Author: kobzonega

internal/controllers/storage/init.go

@@ -294,9 +294,7 @@ func (r *Reconciler) createInitBlobstorageJob(
 	ctx context.Context,
 	storage *resources.StorageClusterBuilder,
 ) error {
-	ydbCr := storage.Unwrap()
-	initJob := resources.NewInitJob(ydbCr)
-	builder := initJob.GetResourceBuilder()
+	builder := storage.GetInitJobBuilder()
 	newResource := builder.Placeholder(storage)
 	_, err := resources.CreateOrUpdateOrMaybeIgnore(ctx, r.Client, newResource, func() error {
 		var err error

internal/resources/storage.go

@@ -49,6 +49,42 @@ func (b *StorageClusterBuilder) NewAnnotations() map[string]string {
 	return an
 }
 
+func (b *StorageClusterBuilder) NewInitJobLabels() labels.Labels {
+	l := labels.Common(b.Name, b.Labels)
+
+	if b.Spec.InitJob != nil {
+		l.Merge(b.Spec.InitJob.AdditionalLabels)
+	}
+	l.Merge(map[string]string{labels.ComponentKey: labels.InitComponent})
+
+	return l
+}
+
+func (b *StorageClusterBuilder) NewInitJobAnnotations() map[string]string {
+	an := annotations.Common(b.Annotations)
+
+	if b.Spec.InitJob != nil {
+		an.Merge(b.Spec.InitJob.AdditionalLabels)
+	}
+	an.Merge(map[string]string{annotations.ConfigurationChecksum: GetSHA256Checksum(b.Spec.Configuration)})
+
+	return an
+}
+
+func (b *StorageClusterBuilder) GetInitJobBuilder() ResourceBuilder {
+	jobName := fmt.Sprintf(InitJobNameFormat, b.Name)
+	jobLabels := b.NewInitJobLabels()
+	jobAnnotations := b.NewInitJobAnnotations()
+
+	return &StorageInitJobBuilder{
+		Storage: b.Unwrap(),
+
+		Name:        jobName,
+		Labels:      jobLabels,
+		Annotations: jobAnnotations,
+	}
+}
+
 func (b *StorageClusterBuilder) GetResourceBuilders(restConfig *rest.Config) []ResourceBuilder {
 	storageLabels := b.NewLabels()
 	storageAnnotations := b.NewAnnotations()

internal/resources/storage_init_job.go

@@ -11,7 +11,6 @@ import (
 
 	api "github.com/ydb-platform/ydb-kubernetes-operator/api/v1alpha1"
 	"github.com/ydb-platform/ydb-kubernetes-operator/internal/annotations"
-	"github.com/ydb-platform/ydb-kubernetes-operator/internal/labels"
 	"github.com/ydb-platform/ydb-kubernetes-operator/internal/ptr"
 )
 
@@ -34,42 +33,6 @@ func (b *StorageInitJobBuilder) Unwrap() *api.Storage {
 	return b.DeepCopy()
 }
 
-func (b *StorageInitJobBuilder) NewLabels() labels.Labels {
-	l := labels.Common(b.Name, b.Labels)
-
-	if b.Spec.InitJob != nil {
-		l.Merge(b.Spec.InitJob.AdditionalLabels)
-	}
-	l.Merge(map[string]string{labels.ComponentKey: labels.InitComponent})
-
-	return l
-}
-
-func (b *StorageInitJobBuilder) NewAnnotations() map[string]string {
-	an := annotations.Common(b.Annotations)
-
-	if b.Spec.InitJob != nil {
-		an.Merge(b.Spec.InitJob.AdditionalLabels)
-	}
-	an.Merge(map[string]string{annotations.ConfigurationChecksum: GetSHA256Checksum(b.Spec.Configuration)})
-
-	return an
-}
-
-func (b *StorageInitJobBuilder) GetResourceBuilder() ResourceBuilder {
-	jobName := fmt.Sprintf(InitJobNameFormat, b.Name)
-	jobLabels := b.NewLabels()
-	jobAnnotations := b.NewAnnotations()
-
-	return &StorageInitJobBuilder{
-		Storage: b.Unwrap(),
-
-		Name:        jobName,
-		Labels:      jobLabels,
-		Annotations: jobAnnotations,
-	}
-}
-
 func (b *StorageInitJobBuilder) Build(obj client.Object) error {
 	job, ok := obj.(*batchv1.Job)
 	if !ok {