Merge branch 'develop'
This commit is contained in:
@@ -169,6 +169,7 @@ void ClientApplication::Quit() {
|
|||||||
//-------------------------
|
//-------------------------
|
||||||
|
|
||||||
void ClientApplication::LoadScene(SceneList sceneIndex) {
|
void ClientApplication::LoadScene(SceneList sceneIndex) {
|
||||||
|
//BUG: #16 Resources are being reloaded between scenes
|
||||||
UnloadScene();
|
UnloadScene();
|
||||||
switch(sceneIndex) {
|
switch(sceneIndex) {
|
||||||
//add scene creation calls here
|
//add scene creation calls here
|
||||||
|
|||||||
@@ -96,6 +96,7 @@ protected:
|
|||||||
void UpdateMap();
|
void UpdateMap();
|
||||||
|
|
||||||
//character management
|
//character management
|
||||||
|
void hCharacterUpdate(CharacterPacket* const);
|
||||||
void hCharacterCreate(CharacterPacket* const);
|
void hCharacterCreate(CharacterPacket* const);
|
||||||
void hCharacterDelete(CharacterPacket* const);
|
void hCharacterDelete(CharacterPacket* const);
|
||||||
void hQueryCharacterExists(CharacterPacket* const);
|
void hQueryCharacterExists(CharacterPacket* const);
|
||||||
|
|||||||
@@ -35,6 +35,24 @@
|
|||||||
//DOCS: new characters will result in create messages
|
//DOCS: new characters will result in create messages
|
||||||
//DOCS: this client's character will exist in both (skipped)
|
//DOCS: this client's character will exist in both (skipped)
|
||||||
|
|
||||||
|
void World::hCharacterUpdate(CharacterPacket* const argPacket) {
|
||||||
|
//TODO: (1) Authentication
|
||||||
|
//NOTE: applies to the local character too
|
||||||
|
|
||||||
|
//check that this character exists
|
||||||
|
std::map<int, BaseCharacter>::iterator characterIt = characterMap.find(argPacket->characterIndex);
|
||||||
|
if (characterIt != characterMap.end()) {
|
||||||
|
//update the origin and motion, if there's a difference
|
||||||
|
if (characterIt->second.GetOrigin() != argPacket->origin) {
|
||||||
|
characterIt->second.SetOrigin(argPacket->origin);
|
||||||
|
}
|
||||||
|
if (characterIt->second.GetMotion() != argPacket->motion) {
|
||||||
|
characterIt->second.SetMotion(argPacket->motion);
|
||||||
|
characterIt->second.CorrectSprite(); //only correct the sprite if the motion changes
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
void World::hCharacterCreate(CharacterPacket* const argPacket) {
|
void World::hCharacterCreate(CharacterPacket* const argPacket) {
|
||||||
//prevent double message
|
//prevent double message
|
||||||
if (characterMap.find(argPacket->characterIndex) != characterMap.end()) {
|
if (characterMap.find(argPacket->characterIndex) != characterMap.end()) {
|
||||||
|
|||||||
@@ -173,7 +173,7 @@ void World::Render(SDL_Surface* const screen) {
|
|||||||
|
|
||||||
//draw the entities
|
//draw the entities
|
||||||
for (auto& it : characterMap) {
|
for (auto& it : characterMap) {
|
||||||
//TODO: (1) depth ordering
|
//BUG: #29 Characters (and other entities) are drawn out of order
|
||||||
it.second.DrawTo(screen, camera.x, camera.y);
|
it.second.DrawTo(screen, camera.x, camera.y);
|
||||||
}
|
}
|
||||||
for (auto& it : monsterMap) {
|
for (auto& it : monsterMap) {
|
||||||
@@ -335,6 +335,9 @@ void World::HandlePacket(SerialPacket* const argPacket) {
|
|||||||
break;
|
break;
|
||||||
|
|
||||||
//character management
|
//character management
|
||||||
|
case SerialPacketType::CHARACTER_UPDATE:
|
||||||
|
hCharacterUpdate(static_cast<CharacterPacket*>(argPacket));
|
||||||
|
break;
|
||||||
case SerialPacketType::CHARACTER_CREATE:
|
case SerialPacketType::CHARACTER_CREATE:
|
||||||
hCharacterCreate(static_cast<CharacterPacket*>(argPacket));
|
hCharacterCreate(static_cast<CharacterPacket*>(argPacket));
|
||||||
break;
|
break;
|
||||||
|
|||||||
@@ -20,7 +20,7 @@ release: clean all package
|
|||||||
#For use on my machine ONLY
|
#For use on my machine ONLY
|
||||||
package:
|
package:
|
||||||
rar a -r -ep Tortuga.rar $(OUTDIR)/*.exe $(OUTDIR)/*.dll
|
rar a -r -ep Tortuga.rar $(OUTDIR)/*.exe $(OUTDIR)/*.dll
|
||||||
rar a -r Tortuga.rar rsc/* copyright.txt README.txt
|
rar a -r Tortuga.rar rsc/* copyright.txt instructions.txt
|
||||||
|
|
||||||
$(OUTDIR):
|
$(OUTDIR):
|
||||||
mkdir $(OUTDIR)
|
mkdir $(OUTDIR)
|
||||||
|
|||||||
@@ -4,6 +4,7 @@ mapMaker = require("map_maker")
|
|||||||
mapSaver = require("map_saver")
|
mapSaver = require("map_saver")
|
||||||
roomSystem = require("room_system")
|
roomSystem = require("room_system")
|
||||||
characterSystem = require("character_system")
|
characterSystem = require("character_system")
|
||||||
|
networkSystem = require("network")
|
||||||
|
|
||||||
local function dumpTable(t)
|
local function dumpTable(t)
|
||||||
print(t)
|
print(t)
|
||||||
@@ -18,12 +19,19 @@ roomSystem.RoomManager.SetOnCreate(function(room, index)
|
|||||||
|
|
||||||
--called ~60 times per second
|
--called ~60 times per second
|
||||||
roomSystem.Room.SetOnTick(room, function(room)
|
roomSystem.Room.SetOnTick(room, function(room)
|
||||||
|
--[[
|
||||||
local character = characterSystem.CharacterManager.GetCharacter("handle")
|
local character = characterSystem.CharacterManager.GetCharacter("handle")
|
||||||
if character ~= nil then
|
if character ~= nil then
|
||||||
--debugging
|
--debugging
|
||||||
local x, y = characterSystem.Character.GetOrigin(character)
|
local originX, originY = characterSystem.Character.GetOrigin(character)
|
||||||
print("character.Origin(x, y): ", x, y)
|
local motionX, motionY = characterSystem.Character.GetMotion(character)
|
||||||
|
if motionY < 0 then
|
||||||
|
characterSystem.Character.SetMotion(character, motionX, 0)
|
||||||
|
networkSystem.PumpCharacterUpdate(character)
|
||||||
|
print("Sending: ", motionX, motionY)
|
||||||
|
end
|
||||||
end
|
end
|
||||||
|
--]]
|
||||||
end)
|
end)
|
||||||
end)
|
end)
|
||||||
|
|
||||||
|
|||||||
@@ -56,8 +56,8 @@ static int getOrigin(lua_State* L) {
|
|||||||
|
|
||||||
static int getMotion(lua_State* L) {
|
static int getMotion(lua_State* L) {
|
||||||
Entity* entity = static_cast<Entity*>(lua_touserdata(L, 1));
|
Entity* entity = static_cast<Entity*>(lua_touserdata(L, 1));
|
||||||
lua_pushnumber(L, entity->GetOrigin().x);
|
lua_pushnumber(L, entity->GetMotion().x);
|
||||||
lua_pushnumber(L, entity->GetOrigin().y);
|
lua_pushnumber(L, entity->GetMotion().y);
|
||||||
return 2;
|
return 2;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
+38
-2
@@ -21,8 +21,45 @@
|
|||||||
*/
|
*/
|
||||||
#include "network_api.hpp"
|
#include "network_api.hpp"
|
||||||
|
|
||||||
|
#include "character_data.hpp"
|
||||||
|
#include "character_manager.hpp"
|
||||||
|
#include "server_utilities.hpp"
|
||||||
|
|
||||||
static int pumpCharacterUpdate(lua_State* L) {
|
static int pumpCharacterUpdate(lua_State* L) {
|
||||||
return 0;
|
CharacterData* characterData = static_cast<CharacterData*>(lua_touserdata(L, 1));
|
||||||
|
|
||||||
|
//determine the character's index
|
||||||
|
int index = -1;
|
||||||
|
for (auto const& it : *CharacterManager::GetSingleton().GetContainer()) {
|
||||||
|
if(characterData == &it.second) {
|
||||||
|
index = it.first;
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
//signal an error
|
||||||
|
if (index == -1) {
|
||||||
|
lua_pushboolean(L, false);
|
||||||
|
return 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
//fill the packet with all of this character's data
|
||||||
|
CharacterPacket newPacket;
|
||||||
|
newPacket.type = SerialPacketType::CHARACTER_UPDATE;
|
||||||
|
newPacket.characterIndex = index;
|
||||||
|
strncpy(newPacket.handle, characterData->GetHandle().c_str(), PACKET_STRING_SIZE);
|
||||||
|
strncpy(newPacket.avatar, characterData->GetAvatar().c_str(), PACKET_STRING_SIZE);
|
||||||
|
newPacket.accountIndex = characterData->GetOwner();
|
||||||
|
newPacket.roomIndex = characterData->GetRoomIndex();
|
||||||
|
newPacket.origin = characterData->GetOrigin();
|
||||||
|
newPacket.motion = characterData->GetMotion();
|
||||||
|
|
||||||
|
//pump to the room
|
||||||
|
pumpPacketProximity(&newPacket, characterData->GetRoomIndex());
|
||||||
|
|
||||||
|
//signal success
|
||||||
|
lua_pushboolean(L, true);
|
||||||
|
return 1;
|
||||||
}
|
}
|
||||||
|
|
||||||
static const luaL_Reg networkLib[] = {
|
static const luaL_Reg networkLib[] = {
|
||||||
@@ -33,5 +70,4 @@ static const luaL_Reg networkLib[] = {
|
|||||||
LUAMOD_API int openNetworkAPI(lua_State* L) {
|
LUAMOD_API int openNetworkAPI(lua_State* L) {
|
||||||
luaL_newlib(L, networkLib);
|
luaL_newlib(L, networkLib);
|
||||||
return 1;
|
return 1;
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -38,6 +38,9 @@
|
|||||||
#include "serial_packet.hpp"
|
#include "serial_packet.hpp"
|
||||||
#include "singleton.hpp"
|
#include "singleton.hpp"
|
||||||
|
|
||||||
|
//server utilities
|
||||||
|
#include "server_utilities.hpp"
|
||||||
|
|
||||||
//APIs
|
//APIs
|
||||||
#include "lua.hpp"
|
#include "lua.hpp"
|
||||||
#include "sqlite3.h"
|
#include "sqlite3.h"
|
||||||
@@ -111,13 +114,7 @@ private:
|
|||||||
void hTextWhisper(TextPacket* const);
|
void hTextWhisper(TextPacket* const);
|
||||||
|
|
||||||
//utility methods
|
//utility methods
|
||||||
void PumpPacket(SerialPacket* const);
|
|
||||||
void PumpPacketProximity(SerialPacket* const argPacket, int roomIndex, Vector2 position, int distance);
|
|
||||||
void CopyCharacterToPacket(CharacterPacket* const packet, int characterIndex);
|
|
||||||
void SaveServerState();
|
void SaveServerState();
|
||||||
void FullClientUnload(int index);
|
|
||||||
void FullAccountUnload(int index);
|
|
||||||
void FullCharacterUnload(int index);
|
|
||||||
|
|
||||||
//APIs and utilities
|
//APIs and utilities
|
||||||
sqlite3* database = nullptr;
|
sqlite3* database = nullptr;
|
||||||
|
|||||||
@@ -46,13 +46,14 @@ void ServerApplication::hCharacterCreate(CharacterPacket* const argPacket) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//push to the rooms
|
//push to the rooms
|
||||||
roomMgr.PushCharacter(characterMgr.Get(characterIndex));
|
CharacterData* characterData = characterMgr.Get(characterIndex);
|
||||||
|
roomMgr.PushCharacter(characterData);
|
||||||
|
|
||||||
//pump this character to all clients
|
//pump this character to all clients
|
||||||
CharacterPacket newPacket;
|
CharacterPacket newPacket;
|
||||||
CopyCharacterToPacket(&newPacket, characterIndex);
|
copyCharacterToPacket(&newPacket, characterIndex);
|
||||||
newPacket.type = SerialPacketType::CHARACTER_CREATE;
|
newPacket.type = SerialPacketType::CHARACTER_CREATE;
|
||||||
PumpPacket(&newPacket);
|
pumpPacketProximity(&newPacket, characterData->GetRoomIndex());
|
||||||
}
|
}
|
||||||
|
|
||||||
void ServerApplication::hCharacterDelete(CharacterPacket* const argPacket) {
|
void ServerApplication::hCharacterDelete(CharacterPacket* const argPacket) {
|
||||||
@@ -90,16 +91,17 @@ void ServerApplication::hCharacterDelete(CharacterPacket* const argPacket) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//pop from the rooms
|
//pop from the rooms
|
||||||
roomMgr.PopCharacter(characterMgr.Get(characterIndex));
|
CharacterData* characterData = characterMgr.Get(characterIndex);
|
||||||
|
roomMgr.PopCharacter(characterData);
|
||||||
//delete the character
|
|
||||||
characterMgr.Delete(characterIndex);
|
|
||||||
|
|
||||||
//pump character delete
|
//pump character delete
|
||||||
CharacterPacket newPacket;
|
CharacterPacket newPacket;
|
||||||
newPacket.type = SerialPacketType::CHARACTER_DELETE;
|
newPacket.type = SerialPacketType::CHARACTER_DELETE;
|
||||||
newPacket.characterIndex = characterIndex;
|
newPacket.characterIndex = characterIndex;
|
||||||
PumpPacket(static_cast<SerialPacket*>(&newPacket));
|
pumpPacketProximity(static_cast<SerialPacket*>(&newPacket), characterData->GetRoomIndex());
|
||||||
|
|
||||||
|
//delete the character
|
||||||
|
characterMgr.Delete(characterIndex);
|
||||||
}
|
}
|
||||||
|
|
||||||
void ServerApplication::hCharacterLoad(CharacterPacket* const argPacket) {
|
void ServerApplication::hCharacterLoad(CharacterPacket* const argPacket) {
|
||||||
@@ -126,13 +128,14 @@ void ServerApplication::hCharacterLoad(CharacterPacket* const argPacket) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//push to the rooms
|
//push to the rooms
|
||||||
roomMgr.PushCharacter(characterMgr.Get(characterIndex));
|
CharacterData* characterData = characterMgr.Get(characterIndex);
|
||||||
|
roomMgr.PushCharacter(characterData);
|
||||||
|
|
||||||
//pump this character to all clients
|
//pump this character to all clients
|
||||||
CharacterPacket newPacket;
|
CharacterPacket newPacket;
|
||||||
CopyCharacterToPacket(&newPacket, characterIndex);
|
copyCharacterToPacket(&newPacket, characterIndex);
|
||||||
newPacket.type = SerialPacketType::CHARACTER_CREATE;
|
newPacket.type = SerialPacketType::CHARACTER_CREATE;
|
||||||
PumpPacket(&newPacket);
|
pumpPacketProximity(&newPacket, characterData->GetRoomIndex());
|
||||||
}
|
}
|
||||||
|
|
||||||
void ServerApplication::hCharacterUnload(CharacterPacket* const argPacket) {
|
void ServerApplication::hCharacterUnload(CharacterPacket* const argPacket) {
|
||||||
@@ -161,14 +164,14 @@ void ServerApplication::hCharacterUnload(CharacterPacket* const argPacket) {
|
|||||||
//pop from the rooms
|
//pop from the rooms
|
||||||
roomMgr.PopCharacter(characterData);
|
roomMgr.PopCharacter(characterData);
|
||||||
|
|
||||||
//unload the character
|
|
||||||
characterMgr.Unload(argPacket->characterIndex);
|
|
||||||
|
|
||||||
//pump character delete
|
//pump character delete
|
||||||
CharacterPacket newPacket;
|
CharacterPacket newPacket;
|
||||||
newPacket.type = SerialPacketType::CHARACTER_DELETE;
|
newPacket.type = SerialPacketType::CHARACTER_DELETE;
|
||||||
newPacket.characterIndex = argPacket->characterIndex;
|
newPacket.characterIndex = argPacket->characterIndex;
|
||||||
PumpPacket(static_cast<SerialPacket*>(&newPacket));
|
pumpPacketProximity(static_cast<SerialPacket*>(&newPacket), characterData->GetRoomIndex());
|
||||||
|
|
||||||
|
//unload the character
|
||||||
|
characterMgr.Unload(argPacket->characterIndex);
|
||||||
}
|
}
|
||||||
|
|
||||||
//-------------------------
|
//-------------------------
|
||||||
@@ -180,10 +183,15 @@ void ServerApplication::hCharacterUnload(CharacterPacket* const argPacket) {
|
|||||||
void ServerApplication::hCharacterMovement(CharacterPacket* const argPacket) {
|
void ServerApplication::hCharacterMovement(CharacterPacket* const argPacket) {
|
||||||
//get the specified objects
|
//get the specified objects
|
||||||
AccountData* accountData = accountMgr.Get(argPacket->accountIndex);
|
AccountData* accountData = accountMgr.Get(argPacket->accountIndex);
|
||||||
|
|
||||||
|
if (!accountData) {
|
||||||
|
throw(std::runtime_error("Failed to move a character, missing account"));
|
||||||
|
}
|
||||||
|
|
||||||
CharacterData* characterData = characterMgr.Get(argPacket->characterIndex);
|
CharacterData* characterData = characterMgr.Get(argPacket->characterIndex);
|
||||||
|
|
||||||
if (!accountData || !characterData) {
|
if (!characterData) {
|
||||||
throw(std::runtime_error("Failed to move a character, missing data"));
|
throw(std::runtime_error("Failed to move a character, missing character"));
|
||||||
}
|
}
|
||||||
|
|
||||||
//get this account's client
|
//get this account's client
|
||||||
@@ -206,9 +214,9 @@ void ServerApplication::hCharacterMovement(CharacterPacket* const argPacket) {
|
|||||||
if (characterData->GetRoomIndex() != argPacket->roomIndex) {
|
if (characterData->GetRoomIndex() != argPacket->roomIndex) {
|
||||||
//delete from the old room
|
//delete from the old room
|
||||||
CharacterPacket newPacket;
|
CharacterPacket newPacket;
|
||||||
CopyCharacterToPacket(&newPacket, argPacket->characterIndex);
|
copyCharacterToPacket(&newPacket, argPacket->characterIndex);
|
||||||
newPacket.type = SerialPacketType::CHARACTER_DELETE;
|
newPacket.type = SerialPacketType::CHARACTER_DELETE;
|
||||||
PumpPacketProximity(&newPacket, characterData->GetRoomIndex(), characterData->GetOrigin(), -1);
|
pumpPacketProximity(&newPacket, characterData->GetRoomIndex());
|
||||||
|
|
||||||
//move the character between rooms
|
//move the character between rooms
|
||||||
roomMgr.PopCharacter(characterData);
|
roomMgr.PopCharacter(characterData);
|
||||||
@@ -216,9 +224,9 @@ void ServerApplication::hCharacterMovement(CharacterPacket* const argPacket) {
|
|||||||
roomMgr.PushCharacter(characterData);
|
roomMgr.PushCharacter(characterData);
|
||||||
|
|
||||||
//create in the new room
|
//create in the new room
|
||||||
CopyCharacterToPacket(&newPacket, argPacket->characterIndex);
|
copyCharacterToPacket(&newPacket, argPacket->characterIndex);
|
||||||
newPacket.type = SerialPacketType::CHARACTER_CREATE;
|
newPacket.type = SerialPacketType::CHARACTER_CREATE;
|
||||||
PumpPacketProximity(&newPacket, characterData->GetRoomIndex(), characterData->GetOrigin(), -1);
|
pumpPacketProximity(&newPacket, characterData->GetRoomIndex());
|
||||||
}
|
}
|
||||||
//if not moving between rooms
|
//if not moving between rooms
|
||||||
else {
|
else {
|
||||||
@@ -228,9 +236,9 @@ void ServerApplication::hCharacterMovement(CharacterPacket* const argPacket) {
|
|||||||
|
|
||||||
//update the clients
|
//update the clients
|
||||||
CharacterPacket newPacket;
|
CharacterPacket newPacket;
|
||||||
CopyCharacterToPacket(&newPacket, argPacket->characterIndex);
|
copyCharacterToPacket(&newPacket, argPacket->characterIndex);
|
||||||
newPacket.type = SerialPacketType::CHARACTER_MOVEMENT;
|
newPacket.type = SerialPacketType::CHARACTER_MOVEMENT;
|
||||||
PumpPacketProximity(&newPacket, characterData->GetRoomIndex(), characterData->GetOrigin(), -1);
|
pumpPacketProximity(&newPacket, characterData->GetRoomIndex());
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -138,7 +138,7 @@ void ServerApplication::hLogoutRequest(ClientPacket* const argPacket) {
|
|||||||
network.SendTo(clientData->GetAddress(), static_cast<SerialPacket*>(&newPacket));
|
network.SendTo(clientData->GetAddress(), static_cast<SerialPacket*>(&newPacket));
|
||||||
|
|
||||||
//save and unload this account and it's characters
|
//save and unload this account and it's characters
|
||||||
FullAccountUnload(argPacket->accountIndex);
|
fullAccountUnload(argPacket->accountIndex);
|
||||||
|
|
||||||
//finished this routine
|
//finished this routine
|
||||||
std::cout << "New logout, " << clientMgr.GetLoadedCount() << " clients and " << accountMgr.GetLoadedCount() << " accounts total" << std::endl;
|
std::cout << "New logout, " << clientMgr.GetLoadedCount() << " clients and " << accountMgr.GetLoadedCount() << " accounts total" << std::endl;
|
||||||
@@ -165,7 +165,7 @@ void ServerApplication::hDisconnectRequest(ClientPacket* const argPacket) {
|
|||||||
network.SendTo(clientData->GetAddress(), static_cast<SerialPacket*>(&newPacket));
|
network.SendTo(clientData->GetAddress(), static_cast<SerialPacket*>(&newPacket));
|
||||||
|
|
||||||
//unload the client, it's accounts, and their characters
|
//unload the client, it's accounts, and their characters
|
||||||
FullClientUnload(argPacket->clientIndex);
|
fullClientUnload(argPacket->clientIndex);
|
||||||
|
|
||||||
//finished this routine
|
//finished this routine
|
||||||
std::cout << "New disconnection, " << clientMgr.GetLoadedCount() << " clients and " << accountMgr.GetLoadedCount() << " accounts total" << std::endl;
|
std::cout << "New disconnection, " << clientMgr.GetLoadedCount() << " clients and " << accountMgr.GetLoadedCount() << " accounts total" << std::endl;
|
||||||
|
|||||||
@@ -69,7 +69,7 @@ void ServerApplication::hQueryCharacterExists(CharacterPacket* const argPacket)
|
|||||||
if (argPacket->roomIndex != -1 && it.second.GetRoomIndex() != argPacket->roomIndex) {
|
if (argPacket->roomIndex != -1 && it.second.GetRoomIndex() != argPacket->roomIndex) {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
CopyCharacterToPacket(&newPacket, it.first);
|
copyCharacterToPacket(&newPacket, it.first);
|
||||||
newPacket.type = SerialPacketType::QUERY_CHARACTER_EXISTS;
|
newPacket.type = SerialPacketType::QUERY_CHARACTER_EXISTS;
|
||||||
network.SendTo(argPacket->srcAddress, static_cast<SerialPacket*>(&newPacket));
|
network.SendTo(argPacket->srcAddress, static_cast<SerialPacket*>(&newPacket));
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -188,7 +188,7 @@ void ServerApplication::Proc() {
|
|||||||
//Check client connections
|
//Check client connections
|
||||||
std::list<int> disconnections = clientMgr.CheckConnections();
|
std::list<int> disconnections = clientMgr.CheckConnections();
|
||||||
for(auto const& it : disconnections) {
|
for(auto const& it : disconnections) {
|
||||||
FullClientUnload(it);
|
fullClientUnload(it);
|
||||||
std::cerr << "Client dropped: " << it << std::endl;
|
std::cerr << "Client dropped: " << it << std::endl;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
+1
-116
@@ -78,7 +78,7 @@ void ServerApplication::hAdminShutdownRequest(ClientPacket* const argPacket) {
|
|||||||
TextPacket newPacket;
|
TextPacket newPacket;
|
||||||
newPacket.type = SerialPacketType::ADMIN_DISCONNECT_FORCED;
|
newPacket.type = SerialPacketType::ADMIN_DISCONNECT_FORCED;
|
||||||
strncpy(newPacket.text, "Server shutdown", PACKET_STRING_SIZE);
|
strncpy(newPacket.text, "Server shutdown", PACKET_STRING_SIZE);
|
||||||
PumpPacket(&newPacket);
|
pumpPacket(&newPacket);
|
||||||
|
|
||||||
//finished this routine
|
//finished this routine
|
||||||
std::cout << "Shutdown signal accepted" << std::endl;
|
std::cout << "Shutdown signal accepted" << std::endl;
|
||||||
@@ -87,118 +87,3 @@ void ServerApplication::hAdminShutdownRequest(ClientPacket* const argPacket) {
|
|||||||
void ServerApplication::SaveServerState() {
|
void ServerApplication::SaveServerState() {
|
||||||
//TODO: (9) empty
|
//TODO: (9) empty
|
||||||
}
|
}
|
||||||
|
|
||||||
//-------------------------
|
|
||||||
//full unload methods
|
|
||||||
//-------------------------
|
|
||||||
|
|
||||||
void ServerApplication::FullClientUnload(int index) {
|
|
||||||
clientMgr.UnloadIf([&](std::pair<const int, ClientData const&> client) -> bool {
|
|
||||||
//skip the wrong clients
|
|
||||||
if (client.first != index) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
//unload associated accounts
|
|
||||||
for (std::map<int, AccountData>::iterator it = accountMgr.GetContainer()->begin(); it != accountMgr.GetContainer()->end(); /* EMPTY */) {
|
|
||||||
if (it->second.GetClientIndex() == index) {
|
|
||||||
FullAccountUnload(it->first);
|
|
||||||
it = accountMgr.GetContainer()->begin();
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
++it;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
//unload this client
|
|
||||||
return true;
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
void ServerApplication::FullAccountUnload(int index) {
|
|
||||||
accountMgr.UnloadIf([&](std::pair<const int, AccountData const&> account) -> bool {
|
|
||||||
//skip the wrong accounts
|
|
||||||
if (account.first != index) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
//unload associated characters
|
|
||||||
for (std::map<int, CharacterData>::iterator it = characterMgr.GetContainer()->begin(); it != characterMgr.GetContainer()->end(); /* EMPTY */) {
|
|
||||||
if (it->second.GetOwner() == index) {
|
|
||||||
FullCharacterUnload(it->first);
|
|
||||||
it = characterMgr.GetContainer()->begin();
|
|
||||||
}
|
|
||||||
else {
|
|
||||||
++it;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
//unload this account
|
|
||||||
return true;
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
void ServerApplication::FullCharacterUnload(int index) {
|
|
||||||
characterMgr.UnloadIf([&](std::pair<const int, CharacterData const&> character) -> bool {
|
|
||||||
//skip the wrong characters
|
|
||||||
if (character.first != index) {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
//pop from the rooms
|
|
||||||
roomMgr.PopCharacter(&character.second);
|
|
||||||
|
|
||||||
//pump character unload
|
|
||||||
CharacterPacket newPacket;
|
|
||||||
newPacket.type = SerialPacketType::CHARACTER_DELETE;
|
|
||||||
newPacket.characterIndex = character.first;
|
|
||||||
//NOTE: more character info as needed
|
|
||||||
|
|
||||||
PumpPacket(&newPacket);
|
|
||||||
|
|
||||||
//unload this character
|
|
||||||
return true;
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
//-------------------------
|
|
||||||
//utility methods
|
|
||||||
//-------------------------
|
|
||||||
|
|
||||||
void ServerApplication::PumpPacket(SerialPacket* const argPacket) {
|
|
||||||
for (auto& it : *clientMgr.GetContainer()) {
|
|
||||||
network.SendTo(it.second.GetAddress(), argPacket);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
void ServerApplication::PumpPacketProximity(SerialPacket* const argPacket, int roomIndex, Vector2 position, int distance) {
|
|
||||||
RoomData* room = roomMgr.Get(roomIndex);
|
|
||||||
|
|
||||||
if (!room) {
|
|
||||||
throw(std::runtime_error("Failed to pump to a non-existant room"));
|
|
||||||
}
|
|
||||||
|
|
||||||
for (auto& character : *room->GetCharacterList()) {
|
|
||||||
if (distance == -1 || (character->GetOrigin() - position).Length() <= distance) {
|
|
||||||
AccountData* account = accountMgr.Get(character->GetOwner());
|
|
||||||
ClientData* client = clientMgr.Get(account->GetClientIndex());
|
|
||||||
network.SendTo(client->GetAddress(), argPacket);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
void ServerApplication::CopyCharacterToPacket(CharacterPacket* const packet, int characterIndex) {
|
|
||||||
CharacterData* character = characterMgr.Get(characterIndex);
|
|
||||||
if (!character) {
|
|
||||||
throw(std::runtime_error("Failed to copy a character to a packet"));
|
|
||||||
}
|
|
||||||
|
|
||||||
//NOTE: keep this up to date when the character changes
|
|
||||||
packet->characterIndex = characterIndex;
|
|
||||||
strncpy(packet->handle, character->GetHandle().c_str(), PACKET_STRING_SIZE);
|
|
||||||
strncpy(packet->avatar, character->GetAvatar().c_str(), PACKET_STRING_SIZE);
|
|
||||||
packet->accountIndex = character->GetOwner();
|
|
||||||
packet->roomIndex = character->GetRoomIndex();
|
|
||||||
packet->origin = character->GetOrigin();
|
|
||||||
packet->motion = character->GetMotion();
|
|
||||||
}
|
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
#config
|
#config
|
||||||
INCLUDES+=.
|
INCLUDES+=. ../accounts ../characters ../clients ../entities ../monsters ../rooms ../waypoints ../../common/gameplay ../../common/map ../../common/network ../../common/network/packet_types ../../common/utilities
|
||||||
LIBS+=
|
LIBS+=
|
||||||
CXXFLAGS+=-std=c++11 $(addprefix -I,$(INCLUDES))
|
CXXFLAGS+=-std=c++11 $(addprefix -I,$(INCLUDES))
|
||||||
|
|
||||||
|
|||||||
@@ -0,0 +1,151 @@
|
|||||||
|
/* Copyright: (c) Kayne Ruse 2013-2015
|
||||||
|
*
|
||||||
|
* This software is provided 'as-is', without any express or implied
|
||||||
|
* warranty. In no event will the authors be held liable for any damages
|
||||||
|
* arising from the use of this software.
|
||||||
|
*
|
||||||
|
* Permission is granted to anyone to use this software for any purpose,
|
||||||
|
* including commercial applications, and to alter it and redistribute it
|
||||||
|
* freely, subject to the following restrictions:
|
||||||
|
*
|
||||||
|
* 1. The origin of this software must not be misrepresented; you must not
|
||||||
|
* claim that you wrote the original software. If you use this software
|
||||||
|
* in a product, an acknowledgment in the product documentation would be
|
||||||
|
* appreciated but is not required.
|
||||||
|
*
|
||||||
|
* 2. Altered source versions must be plainly marked as such, and must not be
|
||||||
|
* misrepresented as being the original software.
|
||||||
|
*
|
||||||
|
* 3. This notice may not be removed or altered from any source
|
||||||
|
* distribution.
|
||||||
|
*/
|
||||||
|
#include "server_utilities.hpp"
|
||||||
|
|
||||||
|
#include "account_manager.hpp"
|
||||||
|
#include "character_manager.hpp"
|
||||||
|
#include "client_manager.hpp"
|
||||||
|
#include "room_manager.hpp"
|
||||||
|
#include "udp_network_utility.hpp"
|
||||||
|
|
||||||
|
//-------------------------
|
||||||
|
//manager unload functions
|
||||||
|
//-------------------------
|
||||||
|
|
||||||
|
void fullClientUnload(int index) {
|
||||||
|
ClientManager::GetSingleton().UnloadIf([index](std::pair<const int, ClientData const&> clientPair) -> bool {
|
||||||
|
//skip the wrong clients
|
||||||
|
if (clientPair.first != index) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
AccountManager& accountMgr = AccountManager::GetSingleton();
|
||||||
|
|
||||||
|
//unload associated accounts
|
||||||
|
for (std::map<int, AccountData>::iterator it = accountMgr.GetContainer()->begin(); it != accountMgr.GetContainer()->end(); /* EMPTY */) {
|
||||||
|
if (it->second.GetClientIndex() == index) {
|
||||||
|
fullAccountUnload(it->first);
|
||||||
|
it = accountMgr.GetContainer()->begin();
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
++it;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
//unload this client
|
||||||
|
return true;
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
void fullAccountUnload(int index) {
|
||||||
|
AccountManager::GetSingleton().UnloadIf([index](std::pair<const int, AccountData const&> accountPair) -> bool {
|
||||||
|
//skip the wrong accounts
|
||||||
|
if (accountPair.first != index) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
CharacterManager& characterMgr = CharacterManager::GetSingleton();
|
||||||
|
|
||||||
|
//unload associated characters
|
||||||
|
for (std::map<int, CharacterData>::iterator it = characterMgr.GetContainer()->begin(); it != characterMgr.GetContainer()->end(); /* EMPTY */) {
|
||||||
|
if (it->second.GetOwner() == index) {
|
||||||
|
fullCharacterUnload(it->first);
|
||||||
|
it = characterMgr.GetContainer()->begin();
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
++it;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
//unload this account
|
||||||
|
return true;
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
void fullCharacterUnload(int index) {
|
||||||
|
CharacterManager::GetSingleton().UnloadIf([index](std::pair<const int, CharacterData const&> characterPair) -> bool {
|
||||||
|
//skip the wrong characters
|
||||||
|
if (characterPair.first != index) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
|
||||||
|
//pop from the rooms
|
||||||
|
RoomManager::GetSingleton().PopCharacter(&characterPair.second);
|
||||||
|
|
||||||
|
//pump character unload
|
||||||
|
CharacterPacket newPacket;
|
||||||
|
newPacket.type = SerialPacketType::CHARACTER_DELETE;
|
||||||
|
newPacket.characterIndex = characterPair.first;
|
||||||
|
//NOTE: more character info as needed
|
||||||
|
|
||||||
|
//TODO: proximity?
|
||||||
|
pumpPacketProximity(&newPacket, characterPair.second.GetRoomIndex());
|
||||||
|
|
||||||
|
//unload this character
|
||||||
|
return true;
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
//-------------------------
|
||||||
|
//utility functions
|
||||||
|
//-------------------------
|
||||||
|
|
||||||
|
void pumpPacket(SerialPacket* const argPacket) {
|
||||||
|
for (auto& it : *ClientManager::GetSingleton().GetContainer()) {
|
||||||
|
UDPNetworkUtility::GetSingleton().SendTo(it.second.GetAddress(), argPacket);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
void pumpPacketProximity(SerialPacket* const argPacket, int roomIndex, Vector2 position, int distance) {
|
||||||
|
RoomData* roomData = RoomManager::GetSingleton().Get(roomIndex);
|
||||||
|
|
||||||
|
if (!roomData) {
|
||||||
|
throw(std::runtime_error("Failed to pump to a non-existant room"));
|
||||||
|
}
|
||||||
|
|
||||||
|
AccountData* accountData = nullptr;
|
||||||
|
ClientData* clientData = nullptr;
|
||||||
|
|
||||||
|
for (auto& characterIt : *roomData->GetCharacterList()) {
|
||||||
|
if (distance == -1 || (characterIt->GetOrigin() - position).Length() <= distance) {
|
||||||
|
accountData = AccountManager::GetSingleton().Get(characterIt->GetOwner());
|
||||||
|
clientData = ClientManager::GetSingleton().Get(accountData->GetClientIndex());
|
||||||
|
UDPNetworkUtility::GetSingleton().SendTo(clientData->GetAddress(), argPacket);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
void copyCharacterToPacket(CharacterPacket* const packet, int characterIndex) {
|
||||||
|
CharacterData* characterData = CharacterManager::GetSingleton().Get(characterIndex);
|
||||||
|
if (!characterData) {
|
||||||
|
throw(std::runtime_error("Failed to copy a character to a packet"));
|
||||||
|
}
|
||||||
|
|
||||||
|
//NOTE: keep this up to date when the character changes
|
||||||
|
packet->characterIndex = characterIndex;
|
||||||
|
strncpy(packet->handle, characterData->GetHandle().c_str(), PACKET_STRING_SIZE);
|
||||||
|
strncpy(packet->avatar, characterData->GetAvatar().c_str(), PACKET_STRING_SIZE);
|
||||||
|
packet->accountIndex = characterData->GetOwner();
|
||||||
|
packet->roomIndex = characterData->GetRoomIndex();
|
||||||
|
packet->origin = characterData->GetOrigin();
|
||||||
|
packet->motion = characterData->GetMotion();
|
||||||
|
}
|
||||||
@@ -0,0 +1,35 @@
|
|||||||
|
/* Copyright: (c) Kayne Ruse 2013-2015
|
||||||
|
*
|
||||||
|
* This software is provided 'as-is', without any express or implied
|
||||||
|
* warranty. In no event will the authors be held liable for any damages
|
||||||
|
* arising from the use of this software.
|
||||||
|
*
|
||||||
|
* Permission is granted to anyone to use this software for any purpose,
|
||||||
|
* including commercial applications, and to alter it and redistribute it
|
||||||
|
* freely, subject to the following restrictions:
|
||||||
|
*
|
||||||
|
* 1. The origin of this software must not be misrepresented; you must not
|
||||||
|
* claim that you wrote the original software. If you use this software
|
||||||
|
* in a product, an acknowledgment in the product documentation would be
|
||||||
|
* appreciated but is not required.
|
||||||
|
*
|
||||||
|
* 2. Altered source versions must be plainly marked as such, and must not be
|
||||||
|
* misrepresented as being the original software.
|
||||||
|
*
|
||||||
|
* 3. This notice may not be removed or altered from any source
|
||||||
|
* distribution.
|
||||||
|
*/
|
||||||
|
#ifndef SERVERUTILITIES_HPP_
|
||||||
|
#define SERVERUTILITIES_HPP_
|
||||||
|
|
||||||
|
#include "serial_packet.hpp"
|
||||||
|
#include "vector2.hpp"
|
||||||
|
|
||||||
|
void fullClientUnload(int index);
|
||||||
|
void fullAccountUnload(int index);
|
||||||
|
void fullCharacterUnload(int index);
|
||||||
|
void pumpPacket(SerialPacket* const argPacket);
|
||||||
|
void pumpPacketProximity(SerialPacket* const argPacket, int roomIndex, Vector2 position = {0, 0}, int distance = -1);
|
||||||
|
void copyCharacterToPacket(CharacterPacket* const packet, int characterIndex);
|
||||||
|
|
||||||
|
#endif
|
||||||
Reference in New Issue
Block a user