outputs_test.go RawHistoryFolder

1package app
2
3import (
4	"context"
5	"testing"
6	"time"
7
8	"github.com/bnema/neferwl/internal/ports"
9)
10
11// Every output gets the latest cursor, and a new output starts with it.
12func TestOutputSetCursor(t *testing.T) {
13	ctx, cancel := context.WithCancel(context.Background())
14	defer cancel()
15	set := newOutputSet(context.Background(), nil)
16	got := map[string]chan ports.CursorChange{}
17	run := func(name string) outputRun {
18		got[name] = make(chan ports.CursorChange, 8)
19		out := got[name]
20		return func(ctx context.Context, _ <-chan ports.Scene, _ <-chan ports.SurfaceContent, cursor <-chan ports.CursorChange, _ <-chan ports.CaptureRequest, _ <-chan ports.SecurityState, _ ports.OutputInstance) error {
21			for {
22				select {
23				case <-ctx.Done():
24					return nil
25				case c := <-cursor:
26					out <- c
27				}
28			}
29		}
30	}
31	expect := func(name string, want ports.CursorChange) {
32		t.Helper()
33		select {
34		case c := <-got[name]:
35			if c.Shape != want.Shape || c.Hidden != want.Hidden {
36				t.Fatalf("%s: %+v, want %+v", name, c, want)
37			}
38		case <-time.After(2 * time.Second):
39			t.Fatalf("%s: no cursor", name)
40		}
41	}
42	set.start(ctx, "A", run("A"))
43	expect("A", ports.CursorChange{})
44	set.setCursor(ports.CursorChange{Shape: "text"})
45	expect("A", ports.CursorChange{Shape: "text"})
46	set.start(ctx, "B", run("B"))
47	expect("B", ports.CursorChange{Shape: "text"})
48	set.setCursor(ports.CursorChange{Hidden: true})
49	expect("A", ports.CursorChange{Hidden: true})
50	expect("B", ports.CursorChange{Hidden: true})
51	if err := set.wait(); err != nil {
52		t.Fatal(err)
53	}
54}