From 80dc876517019aa1a146ac1acae6e00f9de39aff Mon Sep 17 00:00:00 2001 From: unknown Date: Tue, 27 Jun 2023 00:11:00 -0500 Subject: [PATCH] added shard.addEntity() and shard.removeEntity() --- shard/chunks.go | 16 ++++++++++++++-- shard/shardServer.go | 3 +-- 2 files changed, 15 insertions(+), 4 deletions(-) diff --git a/shard/chunks.go b/shard/chunks.go index f3b1aa6..3d7cb83 100644 --- a/shard/chunks.go +++ b/shard/chunks.go @@ -4,6 +4,18 @@ import ( "github.com/CPunch/gopenfusion/core/entity" ) +func (server *ShardServer) addEntity(e entity.Entity) { + pos := e.GetChunk() + server.addEntityToChunks(server.getViewableChunks(pos), e) + server.getChunk(pos).AddEntity(e) +} + +func (server *ShardServer) removeEntity(e entity.Entity) { + pos := e.GetChunk() + server.removeEntityFromChunks(server.getViewableChunks(pos), e) + server.getChunk(pos).RemoveEntity(e) +} + func (server *ShardServer) getChunk(pos entity.ChunkPosition) *entity.Chunk { chunk, ok := server.chunks[pos] if !ok { @@ -35,7 +47,7 @@ func (server *ShardServer) sendOthersPacket(plr *entity.Player, typeID uint32, p func (server *ShardServer) removeEntityFromChunks(chunks []*entity.Chunk, this entity.Entity) { for _, chunk := range chunks { - for e, _ := range chunk.Entities { + for e := range chunk.Entities { if e == this { continue } @@ -57,7 +69,7 @@ func (server *ShardServer) removeEntityFromChunks(chunks []*entity.Chunk, this e func (server *ShardServer) addEntityToChunks(chunks []*entity.Chunk, this entity.Entity) { for _, chunk := range chunks { - for e, _ := range chunk.Entities { + for e := range chunk.Entities { if e == this { continue } diff --git a/shard/shardServer.go b/shard/shardServer.go index 76c40db..d73d69b 100644 --- a/shard/shardServer.go +++ b/shard/shardServer.go @@ -122,8 +122,7 @@ func (server *ShardServer) disconnect(peer *protocol.CNPeer) { plr, ok := server.peers[peer] if ok { log.Printf("Player %d (AccountID %d) disconnected\n", plr.PlayerID, plr.AccountID) - server.removeEntityFromChunks(server.getViewableChunks(plr.Chunk), plr) - server.getChunk(plr.Chunk).RemoveEntity(plr) + server.removeEntity(plr) } log.Printf("Peer %p disconnected from SHARD\n", peer)