mesh-controller/cmd/mesh-controller/adopting_test.go

//go:build integration

package main

import (
	"context"
	"encoding/json"
	"errors"
	sdkdelivery "git.novox.be/novox/mesh-sdk/go/delivery"
	"github.com/nats-io/nats.go/jetstream"
	"github.com/novox/mesh-controller/internal/broker"
	"github.com/novox/mesh-controller/internal/testbus"
	"net/http"
	"reflect"
	"strings"
	"testing"
	"time"

	"git.novox.be/novox/mesh-sdk/go/catalogue"
	"git.novox.be/novox/mesh-sdk/go/overlay"
	"github.com/novox/mesh-controller/internal/inventory"
	"github.com/novox/mesh-controller/internal/link"
)

// novox/hq ADR 0100: taking a module is its cutover; converging a node is one act, previewed, and
// refused while a found container is held; returning to adopted keeps what was taken.

// anAdoptedAnchor is aMesh with the anchor adopted, running a served module the predecessor also
// runs and a module with only a file, and a filter module in the catalogue.
func anAdoptedAnchor(t *testing.T) (*stores, *[]string) {
	t.Helper()
	open := aMesh(t)
	ctx := t.Context()
	register(t, open, catalogue.Manifest{Module: "hello-web", Version: "1",
		Listens: []catalogue.Listening{{Port: 8080, From: catalogue.FromEverywhere}},
		Resources: []map[string]any{
			{"id": "page", "type": "file", "path": "/var/lib/hello-web/index.html", "content": "hi"},
			{"id": "server", "type": "container", "name": "hello-web", "ports": []any{"8080:80"},
				"image": "registry.example/hello@sha256:" + strings.Repeat("a", 64)},
		}})
	register(t, open, catalogue.Manifest{Module: "notes", Version: "1",
		Resources: []map[string]any{
			{"id": "conf", "type": "file", "path": "/etc/notes.conf", "content": "x"},
		}})
	register(t, open, catalogue.Manifest{Module: "nftables", Version: "1",
		Filtering: &catalogue.Filtering{Into: "/etc/nftables.conf"},
		Resources: []map[string]any{{"id": "load", "type": "service", "unit": "mesh-filter.service",
			"state": "running", "restart-on": []any{"filtering"}}}})
	if err := open.inventory.SetAdopted(ctx, "anchor", true); err != nil {
		t.Fatal(err)
	}
	for _, m := range []string{"hello-web", "notes"} {
		if _, err := assign(ctx, open, "anchor", m); err != nil {
			t.Fatal(err)
		}
	}
	onTheBusWithItsHaves(t, open)
	sent := &[]string{}
	saved := sendNodes
	sendNodes = func(_ context.Context, _ *stores, names []string) error {
		*sent = append(*sent, names...)
		return nil
	}
	t.Cleanup(func() { sendNodes = saved })
	return open, sent
}

// reportsHolding has the anchor report, on what it was last sent, holding what is given.
func reportsHolding(t *testing.T, open *stores, held ...link.Held) {
	t.Helper()
	reportsReaching(t, open, []link.Reach{
		{Protocol: "tcp", Address: "0.0.0.0", Port: 22, By: "sshd"},
		{Protocol: "tcp", Address: "0.0.0.0", Port: 8080, By: "hello-web", Published: true,
			ContainerPort: 80},
		{Protocol: "tcp", Address: "0.0.0.0", Port: 5000, By: "predecessor-registry",
			Published: true, ContainerPort: 5000},
		{Protocol: "tcp", Address: "127.0.0.1", Port: 15672, By: "mesh-broker",
			Published: true, ContainerPort: 15672},
	}, held...)
}

