package http

import (
	"encoding/json"
	"io"
	"net/http"
	"net/http/httptest"
	"os"
	"strconv"
	"testing"
	"time"

	log "github.com/sirupsen/logrus"
	"github.com/stretchr/testify/assert"

	"github.com/netbirdio/netbird/management/server"
	"github.com/netbirdio/netbird/management/server/http/api"
)

func BenchmarkCreateSetupKey(b *testing.B) {
	benchCases := []struct {
		name       string
		peers      int
		groups     int
		users      int
		setupKeys  int
		minMsPerOp float64
		maxMsPerOp float64
	}{
		{"Setup Keys - XS", 5, 5, 5, 5, 0.5, 2},
		{"Setup Keys - S", 5, 5, 5, 5, 0.5, 2},
		{"Setup Keys - M", 100, 20, 20, 100, 0.5, 2},
		{"Setup Keys - L", 500, 50, 100, 1000, 0.5, 2},
		{"Setup Keys - XL", 500, 50, 100, 5000, 0.5, 2},
	}

	log.SetOutput(io.Discard)
	defer log.SetOutput(os.Stderr)

	recorder := httptest.NewRecorder()

	for _, bc := range benchCases {
		b.Run(bc.name, func(b *testing.B) {
			apiHandler, am, _ := buildApiBlackBoxWithDBState(b, "testdata/setup_keys.sql", nil)
			populateTestData(b, am.(*server.DefaultAccountManager), bc.peers, bc.groups, bc.users, bc.setupKeys)

			b.ResetTimer()
			start := time.Now()
			for i := 0; i < b.N; i++ {
				requestBody := api.CreateSetupKeyRequest{
					AutoGroups: []string{"someGroupID"},
					ExpiresIn:  expiresIn,
					Name:       newKeyName + strconv.Itoa(i),
					Type:       "reusable",
					UsageLimit: 0,
				}

				// the time marshal will be recorded as well but for our use case that is ok
				body, err := json.Marshal(requestBody)
				assert.NoError(b, err)

				req := buildRequest(b, body, http.MethodPost, "/api/setup-keys", testAdminId)
				apiHandler.ServeHTTP(recorder, req)
			}

			duration := time.Since(start)
			msPerOp := float64(duration.Nanoseconds()) / float64(b.N) / 1e6
			b.ReportMetric(msPerOp, "ms/op")

			if msPerOp < bc.minMsPerOp {
				b.Fatalf("Benchmark %s failed: too fast (%.2f ms/op, minimum %.2f ms/op)", bc.name, msPerOp, bc.minMsPerOp)
			}

			if msPerOp > bc.maxMsPerOp {
				b.Fatalf("Benchmark %s failed: too slow (%.2f ms/op, maximum %.2f ms/op)", bc.name, msPerOp, bc.maxMsPerOp)
			}
		})
	}
}

func BenchmarkUpdateSetupKey(b *testing.B) {
	benchCases := []struct {
		name       string
		peers      int
		groups     int
		users      int
		setupKeys  int
		minMsPerOp float64
		maxMsPerOp float64
	}{
		{"Setup Keys - XS", 5, 5, 5, 5, 0.5, 2},
		{"Setup Keys - S", 5, 5, 5, 5, 0.5, 2},
		{"Setup Keys - M", 100, 20, 20, 100, 0.5, 2},
		{"Setup Keys - L", 500, 50, 100, 1000, 0.5, 2},
		{"Setup Keys - XL", 500, 50, 100, 5000, 0.5, 2},
	}

	log.SetOutput(io.Discard)
	defer log.SetOutput(os.Stderr)

	recorder := httptest.NewRecorder()

	for _, bc := range benchCases {
		b.Run(bc.name, func(b *testing.B) {
			apiHandler, am, _ := buildApiBlackBoxWithDBState(b, "testdata/setup_keys.sql", nil)
			populateTestData(b, am.(*server.DefaultAccountManager), bc.peers, bc.groups, bc.users, bc.setupKeys)

			b.ResetTimer()
			start := time.Now()
			for i := 0; i < b.N; i++ {
				groupId := testGroupId
				if i%2 == 0 {
					groupId = newGroupId
				}
				requestBody := api.SetupKeyRequest{
					AutoGroups: []string{groupId},
					Revoked:    false,
				}

				// the time marshal will be recorded as well but for our use case that is ok
				body, err := json.Marshal(requestBody)
				assert.NoError(b, err)

				req := buildRequest(b, body, http.MethodPut, "/api/setup-keys/"+testKeyId, testAdminId)
				apiHandler.ServeHTTP(recorder, req)
			}

			duration := time.Since(start)
			msPerOp := float64(duration.Nanoseconds()) / float64(b.N) / 1e6
			b.ReportMetric(msPerOp, "ms/op")

			if msPerOp < bc.minMsPerOp {
				b.Fatalf("Benchmark %s failed: too fast (%.2f ms/op, minimum %.2f ms/op)", bc.name, msPerOp, bc.minMsPerOp)
			}

			if msPerOp > bc.maxMsPerOp {
				b.Fatalf("Benchmark %s failed: too slow (%.2f ms/op, maximum %.2f ms/op)", bc.name, msPerOp, bc.maxMsPerOp)
			}
		})
	}
}

