control.go RawHistoryFolder

1package app
2
3import (
4	"context"
5	"errors"
6	"fmt"
7	"io"
8
9	"github.com/bnema/nefercap/internal/adapters/cli"
10	"github.com/bnema/nefercap/internal/adapters/control"
11)
12
13// controlCommand resolves commands that must work without opening a GUI or
14// connecting to Wayland. A rec or all-in-one invocation is a stop toggle when
15// already active.
16func controlCommand(ctx context.Context, command cli.Command, output io.Writer) (handled bool, err error) {
17	switch command {
18	case cli.Rec, cli.AllInOne, cli.Stop:
19		stopped, err := control.Stop(ctx)
20		if err != nil {
21			return true, err
22		}
23		if command == cli.Stop {
24			if !stopped {
25				return true, errors.New("no recording is active")
26			}
27			return true, nil
28		}
29		return stopped, nil
30	case cli.Status:
31		active, err := control.Query(ctx)
32		if err != nil {
33			return true, err
34		}
35		state := "idle"
36		if active {
37			state = "recording"
38		}
39		_, err = fmt.Fprintln(output, state)
40		return true, err
41	default:
42		return false, nil
43	}
44}
45
46// stopOnRequest has one bounded lifetime per recording; the completion channel
47// is joined before closing the control server. No request starts a new worker.
48func stopOnRequest(ctx context.Context, requests <-chan control.Request, cancel context.CancelFunc) <-chan struct{} {
49	done := make(chan struct{})
50	go func() {
51		defer close(done)
52		select {
53		case <-ctx.Done():
54		case request := <-requests:
55			if request == control.RequestStop {
56				cancel()
57			}
58		}
59	}()
60	return done
61}