// reportsReaching has the anchor report, on what it was last sent, what is reachable on it and
// holding what is given.
func reportsReaching(t *testing.T, open *stores, reachable []link.Reach, held ...link.Held) {
	t.Helper()
	ctx := t.Context()
	body, err := composed(t, open, "anchor").Body()
	if err != nil {
		t.Fatal(err)
	}
	if _, err := (link.Enrolment{Inventory: open.inventory}).Heard(ctx, link.Report{
		Node: "anchor", Applied: []string{"hello-web.x"}, Declared: digestOf(body),
		Firewall: "ufw", Held: held, Reachable: reachable,
		// A machine says which of its links face outside on every apply (novox/hq ADR 0140), and a
		// filter is not sent to one that has not. The anchor reports one, as a real host does; this
		// fixture lacked it from 2026-09-28 and nothing ran the test (issue 177).
		Outward: []string{"eth0"},
		// And what filters it (ADR 0168): its front end, the runtime's own, and a chain a
		// predecessor left in the runtime's user chain.
		Filters: anchorFilters,
	}); err != nil {
		t.Fatal(err)
	}
}

// anchorFilters is what the adopted anchor says filters it: ufw's chains, the runtime's, and a
// predecessor's chain the mesh did not write.
var anchorFilters = []link.Filter{
	{Where: "table ip filter, chain ufw-reject-input", Owner: "found-firewall", Refuses: "reject"},
	{Where: "table ip filter, chain DOCKER", Owner: "runtime", Refuses: `iifname != "docker0" oifname "docker0" drop`},
	{Where: "table ip filter, chain DOCKER-USER", Owner: "other", Refuses: `iifname "eth0" tcp dport 6000 drop`},
}

var (
	heldContainer = link.Held{ID: "hello-web.server", Module: "hello-web", Kind: "container",
		Target: "hello-web", Since: time.Now()}
	heldFile = link.Held{ID: "notes.conf", Module: "notes", Kind: "file",
		Target: "/etc/notes.conf", Since: time.Now(), Kept: "/var/lib/mesh-host/kept/abc-notes.conf"}
)

func TestTakingAModuleNotOnTheNodeIsRefused(t *testing.T) {
	open, _ := anAdoptedAnchor(t)
	if _, err := take(t.Context(), open, "anchor", "nftables", takeOptions{Yes: true}); !errors.Is(err, inventory.ErrNotAssigned) {
		t.Fatalf("taking an unassigned module gave %v", err)
	}
	if _, err := take(t.Context(), open, "laptop", "network", takeOptions{Yes: true}); !errors.Is(err, inventory.ErrNotAdopted) {
		t.Fatalf("taking on a converged node gave %v", err)
	}
}

func TestConvergingIsRefusedOnAPreviewThatWouldBeStale(t *testing.T) {
	open, sent := anAdoptedAnchor(t)
	_, err := converge(t.Context(), open, "anchor", false, "", "")
	if err == nil || !strings.Contains(err.Error(), "has not reported") {
		t.Fatalf("a node that never reported was previewed: %v", err)
	}
	if len(*sent) != 0 {
		t.Fatal("a refused converge sent something")
	}
}

func TestTheFlipIsRefusedWhileAFoundContainerIsHeld(t *testing.T) {
	open, sent := anAdoptedAnchor(t)
	reportsHolding(t, open, heldContainer, heldFile)
	_, err := converge(t.Context(), open, "anchor", true, "", "")
	if err == nil || !strings.Contains(err.Error(), "take anchor hello-web once its data has moved") {
		t.Fatalf("the flip was not refused while hello-web holds its found container: %v", err)
	}
	if n, _ := open.inventory.NodeByName(t.Context(), "anchor"); !n.Adopted || len(*sent) != 0 {
		t.Fatal("a refused flip changed something")
	}
}

