anygatecloud/strom
2
1
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

manage state transitions in print_replay tool

Browse Source
This commit is contained in:
adman
2026-05-10 13:01:40 +02:00
parent 148302c94d
commit 57cef25e27
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cmd/strom/print_replay/main.go
+9 -2
View File
@@ -19,6 +19,8 @@ var (
ProtocolVersion = cmd.Int("protocol", -1, "The protocol version")
)
var state = proto_base.Login
func UnpackPacket(r io.Reader) (packet proto_base.EncodeDecodeAble, err error) {
var timestamp, length uint32
err = binary.Read(r, binary.BigEndian, &timestamp)
@@ -40,7 +42,7 @@ func UnpackPacket(r io.Reader) (packet proto_base.EncodeDecodeAble, err error) {
return
}
i, ok := proto.LookUpTypeByPacketInfo(proto_base.ToClient, proto_base.Login, packetId, int32(*ProtocolVersion))
i, ok := proto.LookUpTypeByPacketInfo(proto_base.ToClient, state, packetId, int32(*ProtocolVersion))
if !ok {
packet = &proto.UnCodablePacket{Err: proto.BadPacketIdErr, Data: b.Bytes(), Direction: proto_base.ToClient}
return
@@ -51,6 +53,12 @@ func UnpackPacket(r io.Reader) (packet proto_base.EncodeDecodeAble, err error) {
packet = &proto.UnCodablePacket{Err: err, Data: b.Bytes(), Direction: proto_base.ToClient}
err = nil
}
switch i.Name {
case "success":
state = proto_base.Configuration
case "finish_configuration":
state = proto_base.Play
}
return
}
@@ -78,6 +86,5 @@ func Run(args []string) (err error) {
return
}
fmt.Printf("Packet: %#v\n", packet)
fmt.Printf("Packet lllll: %v\n", packet)
}
}