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

basic BeatLevel progress storage

Browse Source
This commit is contained in:
wish
2024-07-31 22:00:44 +10:00
parent 757c98a9a8
commit f70fd5e6e7
3 changed files with 19 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
schemas/patch-schema/conquest-data.sql Normal file
View File

@@ -0,0 +1,5 @@
BEGIN;
ALTER TABLE public.characters ADD COLUMN IF NOT EXISTS conquest_data BYTEA;
END;

3
server/channelserver/handlers.go
View File

@@ -1091,7 +1091,8 @@ func handleMsgMhfUnreserveSrg(s *Session, p mhfpacket.MHFPacket) {
func handleMsgMhfKickExportForce(s *Session, p mhfpacket.MHFPacket) {} func handleMsgMhfKickExportForce(s *Session, p mhfpacket.MHFPacket) {}
func cleanupEarthStatus(s *Session) { func cleanupEarthStatus(s *Session) {
s.server.db.Exec("DELETE FROM events WHERE event_type='earth'") s.server.db.Exec(`DELETE FROM events WHERE event_type='earth'`)
s.server.db.Exec(`UPDATE characters SET conquest_data=NULL`)
} }
func generateEarthStatusTimestamps(s *Session, start uint32, debug bool) []uint32 { func generateEarthStatusTimestamps(s *Session, start uint32, debug bool) []uint32 {

15
server/channelserver/handlers_seibattle.go
View File

@@ -697,12 +697,16 @@ func handleMsgMhfGetFixedSeibatuRankingTable(s *Session, p mhfpacket.MHFPacket)
func handleMsgMhfReadBeatLevel(s *Session, p mhfpacket.MHFPacket) { func handleMsgMhfReadBeatLevel(s *Session, p mhfpacket.MHFPacket) {
pkt := p.(*mhfpacket.MsgMhfReadBeatLevel) pkt := p.(*mhfpacket.MsgMhfReadBeatLevel)
// This response is fixed and will never change on JP, var data []byte
// but I've left it dynamic for possible other client differences. err := s.server.db.QueryRow(`SELECT conquest_data FROM characters WHERE id = $1`, s.charID).Scan(&data)
if err != nil || len(data) == 0 {
data = []byte{0, 0, 0, 1, 0, 0, 0, 1, 0, 0, 0, 1, 0, 0, 0, 1}
}
bf := byteframe.NewByteFrameFromBytes(data)
resp := byteframe.NewByteFrame() resp := byteframe.NewByteFrame()
for i := 0; i < int(pkt.ValidIDCount); i++ { for i := 0; i < int(pkt.ValidIDCount); i++ {
resp.WriteUint32(pkt.IDs[i]) resp.WriteUint32(pkt.IDs[i])
resp.WriteUint32(0) resp.WriteUint32(bf.ReadUint32())
resp.WriteUint32(0) resp.WriteUint32(0)
resp.WriteUint32(0) resp.WriteUint32(0)
} }
@@ -724,6 +728,11 @@ func handleMsgMhfReadLastWeekBeatRanking(s *Session, p mhfpacket.MHFPacket) {
func handleMsgMhfUpdateBeatLevel(s *Session, p mhfpacket.MHFPacket) { func handleMsgMhfUpdateBeatLevel(s *Session, p mhfpacket.MHFPacket) {
pkt := p.(*mhfpacket.MsgMhfUpdateBeatLevel) pkt := p.(*mhfpacket.MsgMhfUpdateBeatLevel)
bf := byteframe.NewByteFrame()
for i := 0; i < 4; i++ {
bf.WriteInt32(pkt.Data2[i])
}
s.server.db.Exec(`UPDATE characters SET conquest_data = $1 WHERE id = $2`, bf.Data(), s.charID)
doAckBufSucceed(s, pkt.AckHandle, []byte{0x00, 0x00, 0x00, 0x00}) doAckBufSucceed(s, pkt.AckHandle, []byte{0x00, 0x00, 0x00, 0x00})
} }