func TestTakingNamesWhatItReplaces(t *testing.T) {
	open, _ := anAdoptedAnchor(t)
	reportsHolding(t, open, heldContainer, heldFile)
	ctx := t.Context()
	// The machine holds something for the module, so the take acts on the preview the operator
	// saw and names its digest (novox/hq ADR 0163).
	preview, err := take(ctx, open, "anchor", "hello-web", takeOptions{})
	if err != nil {
		t.Fatal(err)
	}
	saw := takeDigestIn(t, preview)
	if !strings.Contains(preview, "nothing taken; `take anchor hello-web --yes "+saw+"`") {
		t.Fatalf("the preview does not say how to act on it:\n%s", preview)
	}
	if taken, _ := open.inventory.Taken(ctx, "anchor"); len(taken) != 0 {
		t.Fatal("the preview took something")
	}
	if _, err := take(ctx, open, "anchor", "hello-web", takeOptions{Yes: true}); err == nil || !strings.Contains(err.Error(), "name its digest") {
		t.Fatalf("--yes without the digest was not refused: %v", err)
	}
	said, err := take(ctx, open, "anchor", "hello-web", takeOptions{Yes: true, Digest: saw})
	if err != nil {
		t.Fatal(err)
	}
	if !strings.Contains(said, "container hello-web (hello-web.server)") ||
		!strings.Contains(said, "compositions of anchor are written") {
		t.Fatalf("taking did not say what it replaces and what to run:\n%s", said)
	}
}

// takeDigestIn is the digest a take's preview printed.
func takeDigestIn(t *testing.T, preview string) string {
	t.Helper()
	for _, line := range strings.Split(preview, "\n") {
		if fields := strings.Fields(line); len(fields) == 2 && fields[0] == "preview" {
			return fields[1]
		}
	}
	t.Fatalf("the preview printed no digest:\n%s", preview)
	return ""
}

// A take acts on the preview the operator saw, and on an account of the machine that is still the
// machine: a changed preview and a stale account refuse (novox/hq ADR 0163, rule 1).
func TestATakeIsRefusedOnAChangedPreviewOrAStaleAccount(t *testing.T) {
	open, _ := anAdoptedAnchor(t)
	ctx := t.Context()
	reportsHolding(t, open, heldContainer, heldFile)
	preview, err := take(ctx, open, "anchor", "hello-web", takeOptions{})
	if err != nil {
		t.Fatal(err)
	}
	saw := takeDigestIn(t, preview)

	// The machine reports again, and what it holds has changed: the found container now carries
	// facts the preview never showed.
	changed := heldContainer
	changed.Facts = map[string]any{"image": "hello:2", "declared_image": "registry.example/hello"}
	reportsHolding(t, open, changed, heldFile)
	_, err = take(ctx, open, "anchor", "hello-web", takeOptions{Yes: true, Digest: saw})
	if err == nil || !strings.Contains(err.Error(), "has changed since preview "+saw) {
		t.Fatalf("a changed preview was acted on: %v", err)
	}
	if taken, _ := open.inventory.Taken(ctx, "anchor"); len(taken) != 0 {
		t.Fatal("a refused take took something")
	}

	// And an account older than the flip allows.
	preview, err = take(ctx, open, "anchor", "hello-web", takeOptions{})
	if err != nil {
		t.Fatal(err)
	}
	saw = takeDigestIn(t, preview)
	saved := reportFreshFor
	reportFreshFor = -time.Second
	defer func() { reportFreshFor = saved }()
	_, err = take(ctx, open, "anchor", "hello-web", takeOptions{Yes: true, Digest: saw})
	if err == nil || !strings.Contains(err.Error(), "a take acts only on an account newer than") {
		t.Fatalf("a stale account was acted on: %v", err)
	}
	reportFreshFor = saved
	if _, err := take(ctx, open, "anchor", "hello-web", takeOptions{Yes: true, Digest: saw}); err != nil {
		t.Fatal(err)
	}
	// A module the machine holds nothing for has nothing to compare: --yes alone suffices.
	if _, err := take(ctx, open, "anchor", "notes", takeOptions{Yes: true}); err == nil {
		// notes holds a file, so this one needs the digest too.
		t.Fatal("notes holds a found file and was taken without a digest")
	}
}

