diff --git a/modules/mesh-conditions/cmd/mesh-conditions/whole_integration_test.go b/modules/mesh-conditions/cmd/mesh-conditions/whole_integration_test.go index 36292d779..48af4aaf2 100644 --- a/modules/mesh-conditions/cmd/mesh-conditions/whole_integration_test.go +++ b/modules/mesh-conditions/cmd/mesh-conditions/whole_integration_test.go @@ -294,7 +294,7 @@ func TestTheKeeperWholeRaisesAndClearsOnTheBus(t *testing.T) { } buckets := []string{"mesh-controller_conditions", "mesh-delivery-assigner_wants", "node-engine_have", "mesh-delivery-assigner_assignments", "mesh-healers_attempts"} - for _, s := range []string{ConditionsState, HistoryState, HeldState, BoundsState} { + for _, s := range []string{ConditionsState, HistoryState, HeldState, ViewsState, BoundsState} { buckets = append(buckets, Module+"_"+s) } for _, b := range buckets { @@ -302,6 +302,12 @@ func TestTheKeeperWholeRaisesAndClearsOnTheBus(t *testing.T) { t.Fatal(err) } } + // Design 47 G ยง388: the catalog's holder is stopped, and the keeper hears the source it kept at an earlier run. + views, _ := js.KeyValue(ctx, Module+"_"+ViewsState) + kept, _ := json.Marshal(keptView{Observer: watchmanModule, Node: "ace"}) + if _, err := views.Create(ctx, viewKey(watchmanModule, "ace"), kept); err != nil { + t.Fatal(err) + } events, err := nc.SubscribeSync("mesh.seat." + Seat + ".event.>") if err != nil { t.Fatal(err)