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	cursors := make(chan ports.CursorChange)
16	set := newOutputSet(context.Background(), nil, outputRoutes{cursor: cursors})
17	got := map[string]chan ports.CursorChange{}
18	run := func(name string) outputRun {
19		got[name] = make(chan ports.CursorChange, 8)
20		out := got[name]
21		return func(ctx context.Context, feed outputFeed) error {
22			cursor := feed.Cursor
23			for {
24				select {
25				case <-ctx.Done():
26					return nil
27				case c := <-cursor:
28					out <- c
29				}
30			}
31		}
32	}
33	expect := func(name string, want ports.CursorChange) {
34		t.Helper()
35		select {
36		case c := <-got[name]:
37			if c.Shape != want.Shape || c.Hidden != want.Hidden {
38				t.Fatalf("%s: %+v, want %+v", name, c, want)
39			}
40		case <-time.After(2 * time.Second):
41			t.Fatalf("%s: no cursor", name)
42		}
43	}
44	set.start(ctx, "A", run("A"))
45	expect("A", ports.CursorChange{})
46	cursors <- ports.CursorChange{Shape: "text"}
47	expect("A", ports.CursorChange{Shape: "text"})
48	set.start(ctx, "B", run("B"))
49	expect("B", ports.CursorChange{Shape: "text"})
50	cursors <- ports.CursorChange{Hidden: true}
51	expect("A", ports.CursorChange{Hidden: true})
52	expect("B", ports.CursorChange{Hidden: true})
53	if err := set.wait(); err != nil {
54		t.Fatal(err)
55	}
56}