package main

import (
	"fmt"
	"log"
	"net/http"
	"strconv"
	"time"

	"github.com/prometheus/client_golang/prometheus"
	"github.com/prometheus/client_golang/prometheus/promauto"
	"github.com/prometheus/client_golang/prometheus/promhttp"
	"golang.org/x/exp/rand"
)

func randomValues(max int) func() (string, bool) {
	i := 0
	return func() (string, bool) {
		i++
		return strconv.Itoa(i), i < max+1
	}
}

func staticList(input []string) func() string {
	return func() string {
		i := rand.Intn(len(input))

		return input[i]
	}
}

type dimension struct {
	label        string
	getNextValue func() string
}

func main() {

	fakeMetrics := []dimension{
		{
			label:        "cluster",
			getNextValue: staticList([]string{"prod-uk1", "prod-eu1", "prod-uk2", "prod-eu2", "prod-uk3", "prod-eu3", "prod-uk4", "prod-eu4", "prod-uk5", "prod-eu5"}),
		},
		{
			label:        "namespace",
			getNextValue: staticList([]string{"default", "kube-api", "kube-system", "kube-public", "kube-node-lease", "kube-ingress", "kube-logging", "kube-metrics", "kube-monitoring", "kube-network", "kube-storage"}),
		},
		{
			label:        "pod",
			getNextValue: staticList([]string{"default"}),
		},
		{
			label:        "container",
			getNextValue: staticList([]string{"container"}),
		},
		{
			label:        "method",
			getNextValue: staticList([]string{"GET", "POST", "DELETE", "PUT", "PATCH"}),
		},
		{
			label:        "address",
			getNextValue: staticList([]string{"/", "/api", "/api/dashboard", "/api/dashboard/:uid", "/api/dashboard/:uid/overview", "/api/dashboard/:uid/overview/:id", "/api/dashboard/:uid/overview/:id/summary", "/api/dashboard/:uid/overview/:id/summary/:type", "/api/dashboard/:uid/overview/:id/summary/:type/:subtype", "/api/dashboard/:uid/overview/:id/summary/:type/:subtype/:id"}),
		},
		{
			label:        "extra_label_name1",
			getNextValue: staticList([]string{"default"}),
		},
		{
			label:        "extra_label_name2",
			getNextValue: staticList([]string{"default"}),
		},
		{
			label:        "extra_label_name3",
			getNextValue: staticList([]string{"default"}),
		},
		{
			label:        "extra_label_name4",
			getNextValue: staticList([]string{"default"}),
		},
		{
			label:        "extra_label_name5",
			getNextValue: staticList([]string{"default"}),
		},
		{
			label:        "extra_label_name6",
			getNextValue: staticList([]string{"default"}),
		},
	}

	dimensions := []string{}
	for _, dim := range fakeMetrics {
		dimensions = append(dimensions, dim.label)
	}

	opsProcessed := promauto.NewCounterVec(prometheus.CounterOpts{
		Name: "fakedata_highcard_http_requests_total",
		Help: "a high cardinality counter",
	}, dimensions)

	http.Handle("/metrics", promhttp.Handler())
	http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
		w.WriteHeader(http.StatusOK)
		w.Write([]byte("Hello, is it me you're looking for?"))
	})

	go func() {
		for {
			labels := []string{}
			for _, dim := range fakeMetrics {
				value := dim.getNextValue()
				labels = append(labels, value)
			}

			opsProcessed.WithLabelValues(labels...).Inc()

			time.Sleep(time.Millisecond)
		}
	}()

	fmt.Printf("Server started at :9111\n")

	log.Fatal(http.ListenAndServe(":9111", nil))
}