diff --git a/modules/nats/cmd/nats-tools/keeper_integration_test.go b/modules/nats/cmd/nats-tools/keeper_integration_test.go index 63e38779f..832b9505a 100644 --- a/modules/nats/cmd/nats-tools/keeper_integration_test.go +++ b/modules/nats/cmd/nats-tools/keeper_integration_test.go @@ -158,7 +158,7 @@ func TestTheBusModuleRunsWhole(t *testing.T) { t.Fatal(err) } defer pconn.Close() - for _, st := range []string{keeper.StateAsked, keeper.StateRequests, keeper.StateSpent, "findings"} { + for _, st := range []string{keeper.StateAsked, keeper.StateRequests, keeper.StateSpent, keeper.StatePlans, "findings"} { if _, err := js.CreateKeyValue(ctx, jetstream.KeyValueConfig{Bucket: "nats_" + st, History: 5}); err != nil { t.Fatal(err) } @@ -521,8 +521,11 @@ func TestTheBusModuleRunsWhole(t *testing.T) { if a := restore("live"); !strings.Contains(a.Error, "names live") { t.Errorf("a restore over a live stream answered %+v", a) } - if err := js.DeleteStream(ctx, "KV_m_drafts"); err != nil { - t.Fatal(err) + // The state's snapshot holds its objects store beside it (design 47 G ยง58): a restore goes over neither. + for _, name := range []string{"KV_m_drafts", "OBJ_m_drafts-objects"} { + if err := js.DeleteStream(ctx, name); err != nil { + t.Fatal(err) + } } a := restore("it was removed by mistake") if a.Accepted == "" {