package hosterrorscache

import (
	"context"
	"errors"
	"log/slog"
	"sync"
	"sync/atomic"
	"testing"

	"github.com/projectdiscovery/nuclei/v3/pkg/protocols/common/contextargs"
	"github.com/projectdiscovery/utils/errkit"
	"github.com/stretchr/testify/require"
)

const (
	protoType = "http"
)

func TestCacheCheck(t *testing.T) {
	cache := New(3, DefaultMaxHostsCount, nil)
	err := errors.New("net/http: timeout awaiting response headers")

	t.Run("increment host error", func(t *testing.T) {
		ctx := newCtxArgs(t.Name())
		for i := 1; i < 3; i++ {
			cache.MarkFailed(protoType, ctx, err)
			got := cache.Check(protoType, ctx)
			require.Falsef(t, got, "got %v in iteration %d", got, i)
		}
	})

	t.Run("flagged", func(t *testing.T) {
		ctx := newCtxArgs(t.Name())
		for i := 1; i <= 3; i++ {
			cache.MarkFailed(protoType, ctx, err)
		}

		got := cache.Check(protoType, ctx)
		require.True(t, got)
	})

	t.Run("mark failed or remove", func(t *testing.T) {
		ctx := newCtxArgs(t.Name())
		cache.MarkFailedOrRemove(protoType, ctx, nil) // nil error should remove the host from cache
		got := cache.Check(protoType, ctx)
		require.False(t, got)
	})
}

func TestCacheCloseReleasesStorageAndIsIdempotent(t *testing.T) {
	cache := New(3, DefaultMaxHostsCount, nil)
	cache.MarkFailed(protoType, newCtxArgs(t.Name()), errors.New("timeout"))

	cache.Close()
	require.Nil(t, cache.failedTargets)

	require.NotPanics(t, cache.Close)
}

func TestCacheAllocatesStorageOnlyForTrackedFailure(t *testing.T) {
	cache := New(3, DefaultMaxHostsCount, nil)
	t.Cleanup(cache.Close)
	ctx := newCtxArgs(t.Name())

	require.Nil(t, cache.failedTargets)
	require.False(t, cache.Check(protoType, ctx))
	cache.Remove(ctx)
	cache.MarkFailedOrRemove(protoType, ctx, nil)
	cache.MarkFailedOrRemove(protoType, ctx, errors.New("template condition failed"))
	require.Nil(t, cache.failedTargets, "read, success, and template errors must not allocate host storage")

	cache.MarkFailedOrRemove(protoType, ctx, errors.New("net/http: timeout awaiting response headers"))
	require.NotNil(t, cache.failedTargets)
}

func TestCacheCloseBeforeFirstFailureKeepsStorageUnallocated(t *testing.T) {
	cache := New(3, DefaultMaxHostsCount, nil)
	cache.Close()

	ctx := newCtxArgs(t.Name())
	require.NotPanics(t, func() {
		cache.MarkFailedOrRemove(protoType, ctx, errors.New("net/http: timeout awaiting response headers"))
		cache.MarkFailedOrRemove(protoType, ctx, nil)
		cache.Remove(ctx)
		require.False(t, cache.Check(protoType, ctx))
	})
	require.Nil(t, cache.failedTargets)
}

func TestCacheCheckTimeout(t *testing.T) {
	// A host that consistently times out (request deadline exceeded) is
	// unresponsive and must be skipped once MaxHostError consecutive timeouts
	// are recorded. Production surfaces these as ErrKindNetworkTemporary.
	cache := New(3, DefaultMaxHostsCount, nil)
	err := errkit.New("context deadline exceeded (Client.Timeout exceeded while awaiting headers)").
		SetKind(errkit.ErrKindNetworkTemporary)

	t.Run("flagged after threshold", func(t *testing.T) {
		ctx := newCtxArgs(t.Name())
		for i := 1; i <= 3; i++ {
			cache.MarkFailed(protoType, ctx, err)
		}
		require.True(t, cache.Check(protoType, ctx), "host with repeated timeouts must be skipped")
	})

	t.Run("reset on success keeps a live host", func(t *testing.T) {
		ctx := newCtxArgs(t.Name())
		cache.MarkFailed(protoType, ctx, err)
		cache.MarkFailed(protoType, ctx, err)
		cache.MarkFailedOrRemove(protoType, ctx, nil) // a successful response resets the host
		require.False(t, cache.Check(protoType, ctx), "a host that responded must not be skipped")
	})
}

