NATS1, NATS6: the bus module's whole test makes the plans state and restores a state's objects store with it
Builds: design 47 G §58, §538 Claude-Session: https://claude.ai/code/session_01NcbgfGKaxw984XyAPfLm4h
This commit is contained in:
@@ -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 == "" {
|
||||
|
||||
Reference in New Issue
Block a user