package router

import (
	"math/rand"

	"gitee.com/wujianhai/protoactor-go/actor"
)

type randomGroupRouter struct {
	GroupRouter
}

type randomPoolRouter struct {
	PoolRouter
}

type randomRouterState struct {
	routees *actor.PIDSet
	sender  actor.SenderContext
}

func (state *randomRouterState) SetSender(sender actor.SenderContext) {
	state.sender = sender
}

func (state *randomRouterState) SetRoutees(routees *actor.PIDSet) {
	state.routees = routees
}

func (state *randomRouterState) GetRoutees() *actor.PIDSet {
	return state.routees
}

func (state *randomRouterState) RouteMessage(message interface{}) {
	pid := randomRoutee(state.routees)
	state.sender.Send(pid, message)
}

func NewRandomPool(size int, opts ...actor.PropsOption) *actor.Props {
	return (&actor.Props{}).
		Configure(actor.WithSpawnFunc(spawner(&randomPoolRouter{PoolRouter{PoolSize: size}}))).
		Configure(opts...)
}

func NewRandomGroup(routees ...*actor.PID) *actor.Props {
	return (&actor.Props{}).Configure(actor.WithSpawnFunc(spawner(&randomGroupRouter{GroupRouter{Routees: actor.NewPIDSet(routees...)}})))
}

func (config *randomPoolRouter) CreateRouterState() State {
	return &randomRouterState{}
}

func (config *randomGroupRouter) CreateRouterState() State {
	return &randomRouterState{}
}

func randomRoutee(routees *actor.PIDSet) *actor.PID {
	l := routees.Len()
	r := rand.Intn(l)
	pid := routees.Get(r)
	return pid
}