61 lines
1.1 KiB
Go
61 lines
1.1 KiB
Go
package test
|
|
|
|
import (
|
|
"statusServer"
|
|
"statusServer/models"
|
|
"testing"
|
|
"time"
|
|
|
|
"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)
|
|
}
|
|
}
|