package trafficsplit

import (
	"context"
	"fmt"
	"os"
	"strings"
	"testing"
	"time"

	"github.com/linkerd/linkerd2/testutil"
)

var TestHelper *testutil.TestHelper

func TestMain(m *testing.M) {
	TestHelper = testutil.NewTestHelper()
	// Block test execution until viz extension is running
	TestHelper.WaitUntilDeployReady(testutil.LinkerdVizDeployReplicas)
	os.Exit(m.Run())
}

func parseStatRows(out string, expectedRowCount, expectedColumnCount int) ([]*testutil.RowStat, error) {
	rows, err := testutil.CheckRowCount(out, expectedRowCount)
	if err != nil {
		return nil, err
	}

	var statRows []*testutil.RowStat

	for _, row := range rows {
		fields := strings.Fields(row)

		if len(fields) != expectedColumnCount {
			return nil, fmt.Errorf(
				"Expected [%d] columns in stat output, got [%d]; full output:\n%s",
				expectedColumnCount, len(fields), row)
		}

		row := &testutil.RowStat{
			Name:               fields[0],
			Meshed:             fields[1],
			Success:            fields[2],
			Rps:                fields[3],
			P50Latency:         fields[4],
			P95Latency:         fields[5],
			P99Latency:         fields[6],
			TCPOpenConnections: fields[7],
		}

		statRows = append(statRows, row)

	}
	return statRows, nil
}

func TestServiceProfileDstOverrides(t *testing.T) {
	ctx := context.Background()
	TestHelper.WithDataPlaneNamespace(ctx, "trafficsplit-test-sp", map[string]string{}, t, func(t *testing.T, prefixedNs string) {
		// First, create a `ServiceProfile`.
		initialSP := `---
apiVersion: linkerd.io/v1alpha2
kind: ServiceProfile
metadata:
  name: backend-svc.linkerd-trafficsplit-test-sp.svc.cluster.local
spec:
  dstOverrides:
    - authority: backend-svc.linkerd-trafficsplit-test-sp.svc.cluster.local
      weight: 1
    - authority: failing-svc.linkerd-trafficsplit-test-sp.svc.cluster.local:8081
      weight: 0
...`
		out, err := TestHelper.KubectlApply(initialSP, prefixedNs)
		if err != nil {
			testutil.AnnotatedFatalf(t, "Failed to apply ServiceProfile",
				"Failed to apply ServiceProfile\n%s", out)
		}

		// Deploy an application that will route traffic to the `backend-svc`.
		out, err = TestHelper.LinkerdRun("inject", "--manual",
			"--proxy-log-level=linkerd=debug,linkerd_service_profiles::client=trace,info",
			"testdata/applications-at-diff-ports.yaml")
		if err != nil {
			testutil.AnnotatedFatal(t, "'linkerd inject' command failed", err)
		}
		out, err = TestHelper.KubectlApply(out, prefixedNs)
		if err != nil {
			testutil.AnnotatedFatalf(t, "'kubectl apply' command failed",
				"'kubectl apply' command failed\n%s", out)
		}
		// Wait for all of its pods to be ready.
		for _, deploy := range []string{"backend", "failing", "slow-cooker"} {
			if err := TestHelper.CheckPods(ctx, prefixedNs, deploy, 1); err != nil {
				//nolint:errorlint
				if rce, ok := err.(*testutil.RestartCountError); ok {
					testutil.AnnotatedWarn(t, "CheckPods timed-out", rce)
				} else {
					testutil.AnnotatedError(t, "CheckPods timed-out", err)
				}
			}
		}

		t.Run("ensure traffic is sent to one backend only", func(t *testing.T) {
			timeout := 40 * time.Second
			expectedRows := []*testutil.RowStat{
				{
					Name:               "backend",
					Meshed:             "1/1",
					Success:            "100.00%",
					TCPOpenConnections: "1",
				},
			}
			err := testutil.RetryFor(timeout, func() error {
				out, err := TestHelper.LinkerdRun("viz", "stat", "deploy", "--namespace", prefixedNs,
					"--from", "deploy/slow-cooker", "-t", "30s")
				if err != nil {
					return err
				}
				rows, err := parseStatRows(out, 1, 8)
				if err != nil {
					return err
				}
				if err := validateRowStats(expectedRows, rows); err != nil {
					return err
				}
				return nil
			})
			if err != nil {
				testutil.AnnotatedFatal(t, fmt.Sprintf("timed-out ensuring traffic is sent to one backend only (%s)", timeout), err)
			}
		})

		t.Run("update traffic split resource with equal weights", func(t *testing.T) {
			updatedSP := `---
apiVersion: linkerd.io/v1alpha2
kind: ServiceProfile
metadata:
  name: backend-svc.linkerd-trafficsplit-test-sp.svc.cluster.local
spec:
  dstOverrides:
    - authority: backend-svc.linkerd-trafficsplit-test-sp.svc.cluster.local
      weight: 1
    - authority: failing-svc.linkerd-trafficsplit-test-sp.svc.cluster.local:8081
      weight: 1
...`
			out, err := TestHelper.KubectlApply(updatedSP, prefixedNs)
			if err != nil {
				testutil.AnnotatedFatalf(t, "failed to update ServiceProfile",
					"failed to update ServiceProfile: %s\n %s", err, out)
			}
		})

		t.Run("ensure traffic is sent to both backends", func(t *testing.T) {
			timeout := 40 * time.Second
			expectedRows := []*testutil.RowStat{
				{
					Name:               "backend",
					Meshed:             "1/1",
					Success:            "100.00%",
					TCPOpenConnections: "1",
				},
				{
					Name:               "failing",
					Meshed:             "1/1",
					Success:            "0.00%",
					TCPOpenConnections: "1",
				},
			}
			err := testutil.RetryFor(timeout, func() error {
				out, err := TestHelper.LinkerdRun("viz", "stat", "deploy", "-n", prefixedNs,
					"--from", "deploy/slow-cooker", "-t", "30s")
				if err != nil {
					return err
				}
				rows, err := parseStatRows(out, 2, 8)
				if err != nil {
					return err
				}
				if err := validateRowStats(expectedRows, rows); err != nil {
					return err
				}
				return nil
			})
			if err != nil {
				out, lerr := TestHelper.LinkerdRun("viz", "stat", "deploy", "-n", prefixedNs,
					"--from", "deploy/slow-cooker", "-t", "30s")
				if lerr == nil {
					fmt.Fprintf(os.Stderr, "----------- linkerd viz stat\n")
					fmt.Fprintf(os.Stderr, "%s", out)
				}
				out, lerr = TestHelper.Kubectl("", "logs", "--tail=1000", "-n", prefixedNs,
					"-l", "app=slow-cooker", "-c", "linkerd-proxy")
				if lerr != nil {
					fmt.Fprintf(os.Stderr, "Failed to run kubectl logs: %s", lerr)
				} else {
					fmt.Fprintf(os.Stderr, "----------- kubectl logs\n")
					fmt.Fprintf(os.Stderr, "%s", out)
				}
				testutil.AnnotatedFatal(t, fmt.Sprintf("timed-out ensuring traffic is sent to both backends (%s)", timeout), err)
			}
		})
	})
}

