mirror of
https://github.com/worldforge/cyphesis
synced 2026-08-13 12:26:04 -04:00
318 lines
10 KiB
C++
318 lines
10 KiB
C++
// This file may be redistributed and modified only under the terms of
|
|
// the GNU General Public License (See COPYING for details).
|
|
// Copyright (C) 2000,2001 Alistair Riddoch
|
|
|
|
#include "Account.h"
|
|
|
|
#include "Connection_methods.h"
|
|
#include "ServerRouting.h"
|
|
#include "Lobby.h"
|
|
#include "ExternalMind.h"
|
|
#include "Persistance.h"
|
|
|
|
#include "rulesets/Character.h"
|
|
|
|
#include "common/const.h"
|
|
#include "common/log.h"
|
|
#include "common/debug.h"
|
|
#include "common/BaseWorld.h"
|
|
|
|
#include <wfmath/atlasconv.h>
|
|
|
|
#include <Atlas/Objects/Operation/Login.h>
|
|
#include <Atlas/Objects/Operation/Logout.h>
|
|
#include <Atlas/Objects/Operation/Sight.h>
|
|
#include <Atlas/Objects/Operation/Create.h>
|
|
#include <Atlas/Objects/Operation/Imaginary.h>
|
|
#include <Atlas/Objects/Operation/Info.h>
|
|
#include <Atlas/Objects/Operation/Look.h>
|
|
#include <Atlas/Objects/Operation/Talk.h>
|
|
#include <Atlas/Objects/Operation/Sound.h>
|
|
|
|
#include <sigc++/bind.h>
|
|
#include <sigc++/object_slot.h>
|
|
|
|
static const bool debug_flag = false;
|
|
|
|
static inline void setRefnoOp(RootOperation * op, const RootOperation & ref_op)
|
|
{
|
|
op->setRefno(ref_op.getSerialno());
|
|
}
|
|
|
|
Account::Account(Connection * conn, const std::string & uname,
|
|
const std::string& passwd, const std::string & id)
|
|
: OOGThing(id), m_connection(conn),
|
|
m_username(uname), m_password(passwd)
|
|
{
|
|
subscribe("logout", OP_LOGOUT);
|
|
subscribe("create", OP_CREATE);
|
|
subscribe("imaginary", OP_IMAGINARY);
|
|
subscribe("talk", OP_TALK);
|
|
subscribe("look", OP_LOOK);
|
|
}
|
|
|
|
Account::~Account()
|
|
{
|
|
ConMap::const_iterator J = m_destroyedConnections.begin();
|
|
for(; J != m_destroyedConnections.end(); J++) {
|
|
J->second->disconnect();
|
|
delete J->second;
|
|
}
|
|
}
|
|
|
|
void Account::characterDestroyed(std::string id)
|
|
{
|
|
m_charactersDict.erase(id);
|
|
ConMap::iterator I = m_destroyedConnections.find(id);
|
|
if (I != m_destroyedConnections.end()) {
|
|
delete I->second;
|
|
m_destroyedConnections.erase(I);
|
|
}
|
|
if (consts::enable_persistence) {
|
|
Persistance::instance()->delCharacter(id);
|
|
}
|
|
}
|
|
|
|
void Account::addCharacter(Entity * chr)
|
|
{
|
|
Character * pchar = dynamic_cast<Character *>(chr);
|
|
if (pchar == 0) {
|
|
return;
|
|
}
|
|
m_charactersDict[chr->getId()] = chr;
|
|
SigC::Connection * con = new SigC::Connection(chr->destroyed.connect(SigC::bind<std::string>(slot(*this, &Account::characterDestroyed), chr->getId())));
|
|
m_destroyedConnections[chr->getId()] = con;
|
|
}
|
|
|
|
Entity * Account::addNewCharacter(const std::string & typestr,
|
|
const Element::MapType & ent)
|
|
{
|
|
BaseWorld & world = m_connection->m_server.m_world;
|
|
debug(std::cout << "Account::Add_character" << std::endl << std::flush;);
|
|
Entity * chr = world.addNewObject(typestr, ent);
|
|
if (chr == 0) {
|
|
return 0;
|
|
}
|
|
debug(std::cout << "Added" << std::endl << std::flush;);
|
|
if (!chr->m_location.isValid()) {
|
|
debug(std::cout << "Setting location" << std::endl << std::flush;);
|
|
chr->m_location.m_loc = &world.m_gameWorld;
|
|
chr->m_location.m_pos = Vector3D(0, 0, 0);
|
|
}
|
|
debug(std::cout << "Location set to: " << chr->m_location << std::endl << std::flush;);
|
|
Character * pchar = dynamic_cast<Character *>(chr);
|
|
if (pchar != 0) {
|
|
pchar->m_externalMind = new ExternalMind(*m_connection, pchar->getId(), pchar->getName());
|
|
// Only genuinely playable characters should go in here. Otherwise
|
|
// if a normal entity gets into the account, and connection, it
|
|
// starts getting hard to tell whether or not they exist.
|
|
m_charactersDict[chr->getId()] = chr;
|
|
SigC::Connection * con = new SigC::Connection(chr->destroyed.connect(SigC::bind<std::string>(slot(*this, &Account::characterDestroyed), chr->getId())));
|
|
m_destroyedConnections[chr->getId()] = con;
|
|
m_connection->addObject(chr);
|
|
if (consts::enable_persistence) {
|
|
Persistance::instance()->addCharacter(*this, *chr);
|
|
}
|
|
}
|
|
|
|
// Hack in default objects
|
|
// This needs to be done in a generic way
|
|
Element::MapType entmap;
|
|
entmap["parents"] = Element::ListType(1,"coin");
|
|
entmap["pos"] = Vector3D(0,0,0).toAtlas();
|
|
entmap["loc"] = chr->getId();
|
|
entmap["name"] = "coin";
|
|
for(int i = 0; i < 10; i++) {
|
|
Create * c = new Create;
|
|
Element::ListType & args = c->getArgs();
|
|
args.push_back(entmap);
|
|
c->setTo(chr->getId());
|
|
world.message(*c, chr);
|
|
}
|
|
|
|
Create c;
|
|
Element::ListType & cargs = c.getArgs();
|
|
cargs.push_back(Element::MapType());
|
|
chr->addToObject(cargs.front().asMap());
|
|
|
|
Sight * s = new Sight;
|
|
Element::ListType & args = s->getArgs();
|
|
args.push_back(c.asObject());
|
|
|
|
world.message(*s, chr);
|
|
|
|
return chr;
|
|
}
|
|
|
|
OpVector Account::LogoutOperation(const Logout & op)
|
|
{
|
|
debug(std::cout << "Account logout: " << getId() << std::endl;);
|
|
Info info;
|
|
Element::ListType & args = info.getArgs();
|
|
args.push_back(op.asObject());
|
|
info.setRefno(op.getSerialno());
|
|
info.setSerialno(m_connection->m_server.getSerialNo());
|
|
info.setFrom(getId());
|
|
info.setTo(getId());
|
|
m_connection->send(info);
|
|
m_connection->close();
|
|
|
|
return OpVector();
|
|
}
|
|
|
|
const char * Account::getType() const
|
|
{
|
|
return "account";
|
|
}
|
|
|
|
void Account::addToObject(Element::MapType & omap) const
|
|
{
|
|
omap["objtype"] = "obj";
|
|
omap["id"] = getId();
|
|
omap["username"] = m_username;
|
|
omap["name"] = m_username;
|
|
if (!m_password.empty()) {
|
|
omap["password"] = m_password;
|
|
}
|
|
omap["parents"] = Element::ListType(1,getType());
|
|
Element::ListType charlist;
|
|
EntityDict::const_iterator I;
|
|
for(I = m_charactersDict.begin(); I != m_charactersDict.end(); I++) {
|
|
charlist.push_back(I->first);
|
|
}
|
|
omap["characters"] = charlist;
|
|
// No need to call BaseEntity::addToObject, as none of the default
|
|
// attributes (location, contains etc.) are relevant to accounts
|
|
}
|
|
|
|
OpVector Account::CreateOperation(const Create & op)
|
|
{
|
|
debug(std::cout << "Account::Operation(create)" << std::endl << std::flush;);
|
|
const Element::ListType & args = op.getArgs();
|
|
if ((args.empty()) || (!args.front().isMap())) {
|
|
return OpVector();
|
|
}
|
|
|
|
const Element::MapType & entmap = args.front().asMap();
|
|
|
|
OpVector er = characterError(op, entmap);
|
|
if (!er.empty()) {
|
|
return er;
|
|
}
|
|
|
|
Element::MapType::const_iterator I = entmap.find("parents");
|
|
if ((I == entmap.end()) || !(I->second.isList()) ||
|
|
(I->second.asList().empty()) ||
|
|
!(I->second.asList().front().isString()) ) {
|
|
return error(op, "Character has no type");
|
|
}
|
|
|
|
const std::string & typestr = I->second.asList().front().asString();
|
|
debug( std::cout << "Account creating a " << typestr << " object"
|
|
<< std::endl << std::flush; );
|
|
|
|
BaseEntity * obj = addNewCharacter(typestr, entmap);
|
|
|
|
if (obj == 0) {
|
|
return error(op, "Character creation failed");
|
|
}
|
|
|
|
Info * info = new Info;
|
|
Element::ListType & info_args = info->getArgs();
|
|
info_args.push_back(Element::MapType());
|
|
obj->addToObject(info_args.front().asMap());
|
|
info->setRefno(op.getSerialno());
|
|
info->setSerialno(m_connection->m_server.getSerialNo());
|
|
|
|
return OpVector(1,info);
|
|
}
|
|
|
|
OpVector Account::ImaginaryOperation(const Imaginary & op)
|
|
{
|
|
const Element::ListType & args = op.getArgs();
|
|
if ((args.empty()) || (!args.front().isMap())) {
|
|
return OpVector();
|
|
}
|
|
|
|
Sight s;
|
|
Element::ListType & sargs = s.getArgs();
|
|
sargs.push_back(op.asObject());
|
|
s.setFrom(getId());
|
|
s.setSerialno(m_connection->m_server.getSerialNo());
|
|
setRefnoOp(&s, op);
|
|
const Element::MapType & arg = args.front().asMap();
|
|
Element::MapType::const_iterator I = arg.find("loc");
|
|
if (I != arg.end()) {
|
|
s.setTo(I->second.asString());
|
|
} else {
|
|
s.setTo(op.getTo());
|
|
}
|
|
return m_connection->m_server.m_lobby.operation(s);
|
|
}
|
|
|
|
OpVector Account::TalkOperation(const Talk & op)
|
|
{
|
|
const Element::ListType & args = op.getArgs();
|
|
if ((args.empty()) || (!args.front().isMap())) {
|
|
return OpVector();
|
|
}
|
|
|
|
Sound s;
|
|
Element::ListType & sargs = s.getArgs();
|
|
sargs.push_back(op.asObject());
|
|
s.setFrom(getId());
|
|
s.setSerialno(m_connection->m_server.getSerialNo());
|
|
setRefnoOp(&s, op);
|
|
const Element::MapType & arg = args.front().asMap();
|
|
Element::MapType::const_iterator I = arg.find("loc");
|
|
if (I != arg.end()) {
|
|
s.setTo(I->second.asString());
|
|
} else {
|
|
s.setTo(op.getTo());
|
|
}
|
|
return m_connection->m_server.m_lobby.operation(s);
|
|
}
|
|
|
|
OpVector Account::LookOperation(const Look & op)
|
|
{
|
|
const Element::ListType & args = op.getArgs();
|
|
if (args.empty()) {
|
|
Sight * s = new Sight;
|
|
s->setTo(getId());
|
|
Element::ListType & s_args = s->getArgs();
|
|
s_args.push_back(Element::MapType());
|
|
m_connection->m_server.m_lobby.addToObject(s_args.front().asMap());
|
|
s->setSerialno(m_connection->m_server.getSerialNo());
|
|
setRefnoOp(s, op);
|
|
return OpVector(1,s);
|
|
}
|
|
Element::MapType::const_iterator I = args.front().asMap().find("id");
|
|
if ((I == args.front().asMap().end()) || (!I->second.isString())) {
|
|
return error(op, "No target for look");
|
|
}
|
|
const std::string & to = I->second.asString();
|
|
EntityDict::const_iterator J = m_charactersDict.find(to);
|
|
if (J != m_charactersDict.end()) {
|
|
Sight * s = new Sight;
|
|
s->setTo(getId());
|
|
Element::ListType & s_args = s->getArgs();
|
|
s_args.push_back(Element::MapType());
|
|
J->second->addToObject(s_args.front().asMap());
|
|
s->setSerialno(m_connection->m_server.getSerialNo());
|
|
setRefnoOp(s, op);
|
|
return OpVector(1,s);
|
|
}
|
|
const AccountDict & accounts = m_connection->m_server.m_lobby.getAccounts();
|
|
AccountDict::const_iterator K = accounts.find(to);
|
|
if (K != accounts.end()) {
|
|
Sight * s = new Sight;
|
|
s->setTo(getId());
|
|
Element::ListType & s_args = s->getArgs();
|
|
s_args.push_back(Element::MapType());
|
|
K->second->addToObject(s_args.front().asMap());
|
|
s->setSerialno(m_connection->m_server.getSerialNo());
|
|
setRefnoOp(s, op);
|
|
return OpVector(1,s);
|
|
}
|
|
return error(op, "Unknown look target");
|
|
}
|