93 lines
2.7 KiB
Go
93 lines
2.7 KiB
Go
package shard
|
|
|
|
import (
|
|
"fmt"
|
|
"log"
|
|
|
|
"github.com/CPunch/gopenfusion/cnet"
|
|
"github.com/CPunch/gopenfusion/cnet/protocol"
|
|
"github.com/CPunch/gopenfusion/internal/redis"
|
|
"github.com/CPunch/gopenfusion/shard/entity"
|
|
)
|
|
|
|
func (server *ShardServer) attachPlayer(peer *cnet.Peer, meta redis.LoginMetadata) (*entity.Player, error) {
|
|
dbPlr, err := server.dbHndlr.GetPlayer(int(meta.PlayerID))
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
plr := entity.NewPlayer(peer, dbPlr)
|
|
|
|
// once we create the player, it's memory address is owned by the
|
|
// server.Start() goroutine. the only functions allowed to access
|
|
// it are the packet handlers as no other goroutines will be
|
|
// concurrently accessing it.
|
|
peer.SetUserData(plr)
|
|
return plr, nil
|
|
}
|
|
|
|
func (server *ShardServer) RequestEnter(peer *cnet.Peer, pkt protocol.Packet) error {
|
|
var enter protocol.SP_CL2FE_REQ_PC_ENTER
|
|
pkt.Decode(&enter)
|
|
|
|
// resending a shard enter packet?
|
|
_plr, ok := peer.UserData().(*entity.Player)
|
|
if ok && _plr != nil {
|
|
return fmt.Errorf("resent enter packet")
|
|
}
|
|
|
|
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
|
|
}
|
|
|
|
plr, err := server.attachPlayer(peer, loginData)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
resp := &protocol.SP_FE2CL_REP_PC_ENTER_SUCC{
|
|
IID: int32(plr.PlayerID),
|
|
PCLoadData2CL: plr.ToPCLoadData2CL(),
|
|
UiSvrTime: protocol.GetTime(),
|
|
}
|
|
|
|
// setup peer
|
|
peer.E_key = protocol.CreateNewKey(resp.UiSvrTime, uint64(resp.IID+1), uint64(resp.PCLoadData2CL.IFusionMatter+1))
|
|
peer.FE_key = loginData.FEKey
|
|
peer.SetActiveKey(cnet.USE_FE)
|
|
|
|
log.Printf("Player %d (AccountID %d) entered\n", resp.IID, loginData.AccountID)
|
|
if err := peer.Send(protocol.P_FE2CL_REP_PC_ENTER_SUCC, resp); err != nil {
|
|
return err
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
func (server *ShardServer) LoadingComplete(peer *cnet.Peer, pkt protocol.Packet) error {
|
|
var loadComplete protocol.SP_CL2FE_REQ_PC_LOADING_COMPLETE
|
|
pkt.Decode(&loadComplete)
|
|
|
|
// was the peer attached to a player?
|
|
plr, ok := peer.UserData().(*entity.Player)
|
|
if !ok || plr == nil {
|
|
return fmt.Errorf("loadingComplete: plr is nil")
|
|
}
|
|
|
|
err := peer.Send(protocol.P_FE2CL_REP_PC_LOADING_COMPLETE_SUCC, protocol.SP_FE2CL_REP_PC_LOADING_COMPLETE_SUCC{IPC_ID: int32(plr.PlayerID)})
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
// we send the chunk updates (PC_NEW, NPC_NEW, etc.) after the enter packet
|
|
chunkPos := entity.MakeChunkPosition(plr.X, plr.Y)
|
|
viewableChunks := server.getViewableChunks(chunkPos)
|
|
|
|
plr.SetChunkPos(chunkPos)
|
|
server.getChunk(chunkPos).AddEntity(plr)
|
|
server.addEntityToChunks(plr, viewableChunks)
|
|
return nil
|
|
}
|