1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
|
// Cyphesis Online RPG Server and AI Engine
// Copyright (C) 2008 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
#include "Router.h"
#include "compose.hpp"
#include "log.h"
#include <Atlas/Objects/Anonymous.h>
#include <Atlas/Objects/Operation.h>
#include <Atlas/Objects/SmartPtr.h>
Router::Router(const std::string & id, long intId) : m_id(id),
m_intId(intId)
{
}
Router::~Router()
{
}
void Router::buildError(const Operation & op,
const std::string & errstring,
const Operation & e,
const std::string & to) const
{
std::vector<Atlas::Objects::Root> & args = e->modifyArgs();
Atlas::Objects::Entity::Anonymous arg1;
arg1->setAttr("message", errstring);
args.push_back(arg1);
args.push_back(op);
if (!to.empty()) {
if (!op->isDefaultSerialno()) {
e->setRefno(op->getSerialno());
}
e->setTo(to);
}
}
/// \brief Report an Error.
///
/// The error reported is noted in the log, and an error operation is
/// genereated.
/// @param op The operation that caused the error.
/// @param errstring A message describing the error.
/// @param res The resulting error operation is returned here.
/// @param to The error operation should be directed to this ID.
void Router::error(const Operation & op,
const std::string & errstring,
OpVector & res,
const std::string & to) const
{
Atlas::Objects::Operation::Error e;
log(NOTICE, String::compose("ERROR generated by %1 with message [%2]",
getId(), errstring));
buildError(op, errstring, e, to);
res.push_back(e);
}
/// \brief Report an Error to a client.
///
/// The error reported generates an error operation.
/// This is used instead of error() when an event occurs which is of no
/// interest to the server admin, or world builder, and should only be
/// be reported to the client. It stops the logs from getting filled
/// with reports of authentication failures, and other similar occurences.
/// @param op The operation that caused the error.
/// @param errstring A message describing the error.
/// @param res The resulting error operation is returned here.
/// @param to The error operation should be directed to this ID.
void Router::clientError(const Operation & op,
const std::string & errstring,
OpVector & res,
const std::string & to) const
{
Atlas::Objects::Operation::Error e;
buildError(op, errstring, e, to);
res.push_back(e);
}
/// \brief Process an operation from an external source
///
/// The ownership of the operation passed in at this point is handed
/// over to the router. The calling code must not modify the operation
/// after passing it to here, or expect the attributes
/// of the operaration to remain the same.
/// @param op The operation to be processed.
void Router::externalOperation(const Operation & op, Link &)
{
}
/// \brief Dispatch an operation that is to this object
void Router::operation(const Operation & op, OpVector & res)
{
}
/// \brief Copy the attribute values of this object to an Atlas Message
void Router::addToMessage(Atlas::Message::MapType & omap) const
{
omap["objtype"] = "obj";
omap["id"] = getId();
}
/// \brief Copy the attribute values of this object to an Atlas Entity
void Router::addToEntity(const Atlas::Objects::Entity::RootEntity & ent) const
{
ent->setObjtype("obj");
ent->setId(getId());
}
|