func TestConvergingPreviewsThenChangesAndAdoptingKeepsWhatWasTaken(t *testing.T) {
	open, sent := anAdoptedAnchor(t)
	ctx := t.Context()
	if _, err := take(ctx, open, "anchor", "hello-web", takeOptions{Yes: true}); err != nil {
		t.Fatal(err)
	}
	*sent = nil // the take composed the node; what follows is judged from here
	reportsHolding(t, open, heldFile)

	preview, err := converge(ctx, open, "anchor", false, "", "")
	if err != nil {
		t.Fatal(err)
	}
	for _, want := range []string{
		"tcp/8080 hello-web (published, container port 80)",
		"declared by hello-web (from anywhere)",
		"WILL CLOSE — no module assigned here declares it",
		// The anchor faces inward and is on the private network: the derived filter admits ssh
		// from the mesh only.
		"WILL CLOSE to everything outside the private network — ssh stays open from the mesh",
		"notes\n      replacing the found file /etc/notes.conf (notes.conf), original kept at",
		"assigns nftables",
		"the found firewall (ufw) is disabled, never flushed",
		// What it routes is not a listener: said not to be previewed, and to be dropped.
		"not previewed: traffic the machine routes that is not a published port",
		"the derived filter drops it unless a module declares it",
	} {
		if !strings.Contains(preview, want) {
			t.Errorf("the preview does not say %q:\n%s", want, preview)
		}
	}
	if strings.Contains(preview, "15672") {
		t.Errorf("a loopback listener is in the preview:\n%s", preview)
	}
	// What filters the machine now, and the fate of each (novox/hq ADR 0168): the predecessor's
	// chain is named as not the mesh's and left, so the reader knows before the flip.
	for _, want := range []string{
		"table ip filter, chain DOCKER-USER",
		"NOT THE MESH'S; left in force",
		`iifname "eth0" tcp dport 6000 drop`,
		"table ip filter, chain ufw-reject-input",
		"the found firewall's; retired with it",
		"the container runtime's own; left",
	} {
		if !strings.Contains(preview, want) {
			t.Errorf("the preview does not say %q:\n%s", want, preview)
		}
	}
	for _, line := range strings.Split(preview, "\n") {
		if strings.Contains(line, "5000") && !strings.Contains(line, "WILL CLOSE") {
			t.Errorf("an undeclared published port is not said to close: %s", line)
		}
	}
	if n, _ := open.inventory.NodeByName(ctx, "anchor"); !n.Adopted || len(*sent) != 0 {
		t.Fatal("the preview changed something")
	}

	if _, err := converge(ctx, open, "anchor", true, digestIn(t, preview), ""); err != nil {
		t.Fatal(err)
	}
	n, _ := open.inventory.NodeByName(ctx, "anchor")
	if n.Adopted {
		t.Fatal("converge --yes left the node adopted")
	}
	taken, _ := open.inventory.Taken(ctx, "anchor")
	if !reflect.DeepEqual(taken, []string{"hello-web", overlay.Name, "nftables", "notes"}) {
		t.Fatalf("the flip took %v", taken)
	}
	if !reflect.DeepEqual(*sent, []string{"anchor"}) {
		t.Fatalf("the flip sent %v", *sent)
	}
	declared := composed(t, open, "anchor")
	if declared.Adoption != nil {
		t.Fatal("a converged node is still sent an adoption envelope")
	}
	if !hasID(declared.Resources, "nftables.filtering") {
		t.Fatal("the converged node is not declared the mesh's filter")
	}

	if _, err := adopt(ctx, open, "anchor"); err != nil {
		t.Fatal(err)
	}
	if _, err := adopt(ctx, open, "anchor"); err == nil {
		t.Fatal("adopting an adopted node was not refused")
	}
	again, _ := open.inventory.Taken(ctx, "anchor")
	if !reflect.DeepEqual(again, taken) {
		t.Fatalf("returning to adopted lost what was taken: %v", again)
	}
	declared = composed(t, open, "anchor")
	if declared.Adoption == nil || len(declared.Adoption.Untaken) != 0 {
		t.Fatalf("returned to adopted, the envelope is %+v", declared.Adoption)
	}
	if hasID(declared.Resources, "nftables.filtering") || hasID(declared.Resources, "nftables.load") {
		t.Fatal("returned to adopted, the mesh's filter is still declared")
	}
}

