captured.go RawHistoryFolder

1package app
2
3import (
4	"context"
5
6	"github.com/bnema/neferwl/internal/adapters/logging"
7	"github.com/bnema/neferwl/internal/ports"
8)
9
10// routeCaptured demultiplexes capture replies from the outputs: replies whose
11// ID carries ports.CaptureIDInternal go to internal, all others to wayland.
12// Both sends give way to ctx. A nil internal means no internal consumer is
13// wired: internal replies are dropped (logged at debug) instead of blocking
14// forever, since nothing would ever receive them. It returns when ctx is done
15// or in is closed.
16func routeCaptured(ctx context.Context, in <-chan ports.CaptureDone, wayland, internal chan<- ports.CaptureDone) {
17	log := logging.For(ctx, "app")
18	for {
19		select {
20		case <-ctx.Done():
21			return
22		case done, ok := <-in:
23			if !ok {
24				return
25			}
26			dst := wayland
27			if done.ID&ports.CaptureIDInternal != 0 {
28				if internal == nil {
29					log.Debug().Uint64("id", done.ID).Msg("internal capture reply dropped: no consumer")
30					continue
31				}
32				dst = internal
33			}
34			select {
35			case dst <- done:
36			case <-ctx.Done():
37				return
38			}
39		}
40	}
41}