broker_codec.go RawHistoryFolder

1package sessionwire
2
3import (
4	"io"
5
6	"github.com/bnema/vev/internal/ports"
7	"github.com/bnema/vev/internal/protocol/wire"
8)
9
10// BrokerCodec translates a raw broker envelope stream into the typed session
11// protocol for the broker's own observation and preview operations.
12// Attachment traffic stays opaque and never passes through this codec.
13type BrokerCodec struct{}
14
15var _ ports.SessionCodec = BrokerCodec{}
16
17// Client returns the typed client view of stream, or nil for a nil stream.
18func (BrokerCodec) Client(stream ports.BrokerEnvelopeStream) ports.ClientConnection {
19	if stream == nil {
20		return nil
21	}
22	return NewClientConnection(brokerEnvelopeTransport{stream: stream})
23}
24
25// brokerEnvelopeTransport carries complete envelopes over a broker stream.
26type brokerEnvelopeTransport struct{ stream ports.BrokerEnvelopeStream }
27
28var _ wire.Transport = brokerEnvelopeTransport{}
29
30func (t brokerEnvelopeTransport) Send(e wire.Envelope) error { return t.stream.SendEnvelope(e.Payload) }
31
32func (t brokerEnvelopeTransport) Recv() (wire.Envelope, error) {
33	data, err := t.stream.RecvEnvelope()
34	if err != nil {
35		return wire.Envelope{}, err
36	}
37	if data == nil {
38		return wire.Envelope{}, io.EOF
39	}
40	return wire.Envelope{Payload: data}, nil
41}
42
43func (t brokerEnvelopeTransport) Close() error { return t.stream.Close() }