📮 emit cyclops install manager (#785)

* emit cyclops install manager

* send only if populated

Author: petar-cvit

cyclops-ctrl/cmd/main/main.go

@@ -68,6 +68,7 @@ func main() {
 	telemetryClient, _ := telemetry.NewClient(
 		getEnvBool("DISABLE_TELEMETRY"),
 		os.Getenv("CYCLOPS_VERSION"),
+		os.Getenv("INSTALL_MANAGER"),
 		setupLog,
 	)
 	telemetryClient.InstanceStart()

cyclops-ctrl/internal/telemetry/client.go

@@ -21,14 +21,15 @@ type logger interface {
 }
 
 type EnqueueClient struct {
-	client     posthog.Client
-	distinctID string
-	version    string
+	client         posthog.Client
+	distinctID     string
+	version        string
+	installManager string
 }
 
 type MockClient struct{}
 
-func NewClient(disable bool, version string, logger logger) (Client, error) {
+func NewClient(disable bool, version, installManager string, logger logger) (Client, error) {
 	if disable {
 		logger.Info("telemetry disabled")
 		return MockClient{}, nil
@@ -56,82 +57,81 @@ func NewClient(disable bool, version string, logger logger) (Client, error) {
 	logger.Info("starting instance with UUID", "UUID", idStr)
 
 	return EnqueueClient{
-		client:     client,
-		distinctID: idStr,
-		version:    version,
+		client:         client,
+		distinctID:     idStr,
+		version:        version,
+		installManager: installManager,
 	}, nil
 }
 
 func (c EnqueueClient) InstanceStart() {
 	_ = c.client.Enqueue(posthog.Capture{
 		Event:      "cyclops-instance-start",
 		DistinctId: c.distinctID,
-		Properties: map[string]interface{}{
-			"version": c.version,
-		},
+		Properties: c.messageProps(),
 	})
 }
 
 func (c EnqueueClient) ModuleReconciliation() {
 	_ = c.client.Enqueue(posthog.Capture{
 		Event:      "module-reconciliation",
 		DistinctId: c.distinctID,
-		Properties: map[string]interface{}{
-			"version": c.version,
-		},
+		Properties: c.messageProps(),
 	})
 }
 
 func (c EnqueueClient) ModuleCreation() {
 	_ = c.client.Enqueue(posthog.Capture{
 		Event:      "module-creation",
 		DistinctId: c.distinctID,
-		Properties: map[string]interface{}{
-			"version": c.version,
-		},
+		Properties: c.messageProps(),
 	})
 }
 
 func (c EnqueueClient) ReleaseUpdate() {
 	_ = c.client.Enqueue(posthog.Capture{
 		Event:      "helm-release-upgrade",
 		DistinctId: c.distinctID,
-		Properties: map[string]interface{}{
-			"version": c.version,
-		},
+		Properties: c.messageProps(),
 	})
 }
 
 func (c EnqueueClient) ReleaseMigration() {
 	_ = c.client.Enqueue(posthog.Capture{
 		Event:      "helm-release-migration",
 		DistinctId: c.distinctID,
-		Properties: map[string]interface{}{
-			"version": c.version,
-		},
+		Properties: c.messageProps(),
 	})
 }
 
 func (c EnqueueClient) TemplateCreation() {
 	_ = c.client.Enqueue(posthog.Capture{
 		Event:      "template-creation",
 		DistinctId: c.distinctID,
-		Properties: map[string]interface{}{
-			"version": c.version,
-		},
+		Properties: c.messageProps(),
 	})
 }
 
 func (c EnqueueClient) TemplateEdit() {
 	_ = c.client.Enqueue(posthog.Capture{
 		Event:      "template-edit",
 		DistinctId: c.distinctID,
-		Properties: map[string]interface{}{
-			"version": c.version,
-		},
+		Properties: c.messageProps(),
 	})
 }
 
+func (c EnqueueClient) messageProps() map[string]interface{} {
+	props := map[string]interface{}{
+		"version": c.version,
+	}
+
+	if props != nil && len(c.installManager) != 0 {
+		props["install_manager"] = c.installManager
+	}
+
+	return props
+}
+
 // region mock client
 
 func (c MockClient) InstanceStart() {

web/docs/usage_metrics/usage_metrics.md

@@ -30,6 +30,7 @@ Each time one of the events above is triggered, Cyclops sends an HTTP request to
 `distinct_id` - generated for each Cyclops instance using [NewUUID](https://pkg.go.dev/github.com/google/uuid#NewUUID) from google/uuid package  
 `event` - which event was triggered; see events above  
 `properties.version` - version of your Cyclops instance
+`properties.install_manager` - emits if Cyclops is installed via other applications/marketplaces (Rancher, Civo marketplace, DigitalOcean marketplace...)
 
 ## Turn off