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
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
|
/*
* The Mana Server
* Copyright (C) 2006-2010 The Mana World Development Team
*
* This file is part of The Mana Server.
*
* The Mana Server 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
* any later version.
*
* The Mana Server 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 The Mana Server. If not, see <http://www.gnu.org/licenses/>.
*/
#ifndef ACCOUNTCONNECTION_H
#define ACCOUNTCONNECTION_H
#include "net/messageout.h"
#include "net/connection.h"
class Entity;
class MapComposite;
/**
* A connection to the account server.
*/
class AccountConnection : public Connection
{
public:
AccountConnection();
~AccountConnection();
/**
* Initializes a connection to the account server described in the
* configuration file. Registers the maps known by MapManager.
*/
bool start(int gameServerPort);
/**
* Sends data of a given character.
*/
void sendCharacterData(Entity *);
/**
* Prepares the account server for a reconnecting player
*/
void playerReconnectAccount(int id, const std::string &magic_token);
/**
* Requests the value of a character-bound variable from the database.
*/
void requestCharacterVar(Entity *, const std::string &);
/**
* Pushes a new character-bound value to the database.
*/
void updateCharacterVar(Entity *, const std::string &name,
const std::string &value);
/**
* Pushes a new value of a map variable to the account server.
*/
void updateMapVar(MapComposite *, const std::string &name,
const std::string &value);
/**
* Pushes a new value of a world variable to the account server.
*/
void updateWorldVar(const std::string &name,
const std::string &value);
/**
* Sends ban message.
*/
void banCharacter(Entity *, int);
/**
* Gathers statistics and sends them.
*/
void sendStatistics();
/**
* Send letter
*/
void sendPost(Entity *, MessageIn &);
/**
* Get post
*/
void getPost(Entity *);
/**
* Change Account Level
*/
void changeAccountLevel(Entity *, int);
/**
* Sends all changed player data to the account server to minimize
* dataloss due to failure of one server component.
*
* The gameserver holds a buffer with all changes made by a character.
* The changes are added at the time they occur. When the buffer
* reaches one of the following limits, the buffer is sent to the
* account server and applied to the database.
*
* The sync buffer is sent when:
* - forced by any process (param force = true)
* - every 10 seconds
* - buffer reaches size of 1kb (SYNC_BUFFER_SIZE)
* - buffer holds more then 20 messages (SYNC_BUFFER_LIMIT)
*
* @param force Send changes even if buffer hasn't reached its size
* or message limit. (used to send in timed schedules)
*/
void syncChanges(bool force = false);
/**
* Write a modification message about character points to the sync
* buffer.
*
* @param charId ID of the character
* @param charPoints character points left for the character
* @param corrPoints correction points left for the character
*/
void updateCharacterPoints(int charId, int charPoints,
int corrPoints);
/**
* @param charId ID of the character
* @param attribId ID of the modified attribute
* @param attribValue New value of the modified attribute
*/
void updateAttributes(int charId, int attrId, double base,
double mod);
/**
* Write a modification message about character skills to the sync
* buffer.
*
* @param charId ID of the character
* @param skillId ID of the skill
* @param skillValue new skill points
*/
void updateExperience(int charId, int skillId, int skillValue);
/**
* Update the status of a character to online (true) or offline
* (false).
*
* @param charId Id of the character.
* @param online True to flag the character as being online.
*/
void updateOnlineStatus(int charId, bool online);
/**
* Adds floor items info on database.
*
* This is used to make them potentially persistent between two server
* restart.
*/
void createFloorItems(int mapId, int itemId, int amount,
int posX, int posY);
/**
* Remove floor items from the database
*/
void removeFloorItems(int mapId, int itemId, int amount,
int posX, int posY);
/**
* Send transaction to account server
*/
void sendTransaction(int id, int action, const std::string &message);
protected:
/**
* Processes server messages.
*/
virtual void processMessage(MessageIn &);
private:
MessageOut* mSyncBuffer; /**< Message buffer to store sync data. */
int mSyncMessages; /**< Number of messages in the sync buffer. */
};
extern AccountConnection *accountHandler;
#endif // ACCOUNTCONNECTION_H
|
