summaryrefslogtreecommitdiff
path: root/internal/server/handler.go
diff options
context:
space:
mode:
authorKyren223 <ulmliad223@gmail.com>2024-10-10 01:15:59 +0300
committerKyren223 <ulmliad223@gmail.com>2024-10-10 01:15:59 +0300
commit6b2a93eadd54b1b16028f0e95faabc9cb2184445 (patch)
tree05df411a82f30c5c1c0954a2f475c5fc5dc401a3 /internal/server/handler.go
parent755df330a4785456387ecafea2e305c1a9f4ba0a (diff)
fix: delete removed packets package
Diffstat (limited to 'internal/server/handler.go')
-rw-r--r--internal/server/handler.go40
1 files changed, 0 insertions, 40 deletions
diff --git a/internal/server/handler.go b/internal/server/handler.go
index 4f99260..88309b4 100644
--- a/internal/server/handler.go
+++ b/internal/server/handler.go
@@ -6,7 +6,6 @@ import (
"sync"
"github.com/kyren223/eko/internal/utils/log"
- "github.com/kyren223/eko/internal/utils/packets"
)
func handleConnection(conn net.Conn, wg *sync.WaitGroup) {
@@ -15,24 +14,6 @@ func handleConnection(conn net.Conn, wg *sync.WaitGroup) {
defer conn.Close()
defer wg.Done()
- // packet, err := packets.ReadPacket(conn)
- // if err != nil {
- // log.Info("Received bad packet: %v", err)
- // err = respondWithError(conn, err, 0)
- // if err != nil {
- // log.Error("Failed to respond to bad packet: %v", err)
- // }
- // return
- // }
- //
- // if ok, reason := isPacketOk(packet); !ok {
- // err = respondWithError(conn, fmt.Errorf("unsupported packet: %v", reason), 0)
- // if err != nil {
- // log.Error("Failed to respond to unsupported packet: %v", err)
- // }
- // return
- // }
-
buffer := make([]byte, 1024)
bytesRead, err := conn.Read(buffer)
if err != nil {
@@ -51,24 +32,3 @@ func handleConnection(conn net.Conn, wg *sync.WaitGroup) {
log.Info("Written %v bytes", bytesWritten)
}
-func isPacketOk(packet packets.Packet) (bool, string) {
- if packet.Version() != packets.V1 {
- return false, "versions other than 1 are not supported"
- }
- if packet.HasFlag(packets.FlagError) {
- return false, "error flag should only be used by the server"
- }
- return true, ""
-}
-
-func respondWithError(conn net.Conn, err error, extraFlag byte) error {
- flag := packets.FlagError | extraFlag
- packet := packets.NewPacket(packets.V1, flag, []byte(err.Error()))
- return packet.Write(conn)
-}
-
-func processPacket(packet packets.Packet) (sessId uint16, data []byte, err error) {
- if packet.HasFlag(packets.FlagHandshake) {
- }
- return
-}