package test

import (
	"testing"
	"time"

	"gitea.tecamino.com/paadi/statusServer"
	"gitea.tecamino.com/paadi/statusServer/models"

	"gitea.tecamino.com/paadi/tecamino-logger/logging"
)

func TestServer(t *testing.T) {
	var err error

	server, err := statusServer.NewStatusServer(models.Config{Port: 8080})
	if err != nil {
		t.Fatal(err)
	}

	go func() {
		err = server.ServeHttp()
	}()
	if err != nil {
		t.Fatal(err)
	}
}

func TestConnection(t *testing.T) {
	s, err := statusServer.NewStatusServer(models.Config{Port: 8080, Log: logging.Config{Debug: true}})
	if err != nil {
		t.Fatal(err)
	}
	go s.ServeHttp()

	time.Sleep(time.Second)

	client1, err := statusServer.NewStatusClient("adrian", "127.0.0.1", 8080, true)
	if err != nil {
		t.Fatal(err)
	}
	client, err := statusServer.NewStatusClient("test", "127.0.0.1", 8080, true)
	if err != nil {
		t.Fatal(err)
	}

	client1.Subscribe("test/info", func(a any) {
		t.Log("test", a)
	})
	var info struct {
		Message string
		Count   int
	}
	info.Message = "test count"
	for range 10 {
		info.Count++
		client.SendInfo(info)
		client.SendInfo("info")
		time.Sleep(time.Second)
	}
}