broker_local_fixture_test.go RawHistoryFolder

1package app
2
3import (
4	"encoding/json"
5	"testing"
6
7	"github.com/stretchr/testify/require"
8
9	"github.com/bnema/vev/internal/ports"
10	"github.com/bnema/vev/internal/protocol"
11	"github.com/bnema/vev/internal/protocol/catalogue"
12)
13
14// Portable local-broker fixtures shared by Linux-only daemon tests and
15// portable broker tests.
16
17const (
18	brokerLocalTestIdentity = "offline-local-daemon"
19	brokerLocalTestEpoch    = ports.BrokerEpoch(11)
20)
21
22// testLocalCatalogue builds one exact-schema catalogue carrying the supplied
23// sessions, marshalled exactly as the daemon's remote-catalog command does.
24func testLocalCatalogue(t *testing.T, sessions ...catalogue.RemoteCatalogSession) string {
25	t.Helper()
26	encoded, err := json.Marshal(catalogue.RemoteCatalog{
27		ProtocolVersion: protocol.Version,
28		SchemaVersion:   catalogue.RemoteCatalogSchemaVersion,
29		Sessions:        sessions,
30	})
31	require.NoError(t, err)
32	return string(encoded) + "\n"
33}