greenhouse-daemon/telemetry.go

package main

import (
	"bytes"
	"fmt"
	"io/ioutil"
	"net/http"
	"strings"
	"time"
)

var telemetryClient *http.Client

func postTelemetry(tyype string, account string, daemonId string, content string) {
	if account != "" {
		account = fmt.Sprintf("&account=%s", account)
	}
	if daemonId != "" {
		daemonId = fmt.Sprintf("&daemon=%s", daemonId)
	}
	response, err := getTelemetryClient().Post(
		fmt.Sprintf("https://telemetry.greenhouse-alpha.server.garden/?type=%s&ip=auto%s%s", tyype, account, daemonId),
		"text/plain",
		bytes.NewBufferString(content),
	)
	if err != nil {
		log.Printf("postTelemetry: %s\n", err)
	} else if response.StatusCode > 299 {
		responseString := "<read error>"
		responseBytes, err := ioutil.ReadAll(response.Body)
		if err == nil {
			responseString = string(responseBytes)
		}
		log.Printf("postTelemetry: HTTP %d: %s\n", response.StatusCode, responseString)
	}
}

func getTelemetryClient() *http.Client {
	if telemetryClient == nil {
		telemetryClient = &http.Client{
			Timeout: time.Second * 10,
		}
	}
	return telemetryClient
}

func fatalfWithTelemetry(format string, args ...interface{}) {
	formatWithoutStackTraces := strings.ReplaceAll(format, "%+v", "%s")
	postTelemetry("daemon-crashed", daemonTelemetryAccount, daemonTelemetryId, fmt.Sprintf(formatWithoutStackTraces, args...))
	log.Fatalf(format, args...)
}