package selector

import (
	"context"
	"math/rand"
	"strconv"
	"sync/atomic"
	"testing"
	"time"

	"github.com/go-kratos/kratos/v2/registry"
	"github.com/stretchr/testify/assert"
)

type mockWeightedNode struct {
	Node

	lastPick int64
}

// Raw returns the original node
func (n *mockWeightedNode) Raw() Node {
	return n.Node
}

// Weight is the runtime calculated weight
func (n *mockWeightedNode) Weight() float64 {
	if n.InitialWeight() != nil {
		return float64(*n.InitialWeight())
	}
	return 100
}

// Pick the node
func (n *mockWeightedNode) Pick() DoneFunc {
	now := time.Now().UnixNano()
	atomic.StoreInt64(&n.lastPick, now)
	return func(ctx context.Context, di DoneInfo) {}
}

// PickElapsed is time elapsed since the latest pick
func (n *mockWeightedNode) PickElapsed() time.Duration {
	return time.Duration(time.Now().UnixNano() - atomic.LoadInt64(&n.lastPick))
}

type mockWeightedNodeBuilder struct{}

func (b *mockWeightedNodeBuilder) Build(n Node) WeightedNode {
	return &mockWeightedNode{Node: n}
}

func mockFilter(version string) Filter {
	return func(_ context.Context, nodes []Node) []Node {
		filters := make([]Node, 0, len(nodes))
		for _, n := range nodes {
			if n.Version() == version {
				filters = append(filters, n)
			}
		}
		return filters
	}
}

type mockBalancerBuilder struct{}

func (b *mockBalancerBuilder) Build() Balancer {
	return &mockBalancer{}
}

type mockBalancer struct{}

func (b *mockBalancer) Pick(ctx context.Context, nodes []WeightedNode) (selected WeightedNode, done DoneFunc, err error) {
	if len(nodes) == 0 {
		err = ErrNoAvailable
		return
	}
	cur := rand.Intn(len(nodes))
	selected = nodes[cur]
	done = selected.Pick()
	return
}

func TestDefault(t *testing.T) {
	builder := DefaultBuilder{
		Node:     &mockWeightedNodeBuilder{},
		Filters:  []Filter{mockFilter("v2.0.0")},
		Balancer: &mockBalancerBuilder{},
	}
	selector := builder.Build()
	var nodes []Node
	nodes = append(nodes, NewNode(
		"127.0.0.1:8080",
		&registry.ServiceInstance{
			ID:        "127.0.0.1:8080",
			Name:      "helloworld",
			Version:   "v2.0.0",
			Endpoints: []string{"http://127.0.0.1:8080"},
			Metadata:  map[string]string{"weight": "10"},
		}))
	nodes = append(nodes, NewNode(
		"127.0.0.1:9090",
		&registry.ServiceInstance{
			ID:        "127.0.0.1:9090",
			Name:      "helloworld",
			Version:   "v1.0.0",
			Endpoints: []string{"http://127.0.0.1:9090"},
			Metadata:  map[string]string{"weight": "10"},
		}))
	selector.Apply(nodes)
	n, done, err := selector.Select(context.Background(), WithNodeFilter(func(node Node) bool {
		return (node.Version() == "v2.0.0")
	}))
	assert.Nil(t, err)
	assert.NotNil(t, n)
	assert.NotNil(t, done)
	assert.Equal(t, "v2.0.0", n.Version())
	assert.NotNil(t, n.Address())
	assert.Equal(t, int64(10), *n.InitialWeight())
	assert.NotNil(t, n.Metadata())
	assert.Equal(t, "helloworld", n.ServiceName())
	done(context.Background(), DoneInfo{})

	// no v3.0.0 instance
	n, done, err = selector.Select(context.Background(), WithNodeFilter(func(node Node) bool {
		return (node.Version() == "v3.0.0")
	}))
	assert.Equal(t, ErrNoAvailable, err)
	assert.Nil(t, done)
	assert.Nil(t, n)

	// apply zero instance
	selector.Apply([]Node{})
	n, done, err = selector.Select(context.Background(), WithNodeFilter(func(node Node) bool {
		return (node.Version() == "v2.0.0")
	}))
	assert.Equal(t, ErrNoAvailable, err)
	assert.Nil(t, done)
	assert.Nil(t, n)

	// apply zero instance
	selector.Apply(nil)
	n, done, err = selector.Select(context.Background(), WithNodeFilter(func(node Node) bool {
		return (node.Version() == "v2.0.0")
	}))
	assert.Equal(t, ErrNoAvailable, err)
	assert.Nil(t, done)
	assert.Nil(t, n)
}

func TestNodeFilterWithRandom(t *testing.T) {
	for i := 0; i < 100; i++ {
		testBaseFilter(t, 1000, rand.Intn(1000))
	}

	testBaseFilter(t, 0, rand.Intn(1000))
	testBaseFilter(t, 1, 1000)
	testBaseFilter(t, 2, 1000)
	testBaseFilter(t, 3, 1000)
	testBaseFilter(t, 1, 0)
	testBaseFilter(t, 2, 0)
	testBaseFilter(t, 3, 0)
}

func testBaseFilter(t *testing.T, length int, reservedRatio int) {
	var raw []WeightedNode
	var targets map[string]WeightedNode = make(map[string]WeightedNode)
	for i := 0; i < length; i++ {
		addr := strconv.FormatInt(int64(i), 10)
		raw = append(raw, &mockWeightedNode{Node: NewNode(
			addr,
			&registry.ServiceInstance{
				ID:        addr,
				Name:      "helloworld",
				Endpoints: []string{addr},
			})})
		if reservedRatio > rand.Intn(length) {
			targets[addr] = raw[i]
		}
	}

	f := func(node Node) bool {
		if _, ok := targets[node.Address()]; ok {
			return true
		}
		return false
	}
	d := Default{}
	raw = d.nodeFilter([]NodeFilter{f}, raw)
	assert.Equal(t, len(targets), len(raw))
	for _, n := range raw {
		_, ok := targets[n.Address()]
		assert.True(t, ok)
	}
}