jschoubben
fae7710bed
R4e's own delivery plan waited for ever in tier 1: the controller took every module but build-agent's own from a referenced builder key, and only R4e's builder and build modules, delivered by that same plan, write references. The builder now says so in its bucket of instances; until it does, a walk asks build-agent as before R4e, and an open walk waiting on a key the running builder cannot reference is judged again at the next look.
55 lines
1.6 KiB
Go
55 lines
1.6 KiB
Go
//go:build integration
|
|
|
|
package builderkeys
|
|
|
|
import (
|
|
"context"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/nats-io/nats.go/jetstream"
|
|
)
|
|
|
|
// 1886/AC1 and AC4 on a real bus: no bucket of instances says no and watches nothing; an instance's key saying
|
|
// references says yes, and its put and its delete each wake the watcher, with no timer.
|
|
func TestTheBuildersSayIsReadAndWatchedOnTheBus(t *testing.T) {
|
|
ctx, cancel := context.WithTimeout(context.Background(), 20*time.Second)
|
|
defer cancel()
|
|
js := aBus(t)
|
|
r := Reader{JS: js}
|
|
if says, err := r.SaysReferences(ctx); err != nil || says {
|
|
t.Fatalf("no bucket: %v %v", says, err)
|
|
}
|
|
if on, err := WatchSays(ctx, js, func() {}); err != nil || on {
|
|
t.Fatalf("no bucket is watched: %v %v", on, err)
|
|
}
|
|
kv, err := js.CreateKeyValue(ctx, jetstream.KeyValueConfig{Bucket: BuilderInstancesBucket, History: 1})
|
|
if err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
woken := make(chan struct{}, 4)
|
|
if on, err := WatchSays(ctx, js, func() { woken <- struct{}{} }); err != nil || !on {
|
|
t.Fatalf("the bucket is not watched: %v %v", on, err)
|
|
}
|
|
wake := func(what string) {
|
|
t.Helper()
|
|
select {
|
|
case <-woken:
|
|
case <-ctx.Done():
|
|
t.Fatalf("%s woke nothing", what)
|
|
}
|
|
}
|
|
put(t, kv, "shanks", []byte(`{"writes":["references"]}`))
|
|
wake("a put")
|
|
if says, err := r.SaysReferences(ctx); err != nil || !says {
|
|
t.Fatalf("an instance saying references: %v %v", says, err)
|
|
}
|
|
if err := kv.Delete(ctx, "shanks"); err != nil {
|
|
t.Fatal(err)
|
|
}
|
|
wake("a delete")
|
|
if says, err := r.SaysReferences(ctx); err != nil || says {
|
|
t.Fatalf("no instance left: %v %v", says, err)
|
|
}
|
|
}
|