diff --git a/modules/mesh-build-go/cmd/mesh-build-go/asks_integration_test.go b/modules/mesh-build-go/cmd/mesh-build-go/asks_integration_test.go index 1d185ceb..aab652b0 100644 --- a/modules/mesh-build-go/cmd/mesh-build-go/asks_integration_test.go +++ b/modules/mesh-build-go/cmd/mesh-build-go/asks_integration_test.go @@ -4,7 +4,6 @@ package main import ( "context" - "os" "sync" "testing" "time" @@ -14,16 +13,18 @@ import ( "git.novox.be/novox/mesh-sdk/go/buildstep" "git.novox.be/novox/mesh-sdk/go/delivery" + "git.novox.be/novox/mesh-sdk/go/testbus" ) // 1887/AC-order, 1887/AC-pull against the real bus: a check ask published before a delivery ask runs after it, and at // capacity 1 the second waits in the stream until the first ends. +// +// **A bus of its own.** The integration level runs every directory's tests at once on one bus, and this test names the +// build seat's stream and its fixed workers (SEAT_NODE_BUILD_GO and its workers) and deletes the stream at its end, so +// anything else on that bus, a puller or a leftover consumer, could hold or take its delivery ask and let the check +// ask run first. It starts from testbus (mesh-sdk, novox/hq ADR 0495 clause 5): a bus for this test alone, gone after it. func TestTheModuleTakesADeliveryAskBeforeAnEarlierCheck(t *testing.T) { - url := os.Getenv("MESH_TEST_NATS") - if url == "" { - t.Skip("MESH_TEST_NATS names no bus: the integration level starts one") - } - nc, err := nats.Connect(url) + nc, err := nats.Connect(testbus.URL(t)) if err != nil { t.Fatal(err) }