func hasID(resources []map[string]any, id string) bool {
	for _, r := range resources {
		if r["id"] == id {
			return true
		}
	}
	return false
}

// The command API refuses a flip exactly as the command line does, in the same words.
func TestTheApiRefusesTheFlipInTheCommandLinesWords(t *testing.T) {
	open, _ := anAdoptedAnchor(t)
	reportsHolding(t, open, heldContainer)
	_, direct := converge(t.Context(), open, "anchor", true, "", "")
	if direct == nil {
		t.Fatal("the flip was not refused")
	}
	got := asking(t, letIn{}, "POST", "/converge", `{"node":"anchor","yes":true}`)
	if got.Code != http.StatusConflict {
		t.Fatalf("got %d: %s", got.Code, got.Body.String())
	}
	var said map[string]any
	if err := json.Unmarshal(got.Body.Bytes(), &said); err != nil {
		t.Fatal(err)
	}
	if said["refused"] != direct.Error() {
		t.Fatalf("the API said %q and the command line %q", said["refused"], direct.Error())
	}
	if got := asking(t, letIn{}, "POST", "/take", `{"node":"anchor"}`); got.Code != http.StatusBadRequest {
		t.Fatalf("a take naming no module got %d", got.Code)
	}
}

// novox/hq ADR 0100: the preview says what the derived filter does, rendered as it is rendered. On
// a machine that faces inward, ssh is admitted from the private network only, and a port a module
// admits from the mesh only closes to everything outside it: both are said to close.
func TestThePreviewSaysWhatNarrowsToTheMeshCloses(t *testing.T) {
	open, _ := anAdoptedAnchor(t)
	ctx := t.Context()
	register(t, open, catalogue.Manifest{Module: "store", Version: "1",
		Listens: []catalogue.Listening{{Port: 5432, From: catalogue.FromMesh}}})
	if _, err := assign(ctx, open, "anchor", "store"); err != nil {
		t.Fatal(err)
	}
	reportsReaching(t, open, []link.Reach{
		{Protocol: "tcp", Address: "0.0.0.0", Port: 22, By: "sshd"},
		{Protocol: "tcp", Address: "0.0.0.0", Port: 5432, By: "postgres"},
		{Protocol: "tcp", Address: "10.77.0.1", Port: 5432, By: "postgres"},
		{Protocol: "tcp", Address: "0.0.0.0", Port: 8080, By: "hello-web", Published: true,
			ContainerPort: 80},
	})
	preview, err := converge(ctx, open, "anchor", false, "", "")
	if err != nil {
		t.Fatal(err)
	}
	lines := map[string]string{}
	for _, line := range strings.Split(preview, "\n") {
		fields := strings.Fields(line)
		if len(fields) > 1 && strings.HasPrefix(fields[0], "tcp/") {
			lines[fields[0]+" "+fields[1]] += line + "\n"
		}
	}
	if got := lines["tcp/22 sshd"]; !strings.Contains(got, "WILL CLOSE to everything outside "+
		"the private network") {
		t.Errorf("ssh on an inward machine is not said to close outside the mesh:\n%s", preview)
	}
	store := lines["tcp/5432 postgres"]
	if strings.Count(store, "WILL CLOSE to everything outside the private network") != 1 ||
		!strings.Contains(store, "declared by store (from mesh)") {
		t.Errorf("the store's narrowing is not said to close, or its mesh address is:\n%s", preview)
	}
	if got := lines["tcp/8080 hello-web"]; !strings.Contains(got, "declared by hello-web (from anywhere)") {
		t.Errorf("a port open to everywhere is not said to stay:\n%s", preview)
	}
}

