5d61149fa3
All checks were successful
CI / Build and Test (push) Successful in 31s
Move NATS startup from New() to Start(), so tests that don't use pubsub never block on server initialization. Add a 10s timeout to WaitForServer() and skip NATS tests gracefully when unavailable.
67 lines
1.3 KiB
Go
67 lines
1.3 KiB
Go
package via
|
|
|
|
import (
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/ryanhamamura/via/h"
|
|
"github.com/stretchr/testify/assert"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
func TestPublishSubscribe_RoundTrip(t *testing.T) {
|
|
v := setupNATSTest(t)
|
|
|
|
type event struct {
|
|
Name string `json:"name"`
|
|
Count int `json:"count"`
|
|
}
|
|
|
|
var got event
|
|
done := make(chan struct{})
|
|
|
|
c := newContext("typed-ctx", "/", v)
|
|
c.View(func() h.H { return h.Div() })
|
|
|
|
_, err := Subscribe(c, "events", func(e event) {
|
|
got = e
|
|
close(done)
|
|
})
|
|
require.NoError(t, err)
|
|
|
|
err = Publish(c, "events", event{Name: "click", Count: 42})
|
|
require.NoError(t, err)
|
|
|
|
select {
|
|
case <-done:
|
|
case <-time.After(2 * time.Second):
|
|
t.Fatal("timed out waiting for message")
|
|
}
|
|
assert.Equal(t, "click", got.Name)
|
|
assert.Equal(t, 42, got.Count)
|
|
}
|
|
|
|
func TestSubscribe_SkipsBadJSON(t *testing.T) {
|
|
v := setupNATSTest(t)
|
|
|
|
type msg struct {
|
|
Text string `json:"text"`
|
|
}
|
|
|
|
called := false
|
|
c := newContext("bad-json-ctx", "/", v)
|
|
c.View(func() h.H { return h.Div() })
|
|
|
|
_, err := Subscribe(c, "topic", func(m msg) {
|
|
called = true
|
|
})
|
|
require.NoError(t, err)
|
|
|
|
// Publish raw invalid JSON — handler should silently skip
|
|
err = c.Publish("topic", []byte("not json"))
|
|
require.NoError(t, err)
|
|
|
|
time.Sleep(50 * time.Millisecond)
|
|
assert.False(t, called)
|
|
}
|