1package cef
2
3import (
4 "sync"
5 "testing"
6
7 "github.com/bnema/dumber/internal/application/port"
8 "github.com/stretchr/testify/require"
9)
10
11func TestRuntimeActivityTrackerStartsQuiescent(t *testing.T) {
12 tracker := NewRuntimeActivityTracker()
13 require.True(t, tracker.Snapshot().Quiescent())
14}
15
16func TestRuntimeActivityTrackerCreationLifecycle(t *testing.T) {
17 tracker := NewRuntimeActivityTracker()
18 tracker.NoteCreationAccepted()
19 require.Equal(t, 1, tracker.Snapshot().PendingCreations)
20 require.False(t, tracker.Snapshot().Quiescent())
21
22 tracker.NoteCreationResolved()
23 require.True(t, tracker.Snapshot().Quiescent())
24
25 // Over-resolution clamps instead of going negative.
26 tracker.NoteCreationResolved()
27 require.Equal(t, 0, tracker.Snapshot().PendingCreations)
28}
29
30func TestRuntimeActivityTrackerViewLifecycle(t *testing.T) {
31 tracker := NewRuntimeActivityTracker()
32 tracker.NoteViewRegistered()
33 tracker.NoteViewRegistered()
34 require.Equal(t, 2, tracker.Snapshot().ActiveViews)
35
36 tracker.NoteViewCloseStarted()
37 snapshot := tracker.Snapshot()
38 require.Equal(t, 1, snapshot.ActiveViews)
39 require.Equal(t, 1, snapshot.PendingCleanup)
40 require.False(t, snapshot.Quiescent())
41
42 tracker.NoteCleanupCompleted()
43 tracker.NoteViewCloseStarted()
44 tracker.NoteCleanupCompleted()
45 require.True(t, tracker.Snapshot().Quiescent())
46}
47
48func TestRuntimeActivityTrackerDownloads(t *testing.T) {
49 tracker := NewRuntimeActivityTracker()
50
51 // Same filename on two browsers are distinct owners.
52 tracker.NoteDownloadStarted(7, 100)
53 tracker.NoteDownloadStarted(9, 100)
54 require.Equal(t, 2, tracker.Snapshot().ActiveDownloads)
55
56 // Progress without a start never creates work.
57 tracker.NoteDownloadProgress(7, 999)
58 require.Equal(t, 2, tracker.Snapshot().ActiveDownloads)
59
60 // Terminal resolves only the exact owner sharing the CEF download ID.
61 tracker.NoteDownloadTerminal(7, 100)
62 require.Equal(t, 1, tracker.Snapshot().ActiveDownloads)
63
64 tracker.NoteDownloadTerminal(9, 100)
65 require.Equal(t, 0, tracker.Snapshot().ActiveDownloads)
66
67 // Duplicate terminals are idempotent; unknown owners change nothing.
68 tracker.NoteDownloadTerminal(9, 100)
69 tracker.NoteDownloadTerminal(7, 424242)
70 require.True(t, tracker.Snapshot().Quiescent())
71}
72
73func TestRuntimeActivityTrackerDropBrowser(t *testing.T) {
74 tracker := NewRuntimeActivityTracker()
75 tracker.NoteDownloadStarted(7, 100)
76 tracker.NoteDownloadStarted(9, 200)
77 tracker.DropBrowser(7)
78 snapshot := tracker.Snapshot()
79 require.Equal(t, 1, snapshot.ActiveDownloads)
80
81 tracker.NoteDownloadTerminal(9, 200)
82 require.True(t, tracker.Snapshot().Quiescent())
83
84 // Dropping an unknown browser notifies nobody and changes nothing.
85 tracker.DropBrowser(12345)
86 require.True(t, tracker.Snapshot().Quiescent())
87}
88
89func TestRuntimeActivityTrackerSubscribeSequenced(t *testing.T) {
90 tracker := NewRuntimeActivityTracker()
91 var mu sync.Mutex
92 var seen []port.RuntimeActivitySnapshot
93 unsubscribe := tracker.Subscribe(func(snapshot port.RuntimeActivitySnapshot) {
94 mu.Lock()
95 seen = append(seen, snapshot)
96 mu.Unlock()
97 })
98 // Initial delivery is synchronous and quiescent.
99 mu.Lock()
100 require.Len(t, seen, 1)
101 require.True(t, seen[0].Quiescent())
102 mu.Unlock()
103
104 tracker.NoteCreationAccepted()
105 tracker.NoteCreationResolved()
106 unsubscribe()
107 tracker.NoteViewRegistered()
108
109 mu.Lock()
110 defer mu.Unlock()
111 require.Len(t, seen, 3, "unsubscribe stops delivery")
112 require.Equal(t, 1, seen[1].PendingCreations)
113 require.True(t, seen[2].Quiescent())
114}