From 77e4b066cb8d506b4bc944ab4eb2d6e4679e2202 Mon Sep 17 00:00:00 2001
From: Arda Serdar Pektezol <1669855+pektezol@users.noreply.github.com>
Date: Sat, 15 Jun 2024 13:58:30 +0300
Subject: enable multithreading with goroutines (#20)

---
 pkg/packets/packets.go | 89 +++++++++++++-------------------------------------
 1 file changed, 22 insertions(+), 67 deletions(-)

(limited to 'pkg/packets/packets.go')

diff --git a/pkg/packets/packets.go b/pkg/packets/packets.go
index 1bf3f57..6ae8a44 100644
--- a/pkg/packets/packets.go
+++ b/pkg/packets/packets.go
@@ -3,100 +3,55 @@ package packets
 import (
 	"github.com/pektezol/bitreader"
 	"github.com/pektezol/sdp.go/pkg/classes"
-	"github.com/pektezol/sdp.go/pkg/writer"
+	"github.com/pektezol/sdp.go/pkg/types"
 )
 
-type MessageType uint8
-
-const (
-	SignOn MessageType = iota + 1
-	Packet
-	SyncTick
-	ConsoleCmd
-	UserCmd
-	DataTables
-	Stop
-	CustomData
-	StringTables
-)
-
-type Message struct {
-	PacketType MessageType
-	TickNumber int32
-	SlotNumber uint8
-	Data       any
-}
-
-func ParseMessage(reader *bitreader.Reader) Message {
-	message := Message{
-		PacketType: MessageType(reader.TryReadUInt8()),
+func ParseMessage(reader *bitreader.Reader, demo *types.Demo) types.Message {
+	message := types.Message{
+		PacketType: types.MessageType(reader.TryReadUInt8()),
 		TickNumber: reader.TryReadSInt32(),
 		SlotNumber: reader.TryReadUInt8(),
 	}
-	writer.AppendLine("[%d] %s (%d):", message.TickNumber, message.PacketType.String(), message.PacketType)
+	demo.Writer.AppendLine("[%d] %s (%d):", message.TickNumber, message.PacketType.String(), message.PacketType)
 	switch message.PacketType {
-	case SignOn:
+	case types.SignOn:
 		signOn := classes.SignOn{}
-		signOn.ParseSignOn(reader)
+		signOn.ParseSignOn(reader, demo)
 		message.Data = signOn
-	case Packet:
+	case types.Packet:
 		packet := classes.Packet{}
-		packet.ParsePacket(reader)
+		packet.ParsePacket(reader, demo)
 		message.Data = packet
-	case SyncTick:
+	case types.SyncTick:
 		syncTick := classes.SyncTick{}
 		syncTick.ParseSyncTick()
 		message.Data = syncTick
-	case ConsoleCmd:
+	case types.ConsoleCmd:
 		consoleCmd := classes.ConsoleCmd{}
-		consoleCmd.ParseConsoleCmd(reader)
+		consoleCmd.ParseConsoleCmd(reader, demo)
 		message.Data = consoleCmd
-	case UserCmd:
+	case types.UserCmd:
 		userCmd := classes.UserCmd{}
-		userCmd.ParseUserCmd(reader)
+		userCmd.ParseUserCmd(reader, demo)
 		message.Data = userCmd
-	case DataTables:
+	case types.DataTables:
 		dataTables := classes.DataTables{}
-		dataTables.ParseDataTables(reader)
+		dataTables.ParseDataTables(reader, demo)
 		message.Data = dataTables
-	case Stop:
+	case types.Stop:
 		stop := classes.Stop{}
-		stop.ParseStop(reader)
+		stop.ParseStop(reader, demo)
 		message.Data = stop
-	case CustomData: // TODO: not sar data
+	case types.CustomData: // TODO: not sar data
 		customData := classes.CustomData{}
-		customData.ParseCustomData(reader, message.TickNumber, uint8(message.PacketType))
+		customData.ParseCustomData(reader, message.TickNumber, uint8(message.PacketType), demo)
 		message.Data = customData
-	case StringTables: // TODO: parsing string table data
+	case types.StringTables: // TODO: parsing string table data
 		stringTables := classes.StringTables{}
-		stringTables.ParseStringTables(reader)
+		stringTables.ParseStringTables(reader, demo)
 		message.Data = stringTables
 	default:
 		panic("invalid packet type")
 	}
 	return message
 }
-
-func (t MessageType) String() string {
-	switch t {
-	case SignOn:
-		return "SIGNON"
-	case Packet:
-		return "PACKET"
-	case SyncTick:
-		return "SYNCTICK"
-	case ConsoleCmd:
-		return "CONSOLECMD"
-	case UserCmd:
-		return "USERCMD"
-	case DataTables:
-		return "DATATABLES"
-	case Stop:
-		return "STOP"
-	case CustomData:
-		return "CUSTOMDATA"
-	case StringTables:
-		return "STRINGTABLES"
-	}
-	return "INVALID"
-}
-- 
cgit v1.2.3