summaryrefslogtreecommitdiffstats
path: root/core/network.go
diff options
context:
space:
mode:
Diffstat (limited to 'core/network.go')
-rw-r--r--core/network.go76
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
-}