diff --git a/cmd/mesh-host/nodeagent_integration_test.go b/cmd/mesh-host/nodeagent_integration_test.go index 025cd54..089ae2b 100644 --- a/cmd/mesh-host/nodeagent_integration_test.go +++ b/cmd/mesh-host/nodeagent_integration_test.go @@ -442,7 +442,7 @@ func h8back(t *testing.T, b *itBed, placement, resolved, candidates nats.KeyValu pkey, _ := delivery.PlacementKey(itNode) // A pass in flight at the switch (issue 1126, 2026-10-28: the last pass of the own run, failing on its run's end, // marked the next agent's modules failed): a config value changed starts one, and the key goes at once. - if _, err := resolved.Put(itNode+".web.greeting", []byte(`{"value":"salut"}`)); err != nil { + if _, err := resolved.Put(itNode+".web.greeting", []byte(`{"value":"salut","source":"module"}`)); err != nil { t.Fatal(err) } if err := placement.Delete(pkey); err != nil { @@ -553,9 +553,9 @@ func h8(t *testing.T, b *itBed, checkBuild bool) (func(), h8state) { key string value []byte }{{manifests, mkey, mraw}, {modules, "web", modv}, {b.haves, hkey, rec}, - {resolved, itNode + ".web.greeting", []byte(`{"value":"bonjour"}`)}, + {resolved, itNode + ".web.greeting", []byte(`{"value":"bonjour","source":"module"}`)}, {manifests, mlkey, mlraw}, {modules, "mailer", mlmod}, {b.haves, hkey2, rec2}, {placement, pkey2, place2}, - {resolved, "it2.mailer.domain", []byte(`{"value":"example.org"}`)}, {builds, buildKey, firstBuild}} { + {resolved, "it2.mailer.domain", []byte(`{"value":"example.org","source":"module"}`)}, {builds, buildKey, firstBuild}} { if _, err := w.kv.Put(w.key, w.value); err != nil { t.Fatal(err) } @@ -590,7 +590,7 @@ func h8(t *testing.T, b *itBed, checkBuild bool) (func(), h8state) { if _, err := builds.Put(buildKey, done); err != nil { t.Fatal(err) } - if _, err := resolved.Put(itNode+".web.greeting", []byte(`{"value":"bonjour"}`)); err != nil { + if _, err := resolved.Put(itNode+".web.greeting", []byte(`{"value":"bonjour","source":"module"}`)); err != nil { t.Fatal(err) } } @@ -608,7 +608,7 @@ func h8rest(t *testing.T, b *itBed, resolved, candidates nats.KeyValue, hkey str t.Errorf("the controller's compositions hold %v; the node composed its own", keys) } first := b.have("web").Composed - if _, err := resolved.Put(itNode+".web.greeting", []byte(`{"value":"salut"}`)); err != nil { + if _, err := resolved.Put(itNode+".web.greeting", []byte(`{"value":"salut","source":"module"}`)); err != nil { t.Fatal(err) } within(t, 3*time.Second, "a changed config value was not composed and applied again", func() bool { return b.file("web") == "greeting=salut\n" })