func TestCacheCheckRawHTTPTimeout(t *testing.T) {
	// rawhttp/unsafe templates surface read timeouts as a plain-string error
	// ("ReadStatusLine: ... i/o timeout") that errkit cannot classify, so it
	// reaches the regex fallback. A host that produces these on every request
	// must still be skipped.
	cache := New(3, DefaultMaxHostsCount, nil)
	err := errors.New("ReadStatusLine: read tcp 127.0.0.1:60087->127.0.0.1:18080: i/o timeout")

	ctx := newCtxArgs(t.Name())
	for i := 1; i <= 3; i++ {
		cache.MarkFailed(protoType, ctx, err)
	}
	require.True(t, cache.Check(protoType, ctx), "host with repeated rawhttp i/o timeouts must be skipped")
}

func TestMarkSkipsParentContextCancellation(t *testing.T) {
	// A failure that happens because the caller's (parent scan) context was
	// cancelled or hit its deadline is not the host's fault and must not be
	// counted. context.DeadlineExceeded otherwise classifies as a temporary
	// network error and would wrongly accumulate.
	cache := New(3, DefaultMaxHostsCount, nil)
	parent, cancel := context.WithCancel(context.Background())
	cancel()
	ctx := contextargs.NewWithInput(parent, "cancelled-host")
	timeout := errkit.New("context deadline exceeded").SetKind(errkit.ErrKindNetworkTemporary)

	for i := 0; i < 5; i++ {
		cache.MarkFailedOrRemove(protoType, ctx, timeout)
	}
	require.False(t, cache.Check(protoType, ctx), "failures under a cancelled parent context must not mark the host")
}

func TestNonConsecutiveTimeoutsDoNotSkip(t *testing.T) {
	// A live host that times out intermittently but succeeds in between must not
	// be skipped: a success resets the count so only consecutive failures reach
	// the threshold. Guards the property the HTTP path relies on.
	cache := New(3, DefaultMaxHostsCount, nil)
	ctx := newCtxArgs(t.Name())
	timeout := errkit.New("i/o timeout").SetKind(errkit.ErrKindNetworkTemporary)

	cache.MarkFailedOrRemove(protoType, ctx, timeout)
	cache.MarkFailedOrRemove(protoType, ctx, timeout)
	cache.MarkFailedOrRemove(protoType, ctx, nil) // successful response resets the host
	cache.MarkFailedOrRemove(protoType, ctx, timeout)
	require.False(t, cache.Check(protoType, ctx), "a success between timeouts must reset the count")
}

func TestTrackErrors(t *testing.T) {
	cache := New(3, DefaultMaxHostsCount, []string{"custom error"})

	for i := 0; i < 100; i++ {
		cache.MarkFailed(protoType, newCtxArgs("custom"), errors.New("got: nested: custom error"))
		got := cache.Check(protoType, newCtxArgs("custom"))
		if i < 2 {
			// till 3 the host is not flagged to skip
			require.False(t, got)
		} else {
			// above 3 it must remain flagged to skip
			require.True(t, got)
		}
	}
	value := cache.Check(protoType, newCtxArgs("custom"))
	require.Equal(t, true, value, "could not get checked value")
}

func TestCacheItemDo(t *testing.T) {
	var (
		count int
		item  cacheItem
	)

	wg := sync.WaitGroup{}
	for i := 0; i < 100; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()
			item.Do(func() {
				count++
			})
		}()
	}
	wg.Wait()

	// ensures the increment happened only once regardless of the multiple call
	require.Equal(t, count, 1)
}

func TestRemove(t *testing.T) {
	cache := New(3, DefaultMaxHostsCount, nil)
	ctx := newCtxArgs(t.Name())
	err := errors.New("net/http: timeout awaiting response headers")

	for i := 0; i < 100; i++ {
		cache.MarkFailed(protoType, ctx, err)
	}

	require.True(t, cache.Check(protoType, ctx))
	cache.Remove(ctx)
	require.False(t, cache.Check(protoType, ctx))
}

