gopenfusion/shard/join.go

81 lines
2.3 KiB
Go
Raw Normal View History

2023-03-27 22:02:13 +00:00
package shard
import (
"fmt"
"log"
2023-08-23 23:16:24 +00:00
"github.com/CPunch/gopenfusion/internal/entity"
"github.com/CPunch/gopenfusion/internal/protocol"
"github.com/CPunch/gopenfusion/internal/redis"
)
2023-06-25 06:51:21 +00:00
func (server *ShardServer) attachPlayer(peer *protocol.CNPeer, meta redis.LoginMetadata) (*entity.Player, error) {
// resending a shard enter packet?
old, _ := server.getPlayer(peer)
2023-06-25 06:51:21 +00:00
if old != nil {
return nil, fmt.Errorf("resent enter packet")
2023-06-25 06:51:21 +00:00
}
// attach player
plr, err := server.dbHndlr.GetPlayer(int(meta.PlayerID))
if err != nil {
return nil, err
}
2023-06-25 08:33:17 +00:00
plr.Peer = peer
2023-06-25 06:51:21 +00:00
server.setPlayer(peer, plr)
2023-06-25 08:33:17 +00:00
return plr, nil
2023-06-25 06:51:21 +00:00
}
func (server *ShardServer) RequestEnter(peer *protocol.CNPeer, pkt protocol.Packet) error {
var enter protocol.SP_CL2FE_REQ_PC_ENTER
pkt.Decode(&enter)
loginData, err := server.redisHndlr.GetLogin(enter.IEnterSerialKey)
if err != nil {
// the error codes for P_FE2CL_REP_PC_ENTER_FAIL aren't referenced in the client :(
peer.Send(protocol.P_FE2CL_REP_PC_ENTER_FAIL, protocol.SP_FE2CL_REP_PC_ENTER_FAIL{})
return err
}
2023-06-25 06:51:21 +00:00
plr, err := server.attachPlayer(peer, loginData)
if err != nil {
return err
}
2023-06-25 06:51:21 +00:00
resp := &protocol.SP_FE2CL_REP_PC_ENTER_SUCC{
IID: int32(plr.PlayerID),
PCLoadData2CL: plr.ToPCLoadData2CL(),
2023-06-25 23:29:31 +00:00
UiSvrTime: protocol.GetTime(),
2023-06-25 06:51:21 +00:00
}
2023-06-25 03:36:04 +00:00
// setup peer
2023-06-25 06:51:21 +00:00
peer.E_key = protocol.CreateNewKey(resp.UiSvrTime, uint64(resp.IID+1), uint64(resp.PCLoadData2CL.IFusionMatter+1))
peer.FE_key = loginData.FEKey
2023-06-25 03:36:04 +00:00
peer.PlayerID = loginData.PlayerID
peer.AccountID = loginData.AccountID
2023-06-25 06:51:21 +00:00
peer.SetActiveKey(protocol.USE_FE)
2023-06-25 03:36:04 +00:00
2023-06-22 23:12:31 +00:00
log.Printf("Player %d (AccountID %d) entered\n", resp.IID, loginData.AccountID)
2023-06-25 08:33:17 +00:00
if err := peer.Send(protocol.P_FE2CL_REP_PC_ENTER_SUCC, resp); err != nil {
return err
}
// we send the chunk updates (PC_NEW, NPC_NEW, etc.) after the enter packet
server.updatePlayerPosition(plr, int(plr.X), int(plr.Y), int(plr.Z), int(plr.Angle))
return nil
}
func (server *ShardServer) LoadingComplete(peer *protocol.CNPeer, pkt protocol.Packet) error {
var loadComplete protocol.SP_CL2FE_REQ_PC_LOADING_COMPLETE
pkt.Decode(&loadComplete)
2023-06-25 06:51:21 +00:00
plr, err := server.getPlayer(peer)
2023-06-25 03:36:04 +00:00
if err != nil {
return err
}
return peer.Send(protocol.P_FE2CL_REP_PC_LOADING_COMPLETE_SUCC, protocol.SP_FE2CL_REP_PC_LOADING_COMPLETE_SUCC{IPC_ID: int32(plr.PlayerID)})
}