diff options
Diffstat (limited to 'core/network.go')
| -rw-r--r-- | core/network.go | 76 |
1 files changed, 0 insertions, 76 deletions
diff --git a/core/network.go b/core/network.go index 40c4112..50c398f 100644 --- a/core/network.go +++ b/core/network.go @@ -3,9 +3,7 @@ package core import ( "encoding/binary" "fmt" - "io" "net" - "strings" ) func Send(conn net.Conn, dataType DataType, data Marshaler) error { @@ -21,77 +19,3 @@ func Send(conn net.Conn, dataType DataType, data Marshaler) error { return nil } - -func Read(r io.Reader) (any, error) { - dType, err := ReadDataType(r) - if err != nil { - return nil, fmt.Errorf("cannot read data type", err) - } - - switch dType { - case TypeUnknown: - return nil, fmt.Errorf("cannot read data type 0x00 (TypeUnknown)") - case TypeHandshake: - return ReadHandshake(r) - case TypeTest: - return ReadTest(r) - default: - return nil, fmt.Errorf("unsupported type: %v", dType) - } -} - -func ReadDataType(r io.Reader) (DataType, error) { - var data uint8 - if err := read(r, &data); err != nil { - return TypeUnknown, err - } - - dType := DataType(data) - - return dType, nil -} - -func ReadHandshake(r io.Reader) (Handshake, error) { - var d Handshake - err := read(r, &d.Version) - return d, err -} - -func ReadTest(r io.Reader) (Test, error) { - var d Test - err := readString(r, &d.Message) - return d, err -} - -func readString(r io.Reader, ptr *string) error { - var ( - sb strings.Builder - buf byte - ) - - for { - if err := read(r, &buf); err != nil { - return err - } - - if buf == 0x0 { - break - } - - if err := sb.WriteByte(buf); err != nil { - fmt.Errorf("cannot write byte to string buffer: %v", err) - } - } - - *ptr = sb.String() - return nil -} - -func read(r io.Reader, ptr any) error { - err := binary.Read(r, binary.BigEndian, ptr) - if err != nil { - return fmt.Errorf("cannot read: %v", err) - } - - return nil -} |
