Merge 0bca28f into 8c9bcde

ododevapispec.yaml

@@ -275,6 +275,24 @@ paths:
               example:
                 message: "Error getting the Devfile content"
 
+  /telemetry:
+    get:
+      description: Get the specific information for sending telemetry data
+      responses:
+        '200':
+          description: 'Specific information for sending telemetry data'
+          content:
+            application/json:
+              schema:
+                $ref: '#/components/schemas/TelemetryResponse'
+        '500':
+          description: Error getting the telemetry data
+          content:
+            application/json:
+              schema:
+                $ref: '#/components/schemas/GeneralError'
+              example:
+                message: "Error getting the telemetry data"
 
   /devstate/devfile:
     put:
@@ -1231,6 +1249,17 @@ components:
       properties:
         content:
           type: string
+    TelemetryResponse:
+      type: object
+      required:
+      - enabled
+      properties:
+        enabled:
+          type: boolean
+        apikey:
+          type: string
+        userid:
+          type: string
     DevstateDevfilePutRequest:
       type: object
       required:

pkg/apiserver-impl/api_default_service.go

@@ -17,6 +17,8 @@ import (
 	odocontext "github.com/redhat-developer/odo/pkg/odo/context"
 	"github.com/redhat-developer/odo/pkg/podman"
 	"github.com/redhat-developer/odo/pkg/preference"
+	"github.com/redhat-developer/odo/pkg/segment"
+	scontext "github.com/redhat-developer/odo/pkg/segment/context"
 	"github.com/redhat-developer/odo/pkg/state"
 	"k8s.io/klog"
 )
@@ -175,3 +177,27 @@ func (s *DefaultApiService) validateDevfile(ctx context.Context, dir string) err
 	}
 	return validate.ValidateDevfileData(devObj.Data)
 }
+
+func (s *DefaultApiService) TelemetryGet(ctx context.Context) (openapi.ImplResponse, error) {
+	var (
+		enabled = scontext.GetTelemetryStatus(ctx)
+		apikey  string
+		userid  string
+	)
+	if enabled {
+		apikey = segment.GetApikey()
+		var err error
+		userid, err = segment.GetUserIdentity(segment.GetTelemetryFilePath())
+		if err != nil {
+			return openapi.Response(http.StatusInternalServerError, openapi.GeneralError{
+				Message: fmt.Sprintf("error getting telemetry data: %s", err),
+			}), nil
+		}
+	}
+
+	return openapi.Response(http.StatusOK, openapi.TelemetryResponse{
+		Enabled: enabled,
+		Apikey:  apikey,
+		Userid:  userid,
+	}), nil
+}

pkg/odo/genericclioptions/runnable.go

@@ -155,6 +155,9 @@ func GenericRun(o Runnable, testClientset clientset.Clientset, cmd *cobra.Comman
 		klog.V(4).Infof("WARNING: debug telemetry, if enabled, will be logged in %s", debugTelemetry)
 	}
 
+	isTelemetryEnabled := segment.IsTelemetryEnabled(userConfig, envcontext.GetEnvConfig(ctx))
+	scontext.SetTelemetryStatus(ctx, isTelemetryEnabled)
+
 	// We can dereference as there is a default value defined for this config field
 	err = scontext.SetCaller(ctx, envConfig.TelemetryCaller)
 	if err != nil {

pkg/segment/integrations.go

@@ -39,7 +39,7 @@ func getTelemetryForDevfileRegistry(ctx context.Context) (registryLibrary.Teleme
 	tag, _ := locale.Detect()
 	td.Locale = tag.String()
 
-	user, err := getUserIdentity(GetTelemetryFilePath())
+	user, err := GetUserIdentity(GetTelemetryFilePath())
 	if err != nil {
 		// default to the generic user ID if the anonymous ID cannot be found
 		td.User = td.Client

pkg/segment/segment.go

@@ -73,6 +73,10 @@ type Client struct {
 	TelemetryFilePath string
 }
 
+func GetApikey() string {
+	return writeKey
+}
+
 // NewClient returns a Client created with the default args
 func NewClient() (*Client, error) {
 	return newCustomClient(
@@ -131,7 +135,7 @@ func (c *Client) Upload(ctx context.Context, data TelemetryData) error {
 	}
 
 	// obtain the user ID
-	userId, uerr := getUserIdentity(c.TelemetryFilePath)
+	userId, uerr := GetUserIdentity(c.TelemetryFilePath)
 	if uerr != nil {
 		return uerr
 	}
@@ -193,8 +197,8 @@ func GetTelemetryFilePath() string {
 	return filepath.Join(homeDir, ".redhat", "anonymousId")
 }
 
-// getUserIdentity returns the anonymous ID if it exists, else creates a new one and sends the data to Segment
-func getUserIdentity(telemetryFilePath string) (string, error) {
+// GetUserIdentity returns the anonymous ID if it exists, else creates a new one and sends the data to Segment
+func GetUserIdentity(telemetryFilePath string) (string, error) {
 	var id []byte
 
 	// Get-or-Create the '$HOME/.redhat' directory