jschoubben
77596f37a3
Kept (keys, steps, each read by another module today) is said with stdio.Keeps before the module serves; announcetest.Check holds the announcement equal to the code. Pinned to mesh-sdk feat/r4e-sdk 9cb4d59. The manifest test's call of the deleted StateReadsNothingDeclares still has to go (the edit is waiting on the operator's permission).
64 lines
1.9 KiB
Go
64 lines
1.9 KiB
Go
//go:build integration
|
|
|
|
package main
|
|
|
|
import (
|
|
"bufio"
|
|
"encoding/json"
|
|
"io"
|
|
"testing"
|
|
|
|
"github.com/nats-io/nats.go"
|
|
|
|
stdio "git.novox.be/novox/mesh-sdk/go"
|
|
"git.novox.be/novox/mesh-sdk/go/announcetest"
|
|
)
|
|
|
|
// 1790 (ADR 0495 §5): served as the runtime serves it, the module announces on the bus every state it keeps, as its
|
|
// code declares them. The runtime's part, publishing what the bundle asks to publish, is played by relay.
|
|
func TestTheModuleAnnouncesEveryStateItKeeps(t *testing.T) {
|
|
const module = "mesh-build-image"
|
|
announcetest.Check(t, module, Kept, func(url string) func() {
|
|
t.Setenv("MESH_MODULE", module)
|
|
t.Setenv("MESH_NODE", "shanks")
|
|
nc, err := nats.Connect(url)
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
if err := keepStates(); err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
inR, inW := io.Pipe()
|
|
outR, outW := io.Pipe()
|
|
go func() { _ = stdio.ServeOn(module, nil, inR, outW) }()
|
|
go relay(t, module, nc, outR, inW)
|
|
return func() { _ = inW.Close(); _ = outW.Close(); nc.Close() }
|
|
})
|
|
}
|
|
|
|
// relay is the runtime's side of the channel: each mesh/publish the bundle asks is published on its module's event
|
|
// subject, mesh.mod.<module>.event.<key>, and answered.
|
|
func relay(t *testing.T, module string, nc *nats.Conn, from io.Reader, to io.Writer) {
|
|
sc := bufio.NewScanner(from)
|
|
sc.Buffer(make([]byte, 1<<20), 1<<24)
|
|
enc := json.NewEncoder(to)
|
|
for sc.Scan() {
|
|
var m struct {
|
|
ID json.RawMessage `json:"id"`
|
|
Method string `json:"method"`
|
|
Params struct {
|
|
Key string `json:"key"`
|
|
Body json.RawMessage `json:"body"`
|
|
} `json:"params"`
|
|
}
|
|
if json.Unmarshal(sc.Bytes(), &m) != nil || m.Method != "mesh/publish" {
|
|
continue
|
|
}
|
|
if err := nc.Publish("mesh.mod."+module+".event."+m.Params.Key, m.Params.Body); err != nil {
|
|
t.Errorf("publishing %s: %v", m.Params.Key, err)
|
|
}
|
|
_ = nc.Flush()
|
|
_ = enc.Encode(map[string]any{"id": m.ID, "result": map[string]any{}})
|
|
}
|
|
}
|