From e6963c543d50c1d6bd43dd045623abaee8f673f2 Mon Sep 17 00:00:00 2001
From: Jens Langhammer <jens.langhammer@beryju.org>
Date: Mon, 8 Nov 2021 19:35:53 +0100
Subject: [PATCH] outpost: remove analytics

Signed-off-by: Jens Langhammer <jens.langhammer@beryju.org>
---
 internal/outpost/ak/analytics.go | 84 --------------------------------
 internal/outpost/ak/api.go       |  1 -
 2 files changed, 85 deletions(-)
 delete mode 100644 internal/outpost/ak/analytics.go

diff --git a/internal/outpost/ak/analytics.go b/internal/outpost/ak/analytics.go
deleted file mode 100644
index 24eda5f2a..000000000
--- a/internal/outpost/ak/analytics.go
+++ /dev/null
@@ -1,84 +0,0 @@
-package ak
-
-import (
-	"bytes"
-	"crypto/sha512"
-	"encoding/hex"
-	"encoding/json"
-	"errors"
-	"fmt"
-	"io/ioutil"
-	"net/http"
-	"net/url"
-	"os"
-
-	log "github.com/sirupsen/logrus"
-	"goauthentik.io/internal/constants"
-)
-
-func exists(name string) bool {
-	_, err := os.Stat(name)
-	if err == nil {
-		return true
-	}
-	if errors.Is(err, os.ErrNotExist) {
-		return false
-	}
-	return false
-}
-
-func getEnv() string {
-	if _, o := os.LookupEnv("KUBERNETES_SERVICE_HOST"); o {
-		return "kubernetes"
-	}
-	if _, o := os.LookupEnv("CI"); o {
-		return "ci"
-	}
-	if exists("/tmp/authentik-mode") {
-		return "embedded"
-	}
-	return "custom"
-}
-
-func analytics(akURL url.URL, on string, t string) {
-	if _, s := os.LookupEnv("AUTHENTIK_DISABLE_ANALYTICS"); s {
-		return
-	}
-	e := getEnv()
-	if e == "ci" {
-		return
-	}
-	body := struct {
-		Domain   string `json:"domain"`
-		Name     string `json:"name"`
-		URL      string `json:"url"`
-		Referrer string `json:"referrer"`
-	}{
-		Domain:   "authentik",
-		Name:     "pageview",
-		URL:      fmt.Sprintf("http://localhost/outpost/%s/%s", e, t),
-		Referrer: fmt.Sprintf("%s (%s)", constants.VERSION, constants.BUILD()),
-	}
-	b, err := json.Marshal(body)
-	if err != nil {
-		log.WithError(err).Debug("test")
-	}
-	ua := fmt.Sprintf("%s-%s", akURL.Host, on)
-	h := sha512.New()
-	h.Write([]byte(ua))
-
-	req, err := http.NewRequest("POST", "https://goauthentik.io/api/event", bytes.NewReader(b))
-	if err != nil {
-		log.WithError(err).Debug("test")
-	}
-	req.Header.Set("Content-Type", "text/plain")
-	req.Header.Set("User-Agent", hex.EncodeToString(h.Sum(nil)))
-	r, err := http.DefaultClient.Do(req)
-	if err != nil {
-		log.WithError(err).Debug("test")
-	}
-	if r.StatusCode >= 400 {
-		b, _ := ioutil.ReadAll(r.Body)
-		log.WithField("status", r.StatusCode).WithField("body", string(b)).Debug("failed")
-	}
-}
diff --git a/internal/outpost/ak/api.go b/internal/outpost/ak/api.go
index df55510c9..7db5a2110 100644
--- a/internal/outpost/ak/api.go
+++ b/internal/outpost/ak/api.go
@@ -67,7 +67,6 @@ func NewAPIController(akURL url.URL, token string) *APIController {
 	}
 	outpost := outposts.Results[0]
 	doGlobalSetup(outpost.Config)
-	go analytics(akURL, outpost.Name, string(outpost.Type))
 
 	log.WithField("name", outpost.Name).Debug("Fetched outpost configuration")