package subscrService

import (
	"testing"
	"time"

	"git.betfavorit.cf/backend/anna-go/adapters"
	"git.betfavorit.cf/backend/anna-go/domain/subsr"
	"git.betfavorit.cf/backend/anna-go/infrastructure/subscrService/ISubs"
	"git.betfavorit.cf/backend/anna-go/infrastructure/subscrService/OnBets"
	"git.betfavorit.cf/backend/anna-go/infrastructure/subscrService/OnMatch"
	"git.betfavorit.cf/backend/anna-go/infrastructure/subscrService/basesub"

	"github.com/twinj/uuid"
)

func TestClosedAllCnn(t *testing.T) {
	IsDisconnected := make(chan bool)
	cnn := ISubs.UserConnector(&adapters.Connection{
		GUID:           uuid.NewV4(),
		IsDisconnected: IsDisconnected,
	})

	onBets := OnBets.New()
	onMatch := OnMatch.New()

	onBets.AddConnection(*&basesub.SubBetParamsConnections{
		UserConn: &cnn,
	})
	onMatch.AddConnection(&basesub.SubMatchConnections{
		SubscriberOnMatch: &subsr.SubscriberOnMatchParam{MatchID: 1},
		UserConn:          &cnn,
	})

	countOnBets := onBets.GetCountConn
	countOnMatch := onMatch.GetCountConnectionOnMatch

	t.Log("countOnBets", countOnBets())
	t.Log("countOnMatch", countOnMatch(1))

	close(IsDisconnected)

	time.Sleep(time.Second * 2)

	t.Log("countOnBets", countOnBets())
	t.Log("countOnMatch", countOnMatch(1))
}

func printCountCnn(t *testing.T) {

}