Set platform and platformVersion in telemetry (#6540)

* Set platform and platformVersion in telemetry

* Vendor oc config client

* Get OC version

* Integration tests for odo dev

* Integration tests for odo deploy

* Update doc

* Apply suggestions from code review

Co-authored-by: Armel Soro <[email protected]>

* Add integration test on odo init

* Fix OC version when no complete version status

---------

Co-authored-by: Armel Soro <[email protected]>

Author: feloy

Diff for: USAGE_DATA.md

@@ -11,6 +11,7 @@ If the user has consented to `odo` collecting usage data, the following data wil
 * Command Success
 * Pseudonymized error message and error type (in case of failure)
 * Whether the command was run from a terminal
+* Whether the command was run in experimental mode
 * `odo` version in use
 
 In addition to this, the following data about user's identity is also noted - 
@@ -22,12 +23,12 @@ The following tables describe the additional information collected by `odo` comm
 
 **odo v3**
 
-| Command                           | Data                                                                          |
-|-----------------------------------|-------------------------------------------------------------------------------|
-| odo init                          | Component Type, Devfile Name, Language, Project Type, Interactive Mode (bool) |
-| odo dev                           | Component Type, Devfile Name, Language, Project Type                          |
-| odo deploy                        | Component Type, Devfile Name, Language, Project Type                          |
-| odo <create/set/delete> namespace | Cluster Type (Possible values: OpenShift 3, OpenShift 4, Kubernetes)          |
+| Command                           | Data                                                                                                            |
+|-----------------------------------|-----------------------------------------------------------------------------------------------------------------|
+| odo init                          | Component Type, Devfile Name, Language, Project Type, Interactive Mode (bool)                                   |
+| odo dev                           | Component Type, Devfile Name, Language, Project Type, Platform (podman, kubernetes, openshift), Platform version|
+| odo deploy                        | Component Type, Devfile Name, Language, Project Type, Platform (kubernetes, openshift), Platform version        |
+| odo <create/set/delete> namespace | Cluster Type (Possible values: OpenShift 3, OpenShift 4, Kubernetes)                                            |
 
 **odo v2**
 

Diff for: pkg/kclient/interface.go

@@ -89,6 +89,7 @@ type ClientInterface interface {
 
 	// oc_server.go
 	GetServerVersion(timeout time.Duration) (*ServerInfo, error)
+	GetOCVersion() (string, error)
 
 	// operators.go
 	IsCSVSupported() (bool, error)

Diff for: pkg/kclient/kclient.go

@@ -22,6 +22,7 @@ import (
 
 	// api clientsets
 	servicecatalogclienset "github.com/kubernetes-sigs/service-catalog/pkg/client/clientset_generated/clientset/typed/servicecatalog/v1beta1"
+	configclientset "github.com/openshift/client-go/config/clientset/versioned/typed/config/v1"
 	projectclientset "github.com/openshift/client-go/project/clientset/versioned/typed/project/v1"
 	routeclientset "github.com/openshift/client-go/route/clientset/versioned/typed/route/v1"
 	userclientset "github.com/openshift/client-go/user/clientset/versioned/typed/user/v1"
@@ -73,6 +74,7 @@ type Client struct {
 	userClient    userclientset.UserV1Interface
 	projectClient projectclientset.ProjectV1Interface
 	routeClient   routeclientset.RouteV1Interface
+	configClient  *configclientset.ConfigV1Client
 }
 
 var _ ClientInterface = (*Client)(nil)
@@ -187,7 +189,10 @@ func NewForConfig(config clientcmd.ClientConfig) (client *Client, err error) {
 	if err != nil {
 		return nil, err
 	}
-
+	client.configClient, err = configclientset.NewForConfig(client.KubeClientConfig)
+	if err != nil {
+		return nil, err
+	}
 	return client, nil
 }
 

Diff for: pkg/kclient/mock_Client.go

@@ -9,6 +9,9 @@ import (
 	"time"
 
 	dfutil "github.com/devfile/library/v2/pkg/util"
+	configv1 "github.com/openshift/api/config/v1"
+	kerrors "k8s.io/apimachinery/pkg/api/errors"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/version"
 	"k8s.io/klog"
 )
@@ -82,3 +85,26 @@ func (c *Client) GetServerVersion(timeout time.Duration) (*ServerInfo, error) {
 
 	return &info, nil
 }
+
+func (c *Client) GetOCVersion() (string, error) {
+	clusterVersion, err := c.configClient.ClusterVersions().Get(context.TODO(), "version", metav1.GetOptions{})
+	if err != nil {
+		return "", err
+	}
+	switch {
+	case kerrors.IsForbidden(err), kerrors.IsNotFound(err):
+		return "", err
+	}
+	if clusterVersion != nil {
+		if len(clusterVersion.Status.History) == 1 {
+			return clusterVersion.Status.History[0].Version, nil
+		}
+		for _, update := range clusterVersion.Status.History {
+			if update.State == configv1.CompletedUpdate {
+				// obtain the version from the last completed update
+				return update.Version, nil
+			}
+		}
+	}
+	return "", errors.New("unable to get OC version")
+}

Diff for: pkg/kclient/oc_server.go

@@ -52,6 +52,7 @@ func (o *DeployOptions) PreInit() string {
 
 // Complete DeployOptions after they've been created
 func (o *DeployOptions) Complete(ctx context.Context, cmdline cmdline.Cmdline, args []string) (err error) {
+	scontext.SetPlatform(ctx, o.clientset.KubernetesClient)
 	return nil
 }
 
@@ -104,7 +105,7 @@ func NewCmdDeploy(name, fullName string) *cobra.Command {
 			return genericclioptions.GenericRun(o, cmd, args)
 		},
 	}
-	clientset.Add(deployCmd, clientset.INIT, clientset.DEPLOY, clientset.FILESYSTEM)
+	clientset.Add(deployCmd, clientset.INIT, clientset.DEPLOY, clientset.FILESYSTEM, clientset.KUBERNETES)
 
 	// Add a defined annotation in order to appear in the help menu
 	util.SetCommandGroup(deployCmd, util.MainGroup)

Diff for: pkg/odo/cli/deploy/deploy.go

@@ -107,10 +107,12 @@ func (o *DevOptions) Validate(ctx context.Context) error {
 		if o.clientset.KubernetesClient == nil {
 			return errors.New("no connection to cluster defined")
 		}
+		scontext.SetPlatform(ctx, o.clientset.KubernetesClient)
 	case commonflags.PlatformPodman:
 		if o.clientset.PodmanClient == nil {
 			return errors.New("unable to access podman. Do you have podman client installed?")
 		}
+		scontext.SetPlatform(ctx, o.clientset.PodmanClient)
 	}
 	return nil
 }

Diff for: pkg/odo/cli/dev/dev.go

@@ -53,4 +53,6 @@ type Client interface {
 	GetRunningPodFromSelector(selector string) (*corev1.Pod, error)
 
 	ListAllComponents() ([]api.ComponentAbstract, error)
+
+	Version() (SystemVersionReport, error)
 }

Diff for: pkg/podman/interface.go

@@ -6,10 +6,13 @@ import (
 	"os"
 	"strings"
 	"sync"
+	"time"
 
 	"github.com/spf13/pflag"
 
 	"github.com/redhat-developer/odo/pkg/kclient"
+	"github.com/redhat-developer/odo/pkg/platform"
+	"github.com/redhat-developer/odo/pkg/podman"
 
 	dfutil "github.com/devfile/library/v2/pkg/util"
 
@@ -28,6 +31,8 @@ const (
 	InteractiveMode  = "interactive"
 	ExperimentalMode = "experimental"
 	Flags            = "flags"
+	Platform         = "platform"
+	PlatformVersion  = "platformVersion"
 )
 
 const (
@@ -98,6 +103,61 @@ func SetClusterType(ctx context.Context, client kclient.ClientInterface) {
 	setContextProperty(ctx, ClusterType, value)
 }
 
+// SetPlatform sets platform and platform_version properties for telemetry data
+func SetPlatform(ctx context.Context, client platform.Client) {
+	switch client := client.(type) {
+	case kclient.ClientInterface:
+		setPlatformCluster(ctx, client)
+	case podman.Client:
+		setPlatformPodman(ctx, client)
+	}
+}
+
+func setPlatformCluster(ctx context.Context, client kclient.ClientInterface) {
+	var value string
+	if client == nil {
+		value = NOTFOUND
+	} else {
+		// We are not checking ServerVersion to decide the cluster type because it does not always return the version,
+		// it sometimes fails to retrieve the data if user is using minishift or plain oc cluster
+
+		isOC, err := client.IsProjectSupported()
+		if err != nil {
+			klog.V(3).Info(fmt.Errorf("unable to detect project support: %w", err))
+			value = NOTFOUND
+		} else {
+			if isOC {
+				value = "openshift"
+				ocVersion, err := client.GetOCVersion()
+				if err == nil {
+					setContextProperty(ctx, PlatformVersion, ocVersion)
+				} else {
+					klog.V(3).Info(fmt.Errorf("unable to detect platform version: %w", err))
+				}
+			} else {
+				value = "kubernetes"
+				serverInfo, err := client.GetServerVersion(time.Second)
+				if err == nil {
+					setContextProperty(ctx, PlatformVersion, serverInfo.KubernetesVersion)
+				} else {
+					klog.V(3).Info(fmt.Errorf("unable to detect platform version: %w", err))
+				}
+			}
+		}
+	}
+	setContextProperty(ctx, Platform, value)
+}
+
+func setPlatformPodman(ctx context.Context, client podman.Client) {
+	setContextProperty(ctx, Platform, "podman")
+	version, err := client.Version()
+	if err != nil {
+		klog.V(3).Info(fmt.Errorf("unable to get podman version: %w", err))
+		return
+	}
+	setContextProperty(ctx, PlatformVersion, version.Client.Version)
+}
+
 // SetTelemetryStatus sets telemetry status before a command is run
 func SetTelemetryStatus(ctx context.Context, isEnabled bool) {
 	setContextProperty(ctx, TelemetryStatus, isEnabled)

Diff for: pkg/podman/mock.go

@@ -241,6 +241,14 @@ var _ = Describe("odo dev command tests", func() {
 						experimentalValue = true
 					}
 					Expect(td.Properties.CmdProperties[segment.ExperimentalMode]).To(Equal(experimentalValue))
+					if podman {
+						Expect(td.Properties.CmdProperties[segment.Platform]).To(Equal("podman"))
+					} else if os.Getenv("KUBERNETES") == "true" {
+						Expect(td.Properties.CmdProperties[segment.Platform]).To(Equal("kubernetes"))
+					} else {
+						Expect(td.Properties.CmdProperties[segment.Platform]).To(Equal("openshift"))
+					}
+					Expect(td.Properties.CmdProperties[segment.PlatformVersion]).ToNot(BeEmpty())
 				})
 			}))
 

Diff for: pkg/segment/context/context.go

@@ -4,6 +4,7 @@ import (
 	"fmt"
 	"net/http"
 	"net/http/httptest"
+	"os"
 	"path"
 	"path/filepath"
 	"regexp"
@@ -221,6 +222,12 @@ ComponentSettings:
 			Expect(td.Properties.CmdProperties).Should(HaveKey(segment.Caller))
 			Expect(td.Properties.CmdProperties[segment.Caller]).To(BeEmpty())
 			Expect(td.Properties.CmdProperties[segment.ExperimentalMode]).To(Equal(false))
+			if os.Getenv("KUBERNETES") == "true" {
+				Expect(td.Properties.CmdProperties[segment.Platform]).To(Equal("kubernetes"))
+			} else {
+				Expect(td.Properties.CmdProperties[segment.Platform]).To(Equal("openshift"))
+			}
+			Expect(td.Properties.CmdProperties[segment.PlatformVersion]).ToNot(BeEmpty())
 		})
 	})
 

Diff for: tests/integration/cmd_dev_test.go

@@ -567,6 +567,8 @@ var _ = Describe("odo devfile init command tests", func() {
 							Expect(td.Properties.CmdProperties[segmentContext.Language]).To(ContainSubstring("Go"))
 							Expect(td.Properties.CmdProperties[segmentContext.ProjectType]).To(ContainSubstring("Go"))
 							Expect(td.Properties.CmdProperties[segmentContext.Flags]).To(ContainSubstring("devfile name"))
+							Expect(td.Properties.CmdProperties[segmentContext.Platform]).To(BeNil())
+							Expect(td.Properties.CmdProperties[segmentContext.PlatformVersion]).To(BeNil())
 							tt.callerChecker(stdout, stderr, td)
 						})