//go:build integration

package process

import (
	"strings"
	"testing"

	"github.com/nats-io/nats.go/jetstream"

	"git.novox.be/novox/mesh-sdk/go/announce"
)

// 1790/S10: on a real bus, a process's Keeps lands on its module's own announcement subject, in the events stream, as
// the module's announcement; a state it did not announce is then refused at the call.
func TestAProcessAnnouncesWhatItKeepsOnTheBus(t *testing.T) {
	url, account := grantedSendProcess(t)
	_, admin := adminJS(t, url)
	stream, err := admin.CreateStream(ctxFor(t), jetstream.StreamConfig{Name: "MAIL_STATES", Subjects: []string{announce.Subject("mesh-mail")}})
	if err != nil {
		t.Fatal(err)
	}
	conn, err := Connect(account)
	if err != nil {
		t.Fatal(err)
	}
	defer conn.Close()
	if err := conn.Keeps(announce.State{Name: "accounts", Readable: true}, announce.State{Name: "drafts"}); err != nil {
		t.Fatal(err)
	}
	msg, err := stream.GetMsg(ctxFor(t), 1)
	if err != nil {
		t.Fatalf("no announcement in the stream: %v", err)
	}
	if msg.Subject != "mesh.mod.mesh-mail.event.states" || msg.Header.Get("x-source") != "mesh-mail" {
		t.Fatalf("announced on %s with %v", msg.Subject, msg.Header)
	}
	got, err := announce.Decode(msg.Data)
	if err != nil || !got.Readable("accounts") || !got.Keeps("drafts") || got.Readable("drafts") || got.Node != "novox" {
		t.Fatalf("announced %s (%v)", msg.Data, err)
	}
	if _, err := conn.State("outbox").Get("k"); err == nil || !strings.Contains(err.Error(), `"outbox"`) {
		t.Fatalf("an unannounced state was bound: %v", err)
	}
}