Mirror/Erupe
1
0
Fork 0
mirror of https://github.com/Mezeporta/Erupe.git synced 2026-03-27 01:53:19 +01:00
Code Issues Packages Projects Releases Wiki Activity

improve server logging

Browse Source
This commit is contained in:
wishu
2022-07-19 01:21:02 +10:00
parent d3ef857209
commit 8817511b3c
2 changed files with 46 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
Erupe/server/channelserver/handlers_object.go
View File

@@ -55,7 +55,7 @@ func handleMsgSysDeleteObject(s *Session, p mhfpacket.MHFPacket) {}
func handleMsgSysPositionObject(s *Session, p mhfpacket.MHFPacket) { func handleMsgSysPositionObject(s *Session, p mhfpacket.MHFPacket) {
pkt := p.(*mhfpacket.MsgSysPositionObject) pkt := p.(*mhfpacket.MsgSysPositionObject)
if s.server.erupeConfig.DevMode && s.server.erupeConfig.DevModeOptions.OpcodeMessages { if s.server.erupeConfig.DevMode && s.server.erupeConfig.DevModeOptions.LogInboundMessages {
fmt.Printf("[%s] with objectID [%d] move to (%f,%f,%f)\n\n", s.Name, pkt.ObjID, pkt.X, pkt.Y, pkt.Z) fmt.Printf("[%s] with objectID [%d] move to (%f,%f,%f)\n\n", s.Name, pkt.ObjID, pkt.X, pkt.Y, pkt.Z)
} }
s.stage.Lock() s.stage.Lock()

66
Erupe/server/channelserver/sys_session.go
View File

@@ -84,13 +84,8 @@ func (s *Session) Start() {
// QueueSend queues a packet (raw []byte) to be sent. // QueueSend queues a packet (raw []byte) to be sent.
func (s *Session) QueueSend(data []byte) { func (s *Session) QueueSend(data []byte) {
if s.server.erupeConfig.DevMode && s.server.erupeConfig.DevModeOptions.LogOutboundMessages { bf := byteframe.NewByteFrameFromBytes(data[:2])
fmt.Printf("Server send to [%s]\n", s.Name) s.logMessage(bf.ReadUint16(), data, "Server", s.Name)
bf := byteframe.NewByteFrameFromBytes(data[:2])
opcode := network.PacketID(bf.ReadUint16())
fmt.Printf("Opcode: %s\n", opcode)
fmt.Printf("Data [%d bytes]:\n%s\n", len(data), hex.Dump(data))
}
s.sendPackets <- data s.sendPackets <- data
} }
@@ -168,7 +163,8 @@ func (s *Session) recvLoop() {
func (s *Session) handlePacketGroup(pktGroup []byte) { func (s *Session) handlePacketGroup(pktGroup []byte) {
bf := byteframe.NewByteFrameFromBytes(pktGroup) bf := byteframe.NewByteFrameFromBytes(pktGroup)
opcode := network.PacketID(bf.ReadUint16()) opcodeUint16 := bf.ReadUint16()
opcode := network.PacketID(opcodeUint16)
// This shouldn't be needed, but it's better to recover and let the connection die than to panic the server. // This shouldn't be needed, but it's better to recover and let the connection die than to panic the server.
defer func() { defer func() {
@@ -178,19 +174,8 @@ func (s *Session) handlePacketGroup(pktGroup []byte) {
} }
}() }()
// Print any (non-common spam) packet opcodes and data. s.logMessage(opcodeUint16, pktGroup, s.Name, "Server")
if s.server.erupeConfig.DevMode && s.server.erupeConfig.DevModeOptions.OpcodeMessages {
if opcode != network.MSG_SYS_END &&
opcode != network.MSG_SYS_PING &&
opcode != network.MSG_SYS_NOP &&
opcode != network.MSG_SYS_TIME &&
opcode != network.MSG_SYS_POSITION_OBJECT &&
opcode != network.MSG_SYS_EXTEND_THRESHOLD {
fmt.Printf("[%s] send to Server\n", s.Name)
fmt.Printf("Opcode: %s\n", opcode)
fmt.Printf("Data [%d bytes]:\n%s\n", len(pktGroup), hex.Dump(pktGroup))
}
}
if opcode == network.MSG_SYS_LOGOUT { if opcode == network.MSG_SYS_LOGOUT {
s.rawConn.Close() s.rawConn.Close()
} }
@@ -214,3 +199,42 @@ func (s *Session) handlePacketGroup(pktGroup []byte) {
s.handlePacketGroup(remainingData) s.handlePacketGroup(remainingData)
} }
} }
func ignored(opcode network.PacketID) bool {
ignoreList := []network.PacketID{
network.MSG_SYS_END,
network.MSG_SYS_PING,
network.MSG_SYS_NOP,
network.MSG_SYS_TIME,
network.MSG_SYS_EXTEND_THRESHOLD,
network.MSG_SYS_POSITION_OBJECT,
network.MSG_MHF_ENUMERATE_QUEST,
network.MSG_MHF_SAVEDATA,
}
set := make(map[network.PacketID]struct{}, len(ignoreList))
for _, s := range ignoreList {
set[s] = struct{}{}
}
_, r := set[opcode]
return r
}
func (s *Session) logMessage(opcode uint16, data []byte, sender string, recipient string) {
if !s.server.erupeConfig.DevMode {
return
}
if sender == "Server" && !s.server.erupeConfig.DevModeOptions.LogOutboundMessages {
return
} else if !s.server.erupeConfig.DevModeOptions.LogInboundMessages {
return
}
opcodePID := network.PacketID(opcode)
if ignored(opcodePID) {
return
}
fmt.Printf("[%s] -> [%s]\n", sender, recipient)
fmt.Printf("Opcode: %s\n", opcodePID)
fmt.Printf("Data [%d bytes]:\n%s\n", len(data), hex.Dump(data))
}