sashakoshka/hopp
sashakoshka/hopp
1
0
Fork 0
Code Issues 8 Pull Requests Actions Packages Projects Releases Wiki Activity

examples/chat: Re-generate

Browse Source
This commit is contained in:
Sasha Koshka 2025-11-19 19:45:16 -05:00
parent 52b4c44db3
commit d6dc6d6e78
1 changed files with 16 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
examples/chat/protocol.go
View File

@ -103,29 +103,29 @@ func(this *MessageError) Encode(encoder *tape.Encoder) (n int, err error) {
nn, err = encoder.WriteUintN(2, tag_1.CN() + 1) nn, err = encoder.WriteUintN(2, tag_1.CN() + 1)
n += nn; if err != nil { return n, err } n += nn; if err != nil { return n, err }
{ {
nn, err = encoder.WriteUint16(0x0000)
n += nn; if err != nil { return n, err }
tag_2 := tape.LI.WithCN(1)
nn, err = encoder.WriteUint8(uint8(tag_2))
n += nn; if err != nil { return n, err }
nn, err = encoder.WriteUint16(uint16((*this).Code))
n += nn; if err != nil { return n, err }
if value, ok := (*this).Description.Value(); ok { if value, ok := (*this).Description.Value(); ok {
nn, err = encoder.WriteUint16(0x0001) nn, err = encoder.WriteUint16(0x0001)
n += nn; if err != nil { return n, err } n += nn; if err != nil { return n, err }
tag_3 := tape.StringTag(string(value)) tag_2 := tape.StringTag(string(value))
nn, err = encoder.WriteUint8(uint8(tag_3)) nn, err = encoder.WriteUint8(uint8(tag_2))
n += nn; if err != nil { return n, err } n += nn; if err != nil { return n, err }
if len(value) > tape.MaxStructureLength { if len(value) > tape.MaxStructureLength {
return n, tape.ErrTooLong return n, tape.ErrTooLong
} }
if tag_3.Is(tape.LBA) { if tag_2.Is(tape.LBA) {
nn, err = encoder.WriteUintN(uint64(len(value)), tag_3.CN()) nn, err = encoder.WriteUintN(uint64(len(value)), tag_2.CN())
n += nn; if err != nil { return n, err } n += nn; if err != nil { return n, err }
} }
nn, err = encoder.Write([]byte(value)) nn, err = encoder.Write([]byte(value))
n += nn; if err != nil { return n, err } n += nn; if err != nil { return n, err }
} }
nn, err = encoder.WriteUint16(0x0000)
n += nn; if err != nil { return n, err }
tag_3 := tape.LI.WithCN(1)
nn, err = encoder.WriteUint8(uint8(tag_3))
n += nn; if err != nil { return n, err }
nn, err = encoder.WriteUint16(uint16((*this).Code))
n += nn; if err != nil { return n, err }
} }
return n, nil return n, nil
} }
@ -723,6 +723,11 @@ func Receive(trans hopp.Trans) (message ReceivedMessage, n int, err error) {
if err != nil { return nil, n, err } if err != nil { return nil, n, err }
decoder := tape.NewDecoder(reader) decoder := tape.NewDecoder(reader)
switch method { switch method {
case 0x0000:
var message MessageError
nn, err := message.Decode(decoder)
n += nn; if err != nil { return nil, n, err }
return message, n, nil
case 0x0001: case 0x0001:
var message MessageSuccess var message MessageSuccess
nn, err := message.Decode(decoder) nn, err := message.Decode(decoder)
@ -748,11 +753,6 @@ func Receive(trans hopp.Trans) (message ReceivedMessage, n int, err error) {
nn, err := message.Decode(decoder) nn, err := message.Decode(decoder)
n += nn; if err != nil { return nil, n, err } n += nn; if err != nil { return nil, n, err }
return message, n, nil return message, n, nil
case 0x0000:
var message MessageError
nn, err := message.Decode(decoder)
n += nn; if err != nil { return nil, n, err }
return message, n, nil
} }
return nil, n, fmt.Errorf("%w: M%04X", hopp.ErrUnknownMethod, method) return nil, n, fmt.Errorf("%w: M%04X", hopp.ErrUnknownMethod, method)
} }