From 994071243fc80990cf09e820b671006e9bd31c76 Mon Sep 17 00:00:00 2001 From: Gab <24553253+gabrix73@users.noreply.github.com> Date: Thu, 13 Aug 2026 14:04:30 +0200 Subject: Separate active YAMN code from Katzenpost PoC --- katzenpost/dispatcher/codec.go | 29 +++++++++++++++++++++++++++++ 1 file changed, 29 insertions(+) create mode 100644 katzenpost/dispatcher/codec.go (limited to 'katzenpost/dispatcher/codec.go') diff --git a/katzenpost/dispatcher/codec.go b/katzenpost/dispatcher/codec.go new file mode 100644 index 0000000..3053dde --- /dev/null +++ b/katzenpost/dispatcher/codec.go @@ -0,0 +1,29 @@ +package dispatcher + +import ( + "fmt" + + "github.com/fxamacker/cbor/v2" +) + +func EncodeEnvelope(envelope Envelope) ([]byte, error) { + encoded, err := cbor.Marshal(envelope) + if err != nil { + return nil, fmt.Errorf("encode envelope: %w", err) + } + if len(encoded) > MaxEnvelopeBytes { + return nil, fmt.Errorf("encoded envelope is too large") + } + return encoded, nil +} + +func DecodeEnvelope(encoded []byte) (Envelope, error) { + if len(encoded) == 0 || len(encoded) > MaxEnvelopeBytes { + return Envelope{}, fmt.Errorf("invalid encoded envelope size") + } + var envelope Envelope + if err := cbor.Unmarshal(encoded, &envelope); err != nil { + return Envelope{}, fmt.Errorf("decode envelope: %w", err) + } + return envelope, nil +} -- cgit v1.2.3