mirror of
https://github.com/CPunch/gopenfusion.git
synced 2024-11-10 02:20:05 +00:00
CPunch
1f66acfd25
started out as me making a service abstraction..
- db.Player exists again, and entity.Player uses it as an embedded struct
- chunk.ForEachEntity() lets you add/remove entities during iteration now
- removed account related fields from CNPeer
- protocol/pool has been merged with protocol.
use protocol.GetBuffer() and protocol.PutBuffer().
- new protocol/internal/service!
service.Service is an abstraction layer to handle multiple CNPeer*
connections and allows you to associate each with an interface{} uData.
In the future it might also handle a task queue for jobs that
modify/interact with the player's uData, called from service.handleEvents()
- PacketHandler callback type has a new param! uData is passed as well now
- much of loginserver/shardserver is now handled by the shared service
abstraction
- SHARD: NPC_ENTER packets are now sent on player loading complete
rather than on enter.
69 lines
2.0 KiB
Go
69 lines
2.0 KiB
Go
package shard
|
|
|
|
import (
|
|
"github.com/CPunch/gopenfusion/config"
|
|
"github.com/CPunch/gopenfusion/internal/db"
|
|
"github.com/CPunch/gopenfusion/internal/entity"
|
|
"github.com/CPunch/gopenfusion/internal/protocol"
|
|
"github.com/CPunch/gopenfusion/internal/redis"
|
|
"github.com/CPunch/gopenfusion/internal/service"
|
|
)
|
|
|
|
type PacketHandler func(peer *protocol.CNPeer, pkt protocol.Packet) error
|
|
|
|
type ShardServer struct {
|
|
service *service.Service
|
|
dbHndlr *db.DBHandler
|
|
redisHndlr *redis.RedisHandler
|
|
chunks map[entity.ChunkPosition]*entity.Chunk
|
|
}
|
|
|
|
func NewShardServer(dbHndlr *db.DBHandler, redisHndlr *redis.RedisHandler, port int) (*ShardServer, error) {
|
|
srvc, err := service.NewService("SHARD", port)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
server := &ShardServer{
|
|
service: srvc,
|
|
dbHndlr: dbHndlr,
|
|
redisHndlr: redisHndlr,
|
|
chunks: make(map[entity.ChunkPosition]*entity.Chunk),
|
|
}
|
|
|
|
srvc.AddPacketHandler(protocol.P_CL2FE_REQ_PC_ENTER, server.RequestEnter)
|
|
srvc.AddPacketHandler(protocol.P_CL2FE_REQ_PC_LOADING_COMPLETE, server.LoadingComplete)
|
|
srvc.AddPacketHandler(protocol.P_CL2FE_REQ_PC_MOVE, server.playerMove)
|
|
srvc.AddPacketHandler(protocol.P_CL2FE_REQ_PC_STOP, server.playerStop)
|
|
srvc.AddPacketHandler(protocol.P_CL2FE_REQ_PC_JUMP, server.playerJump)
|
|
srvc.AddPacketHandler(protocol.P_CL2FE_REQ_SEND_FREECHAT_MESSAGE, server.freeChat)
|
|
srvc.AddPacketHandler(protocol.P_CL2FE_REQ_SEND_MENUCHAT_MESSAGE, server.menuChat)
|
|
srvc.AddPacketHandler(protocol.P_CL2FE_REQ_PC_AVATAR_EMOTES_CHAT, server.emoteChat)
|
|
|
|
srvc.OnConnect = server.onConnect
|
|
srvc.OnDisconnect = server.onDisconnect
|
|
|
|
redisHndlr.RegisterShard(redis.ShardMetadata{
|
|
IP: config.GetAnnounceIP(),
|
|
Port: port,
|
|
})
|
|
|
|
return server, nil
|
|
}
|
|
|
|
func (server *ShardServer) Start() {
|
|
server.LoadNPCs()
|
|
server.service.Start()
|
|
}
|
|
|
|
func (server *ShardServer) onDisconnect(peer *protocol.CNPeer, _plr interface{}) {
|
|
// remove from chunks
|
|
if _plr != nil {
|
|
server.removeEntity(_plr.(*entity.Player))
|
|
}
|
|
}
|
|
|
|
func (server *ShardServer) onConnect(peer *protocol.CNPeer) interface{} {
|
|
return nil
|
|
}
|