Fix: The hash generation is broken, because an omitempty was removed (#52)

* Fix: The hash genrration is brokewn, because a `omitempty` was removed

This means rthat in production ALL pods are restarting, which is unwanted.
For now a breaking API change has been applied to explicit set the value.
We already has a ticket to harmonize the complete CRD API.

* Ran `make generate`

Author: Robert-Stam

api/v1/qdrantcluster_types.go

@@ -59,7 +59,7 @@ func GetQdrantClusterCrdForHash(qc QdrantCluster) QdrantCluster {
 	cloned.Resources.Storage = ""
 	cloned.RestartAllPodsConcurrently = false
 	cloned.Service = nil
-	cloned.ServicePerNode = false
+	cloned.ServicePerNode = nil
 	cloned.Size = 1
 	if v := cloned.StatefulSet; v != nil {
 		v.Annotations = nil
@@ -86,7 +86,7 @@ type QdrantClusterSpec struct {
 	// ServicePerNode specifies whether the cluster should start a dedicated service for each node.
 	// +kubebuilder:default=true
 	// +optional
-	ServicePerNode bool `json:"servicePerNode"`
+	ServicePerNode *bool `json:"servicePerNode,omitempty"`
 	// ClusterManager specifies whether to use the cluster manager for this cluster.
 	// The Python-operator will deploy a dedicated cluster manager instance.
 	// The Go-operator will use a shared instance.

api/v1/qdrantcluster_types_test.go

@@ -1,8 +1,12 @@
 package v1
 
 import (
+	"crypto/sha256"
+	"encoding/json"
+	"fmt"
 	"testing"
 
+	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 )
 
@@ -17,3 +21,51 @@ func TestValidate(t *testing.T) {
 	require.Error(t, err)
 	require.ErrorContains(t, err, "Spec.Resources.CPU error: quantities must match the regular expression '^([+-]?[0-9.]+)([eEinumkKMGTP]*[-+]?[0-9]*)$'")
 }
+
+func TestGetQdrantClusterCrdForHash(t *testing.T) {
+	qc := QdrantCluster{}
+	hash, err := getQdrantClusterCrdHash(qc)
+	require.NoError(t, err)
+	assert.Equal(t, "523a8cb", hash)
+
+	falseVal := false
+	qc.Spec.ServicePerNode = &falseVal
+	hash, err = getQdrantClusterCrdHash(qc)
+	require.NoError(t, err)
+	assert.Equal(t, "523a8cb", hash)
+
+	trueVal := true
+	qc.Spec.ServicePerNode = &trueVal
+	hash, err = getQdrantClusterCrdHash(qc)
+	require.NoError(t, err)
+	assert.Equal(t, "523a8cb", hash)
+}
+
+// getQdrantClusterCrdHash created a hash for the provided QdrantCluster,
+// however a subset only, see GetQdrantClusterCrdForHash for details.
+func getQdrantClusterCrdHash(qc QdrantCluster) (string, error) {
+	inspect := GetQdrantClusterCrdForHash(qc)
+	// Get the hash, so we can diff later
+	hash, err := getHash(inspect)
+	if err != nil {
+		return "", fmt.Errorf("failed to get hash for QdrantCluster: %w", err)
+	}
+	return hash, err
+}
+
+// Get hash of provided value.
+// Returns the first 7 characters of the hash (like GitHub).
+func getHash(v any) (string, error) {
+	json, err := json.Marshal(v)
+	if err != nil {
+		return "", fmt.Errorf("marshal failed: %w", err)
+	}
+	// Initialize hash
+	hash := sha256.New()
+	// add the serialized content
+	hash.Write(json)
+	// close hash
+	sum := hash.Sum(nil)
+	// Return first 7 characters
+	return fmt.Sprintf("%x", sum)[:7], nil
+}