// digestIn is the digest a converge preview printed.
func digestIn(t *testing.T, preview string) string {
	t.Helper()
	for _, line := range strings.Split(preview, "\n") {
		if fields := strings.Fields(line); len(fields) == 2 && fields[0] == "preview" {
			return fields[1]
		}
	}
	t.Fatalf("the preview printed no digest:\n%s", preview)
	return ""
}

// The flip acts on the preview the operator saw: it names that preview's digest, and it is refused
// when the digest is missing, when anything the preview says has changed since, or when the node's
// account of itself is too old to be the machine as it is.
func TestTheFlipActsOnlyOnThePreviewTheOperatorSaw(t *testing.T) {
	open, sent := anAdoptedAnchor(t)
	ctx := t.Context()
	if _, err := take(ctx, open, "anchor", "hello-web", takeOptions{Yes: true}); err != nil {
		t.Fatal(err)
	}
	*sent = nil // the take composed the node; what follows is judged from here
	reportsHolding(t, open, heldFile)
	preview, err := converge(ctx, open, "anchor", false, "", "")
	if err != nil {
		t.Fatal(err)
	}
	saw := digestIn(t, preview)
	if !strings.Contains(preview, "converge anchor --yes "+saw) {
		t.Fatalf("the preview does not say how to act on it:\n%s", preview)
	}
	unchanged := func() {
		t.Helper()
		if n, _ := open.inventory.NodeByName(ctx, "anchor"); !n.Adopted || len(*sent) != 0 {
			t.Fatal("a refused flip changed something")
		}
	}

	if _, err := converge(ctx, open, "anchor", true, "", ""); err == nil ||
		!strings.Contains(err.Error(), "--yes "+saw) {
		t.Fatalf("a flip naming no preview was not refused: %v", err)
	}
	unchanged()

	// Something new is reachable: the preview the operator saw is not what would happen.
	reportsReaching(t, open, []link.Reach{
		{Protocol: "tcp", Address: "0.0.0.0", Port: 22, By: "sshd"},
		{Protocol: "tcp", Address: "0.0.0.0", Port: 8080, By: "hello-web", Published: true,
			ContainerPort: 80},
		{Protocol: "tcp", Address: "0.0.0.0", Port: 6000, By: "something-new"},
	}, heldFile)
	_, err = converge(ctx, open, "anchor", true, saw, "")
	if err == nil || !strings.Contains(err.Error(), "has changed since preview "+saw) {
		t.Fatalf("a flip on a changed preview was not refused: %v", err)
	}
	unchanged()

	// An account older than the flip trusts is refused, whatever digest is named.
	again, err := converge(ctx, open, "anchor", false, "", "")
	if err != nil {
		t.Fatal(err)
	}
	saved := reportFreshFor
	reportFreshFor = time.Nanosecond
	_, err = converge(ctx, open, "anchor", true, digestIn(t, again), "")
	reportFreshFor = saved
	if err == nil || !strings.Contains(err.Error(), "wait for its next report") {
		t.Fatalf("a flip on an old account was not refused: %v", err)
	}
	unchanged()

	if _, err := converge(ctx, open, "anchor", true, digestIn(t, again), ""); err != nil {
		t.Fatalf("the flip on the preview just seen was refused: %v", err)
	}
	if n, _ := open.inventory.NodeByName(ctx, "anchor"); n.Adopted {
		t.Fatal("the flip did not converge the node")
	}
}

