production_seams_helpers_test.go RawHistoryFolder

1package daemon
2
3import (
4	"github.com/bnema/vev/internal/domain"
5	"github.com/bnema/vev/internal/protocol"
6	themeui "github.com/bnema/vev/internal/usecase/theme"
7)
8
9// ptyReader runs one pane reader for tests that register it with sessWg.Add
10// first. Production launches readPanePTY through sessWg.Go.
11func (d *Daemon) ptyReader(sess *session, tb *tab, p *pane) {
12	defer d.sessWg.Done()
13	if p != nil && p.ownerSnapshot() == nil && sess != nil && tb != nil {
14		publishPaneOwner(p, sess, tb, 0)
15	}
16	d.readPanePTY(p)
17}
18
19// processPTYData feeds bytes through the pane's VT parsing path.
20func (d *Daemon) processPTYData(_ *session, _ *tab, p *pane, data []byte, bufferDuringApply bool) {
21	d.processPanePTYData(p, data, bufferDuringApply)
22}
23
24// setThemeForTest publishes a complete applied snapshot for tests that do not
25// exercise daemon configuration.
26func (ac *attachedClient) setThemeForTest(t themeui.Theme) {
27	ac.setAppliedTheme(appliedTheme{Raw: t, Resolved: themeui.Resolve(t, domain.ThemeAccent{Mode: domain.ThemeAccentAuto})})
28}
29
30// sideEffect builds output without advancing the state stream, under the view
31// lock.
32func (s *attachmentOutput) sideEffect(data []byte, echoAck uint64) (protocol.Output, error) {
33	s.lockView()
34	defer s.unlockView()
35	return s.sideEffectLocked(data, echoAck)
36}
37
38// outstanding reports state frames sent but not yet acknowledged.
39func (s *attachmentOutput) outstanding() uint64 {
40	if s == nil {
41		return 0
42	}
43	s.lockView()
44	defer s.unlockView()
45	return s.next - s.acked
46}