[installation-telemetry]: get installationAdmin data from server

Author: Simon Emms

components/installation-telemetry/cmd/send.go

@@ -9,6 +9,8 @@ import (
 	"os"
 
 	"github.com/gitpod-io/gitpod/common-go/log"
+	"github.com/gitpod-io/gitpod/installation-telemetry/pkg/common"
+	"github.com/gitpod-io/gitpod/installation-telemetry/pkg/server"
 	"github.com/spf13/cobra"
 	"gopkg.in/segmentio/analytics-go.v3"
 )
@@ -19,9 +21,17 @@ var sendCmd = &cobra.Command{
 	Use:   "send",
 	Short: "Sends telemetry data",
 	RunE: func(cmd *cobra.Command, args []string) (err error) {
-		// @todo(sje): replace with a database call to get status
-		canSendData := false
-		if !canSendData {
+		config, err := common.NewConfig()
+		if err != nil {
+			return err
+		}
+
+		data, err := server.GetInstallationAdminData(*config)
+		if err != nil {
+			return err
+		}
+
+		if !data.Settings.SendTelemetry {
 			log.Info("installation-telemetry is not permitted to send - exiting")
 			return nil
 		}
@@ -30,11 +40,6 @@ var sendCmd = &cobra.Command{
 			return fmt.Errorf("segmentIOToken build variable not set")
 		}
 
-		domainHash := os.Getenv("GITPOD_DOMAIN_HASH")
-		if domainHash == "" {
-			return fmt.Errorf("GITPOD_DOMAIN_HASH envvar not set")
-		}
-
 		versionId := os.Getenv("GITPOD_INSTALLATION_VERSION")
 		if versionId == "" {
 			return fmt.Errorf("GITPOD_INSTALLATION_VERSION envvar not set")
@@ -46,7 +51,7 @@ var sendCmd = &cobra.Command{
 		}()
 
 		telemetry := analytics.Track{
-			UserId: domainHash,
+			UserId: data.ID,
 			Event:  "Installation telemetry",
 			Properties: analytics.NewProperties().
 				Set("version", versionId),

components/installation-telemetry/go.mod

@@ -19,3 +19,53 @@ require (
 )
 
 replace github.com/gitpod-io/gitpod/common-go => ../common-go // leeway
+
+replace k8s.io/api => k8s.io/api v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/apiextensions-apiserver => k8s.io/apiextensions-apiserver v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/apimachinery => k8s.io/apimachinery v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/apiserver => k8s.io/apiserver v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/cli-runtime => k8s.io/cli-runtime v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/client-go => k8s.io/client-go v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/cloud-provider => k8s.io/cloud-provider v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/cluster-bootstrap => k8s.io/cluster-bootstrap v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/code-generator => k8s.io/code-generator v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/component-base => k8s.io/component-base v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/cri-api => k8s.io/cri-api v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/csi-translation-lib => k8s.io/csi-translation-lib v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/kube-aggregator => k8s.io/kube-aggregator v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/kube-controller-manager => k8s.io/kube-controller-manager v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/kube-proxy => k8s.io/kube-proxy v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/kube-scheduler => k8s.io/kube-scheduler v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/kubelet => k8s.io/kubelet v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/legacy-cloud-providers => k8s.io/legacy-cloud-providers v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/metrics => k8s.io/metrics v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/sample-apiserver => k8s.io/sample-apiserver v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/component-helpers => k8s.io/component-helpers v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/controller-manager => k8s.io/controller-manager v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/kubectl => k8s.io/kubectl v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/mount-utils => k8s.io/mount-utils v0.22.2 // leeway indirect from components/common-go:lib
+
+replace k8s.io/pod-security-admission => k8s.io/pod-security-admission v0.22.2 // leeway indirect from components/common-go:lib

components/installation-telemetry/pkg/common/config.go

@@ -0,0 +1,26 @@
+// Copyright (c) 2022 Gitpod GmbH. All rights reserved.
+// Licensed under the GNU Affero General Public License (AGPL).
+// See License-AGPL.txt in the project root for license information.
+
+package common
+
+import (
+	"fmt"
+	"os"
+)
+
+type Config struct {
+	Server string
+}
+
+func NewConfig() (*Config, error) {
+	config := Config{
+		Server: os.Getenv("SERVER_URL"),
+	}
+
+	if config.Server == "" {
+		return nil, fmt.Errorf("SERVER_URL required")
+	}
+
+	return &config, nil
+}

components/installation-telemetry/pkg/server/installationAdmin.go

@@ -0,0 +1,44 @@
+// Copyright (c) 2022 Gitpod GmbH. All rights reserved.
+// Licensed under the GNU Affero General Public License (AGPL).
+// See License-AGPL.txt in the project root for license information.
+
+package server
+
+import (
+	"encoding/json"
+	"fmt"
+	"io/ioutil"
+	"net/http"
+
+	"github.com/gitpod-io/gitpod/installation-telemetry/pkg/common"
+)
+
+type InstallationAdminSettings struct {
+	SendTelemetry bool `json:"sendTelemetry"`
+}
+
+type InstallationAdminData struct {
+	ID       string                    `json:"id"`
+	Settings InstallationAdminSettings `json:"settings"`
+}
+
+func GetInstallationAdminData(config common.Config) (*InstallationAdminData, error) {
+	resp, err := http.Get(fmt.Sprintf("%s/data", config.Server))
+	if err != nil {
+		return nil, err
+	}
+
+	defer resp.Body.Close()
+
+	body, err := ioutil.ReadAll(resp.Body)
+	if err != nil {
+		return nil, err
+	}
+
+	var data InstallationAdminData
+	if err := json.Unmarshal(body, &data); err != nil {
+		return nil, err
+	}
+
+	return &data, nil
+}