// novox/hq ADR 0103: the preview names every kind of thing a module the flip takes holds as found,
// not only its files, and the digest changes when any of them does.
func TestThePreviewNamesEveryHeldKind(t *testing.T) {
	open, _ := anAdoptedAnchor(t)
	ctx := t.Context()
	if _, err := take(ctx, open, "anchor", "hello-web", takeOptions{Yes: true}); err != nil {
		t.Fatal(err)
	}
	since := time.Now()
	held := []link.Held{heldFile,
		{ID: "notes.data", Module: "notes", Kind: "directory", Target: "/var/lib/notes", Since: since},
		{ID: "notes.daemon", Module: "notes", Kind: "service", Target: "notes.service", Since: since},
		{ID: "notes.seed", Module: "notes", Kind: "archive", Target: "/srv/notes", Since: since},
		{ID: "notes.worker", Module: "notes", Kind: "process", Target: "notes-worker", Since: since},
		{ID: "notes.account", Module: "notes", Kind: "user", Target: "notes", Since: since},
	}
	reportsHolding(t, open, held...)
	preview, err := converge(ctx, open, "anchor", false, "", "")
	if err != nil {
		t.Fatal(err)
	}
	for _, want := range []string{
		"replacing the found directory /var/lib/notes (notes.data)",
		"replacing the found service notes.service (notes.daemon)",
		"replacing the found archive /srv/notes (notes.seed)",
		"replacing the found process notes-worker (notes.worker)",
		"replacing the found user notes (notes.account)",
	} {
		if !strings.Contains(preview, want) {
			t.Errorf("the preview does not say %q:\n%s", want, preview)
		}
	}
	reportsHolding(t, open, held[:len(held)-1]...)
	fewer, err := converge(ctx, open, "anchor", false, "", "")
	if err != nil {
		t.Fatal(err)
	}
	if digestIn(t, fewer) == digestIn(t, preview) {
		t.Fatal("the digest does not change with what is held")
	}
}

// novox/hq ADR 0100: the flip acts on what the node said is reachable, so an account naming nothing
// is refused. Every machine that is up answers on ssh; nothing reported means the host's collectors
// did not, and flipping would close ports the preview never named.
func TestTheFlipIsRefusedOnAnAccountNamingNothingReachable(t *testing.T) {
	open, sent := anAdoptedAnchor(t)
	ctx := t.Context()
	if _, err := take(ctx, open, "anchor", "hello-web", takeOptions{Yes: true}); err != nil {
		t.Fatal(err)
	}
	*sent = nil // the take composed the node; what follows is judged from here
	// Only a loopback listener: nothing off the machine, which is the same silence.
	reportsReaching(t, open, []link.Reach{
		{Protocol: "tcp", Address: "127.0.0.1", Port: 15672, By: "mesh-broker"},
	}, heldFile)
	preview, err := converge(ctx, open, "anchor", false, "", "")
	if err != nil {
		t.Fatal(err)
	}
	if !strings.Contains(preview, "this account looks partial") {
		t.Errorf("the preview does not mark a partial account:\n%s", preview)
	}
	_, err = converge(ctx, open, "anchor", true, digestIn(t, preview), "")
	if err == nil || !strings.Contains(err.Error(), "says nothing is reachable on it") {
		t.Fatalf("the flip was not refused on an account naming nothing: %v", err)
	}
	if n, _ := open.inventory.NodeByName(ctx, "anchor"); !n.Adopted || len(*sent) != 0 {
		t.Fatal("a refused flip changed something")
	}
}

