CLOUDP-337358 - Telemetry multi arch (#356)

# Summary

<!-- Enter your issue summary here.-->

## Proof of Work

<!-- Enter your proof that it works here.-->

## Checklist

- [ ] Have you linked a jira ticket and/or is the ticket in the title?
- [ ] Have you checked whether your jira ticket required DOCSP changes?
- [ ] Have you added changelog file?
    - use `skip-changelog` label if not needed
- refer to [Changelog files and Release
Notes](https://github.com/mongodb/mongodb-kubernetes/blob/master/CONTRIBUTING.md#changelog-files-and-release-notes)
section in CONTRIBUTING.md for more details

Author: nammn

mongodb-community-operator/pkg/kube/client/mocked_manager.go

@@ -79,7 +79,7 @@ func (m *MockedManager) GetAdmissionDecoder() admission.Decoder {
 
 // GetAPIReader returns the client reader
 func (m *MockedManager) GetAPIReader() k8sClient.Reader {
-	return nil
+	return m.Client
 }
 
 // GetClient returns a client configured with the Config

pkg/telemetry/collector.go

@@ -2,6 +2,7 @@ package telemetry
 
 import (
 	"context"
+	"runtime"
 	"slices"
 	"strings"
 	"time"
@@ -182,6 +183,8 @@ func collectOperatorSnapshot(ctx context.Context, memberClusterMap map[string]Co
 		OperatorID:           operatorUUID,
 		OperatorVersion:      versionutil.StaticContainersOperatorVersion(),
 		OperatorType:         MEKO,
+		OperatorArchitecture: runtime.GOARCH,
+		OperatorOS:           runtime.GOOS,
 	}
 
 	event := createEvent(operatorEvent, time.Now(), Operators)

pkg/telemetry/collector_test.go

@@ -3,15 +3,18 @@ package telemetry
 import (
 	"context"
 	"errors"
+	"runtime"
 	"testing"
 	"time"
 
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 	"k8s.io/apimachinery/pkg/types"
+	"k8s.io/client-go/rest"
 	"k8s.io/utils/ptr"
 	"sigs.k8s.io/controller-runtime/pkg/client"
 
+	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 
 	mdbv1 "github.com/mongodb/mongodb-kubernetes/api/v1/mdb"
@@ -1331,3 +1334,93 @@ func TestAddSearchEvents(t *testing.T) {
 		})
 	}
 }
+
+func TestCollectOperatorSnapshot(t *testing.T) {
+	tests := map[string]struct {
+		memberClusterMap map[string]ConfigClient
+		expectedProps    OperatorUsageSnapshotProperties
+	}{
+		"single cluster": {
+			memberClusterMap: map[string]ConfigClient{},
+			expectedProps: OperatorUsageSnapshotProperties{
+				OperatorID:           testOperatorUUID,
+				OperatorType:         MEKO,
+				OperatorArchitecture: runtime.GOARCH,
+				OperatorOS:           runtime.GOOS,
+			},
+		},
+		"multi cluster": {
+			memberClusterMap: map[string]ConfigClient{
+				"cluster1": &mockConfigClient{clusterUUID: "cluster-uuid-1"},
+				"cluster2": &mockConfigClient{clusterUUID: "cluster-uuid-2"},
+			},
+			expectedProps: OperatorUsageSnapshotProperties{
+				OperatorID:           testOperatorUUID,
+				OperatorType:         MEKO,
+				OperatorArchitecture: runtime.GOARCH,
+				OperatorOS:           runtime.GOOS,
+			},
+		},
+	}
+
+	for name, test := range tests {
+		t.Run(name, func(t *testing.T) {
+			t.Parallel()
+
+			kubeSystemNamespace := &corev1.Namespace{
+				ObjectMeta: metav1.ObjectMeta{
+					Name: "kube-system",
+					UID:  types.UID("operator-cluster-uuid"),
+				},
+			}
+
+			k8sClient := mock.NewEmptyFakeClientBuilder().WithObjects(kubeSystemNamespace).Build()
+			mgr := mockClient.NewManagerWithClient(k8sClient)
+
+			ctx := context.Background()
+
+			events := collectOperatorSnapshot(ctx, test.memberClusterMap, mgr, testOperatorUUID, "", "")
+
+			require.Len(t, events, 1, "expected exactly one operator event")
+			event := events[0]
+
+			assert.Equal(t, Operators, event.Source)
+			require.NotNil(t, event.Timestamp, "event timestamp is nil")
+
+			assert.Equal(t, runtime.GOARCH, event.Properties["operatorArchitecture"])
+			assert.Equal(t, runtime.GOOS, event.Properties["operatorOS"])
+			assert.Equal(t, testOperatorUUID, event.Properties["operatorID"])
+			assert.Equal(t, string(MEKO), event.Properties["operatorType"])
+
+			assert.Contains(t, event.Properties, "kubernetesClusterID")
+			assert.Contains(t, event.Properties, "kubernetesClusterIDs")
+			assert.Contains(t, event.Properties, "operatorVersion")
+		})
+	}
+}
+
+// mockConfigClient is a simple mock implementation of ConfigClient for testing
+type mockConfigClient struct {
+	clusterUUID string
+}
+
+func (m *mockConfigClient) GetConfig() *rest.Config {
+	return &rest.Config{}
+}
+
+func (m *mockConfigClient) GetAPIReader() client.Reader {
+	uuid := m.clusterUUID
+	if uuid == "" {
+		uuid = "default-cluster-uuid"
+	}
+
+	kubeSystemNamespace := &corev1.Namespace{
+		ObjectMeta: metav1.ObjectMeta{
+			Name: "kube-system",
+			UID:  types.UID(uuid),
+		},
+	}
+
+	k8sClient := mock.NewEmptyFakeClientBuilder().WithObjects(kubeSystemNamespace).Build()
+	return k8sClient
+}

pkg/telemetry/types.go

@@ -20,6 +20,8 @@ type OperatorUsageSnapshotProperties struct {
 	OperatorID           string       `json:"operatorID"`           // Operator UUID
 	OperatorVersion      string       `json:"operatorVersion"`      // Version of the operator
 	OperatorType         OperatorType `json:"operatorType"`         // MEKO, MCK, MCO (here meko)
+	OperatorArchitecture string       `json:"operatorArchitecture"` // Architecture of the operator binary (amd64, arm64, s390x, ppc64le)
+	OperatorOS           string       `json:"operatorOS"`           // Operating system of the operator binary (linux, darwin, windows)
 }
 
 func (p OperatorUsageSnapshotProperties) ConvertToFlatMap() (map[string]any, error) {

scripts/release/tests/build_info_test.py

@@ -274,7 +274,7 @@ def test_load_build_info_staging(git_repo: Repo):
             ),
             "init-ops-manager": ImageInfo(
                 repository="268558157000.dkr.ecr.us-east-1.amazonaws.com/staging/mongodb-kubernetes-init-ops-manager",
-                platforms=["linux/arm64", "linux/amd64", "linux/s390x", "linux/ppc64le"],
+                platforms=["linux/amd64"],
                 version=expected_commit_sha,
                 dockerfile_path="docker/mongodb-kubernetes-init-ops-manager/Dockerfile.atomic",
                 sign=True,
@@ -382,7 +382,7 @@ def test_load_build_info_release(
             ),
             "init-ops-manager": ImageInfo(
                 repository="quay.io/mongodb/mongodb-kubernetes-init-ops-manager",
-                platforms=["linux/arm64", "linux/amd64", "linux/s390x", "linux/ppc64le"],
+                platforms=["linux/amd64"],
                 version=version,
                 dockerfile_path="docker/mongodb-kubernetes-init-ops-manager/Dockerfile.atomic",
                 sign=True,

scripts/release/tests/release_info_test.py

@@ -30,7 +30,7 @@ def test_create_release_info_json(
             },
             "init-ops-manager": {
                 "repository": "quay.io/mongodb/mongodb-kubernetes-init-ops-manager",
-                "platforms": ["linux/arm64", "linux/amd64", "linux/s390x", "linux/ppc64le"],
+                "platforms": ["linux/amd64"],
                 "version": "1.2.0",
             },
             "database": {

scripts/release/tests/test_detect_ops_manager_changes.py

@@ -161,28 +161,6 @@ def test_new_ops_manager_version_added(self):
             changed_agents = detect_ops_manager_changes()
             self.assertIn(("108.0.0.8694-1", "100.10.0"), changed_agents)
 
-    def test_ops_manager_version_modified(self):
-        """Test that modifying existing OM version is NOT detected (only new versions are detected)"""
-        modified_current = json.loads(json.dumps(self.current_release_data))
-        modified_current["supportedImages"]["mongodb-agent"]["opsManagerMapping"]["ops_manager"]["6.0.26"][
-            "agent_version"
-        ] = "12.0.35.7911-1"
-
-        with (
-            patch(
-                "scripts.release.agent.detect_ops_manager_changes.load_current_release_json",
-                return_value=modified_current,
-            ),
-            patch(
-                "scripts.release.agent.detect_ops_manager_changes.load_release_json_from_master",
-                return_value=self.master_release_data,
-            ),
-        ):
-
-            changed_agents = detect_ops_manager_changes()
-            # Modified existing OM versions should NOT be detected
-            self.assertEqual(changed_agents, [])
-
     def test_cloud_manager_changed(self):
         """Test detection when cloud_manager is changed"""
         modified_current = json.loads(json.dumps(self.current_release_data))