func TestCacheMarkFailed(t *testing.T) {
	cache := New(3, DefaultMaxHostsCount, nil)

	tests := []struct {
		host     string
		expected int32
	}{
		{"http://example.com:80", 1},
		{"example.com:80", 2},
		// earlier if port is not provided then port was omitted
		// but from now it will default to appropriate http scheme based port with 80 as default
		{"example.com:443", 1},
	}

	for _, test := range tests {
		normalizedCacheValue := cache.GetKeyFromContext(newCtxArgs(test.host), nil)
		cache.MarkFailed(protoType, newCtxArgs(test.host), errors.New("no address found for host"))
		failedTarget, err := cache.failedTargets.Get(normalizedCacheValue)
		require.Nil(t, err)
		require.NotNil(t, failedTarget)

		require.EqualValues(t, test.expected, failedTarget.errors.Load())
	}
}

func TestCacheMarkFailedConcurrent(t *testing.T) {
	cache := New(3, DefaultMaxHostsCount, nil)

	tests := []struct {
		host     string
		expected int32
	}{
		{"http://example.com:80", 200},
		{"example.com:80", 200},
		{"example.com:443", 100},
	}

	// the cache is not atomic during items creation, so we pre-create them with counter to zero
	failedTargets := cache.getFailedTargets(true)
	for _, test := range tests {
		normalizedValue := cache.NormalizeCacheValue(test.host)
		newItem := &cacheItem{errors: atomic.Int32{}}
		newItem.errors.Store(0)
		_ = failedTargets.Set(normalizedValue, newItem)
	}

	wg := sync.WaitGroup{}
	for _, test := range tests {
		currentTest := test
		for i := 0; i < 100; i++ {
			wg.Add(1)
			go func() {
				defer wg.Done()
				cache.MarkFailed(protoType, newCtxArgs(currentTest.host), errors.New("net/http: timeout awaiting response headers"))
			}()
		}
	}
	wg.Wait()

	for _, test := range tests {
		require.True(t, cache.Check(protoType, newCtxArgs(test.host)))

		normalizedCacheValue := cache.NormalizeCacheValue(test.host)
		failedTarget, err := cache.failedTargets.Get(normalizedCacheValue)
		require.Nil(t, err)
		require.NotNil(t, failedTarget)

		require.EqualValues(t, test.expected, failedTarget.errors.Load())
	}
}

func TestCacheCheckConcurrent(t *testing.T) {
	cache := New(3, DefaultMaxHostsCount, nil)
	ctx := newCtxArgs(t.Name())

	wg := sync.WaitGroup{}
	for i := 1; i <= 100; i++ {
		wg.Add(1)
		go func() {
			defer wg.Done()
			cache.MarkFailed(protoType, ctx, errors.New("no address found for host"))
			if i >= 3 {
				got := cache.Check(protoType, ctx)
				require.True(t, got)
			}
		}()
	}
	wg.Wait()
}

func newCtxArgs(value string) *contextargs.Context {
	ctx := contextargs.NewWithInput(context.TODO(), value)
	return ctx
}

func TestGetKeyFromContextPinnedTarget(t *testing.T) {
	cache := New(3, DefaultMaxHostsCount, nil)
	pinned := contextargs.NewWithMetaInput(context.Background(), &contextargs.MetaInput{
		Input:    "https://a.example",
		CustomIP: "192.0.2.10",
	})
	// fastdialer reports the dialed hostname as the error address
	dialErr := errkit.WithAttr(errkit.New("connection refused"), slog.String("address", "a.example:443"))
	require.Equal(t, cache.GetKeyFromContext(pinned, nil), cache.GetKeyFromContext(pinned, dialErr))

	// an error from another host keeps its own address
	otherErr := errkit.WithAttr(errkit.New("connection refused"), slog.String("address", "b.example:443"))
	require.Equal(t, "b.example:443", cache.GetKeyFromContext(pinned, otherErr))

	// an internationalized hostname is reported in its ASCII form
	idn := contextargs.NewWithMetaInput(context.Background(), &contextargs.MetaInput{
		Input:    "https://bücher.example",
		CustomIP: "192.0.2.10",
	})
	idnErr := errkit.WithAttr(errkit.New("connection refused"), slog.String("address", "xn--bcher-kva.example:443"))
	require.Equal(t, "192.0.2.10:443", cache.GetKeyFromContext(idn, idnErr))
}