// onTheBusWithItsHaves gives the controller a bus that holds, for the anchor, a want and a have of its module that agree: the node
// has everything wanted of it, as read from the haves (novox/hq ADR 0539 §9), so a flip is refused for what it is about and
// not because the bus could not be read.
func onTheBusWithItsHaves(t *testing.T, open *stores) {
	t.Helper()
	ctx := t.Context()
	js, err := broker.Dial(testbus.URL(t))
	if err != nil {
		t.Fatal(err)
	}
	t.Cleanup(js.Close)
	servingBus.Store(js)
	t.Cleanup(func() { servingBus.Store(nil) })
	api, err := jetstream.New(js.Conn())
	if err != nil {
		t.Fatal(err)
	}
	fp := sdkdelivery.SourcePrefix2 + strings.Repeat("a", 64)
	composed := "sha256:" + strings.Repeat("b", 64)
	put := func(bucket, key string, value []byte) {
		kv, err := api.CreateOrUpdateKeyValue(ctx, jetstream.KeyValueConfig{Bucket: bucket})
		if err != nil {
			t.Fatal(err)
		}
		if _, err := kv.Put(ctx, key, value); err != nil {
			t.Fatal(err)
		}
	}
	wantKey, err := sdkdelivery.WantKey("anchor", "hello-web")
	if err != nil {
		t.Fatal(err)
	}
	haveKey, err := sdkdelivery.HaveKey("anchor", "hello-web")
	if err != nil {
		t.Fatal(err)
	}
	want, err := sdkdelivery.EncodeWant(sdkdelivery.Want{FP: fp, Composed: composed})
	if err != nil {
		t.Fatal(err)
	}
	have, err := sdkdelivery.EncodeHave(sdkdelivery.Have{FP: fp, Composed: composed, Phase: sdkdelivery.PhaseRunning, Health: sdkdelivery.HealthOK})
	if err != nil {
		t.Fatal(err)
	}
	put(sdkdelivery.AssignerWantsBucket, wantKey, want)
	put(sdkdelivery.HaveBucket, haveKey, have)
}

// **When the bus cannot be read, whether the machine runs what is wanted is not known, and the flip says exactly that** (issue
// 1945): not "push", and not "has not reported".
func TestTheFlipIsRefusedWithTheBusUnreachableSayingItCannotTell(t *testing.T) {
	open, sent := anAdoptedAnchor(t)
	reportsHolding(t, open, heldContainer, heldFile)
	servingBus.Store(nil) // this process has no bus now, and no address to dial
	_, err := converge(t.Context(), open, "anchor", true, "", "")
	if err == nil || !strings.Contains(err.Error(), "cannot tell whether anchor runs what is wanted: the bus is not reachable") ||
		strings.Contains(err.Error(), "push") {
		t.Fatalf("the flip with the bus out of reach: %v", err)
	}
	if len(*sent) != 0 {
		t.Fatal("a refused flip sent something")
	}
}

// **A take composes the node only when it is performed** (issue 1945): a preview, a take that names no digest and a take refused
// for a changed preview compose nothing; the performed take composes the machine once, and says so.
func TestATakeComposesTheNodeOnlyWhenItIsPerformed(t *testing.T) {
	open, sent := anAdoptedAnchor(t)
	ctx := t.Context()
	reportsHolding(t, open, heldContainer, heldFile)
	preview, err := take(ctx, open, "anchor", "hello-web", takeOptions{})
	if err != nil {
		t.Fatal(err)
	}
	if _, err := take(ctx, open, "anchor", "hello-web", takeOptions{Yes: true}); err == nil {
		t.Fatal("a take of a held module without the preview's digest was performed")
	}
	if _, err := take(ctx, open, "anchor", "hello-web", takeOptions{Yes: true, Digest: "not-the-digest"}); err == nil {
		t.Fatal("a take naming another preview's digest was performed")
	}
	if len(*sent) != 0 {
		t.Fatalf("a preview or a refused take composed %v", *sent)
	}
	said, err := take(ctx, open, "anchor", "hello-web", takeOptions{Yes: true, Digest: takeDigestIn(t, preview)})
	if err != nil {
		t.Fatal(err)
	}
	if len(*sent) != 1 || (*sent)[0] != "anchor" || !strings.Contains(said, "compositions of anchor are written") {
		t.Fatalf("the performed take composed %v and said:\n%s", *sent, said)
	}
}