// Cyphesis Online RPG Server and AI Engine // Copyright (C) 2000,2001 Alistair Riddoch // // This program is free software; you can redistribute it and/or modify // it under the terms of the GNU General Public License as published by // the Free Software Foundation; either version 2 of the License, or // (at your option) any later version. // // This program is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU General Public License for more details. // // You should have received a copy of the GNU General Public License // along with this program; if not, write to the Free Software Foundation, // Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA // $Id: Lobby.cpp,v 1.38 2006-10-26 00:48:14 alriddoch Exp $ #include "Lobby.h" #include "Connection_methods.h" #include "ServerRouting.h" #include "common/debug.h" #include "common/serialno.h" #include #include #include using Atlas::Message::MapType; using Atlas::Message::ListType; using Atlas::Objects::Operation::Appearance; using Atlas::Objects::Operation::Disappearance; using Atlas::Objects::Entity::Anonymous; static const bool debug_flag = false; Lobby::Lobby(ServerRouting & s, const std::string & id, long intId) : OOGThing(id, intId), m_server(s) { } Lobby::~Lobby() { } void Lobby::addAccount(Account * ac) { debug(std::cout << "Lobby::addAccount(" << ac->getId() << ")" << std::endl << std::flush;); Appearance a; Anonymous us; us->setId(ac->getId()); us->setLoc(getId()); a->setArgs1(us); a->setFrom(ac->getId()); a->setTo(getId()); OpVector res; operation(a, res); assert(res.empty()); m_accounts[ac->getId()] = ac; } void Lobby::delAccount(Account * ac) { debug(std::cout << "Lobby::delAccount(" << ac->getId() << ")" << std::endl << std::flush;); Disappearance d; Anonymous us; us->setId(ac->getId()); us->setLoc(getId()); d->setArgs1(us); d->setFrom(ac->getId()); d->setTo(getId()); OpVector res; operation(d, res); assert(res.empty()); m_accounts.erase(ac->getId()); } void Lobby::operation(const Operation & op, OpVector & res) { debug(std::cout << "Lobby::operation(" << op->getParents().front() << std::endl << std::flush; ); const std::string & to = op->getTo(); if (to.empty() || to == getId()) { Operation newop(op.copy()); AccountDict::const_iterator I = m_accounts.begin(); AccountDict::const_iterator Iend = m_accounts.end(); for (; I != Iend; ++I) { Connection * c = I->second->m_connection; if (c != 0) { newop->setTo(I->first); debug(std::cout << "Lobby sending " << newop->getParents().front() << " operation to " << I->first << std::endl << std::flush; ); c->send(newop); } } } else { AccountDict::const_iterator I = m_accounts.find(to); if (I == m_accounts.end()) { error(op, "Target account not logged in", res); } else { Connection * c = I->second->m_connection; if (c == 0) { error(op, "Target account not logged in", res); } else { c->send(op); } } } } void Lobby::addToMessage(MapType & omap) const { omap["name"] = "lobby"; ListType plist(1, "room"); omap["parents"] = plist; ListType player_list; AccountDict::const_iterator Iend = m_accounts.end(); for (AccountDict::const_iterator I = m_accounts.begin(); I != Iend; ++I) { player_list.push_back(I->first); } omap["people"] = player_list; omap["rooms"] = ListType(); BaseEntity::addToMessage(omap); } void Lobby::addToEntity(const Atlas::Objects::Entity::RootEntity & ent) const { ent->setName("lobby"); ListType plist(1, "room"); ent->setParents(std::list(1,"room")); ListType player_list; AccountDict::const_iterator Iend = m_accounts.end(); for (AccountDict::const_iterator I = m_accounts.begin(); I != Iend; ++I) { player_list.push_back(I->first); } ent->setAttr("people", player_list); ent->setAttr("rooms", ListType()); BaseEntity::addToEntity(ent); }