func validateRowStats(expectedRowStats, actualRowStats []*testutil.RowStat) error {
	if len(expectedRowStats) != len(actualRowStats) {
		return fmt.Errorf("Expected number of rows to be %d, but found %d", len(expectedRowStats), len(actualRowStats))
	}
	for i := 0; i < len(expectedRowStats); i++ {
		err := compareRowStat(expectedRowStats[i], actualRowStats[i])
		if err != nil {
			return err
		}
	}
	return nil
}

func compareRowStat(expectedRow, actualRow *testutil.RowStat) error {
	if actualRow.Name != expectedRow.Name {
		return fmt.Errorf("Expected name to be '%s', got '%s'",
			expectedRow.Name, actualRow.Name)
	}
	if actualRow.Meshed != expectedRow.Meshed {
		return fmt.Errorf("Expected meshed to be '%s', got '%s'",
			expectedRow.Meshed, actualRow.Meshed)
	}
	if !strings.HasSuffix(actualRow.Rps, "rps") {
		return fmt.Errorf("Unexpected rps for [%s], got [%s]",
			actualRow.Name, actualRow.Rps)
	}
	if !strings.HasSuffix(actualRow.P50Latency, "ms") {
		return fmt.Errorf("Unexpected p50 latency for [%s], got [%s]",
			actualRow.Name, actualRow.P50Latency)
	}
	if !strings.HasSuffix(actualRow.P95Latency, "ms") {
		return fmt.Errorf("Unexpected p95 latency for [%s], got [%s]",
			actualRow.Name, actualRow.P95Latency)
	}
	if !strings.HasSuffix(actualRow.P99Latency, "ms") {
		return fmt.Errorf("Unexpected p99 latency for [%s], got [%s]",
			actualRow.Name, actualRow.P99Latency)
	}
	if actualRow.Success != expectedRow.Success {
		return fmt.Errorf("Expected success to be '%s', got '%s'",
			expectedRow.Success, actualRow.Success)
	}
	if actualRow.TCPOpenConnections != expectedRow.TCPOpenConnections {
		return fmt.Errorf("Expected tcp to be '%s', got '%s'",
			expectedRow.TCPOpenConnections, actualRow.TCPOpenConnections)
	}
	return nil
}