Mirror/Erupe
1
0
Fork 0
mirror of https://github.com/Mezeporta/Erupe.git synced 2025-12-14 07:55:33 +01:00
Code Issues Packages Projects Releases Wiki Activity

clean up user binary querying

Browse Source
This commit is contained in:
wish
2022-08-11 14:58:58 +10:00
parent 2a65977a44
commit e89c6f50ae
1 changed files with 6 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
server/channelserver/handlers_users.go
View File

@@ -39,25 +39,18 @@ func handleMsgSysGetUserBinary(s *Session, p mhfpacket.MHFPacket) {
s.server.userBinaryPartsLock.RLock() s.server.userBinaryPartsLock.RLock()
defer s.server.userBinaryPartsLock.RUnlock() defer s.server.userBinaryPartsLock.RUnlock()
data, ok := s.server.userBinaryParts[userBinaryPartID{charID: pkt.CharID, index: pkt.BinaryType}] data, ok := s.server.userBinaryParts[userBinaryPartID{charID: pkt.CharID, index: pkt.BinaryType}]
resp := byteframe.NewByteFrame()
// If we can't get the real data, try to get it from the database. // If we can't get the real data, try to get it from the database.
if !ok { if !ok {
var data []byte err := s.server.db.QueryRow(fmt.Sprintf("SELECT type%d FROM user_binaries WHERE id=$1", pkt.BinaryType), pkt.CharID).Scan(&data)
rows, _ := s.server.db.Queryx(fmt.Sprintf("SELECT type%d FROM user_binaries WHERE id=$1", pkt.BinaryType), pkt.CharID) if err != nil {
for rows.Next() { doAckBufFail(s, pkt.AckHandle, make([]byte, 4))
rows.Scan(&data) } else {
resp.WriteBytes(data) doAckBufSucceed(s, pkt.AckHandle, data)
doAckBufSucceed(s, pkt.AckHandle, resp.Data())
return
} }
doAckBufFail(s, pkt.AckHandle, make([]byte, 4))
return
} else { } else {
resp.WriteBytes(data) doAckBufSucceed(s, pkt.AckHandle, data)
} }
doAckBufSucceed(s, pkt.AckHandle, resp.Data())
} }
func handleMsgSysNotifyUserBinary(s *Session, p mhfpacket.MHFPacket) {} func handleMsgSysNotifyUserBinary(s *Session, p mhfpacket.MHFPacket) {}