interactive_test.go

//go:build interactive

package e2e

import (
	"fmt"
	"testing"

	"github.com/efficientgo/core/testutil"
	"github.com/efficientgo/e2e"
	e2einteractive "github.com/efficientgo/e2e/interactive"
)

func TestInteractiveSetup(t *testing.T) {
	fmt.Printf("Starting services...\n")

	e, err := e2e.New(e2e.WithName(envInteractive))
	testutil.Ok(t, err)
	t.Cleanup(e.Close)

	prepareConfigsAndCerts(t, interactive, e)
	_, token, rateLimiterAddr := startBaseServices(t, e, interactive)
	readEndpoint, writeEndpoint, readExtEndpoint := startServicesForMetrics(t, e)
	logsEndpoint, logsExtEndpoint := startServicesForLogs(t, e)
	rulesEndpoint := startServicesForRules(t, e)
	internalOtlpEndpoint, httpExternalQueryEndpoint, httpInternalQueryEndpoint := startServicesForTraces(t, e)

	api, err := newObservatoriumAPIService(
		e,
		withMetricsEndpoints("http://"+readEndpoint, "http://"+writeEndpoint),
		withLogsEndpoints("http://"+logsEndpoint),
		withRulesEndpoint("http://"+rulesEndpoint),
		withRateLimiter(rateLimiterAddr),
		withGRPCListenEndpoint(":8317"),
		withOtelTraceEndpoint(internalOtlpEndpoint),
		withJaegerEndpoint("http://"+httpInternalQueryEndpoint),
	)
	testutil.Ok(t, err)
	testutil.Ok(t, e2e.StartAndWaitReady(api))

	up, err := newUpRun(
		e, "up-metrics-read-write", metrics,
		"https://"+api.InternalEndpoint("https")+"/api/metrics/v1/"+defaultTenantName+"/api/v1/query",
		"https://"+api.InternalEndpoint("https")+"/api/metrics/v1/"+defaultTenantName+"/api/v1/receive",
		withToken(token),
		withRunParameters(&runParams{period: "5000ms", threshold: "1", latency: "10s", duration: "0"}),
	)
	testutil.Ok(t, err)
	testutil.Ok(t, e2e.StartAndWaitReady(up))

	testutil.Ok(t, e2einteractive.OpenInBrowser("http://"+readExtEndpoint))

	up, err = newUpRun(
		e, "up-logs-read-write", logs,
		"https://"+api.InternalEndpoint("https")+"/api/logs/v1/"+defaultTenantName+"/loki/api/v1/query",
		"https://"+api.InternalEndpoint("https")+"/api/logs/v1/"+defaultTenantName+"/loki/api/v1/push",
		withToken(token),
		withRunParameters(&runParams{initialDelay: "100ms", period: "1s", threshold: "1", latency: "10s", duration: "0"}),
	)
	testutil.Ok(t, err)
	testutil.Ok(t, e2e.StartAndWaitReady(up))

	fmt.Printf("\n")
	fmt.Printf("You're all set up!\n")
	fmt.Printf("========================================\n")
	fmt.Printf("Observatorium API on host machine: 		%s \n", api.Endpoint("https"))
	fmt.Printf("Observatorium internal server on host machine: 	%s \n", api.Endpoint("http-internal"))
	fmt.Printf("Thanos Query on host machine: 			%s \n", readExtEndpoint)
	fmt.Printf("Loki on host machine: 				%s \n", logsExtEndpoint)
	fmt.Printf("Observatorium gRPC API on host machine:           %s\n", api.Endpoint("grpc"))
	fmt.Printf("Jaeger Query on host machine (HTTP):              %s\n", httpExternalQueryEndpoint)

	fmt.Printf("API Token: 					%s \n\n", token)

	testutil.Ok(t, e2einteractive.RunUntilEndpointHit())
}