test(01-02): add failing test for typed events and context

- Cover Fire/Collect/UntilHandled, priority, panics and bus isolation
- Require towel actor/org/collection/locale accessors on context
- Assert hello command demonstrates all three dispatch modes

festival/bus_test.go

@@ -0,0 +1,166 @@
+package festival
+
+import (
+	"context"
+	"errors"
+	"strings"
+	"testing"
+)
+
+type evt struct {
+	data    map[string]any
+	handled bool
+}
+
+func (e *evt) Collected() map[string]any { return e.data }
+func (e *evt) IsHandled() bool           { return e.handled }
+
+func TestFireRunsAllListenersAndJoinsErrors(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 errors.New("err-a")
+	})
+	bus.Listen[*evt]("golem15.b", func(ctx context.Context, e *evt) error {
+		order = append(order, "b")
+		return errors.New("err-b")
+	})
+	err := bus.Fire(context.Background(), &evt{})
+	if err == nil {
+		t.Fatal("expected joined errors")
+	}
+	if !strings.Contains(err.Error(), "err-a") || !strings.Contains(err.Error(), "err-b") {
+		t.Fatalf("joined error = %v", err)
+	}
+	if strings.Join(order, ",") != "a,b" {
+		t.Fatalf("order = %v, want a,b", order)
+	}
+}
+
+func TestCollectMergesPayloadsLaterWinsAndKeepsPartialOnError(t *testing.T) {
+	bus := New()
+	bus.Listen[*evt]("golem15.a", func(ctx context.Context, e *evt) error {
+		e.data = map[string]any{"k": "a", "only": "a"}
+		return nil
+	})
+	bus.Listen[*evt]("golem15.b", func(ctx context.Context, e *evt) error {
+		e.data = map[string]any{"k": "b"}
+		return errors.New("collect-b")
+	})
+	got, err := bus.Collect(context.Background(), &evt{})
+	if err == nil || !strings.Contains(err.Error(), "collect-b") {
+		t.Fatalf("expected collect error, got %v", err)
+	}
+	if got["k"] != "b" {
+		t.Fatalf("later listener should win k, got %v", got)
+	}
+	if got["only"] != "a" {
+		t.Fatalf("partial payload missing only=a: %v", got)
+	}
+}
+
+func TestUntilHandledStopsOnFirstHandled(t *testing.T) {
+	bus := New()
+	var order []string
+	bus.Listen[*evt]("golem15.a", func(ctx context.Context, e *evt) error {
+		order = append(order, "a")
+		e.handled = true
+		return nil
+	})
+	bus.Listen[*evt]("golem15.b", func(ctx context.Context, e *evt) error {
+		order = append(order, "b")
+		return nil
+	})
+	ok, err := bus.UntilHandled(context.Background(), &evt{})
+	if err != nil {
+		t.Fatal(err)
+	}
+	if !ok {
+		t.Fatal("expected handled")
+	}
+	if strings.Join(order, ",") != "a" {
+		t.Fatalf("order = %v, want only a", order)
+	}
+}
+
+func TestUntilHandledStopsOnFirstError(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 errors.New("stop")
+	})
+	bus.Listen[*evt]("golem15.b", func(ctx context.Context, e *evt) error {
+		order = append(order, "b")
+		e.handled = true
+		return nil
+	})
+	ok, err := bus.UntilHandled(context.Background(), &evt{})
+	if err == nil || !strings.Contains(err.Error(), "stop") {
+		t.Fatalf("expected first error, got ok=%v err=%v", ok, err)
+	}
+	if ok {
+		t.Fatal("error should not report handled")
+	}
+	if strings.Join(order, ",") != "a" {
+		t.Fatalf("order = %v, want only a", order)
+	}
+}
+
+func TestPriorityDescendingStableTies(t *testing.T) {
+	bus := New()
+	var order []string
+	bus.ListenPriority[*evt]("golem15.low", 1, func(ctx context.Context, e *evt) error {
+		order = append(order, "low")
+		return nil
+	})
+	bus.Listen[*evt]("golem15.default-a", func(ctx context.Context, e *evt) error {
+		order = append(order, "default-a")
+		return nil
+	})
+	bus.Listen[*evt]("golem15.default-b", func(ctx context.Context, e *evt) error {
+		order = append(order, "default-b")
+		return nil
+	})
+	bus.ListenPriority[*evt]("golem15.high", 10, func(ctx context.Context, e *evt) error {
+		order = append(order, "high")
+		return nil
+	})
+	if err := bus.Fire(context.Background(), &evt{}); err != nil {
+		t.Fatal(err)
+	}
+	if strings.Join(order, ",") != "high,low,default-a,default-b" {
+		t.Fatalf("order = %v", order)
+	}
+}
+
+func TestPanicRecoveredNamesOwnerPlugin(t *testing.T) {
+	bus := New()
+	bus.Listen[*evt]("golem15.boom", func(ctx context.Context, e *evt) error {
+		panic("kapow")
+	})
+	err := bus.Fire(context.Background(), &evt{})
+	if err == nil {
+		t.Fatal("expected panic error")
+	}
+	if !strings.Contains(err.Error(), "golem15.boom") {
+		t.Fatalf("error should name owner plugin, got %v", err)
+	}
+}
+
+func TestBusesAreIsolated(t *testing.T) {
+	a := New()
+	b := New()
+	called := false
+	a.Listen[*evt]("golem15.a", func(ctx context.Context, e *evt) error {
+		called = true
+		return nil
+	})
+	if err := b.Fire(context.Background(), &evt{}); err != nil {
+		t.Fatal(err)
+	}
+	if called {
+		t.Fatal("bus B should not invoke bus A's listeners")
+	}
+}