func BenchmarkGetOneSetupKey(b *testing.B) {
	benchCases := []struct {
		name       string
		peers      int
		groups     int
		users      int
		setupKeys  int
		minMsPerOp float64
		maxMsPerOp float64
	}{
		{"Setup Keys - XS", 5, 5, 5, 5, 0.5, 2},
		{"Setup Keys - S", 5, 5, 5, 5, 0.5, 2},
		{"Setup Keys - M", 100, 20, 20, 100, 0.5, 2},
		{"Setup Keys - L", 500, 50, 100, 1000, 0.5, 2},
		{"Setup Keys - XL", 500, 50, 100, 5000, 0.5, 2},
	}

	log.SetOutput(io.Discard)
	defer log.SetOutput(os.Stderr)

	recorder := httptest.NewRecorder()

	for _, bc := range benchCases {
		b.Run(bc.name, func(b *testing.B) {
			apiHandler, am, _ := buildApiBlackBoxWithDBState(b, "testdata/setup_keys.sql", nil)
			populateTestData(b, am.(*server.DefaultAccountManager), bc.peers, bc.groups, bc.users, bc.setupKeys)

			b.ResetTimer()
			start := time.Now()
			for i := 0; i < b.N; i++ {
				req := buildRequest(b, nil, http.MethodGet, "/api/setup-keys/"+testKeyId, testAdminId)
				apiHandler.ServeHTTP(recorder, req)
			}

			duration := time.Since(start)
			msPerOp := float64(duration.Nanoseconds()) / float64(b.N) / 1e6
			b.ReportMetric(msPerOp, "ms/op")

			if msPerOp < bc.minMsPerOp {
				b.Fatalf("Benchmark %s failed: too fast (%.2f ms/op, minimum %.2f ms/op)", bc.name, msPerOp, bc.minMsPerOp)
			}

			if msPerOp > bc.maxMsPerOp {
				b.Fatalf("Benchmark %s failed: too slow (%.2f ms/op, maximum %.2f ms/op)", bc.name, msPerOp, bc.maxMsPerOp)
			}
		})
	}
}

func BenchmarkGetAllSetupKeys(b *testing.B) {
	benchCases := []struct {
		name       string
		peers      int
		groups     int
		users      int
		setupKeys  int
		minMsPerOp float64
		maxMsPerOp float64
	}{
		{"Setup Keys - XS", 5, 5, 5, 5, 0.5, 2},
		{"Setup Keys - S", 5, 5, 5, 5, 0.5, 2},
		{"Setup Keys - M", 100, 20, 20, 100, 0.5, 2},
		{"Setup Keys - L", 500, 50, 100, 1000, 5, 10},
		{"Setup Keys - XL", 500, 50, 100, 5000, 25, 45},
	}

	log.SetOutput(io.Discard)
	defer log.SetOutput(os.Stderr)

	recorder := httptest.NewRecorder()

	for _, bc := range benchCases {
		b.Run(bc.name, func(b *testing.B) {
			apiHandler, am, _ := buildApiBlackBoxWithDBState(b, "testdata/setup_keys.sql", nil)
			populateTestData(b, am.(*server.DefaultAccountManager), bc.peers, bc.groups, bc.users, bc.setupKeys)

			b.ResetTimer()
			start := time.Now()
			for i := 0; i < b.N; i++ {
				req := buildRequest(b, nil, http.MethodGet, "/api/setup-keys", testAdminId)
				apiHandler.ServeHTTP(recorder, req)
			}

			duration := time.Since(start)
			msPerOp := float64(duration.Nanoseconds()) / float64(b.N) / 1e6
			b.ReportMetric(msPerOp, "ms/op")

			if msPerOp < bc.minMsPerOp {
				b.Fatalf("Benchmark %s failed: too fast (%.2f ms/op, minimum %.2f ms/op)", bc.name, msPerOp, bc.minMsPerOp)
			}

			if msPerOp > bc.maxMsPerOp {
				b.Fatalf("Benchmark %s failed: too slow (%.2f ms/op, maximum %.2f ms/op)", bc.name, msPerOp, bc.maxMsPerOp)
			}
		})
	}
}

func BenchmarkDeleteSetupKey(b *testing.B) {
	benchCases := []struct {
		name       string
		peers      int
		groups     int
		users      int
		setupKeys  int
		minMsPerOp float64
		maxMsPerOp float64
	}{
		{"Setup Keys - XS", 5, 5, 5, 5, 0.5, 2},
		{"Setup Keys - S", 5, 5, 5, 5, 0.5, 2},
		{"Setup Keys - M", 100, 20, 20, 100, 0.5, 2},
		{"Setup Keys - L", 500, 50, 100, 1000, 0.5, 2},
		{"Setup Keys - XL", 500, 50, 100, 5000, 0.5, 2},
	}

	log.SetOutput(io.Discard)
	defer log.SetOutput(os.Stderr)

	recorder := httptest.NewRecorder()

	for _, bc := range benchCases {
		b.Run(bc.name, func(b *testing.B) {
			apiHandler, am, _ := buildApiBlackBoxWithDBState(b, "testdata/setup_keys.sql", nil)
			populateTestData(b, am.(*server.DefaultAccountManager), bc.peers, bc.groups, bc.users, bc.setupKeys)

			b.ResetTimer()
			start := time.Now()
			for i := 0; i < b.N; i++ {
				// depending on the test case we may fail do delete keys as no more keys are there
				req := buildRequest(b, nil, http.MethodGet, "/api/setup-keys/"+"oldkey-"+strconv.Itoa(i), testAdminId)
				apiHandler.ServeHTTP(recorder, req)
			}

			duration := time.Since(start)
			msPerOp := float64(duration.Nanoseconds()) / float64(b.N) / 1e6
			b.ReportMetric(msPerOp, "ms/op")

			if msPerOp < bc.minMsPerOp {
				b.Fatalf("Benchmark %s failed: too fast (%.2f ms/op, minimum %.2f ms/op)", bc.name, msPerOp, bc.minMsPerOp)
			}

			if msPerOp > bc.maxMsPerOp {
				b.Fatalf("Benchmark %s failed: too slow (%.2f ms/op, maximum %.2f ms/op)", bc.name, msPerOp, bc.maxMsPerOp)
			}
		})
	}
}