client_preview.go RawHistoryFolder

1package brokeripc
2
3import (
4	"sync"
5
6	"github.com/bnema/vev/internal/adapters/brokerwire"
7	"github.com/bnema/vev/internal/ports"
8	"github.com/bnema/vev/internal/protocol"
9)
10
11type clientPreviewSubscription struct {
12	client  *client
13	request ports.BrokerPreviewRequest
14	mu      sync.Mutex
15	latest  ports.BrokerPreviewPublication
16	changed chan struct{}
17	once    sync.Once
18}
19
20func newClientPreviewSubscription(c *client, request ports.BrokerPreviewRequest) *clientPreviewSubscription {
21	return &clientPreviewSubscription{client: c, request: request, changed: make(chan struct{}, 1), latest: ports.BrokerPreviewPublication{
22		Epoch: request.Epoch, Connection: request.Connection, Generation: request.Generation, Target: request.Preview.Target,
23		Width: request.Preview.Width, Height: request.Preview.Height, Err: ports.BrokerError{Code: ports.BrokerErrorUnavailable, Text: "preview pending"},
24	}}
25}
26func (s *clientPreviewSubscription) Changed() <-chan struct{} { return s.changed }
27func (s *clientPreviewSubscription) Latest() ports.BrokerPreviewPublication {
28	s.mu.Lock()
29	defer s.mu.Unlock()
30	return s.latest
31}
32func (s *clientPreviewSubscription) publish(p ports.BrokerPreviewPublication) {
33	s.mu.Lock()
34	s.latest = p
35	s.mu.Unlock()
36	select {
37	case s.changed <- struct{}{}:
38	default:
39	}
40}
41func (s *clientPreviewSubscription) Close() {
42	s.once.Do(func() {
43		s.client.mu.Lock()
44		active := s.client.preview == s
45		if active {
46			s.client.preview = nil
47		}
48		s.client.mu.Unlock()
49		if active {
50			_ = s.client.sendAsync(brokerwire.CancelPreview{Epoch: s.request.Epoch, Connection: s.request.Connection, Generation: s.request.Generation})
51		}
52	})
53}
54
55var _ ports.BrokerPreviewSubscription = (*clientPreviewSubscription)(nil)
56var _ = protocol.RemotePreview{}