test(01-04): cover config, lifecycle, services, events and context

- Table-driven compass precedence, malformed YAML, snake_case env and concurrent reads
- Party duplicate/missing/cycle, reordered manifest, HasConfig/HasCommands discovery
- Isolated backpack services, festival panic payload omission, towel nested isolation

festival/bus_test.go

@@ -4,6 +4,8 @@ import (
 	"context"
 	"errors"
 	"strings"
+	"sync"
+	"sync/atomic"
 	"testing"
 )
 
@@ -164,3 +166,109 @@ func TestBusesAreIsolated(t *testing.T) {
 		t.Fatal("bus B should not invoke bus A's listeners")
 	}
 }
+
+func TestConcurrentIndependentAppBuses(t *testing.T) {
+	a := New()
+	b := New()
+	var aCount, bCount atomic.Int64
+	a.Listen[*evt]("golem15.a", func(ctx context.Context, e *evt) error {
+		aCount.Add(1)
+		return nil
+	})
+	b.Listen[*evt]("golem15.b", func(ctx context.Context, e *evt) error {
+		bCount.Add(1)
+		return nil
+	})
+	var wg sync.WaitGroup
+	const n = 40
+	for i := 0; i < n; i++ {
+		wg.Add(2)
+		go func() {
+			defer wg.Done()
+			if err := a.Fire(context.Background(), &evt{}); err != nil {
+				t.Errorf("bus A: %v", err)
+			}
+		}()
+		go func() {
+			defer wg.Done()
+			if err := b.Fire(context.Background(), &evt{}); err != nil {
+				t.Errorf("bus B: %v", err)
+			}
+		}()
+	}
+	wg.Wait()
+	if aCount.Load() != n || bCount.Load() != n {
+		t.Fatalf("counts a=%d b=%d, want %d each", aCount.Load(), bCount.Load(), n)
+	}
+}
+
+func TestPanicRecoveryOmitsEventPayload(t *testing.T) {
+	bus := New()
+	bus.Listen[*evt]("golem15.boom", func(ctx context.Context, e *evt) error {
+		panic("secret-payload-xyz")
+	})
+	event := &evt{data: map[string]any{"secret": "classified"}}
+	err := bus.Fire(context.Background(), event)
+	if err == nil {
+		t.Fatal("expected panic error")
+	}
+	msg := err.Error()
+	if !strings.Contains(msg, "golem15.boom") {
+		t.Fatalf("error should name owner plugin, got %v", err)
+	}
+	if strings.Contains(msg, "secret-payload-xyz") || strings.Contains(msg, "classified") {
+		t.Fatalf("panic recovery leaked payload: %v", err)
+	}
+}
+
+func TestFireWithNoListeners(t *testing.T) {
+	bus := New()
+	if err := bus.Fire(context.Background(), &evt{}); err != nil {
+		t.Fatalf("Fire with no listeners: %v", err)
+	}
+}
+
+func TestCollectWithoutCollectableReturnsEmptyMap(t *testing.T) {
+	type plain struct{ n int }
+	bus := New()
+	bus.Listen[plain]("golem15.a", func(ctx context.Context, e plain) error { return nil })
+	got, err := bus.Collect(context.Background(), plain{n: 1})
+	if err != nil {
+		t.Fatal(err)
+	}
+	if len(got) != 0 {
+		t.Fatalf("payload = %v, want empty", got)
+	}
+}
+
+func TestUntilHandledNeverHandled(t *testing.T) {
+	bus := New()
+	var order []string
+	bus.Listen[*evt]("golem15.a", func(ctx context.Context, e *evt) error {
+		order = append(order, "a")
+		return nil
+	})
+	ok, err := bus.UntilHandled(context.Background(), &evt{})
+	if err != nil {
+		t.Fatal(err)
+	}
+	if ok {
+		t.Fatal("expected unhandled")
+	}
+	if strings.Join(order, ",") != "a" {
+		t.Fatalf("order = %v, want a", order)
+	}
+}
+
+func TestListenNilBusOrFnIsNoop(t *testing.T) {
+	var bus *Bus
+	bus.Listen[*evt]("golem15.a", func(ctx context.Context, e *evt) error { return errors.New("should not run") })
+	if err := bus.Fire(context.Background(), &evt{}); err != nil {
+		t.Fatalf("nil bus Fire: %v", err)
+	}
+	live := New()
+	live.Listen[*evt]("golem15.a", nil)
+	if err := live.Fire(context.Background(), &evt{}); err != nil {
+		t.Fatalf("nil fn Fire: %v", err)
+	}
+}