feat: dispatch server rank update event

Author: akiver

pkg/demoinfocs/net_messages.go

@@ -5,6 +5,7 @@ import (
 	"encoding/binary"
 	"fmt"
 
+	"github.com/markus-wa/go-unassert"
 	"github.com/markus-wa/ice-cipher-go/pkg/ice"
 	"google.golang.org/protobuf/proto"
 
@@ -108,6 +109,28 @@ func (p *parser) handleServerInfoS2(srvInfo *msgs2.CSVCMsg_ServerInfo) {
 	})
 }
 
+func (p *parser) handleServerRankUpdate(msg *msgs2.CCSUsrMsg_ServerRankUpdate) {
+	for _, v := range msg.RankUpdate {
+		steamID32 := uint32(v.GetAccountId())
+		player, ok := p.gameState.playersBySteamID32[steamID32]
+		if !ok {
+			errMsg := fmt.Sprintf("rank update for unknown player with SteamID32=%d", steamID32)
+
+			p.eventDispatcher.Dispatch(events.ParserWarn{Message: errMsg})
+			unassert.Error(errMsg)
+		}
+
+		p.eventDispatcher.Dispatch(events.RankUpdate{
+			SteamID32:  v.GetAccountId(),
+			RankOld:    int(v.GetRankOld()),
+			RankNew:    int(v.GetRankNew()),
+			WinCount:   int(v.GetNumWins()),
+			RankChange: v.GetRankChange(),
+			Player:     player,
+		})
+	}
+}
+
 func (p *parser) handleEncryptedData(msg *msg.CSVCMsg_EncryptedData) {
 	if msg.GetKeyType() != 2 {
 		return

pkg/demoinfocs/parser.go

@@ -411,6 +411,7 @@ func NewParserWithConfig(demostream io.Reader, config ParserConfig) Parser {
 	p.msgDispatcher.RegisterHandler(p.handleCreateStringTableS2)
 	p.msgDispatcher.RegisterHandler(p.handleUpdateStringTableS2)
 	p.msgDispatcher.RegisterHandler(p.handleSetConVarS2)
+	p.msgDispatcher.RegisterHandler(p.handleServerRankUpdate)
 
 	if config.MsgQueueBufferSize >= 0 {
 		p.initMsgQueue(config.MsgQueueBufferSize)