From e723d498e760d2ed90808ff4c2a239fc3515f059 Mon Sep 17 00:00:00 2001 From: jochen Date: Thu, 12 Nov 2026 05:08:17 +0100 Subject: [PATCH] NATS1, NATS6: the bus module's whole test makes the plans state and restores a state's objects store with it MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Builds: design 47 G §58, §538 Claude-Session: https://claude.ai/code/session_01NcbgfGKaxw984XyAPfLm4h --- modules/nats/cmd/nats-tools/keeper_integration_test.go | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) 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 == "" {