Context Navigation

char.c @ 23

Revision 1, 137.3 kB (checked in by jinshiro, 17 years ago)

Line
1	// Copyright (c) Athena Dev Teams - Licensed under GNU GPL
2	// For more information, see LICENCE in the main folder
3
4	#include "../common/cbasetypes.h"
5	#include "../common/strlib.h"
6	#include "../common/core.h"
7	#include "../common/timer.h"
8	#include "../common/mmo.h"
9	#include "../common/db.h"
10	#include "../common/malloc.h"
11	#include "../common/mapindex.h"
12	#include "../common/showmsg.h"
13	#include "../common/socket.h"
14	#include "../common/version.h"
15	#include "../common/utils.h"
16	#include "inter.h"
17	#include "int_guild.h"
18	#include "int_homun.h"
19	#include "int_party.h"
20	#include "char.h"
21
22	#include <sys/types.h>
23	#include <time.h>
24	#include <signal.h>
25	#include <string.h>
26	#include <stdarg.h>
27	#include <stdio.h>
28	#include <stdlib.h>
29
30	// private declarations
31	#define CHAR_CONF_NAME "conf/char_athena.conf"
32	#define LAN_CONF_NAME "conf/subnet_athena.conf"
33	#define SQL_CONF_NAME "conf/inter_athena.conf"
34
35	char char_db[256] = "char";
36	char scdata_db[256] = "sc_data";
37	char cart_db[256] = "cart_inventory";
38	char inventory_db[256] = "inventory";
39	char charlog_db[256] = "charlog";
40	char storage_db[256] = "storage";
41	char interlog_db[256] = "interlog";
42	char reg_db[256] = "global_reg_value";
43	char skill_db[256] = "skill";
44	char memo_db[256] = "memo";
45	char guild_db[256] = "guild";
46	char guild_alliance_db[256] = "guild_alliance";
47	char guild_castle_db[256] = "guild_castle";
48	char guild_expulsion_db[256] = "guild_expulsion";
49	char guild_member_db[256] = "guild_member";
50	char guild_position_db[256] = "guild_position";
51	char guild_skill_db[256] = "guild_skill";
52	char guild_storage_db[256] = "guild_storage";
53	char party_db[256] = "party";
54	char pet_db[256] = "pet";
55	char mail_db[256] = "mail"; // MAIL SYSTEM
56	char auction_db[256] = "auction"; // Auctions System
57	char friend_db[256] = "friends";
58	char hotkey_db[256] = "hotkey";
59	char quest_db[256] = "quest";
60	char quest_obj_db[256] = "quest_objective";
61
62	//If your code editor is having problems syntax highlighting this file, uncomment this and RECOMMENT IT BEFORE COMPILING
63	//#undef TXT_SQL_CONVERT
64	#ifndef TXT_SQL_CONVERT
65	static DBMap* char_db_; // int char_id -> struct mmo_charstatus*
66
67	char db_path[1024] = "db";
68
69	int db_use_sqldbs;
70
71	char login_db[256] = "login";
72	char login_db_account_id[32] = "account_id";
73	char login_db_level[32] = "level";
74
75	int lowest_gm_level = 1;
76
77	struct mmo_map_server {
78	int fd;
79	uint32 ip;
80	uint16 port;
81	int users;
82	unsigned short map[MAX_MAP_PER_SERVER];
83	} server[MAX_MAP_SERVERS];
84
85	int login_fd=-1, char_fd=-1;
86	char userid[24];
87	char passwd[24];
88	char server_name[20];
89	char wisp_server_name[NAME_LENGTH] = "Server";
90	char login_ip_str[128];
91	uint32 login_ip = 0;
92	uint16 login_port = 6900;
93	char char_ip_str[128];
94	uint32 char_ip = 0;
95	char bind_ip_str[128];
96	uint32 bind_ip = INADDR_ANY;
97	uint16 char_port = 6121;
98	int char_maintenance = 0;
99	bool char_new = true;
100	int char_new_display = 0;
101
102	int name_ignoring_case = 0; // Allow or not identical name for characters but with a different case by [Yor]
103	int char_name_option = 0; // Option to know which letters/symbols are authorised in the name of a character (0: all, 1: only those in char_name_letters, 2: all EXCEPT those in char_name_letters) by [Yor]
104	char unknown_char_name[NAME_LENGTH] = "Unknown"; // Name to use when the requested name cannot be determined
105	#define TRIM_CHARS "\032\t\x0A\x0D " //The following characters are trimmed regardless because they cause confusion and problems on the servers. [Skotlex]
106	char char_name_letters[1024] = ""; // list of letters/symbols used to authorise or not a name of a character. by [Yor]
107	bool char_rename = true;
108
109	int char_per_account = 0; //Maximum charas per account (default unlimited) [Sirius]
110	int char_del_level = 0; //From which level u can delete character [Lupus]
111
112	int log_char = 1; // loggin char or not [devil]
113	int log_inter = 1; // loggin inter or not [devil]
114
115	#ifdef TXT_SQL_CONVERT
116	int save_log = 0; //Have the logs be off by default when converting
117	#else
118	int save_log = 1;
119	#endif
120
121	static int online_check = 1; //If one, it won't let players connect when their account is already registered online and will send the relevant map server a kick user request. [Skotlex]
122
123	// Advanced subnet check [LuzZza]
124	struct s_subnet {
125	uint32 mask;
126	uint32 char_ip;
127	uint32 map_ip;
128	} subnet[16];
129	int subnet_count = 0;
130
131	struct char_session_data {
132	bool auth; // whether the session is authed or not
133	int account_id, login_id1, login_id2, sex;
134	int found_char[MAX_CHARS]; // ids of chars on this account
135	char email[40]; // e-mail (default: a@a.com) by [Yor]
136	time_t expiration_time; // # of seconds 1/1/1970 (timestamp): Validity limit of the account (0 = unlimited)
137	};
138
139	int char_num, char_max;
140	int max_connect_user = 0;
141	int gm_allow_level = 99;
142	int autosave_interval = DEFAULT_AUTOSAVE_INTERVAL;
143	int start_zeny = 0;
144	int start_weapon = 1201;
145	int start_armor = 2301;
146	int guild_exp_rate = 100;
147
148	//Custom limits for the fame lists. [Skotlex]
149	int fame_list_size_chemist = MAX_FAME_LIST;
150	int fame_list_size_smith = MAX_FAME_LIST;
151	int fame_list_size_taekwon = MAX_FAME_LIST;
152
153	// Char-server-side stored fame lists [DracoRPG]
154	struct fame_list smith_fame_list[MAX_FAME_LIST];
155	struct fame_list chemist_fame_list[MAX_FAME_LIST];
156	struct fame_list taekwon_fame_list[MAX_FAME_LIST];
157
158	// check for exit signal
159	// 0 is saving complete
160	// other is char_id
161	unsigned int save_flag = 0;
162
163	// Initial position (it's possible to set it in conf file)
164	struct point start_point = { 0, 53, 111 };
165
166	bool char_gm_read = false;
167	struct gm_account *gm_account = NULL;
168	int GM_num = 0;
169
170	int console = 0;
171
172	//-----------------------------------------------------
173	// Auth database
174	//-----------------------------------------------------
175	#define AUTH_TIMEOUT 30000
176
177	struct auth_node {
178	int account_id;
179	int char_id;
180	uint32 login_id1;
181	uint32 login_id2;
182	uint32 ip;
183	int sex;
184	time_t expiration_time; // # of seconds 1/1/1970 (timestamp): Validity limit of the account (0 = unlimited)
185	};
186
187	static DBMap* auth_db; // int account_id -> struct auth_node*
188
189	//-----------------------------------------------------
190	// Online User Database
191	//-----------------------------------------------------
192
193	struct online_char_data {
194	int account_id;
195	int char_id;
196	int fd;
197	int waiting_disconnect;
198	short server; // -2: unknown server, -1: not connected, 0+: id of server
199	};
200
201	static DBMap* online_char_db; // int account_id -> struct online_char_data*
202	static int chardb_waiting_disconnect(int tid, unsigned int tick, int id, intptr data);
203
204	static void* create_online_char_data(DBKey key, va_list args)
205	{
206	struct online_char_data* character;
207	CREATE(character, struct online_char_data, 1);
208	character->account_id = key.i;
209	character->char_id = -1;
210	character->server = -1;
211	character->fd = -1;
212	character->waiting_disconnect = -1;
213	return character;
214	}
215
216	void set_char_charselect(int account_id)
217	{
218	struct online_char_data* character;
219
220	character = (struct online_char_data*)idb_ensure(online_char_db, account_id, create_online_char_data);
221
222	if( character->server > -1 )
223	server[character->server].users--;
224
225	character->char_id = -1;
226	character->server = -1;
227
228	if(character->waiting_disconnect != -1) {
229	delete_timer(character->waiting_disconnect, chardb_waiting_disconnect);
230	character->waiting_disconnect = -1;
231	}
232
233	if (login_fd > 0 && !session[login_fd]->flag.eof)
234	{
235	WFIFOHEAD(login_fd,6);
236	WFIFOW(login_fd,0) = 0x272c;
237	WFIFOL(login_fd,2) = account_id;
238	WFIFOSET(login_fd,6);
239	}
240
241	}
242
243	void set_char_online(int map_id, int char_id, int account_id)
244	{
245	struct online_char_data* character;
246	struct mmo_charstatus *cp;
247
248	//Update DB
249	if( SQL_ERROR == Sql_Query(sql_handle, "UPDATE `%s` SET `online`='1' WHERE `char_id`='%d'", char_db, char_id) )
250	Sql_ShowDebug(sql_handle);
251
252	//Check to see for online conflicts
253	character = (struct online_char_data*)idb_ensure(online_char_db, account_id, create_online_char_data);
254	if (online_check && character->char_id != -1 && character->server > -1 && character->server != map_id)
255	{
256	ShowNotice("set_char_online: Character %d:%d marked in map server %d, but map server %d claims to have (%d:%d) online!\n",
257	character->account_id, character->char_id, character->server, map_id, account_id, char_id);
258	mapif_disconnectplayer(server[character->server].fd, character->account_id, character->char_id, 2);
259	}
260
261	//Update state data
262	character->char_id = char_id;
263	character->server = map_id;
264
265	if( character->server > -1 )
266	server[character->server].users++;
267
268	//Get rid of disconnect timer
269	if(character->waiting_disconnect != -1) {
270	delete_timer(character->waiting_disconnect, chardb_waiting_disconnect);
271	character->waiting_disconnect = -1;
272	}
273
274	//Set char online in guild cache. If char is in memory, use the guild id on it, otherwise seek it.
275	cp = (struct mmo_charstatus*)idb_get(char_db_,char_id);
276	inter_guild_CharOnline(char_id, cp?cp->guild_id:-1);
277
278	//Notify login server
279	if (login_fd > 0 && !session[login_fd]->flag.eof)
280	{
281	WFIFOHEAD(login_fd,6);
282	WFIFOW(login_fd,0) = 0x272b;
283	WFIFOL(login_fd,2) = account_id;
284	WFIFOSET(login_fd,6);
285	}
286	}
287
288	void set_char_offline(int char_id, int account_id)
289	{
290	struct online_char_data* character;
291
292	if ( char_id == -1 )
293	{
294	if( SQL_ERROR == Sql_Query(sql_handle, "UPDATE `%s` SET `online`='0' WHERE `account_id`='%d'", char_db, account_id) )
295	Sql_ShowDebug(sql_handle);
296	}
297	else
298	{
299	struct mmo_charstatus* cp = (struct mmo_charstatus*)idb_get(char_db_,char_id);
300	inter_guild_CharOffline(char_id, cp?cp->guild_id:-1);
301	if (cp)
302	idb_remove(char_db_,char_id);
303
304	if( SQL_ERROR == Sql_Query(sql_handle, "UPDATE `%s` SET `online`='0' WHERE `char_id`='%d'", char_db, char_id) )
305	Sql_ShowDebug(sql_handle);
306	}
307
308	if ((character = (struct online_char_data*)idb_get(online_char_db, account_id)) != NULL)
309	{ //We don't free yet to avoid aCalloc/aFree spamming during char change. [Skotlex]
310	if( character->server > -1 )
311	server[character->server].users--;
312
313	if(character->waiting_disconnect != -1){
314	delete_timer(character->waiting_disconnect, chardb_waiting_disconnect);
315	character->waiting_disconnect = -1;
316	}
317
318	//If user is NOT at char screen, delete entry [Kevin]
319	if(character->char_id != -1)
320	{
321	idb_remove(online_char_db, account_id);
322	}
323	}
324
325	if (login_fd > 0 && !session[login_fd]->flag.eof && (char_id == -1 \|\| character == NULL \|\| character->char_id != -1))
326	{
327	WFIFOHEAD(login_fd,6);
328	WFIFOW(login_fd,0) = 0x272c;
329	WFIFOL(login_fd,2) = account_id;
330	WFIFOSET(login_fd,6);
331	}
332	}
333
334	static int char_db_setoffline(DBKey key, void* data, va_list ap)
335	{
336	struct online_char_data* character = (struct online_char_data*)data;
337	int server = va_arg(ap, int);
338	if (server == -1) {
339	character->char_id = -1;
340	character->server = -1;
341	if(character->waiting_disconnect != -1){
342	delete_timer(character->waiting_disconnect, chardb_waiting_disconnect);
343	character->waiting_disconnect = -1;
344	}
345	} else if (character->server == server)
346	character->server = -2; //In some map server that we aren't connected to.
347	return 0;
348	}
349
350	static int char_db_kickoffline(DBKey key, void* data, va_list ap)
351	{
352	struct online_char_data* character = (struct online_char_data*)data;
353	int server_id = va_arg(ap, int);
354
355	if (server_id > -1 && character->server != server_id)
356	return 0;
357
358	//Kick out any connected characters, and set them offline as appropiate.
359	if (character->server > -1)
360	mapif_disconnectplayer(server[character->server].fd, character->account_id, character->char_id, 1);
361	else if (character->waiting_disconnect == -1)
362	set_char_offline(character->char_id, character->account_id);
363	else
364	return 0; // fail
365
366	return 1;
367	}
368
369	void set_all_offline(int id)
370	{
371	if (id < 0)
372	ShowNotice("Sending all users offline.\n");
373	else
374	ShowNotice("Sending users of map-server %d offline.\n",id);
375	online_char_db->foreach(online_char_db,char_db_kickoffline,id);
376
377	if (id >= 0 \|\| login_fd <= 0 \|\| session[login_fd]->flag.eof)
378	return;
379	//Tell login-server to also mark all our characters as offline.
380	WFIFOHEAD(login_fd,2);
381	WFIFOW(login_fd,0) = 0x2737;
382	WFIFOSET(login_fd,2);
383	}
384
385	void set_all_offline_sql(void)
386	{
387	//Set all players to 'OFFLINE'
388	if( SQL_ERROR == Sql_Query(sql_handle, "UPDATE `%s` SET `online` = '0'", char_db) )
389	Sql_ShowDebug(sql_handle);
390	if( SQL_ERROR == Sql_Query(sql_handle, "UPDATE `%s` SET `online` = '0'", guild_member_db) )
391	Sql_ShowDebug(sql_handle);
392	if( SQL_ERROR == Sql_Query(sql_handle, "UPDATE `%s` SET `connect_member` = '0'", guild_db) )
393	Sql_ShowDebug(sql_handle);
394	}
395
396	//----------------------------------------------------------------------
397	// Determine if an account (id) is a GM account
398	// and returns its level (or 0 if it isn't a GM account or if not found)
399	//----------------------------------------------------------------------
400	int isGM(int account_id)
401	{
402	int i;
403
404	for(i = 0; i < GM_num; i++)
405	if (gm_account[i].account_id == account_id)
406	return gm_account[i].level;
407	return 0;
408	}
409
410	void read_gm_account(void)
411	{
412	if(!char_gm_read)
413	return;
414
415	if (gm_account != NULL)
416	aFree(gm_account);
417	GM_num = 0;
418
419	if( SQL_ERROR == Sql_Query(lsql_handle, "SELECT `%s`,`%s` FROM `%s` WHERE `%s`>='%d'", login_db_account_id, login_db_level, login_db, login_db_level, lowest_gm_level) )
420	Sql_ShowDebug(lsql_handle);
421
422	if( Sql_NumRows(lsql_handle) > 0 )
423	{
424	char* data;
425
426	CREATE(gm_account, struct gm_account, (size_t)Sql_NumRows(lsql_handle));
427	while( SQL_SUCCESS == Sql_NextRow(lsql_handle) )
428	{
429	// account_id
430	Sql_GetData(lsql_handle, 0, &data, NULL);
431	gm_account[GM_num].account_id = atoi(data);
432	// account_id
433	Sql_GetData(lsql_handle, 1, &data, NULL);
434	gm_account[GM_num].level = atoi(data);
435	++GM_num;
436	}
437	}
438	Sql_FreeResult(lsql_handle);
439
440	mapif_send_gmaccounts();
441	}
442
443	static void* create_charstatus(DBKey key, va_list args)
444	{
445	struct mmo_charstatus *cp;
446	cp = (struct mmo_charstatus *) aCalloc(1,sizeof(struct mmo_charstatus));
447	cp->char_id = key.i;
448	return cp;
449	}
450	#endif //TXT_SQL_CONVERT
451
452	int mmo_char_tosql(int char_id, struct mmo_charstatus* p)
453	{
454	int i = 0;
455	int count = 0;
456	int diff = 0;
457	char save_status[128]; //For displaying save information. [Skotlex]
458	struct mmo_charstatus *cp;
459	StringBuf buf;
460
461	if (char_id!=p->char_id) return 0;
462
463	#ifndef TXT_SQL_CONVERT
464	cp = (struct mmo_charstatus*)idb_ensure(char_db_, char_id, create_charstatus);
465	#else
466	cp = (struct mmo_charstatus*)aCalloc(1, sizeof(struct mmo_charstatus));
467	#endif
468
469	StringBuf_Init(&buf);
470	memset(save_status, 0, sizeof(save_status));
471
472	//map inventory data
473	if( memcmp(p->inventory, cp->inventory, sizeof(p->inventory)) )
474	{
475	memitemdata_to_sql(p->inventory, MAX_INVENTORY, p->char_id, TABLE_INVENTORY);
476	strcat(save_status, " inventory");
477	}
478
479	//map cart data
480	if( memcmp(p->cart, cp->cart, sizeof(p->cart)) )
481	{
482	memitemdata_to_sql(p->cart, MAX_CART, p->char_id, TABLE_CART);
483	strcat(save_status, " cart");
484	}
485
486	#ifdef TXT_SQL_CONVERT
487	{ //Insert the barebones to then update the rest.
488	char esc_name[NAME_LENGTH*2+1];
489
490	Sql_EscapeStringLen(sql_handle, esc_name, p->name, strnlen(p->name, NAME_LENGTH));
491	if( SQL_ERROR == Sql_Query(sql_handle, "REPLACE INTO `%s` (`char_id`, `account_id`, `char_num`, `name`) VALUES ('%d', '%d', '%d', '%s')",
492	char_db, p->char_id, p->account_id, p->slot, esc_name) )
493	{
494	Sql_ShowDebug(sql_handle);
495	}
496
497	strcat(save_status, " creation");
498	}
499	#endif
500
501	if (
502	(p->base_exp != cp->base_exp) \|\| (p->base_level != cp->base_level) \|\|
503	(p->job_level != cp->job_level) \|\| (p->job_exp != cp->job_exp) \|\|
504	(p->zeny != cp->zeny) \|\|
505	(p->last_point.x != cp->last_point.x) \|\| (p->last_point.y != cp->last_point.y) \|\|
506	(p->max_hp != cp->max_hp) \|\| (p->hp != cp->hp) \|\|
507	(p->max_sp != cp->max_sp) \|\| (p->sp != cp->sp) \|\|
508	(p->status_point != cp->status_point) \|\| (p->skill_point != cp->skill_point) \|\|
509	(p->str != cp->str) \|\| (p->agi != cp->agi) \|\| (p->vit != cp->vit) \|\|
510	(p->int_ != cp->int_) \|\| (p->dex != cp->dex) \|\| (p->luk != cp->luk) \|\|
511	(p->option != cp->option) \|\|
512	(p->party_id != cp->party_id) \|\| (p->guild_id != cp->guild_id) \|\|
513	(p->pet_id != cp->pet_id) \|\| (p->weapon != cp->weapon) \|\| (p->hom_id != cp->hom_id) \|\|
514	(p->shield != cp->shield) \|\| (p->head_top != cp->head_top) \|\|
515	(p->head_mid != cp->head_mid) \|\| (p->head_bottom != cp->head_bottom)
516	)
517	{ //Save status
518	if( SQL_ERROR == Sql_Query(sql_handle, "UPDATE `%s` SET `base_level`='%d', `job_level`='%d',"
519	"`base_exp`='%u', `job_exp`='%u', `zeny`='%d',"
520	"`max_hp`='%d',`hp`='%d',`max_sp`='%d',`sp`='%d',`status_point`='%d',`skill_point`='%d',"
521	"`str`='%d',`agi`='%d',`vit`='%d',`int`='%d',`dex`='%d',`luk`='%d',"
522	"`option`='%d',`party_id`='%d',`guild_id`='%d',`pet_id`='%d',`homun_id`='%d',"
523	"`weapon`='%d',`shield`='%d',`head_top`='%d',`head_mid`='%d',`head_bottom`='%d',"
524	"`last_map`='%s',`last_x`='%d',`last_y`='%d',`save_map`='%s',`save_x`='%d',`save_y`='%d'"
525	" WHERE `account_id`='%d' AND `char_id` = '%d'",
526	char_db, p->base_level, p->job_level,
527	p->base_exp, p->job_exp, p->zeny,
528	p->max_hp, p->hp, p->max_sp, p->sp, p->status_point, p->skill_point,
529	p->str, p->agi, p->vit, p->int_, p->dex, p->luk,
530	p->option, p->party_id, p->guild_id, p->pet_id, p->hom_id,
531	p->weapon, p->shield, p->head_top, p->head_mid, p->head_bottom,
532	mapindex_id2name(p->last_point.map), p->last_point.x, p->last_point.y,
533	mapindex_id2name(p->save_point.map), p->save_point.x, p->save_point.y,
534	p->account_id, p->char_id) )
535	{
536	Sql_ShowDebug(sql_handle);
537	}
538	strcat(save_status, " status");
539	}
540
541	//Values that will seldom change (to speed up saving)
542	if (
543	(p->hair != cp->hair) \|\| (p->hair_color != cp->hair_color) \|\| (p->clothes_color != cp->clothes_color) \|\|
544	(p->class_ != cp->class_) \|\|
545	(p->partner_id != cp->partner_id) \|\| (p->father != cp->father) \|\|
546	(p->mother != cp->mother) \|\| (p->child != cp->child) \|\|
547	(p->karma != cp->karma) \|\| (p->manner != cp->manner) \|\|
548	(p->fame != cp->fame)
549	)
550	{
551	if( SQL_ERROR == Sql_Query(sql_handle, "UPDATE `%s` SET `class`='%d',"
552	"`hair`='%d',`hair_color`='%d',`clothes_color`='%d',"
553	"`partner_id`='%d', `father`='%d', `mother`='%d', `child`='%d',"
554	"`karma`='%d',`manner`='%d', `fame`='%d'"
555	" WHERE `account_id`='%d' AND `char_id` = '%d'",
556	char_db, p->class_,
557	p->hair, p->hair_color, p->clothes_color,
558	p->partner_id, p->father, p->mother, p->child,
559	p->karma, p->manner, p->fame,
560	p->account_id, p->char_id) )
561	{
562	Sql_ShowDebug(sql_handle);
563	}
564
565	strcat(save_status, " status2");
566	}
567
568	//memo points
569	if( memcmp(p->memo_point, cp->memo_point, sizeof(p->memo_point)) )
570	{
571	char esc_mapname[NAME_LENGTH*2+1];
572
573	//`memo` (`memo_id`,`char_id`,`map`,`x`,`y`)
574	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `char_id`='%d'", memo_db, p->char_id) )
575	Sql_ShowDebug(sql_handle);
576
577	//insert here.
578	StringBuf_Clear(&buf);
579	StringBuf_Printf(&buf, "INSERT INTO `%s`(`char_id`,`map`,`x`,`y`) VALUES ", memo_db);
580	for( i = 0, count = 0; i < MAX_MEMOPOINTS; ++i )
581	{
582	if( p->memo_point[i].map )
583	{
584	if( count )
585	StringBuf_AppendStr(&buf, ",");
586	Sql_EscapeString(sql_handle, esc_mapname, mapindex_id2name(p->memo_point[i].map));
587	StringBuf_Printf(&buf, "('%d', '%s', '%d', '%d')", char_id, esc_mapname, p->memo_point[i].x, p->memo_point[i].y);
588	++count;
589	}
590	}
591	if( count )
592	{
593	if( SQL_ERROR == Sql_QueryStr(sql_handle, StringBuf_Value(&buf)) )
594	Sql_ShowDebug(sql_handle);
595	}
596
597	strcat(save_status, " memo");
598	}
599
600	//FIXME: is this neccessary? [ultramage]
601	for(i=0;i<MAX_SKILL;i++)
602	if ((p->skill[i].lv != 0) && (p->skill[i].id == 0))
603	p->skill[i].id = i; // Fix skill tree
604
605
606	//skills
607	if( memcmp(p->skill, cp->skill, sizeof(p->skill)) )
608	{
609	//`skill` (`char_id`, `id`, `lv`)
610	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `char_id`='%d'", skill_db, p->char_id) )
611	Sql_ShowDebug(sql_handle);
612
613	StringBuf_Clear(&buf);
614	StringBuf_Printf(&buf, "INSERT INTO `%s`(`char_id`,`id`,`lv`) VALUES ", skill_db);
615	//insert here.
616	for( i = 0, count = 0; i < MAX_SKILL; ++i )
617	{
618	if(p->skill[i].id && p->skill[i].flag!=1)
619	{
620	if( count )
621	StringBuf_AppendStr(&buf, ",");
622	StringBuf_Printf(&buf, "('%d','%d','%d')", char_id, p->skill[i].id, (p->skill[i].flag == 0 ? p->skill[i].lv : p->skill[i].flag - 2));
623	++count;
624	}
625	}
626	if( count )
627	{
628	if( SQL_ERROR == Sql_QueryStr(sql_handle, StringBuf_Value(&buf)) )
629	Sql_ShowDebug(sql_handle);
630	}
631
632	strcat(save_status, " skills");
633	}
634
635	diff = 0;
636	for(i = 0; i < MAX_FRIENDS; i++){
637	if(p->friends[i].char_id != cp->friends[i].char_id \|\|
638	p->friends[i].account_id != cp->friends[i].account_id){
639	diff = 1;
640	break;
641	}
642	}
643
644	if(diff == 1)
645	{ //Save friends
646	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `char_id`='%d'", friend_db, char_id) )
647	Sql_ShowDebug(sql_handle);
648
649	StringBuf_Clear(&buf);
650	StringBuf_Printf(&buf, "INSERT INTO `%s` (`char_id`, `friend_account`, `friend_id`) VALUES ", friend_db);
651	for( i = 0, count = 0; i < MAX_FRIENDS; ++i )
652	{
653	if( p->friends[i].char_id > 0 )
654	{
655	if( count )
656	StringBuf_AppendStr(&buf, ",");
657	StringBuf_Printf(&buf, "('%d','%d','%d')", char_id, p->friends[i].account_id, p->friends[i].char_id);
658	count++;
659	}
660	}
661	if( count )
662	{
663	if( SQL_ERROR == Sql_QueryStr(sql_handle, StringBuf_Value(&buf)) )
664	Sql_ShowDebug(sql_handle);
665	else
666	strcat(save_status, " friends");
667	}
668	else //Friend list cleared.
669	strcat(save_status, " friends");
670	}
671
672	#ifdef HOTKEY_SAVING
673	// hotkeys
674	StringBuf_Clear(&buf);
675	StringBuf_Printf(&buf, "REPLACE INTO `%s` (`char_id`, `hotkey`, `type`, `itemskill_id`, `skill_lvl`) VALUES ", hotkey_db);
676	diff = 0;
677	for(i = 0; i < ARRAYLENGTH(p->hotkeys); i++){
678	if(memcmp(&p->hotkeys[i], &cp->hotkeys[i], sizeof(struct hotkey)))
679	{
680	if( diff )
681	StringBuf_AppendStr(&buf, ",");// not the first hotkey
682	StringBuf_Printf(&buf, "('%d','%u','%u','%u','%u')", char_id, (unsigned int)i, (unsigned int)p->hotkeys[i].type, p->hotkeys[i].id , (unsigned int)p->hotkeys[i].lv);
683	diff = 1;
684	}
685	}
686	if(diff) {
687	if( SQL_ERROR == Sql_QueryStr(sql_handle, StringBuf_Value(&buf)) )
688	Sql_ShowDebug(sql_handle);
689	else
690	strcat(save_status, " hotkeys");
691	}
692	#endif
693	StringBuf_Destroy(&buf);
694	if (save_status[0]!='\0' && save_log)
695	ShowInfo("Saved char %d - %s:%s.\n", char_id, p->name, save_status);
696	#ifndef TXT_SQL_CONVERT
697	memcpy(cp, p, sizeof(struct mmo_charstatus));
698	#else
699	aFree(cp);
700	#endif
701	return 0;
702	}
703
704	/// Saves an array of 'item' entries into the specified table.
705	int memitemdata_to_sql(const struct item items[], int max, int id, int tableswitch)
706	{
707	StringBuf buf;
708	SqlStmt* stmt;
709	int i;
710	int j;
711	const char* tablename;
712	const char* selectoption;
713	struct item item; // temp storage variable
714	bool* flag; // bit array for inventory matching
715	bool found;
716
717	switch (tableswitch) {
718	case TABLE_INVENTORY: tablename = inventory_db; selectoption = "char_id"; break;
719	case TABLE_CART: tablename = cart_db; selectoption = "char_id"; break;
720	case TABLE_STORAGE: tablename = storage_db; selectoption = "account_id"; break;
721	case TABLE_GUILD_STORAGE: tablename = guild_storage_db; selectoption = "guild_id"; break;
722	default:
723	ShowError("Invalid table name!\n");
724	return 1;
725	}
726
727
728	// The following code compares inventory with current database values
729	// and performs modification/deletion/insertion only on relevant rows.
730	// This approach is more complicated than a trivial delete&insert, but
731	// it significantly reduces cpu load on the database server.
732
733	StringBuf_Init(&buf);
734	StringBuf_AppendStr(&buf, "SELECT `id`, `nameid`, `amount`, `equip`, `identify`, `refine`, `attribute`");
735	for( j = 0; j < MAX_SLOTS; ++j )
736	StringBuf_Printf(&buf, ", `card%d`", j);
737	StringBuf_Printf(&buf, " FROM `%s` WHERE `%s`='%d'", tablename, selectoption, id);
738
739	stmt = SqlStmt_Malloc(sql_handle);
740	if( SQL_ERROR == SqlStmt_PrepareStr(stmt, StringBuf_Value(&buf))
741	\|\| SQL_ERROR == SqlStmt_Execute(stmt) )
742	{
743	SqlStmt_ShowDebug(stmt);
744	SqlStmt_Free(stmt);
745	StringBuf_Destroy(&buf);
746	return 1;
747	}
748
749	SqlStmt_BindColumn(stmt, 0, SQLDT_INT, &item.id, 0, NULL, NULL);
750	SqlStmt_BindColumn(stmt, 1, SQLDT_SHORT, &item.nameid, 0, NULL, NULL);
751	SqlStmt_BindColumn(stmt, 2, SQLDT_SHORT, &item.amount, 0, NULL, NULL);
752	SqlStmt_BindColumn(stmt, 3, SQLDT_USHORT, &item.equip, 0, NULL, NULL);
753	SqlStmt_BindColumn(stmt, 4, SQLDT_CHAR, &item.identify, 0, NULL, NULL);
754	SqlStmt_BindColumn(stmt, 5, SQLDT_CHAR, &item.refine, 0, NULL, NULL);
755	SqlStmt_BindColumn(stmt, 6, SQLDT_CHAR, &item.attribute, 0, NULL, NULL);
756	for( j = 0; j < MAX_SLOTS; ++j )
757	SqlStmt_BindColumn(stmt, 7+j, SQLDT_SHORT, &item.card[j], 0, NULL, NULL);
758
759	// bit array indicating which inventory items have already been matched
760	flag = (bool*) aCallocA(max, sizeof(bool));
761
762	while( SQL_SUCCESS == SqlStmt_NextRow(stmt) )
763	{
764	found = false;
765	// search for the presence of the item in the char's inventory
766	for( i = 0; i < max; ++i )
767	{
768	// skip empty and already matched entries
769	if( items[i].nameid == 0 \|\| flag[i] )
770	continue;
771
772	if( items[i].nameid == item.nameid
773	&& items[i].card[0] == item.card[0]
774	&& items[i].card[2] == item.card[2]
775	&& items[i].card[3] == item.card[3]
776	) { //They are the same item.
777	ARR_FIND( 0, MAX_SLOTS, j, items[i].card[j] != item.card[j] );
778	if( j == MAX_SLOTS &&
779	items[i].amount == item.amount &&
780	items[i].equip == item.equip &&
781	items[i].identify == item.identify &&
782	items[i].refine == item.refine &&
783	items[i].attribute == item.attribute )
784	; //Do nothing.
785	else
786	{
787	// update all fields.
788	StringBuf_Clear(&buf);
789	StringBuf_Printf(&buf, "UPDATE `%s` SET `amount`='%d', `equip`='%d', `identify`='%d', `refine`='%d',`attribute`='%d'",
790	tablename, items[i].amount, items[i].equip, items[i].identify, items[i].refine, items[i].attribute);
791	for( j = 0; j < MAX_SLOTS; ++j )
792	StringBuf_Printf(&buf, ", `card%d`=%d", j, items[i].card[j]);
793	StringBuf_Printf(&buf, " WHERE `id`='%d' LIMIT 1", item.id);
794
795	if( SQL_ERROR == Sql_QueryStr(sql_handle, StringBuf_Value(&buf)) )
796	Sql_ShowDebug(sql_handle);
797	}
798
799	found = flag[i] = true; //Item dealt with,
800	break; //skip to next item in the db.
801	}
802	}
803	if( !found )
804	{// Item not present in inventory, remove it.
805	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE from `%s` where `id`='%d'", tablename, item.id) )
806	Sql_ShowDebug(sql_handle);
807	}
808	}
809	SqlStmt_Free(stmt);
810
811	StringBuf_Clear(&buf);
812	StringBuf_Printf(&buf, "INSERT INTO `%s`(`%s`, `nameid`, `amount`, `equip`, `identify`, `refine`, `attribute`", tablename, selectoption);
813	for( j = 0; j < MAX_SLOTS; ++j )
814	StringBuf_Printf(&buf, ", `card%d`", j);
815	StringBuf_AppendStr(&buf, ") VALUES ");
816
817	found = false;
818	// insert non-matched items into the db as new items
819	for( i = 0; i < max; ++i )
820	{
821	// skip empty and already matched entries
822	if( items[i].nameid == 0 \|\| flag[i] )
823	continue;
824
825	if( found )
826	StringBuf_AppendStr(&buf, ",");
827	else
828	found = true;
829
830	StringBuf_Printf(&buf, "('%d', '%d', '%d', '%d', '%d', '%d', '%d'",
831	id, items[i].nameid, items[i].amount, items[i].equip, items[i].identify, items[i].refine, items[i].attribute);
832	for( j = 0; j < MAX_SLOTS; ++j )
833	StringBuf_Printf(&buf, ", '%d'", items[i].card[j]);
834	StringBuf_AppendStr(&buf, ")");
835	}
836
837	if( found && SQL_ERROR == Sql_QueryStr(sql_handle, StringBuf_Value(&buf)) )
838	Sql_ShowDebug(sql_handle);
839
840	StringBuf_Destroy(&buf);
841	aFree(flag);
842
843	return 0;
844	}
845
846	int mmo_char_tobuf(uint8* buf, struct mmo_charstatus* p);
847
848	#ifndef TXT_SQL_CONVERT
849	//=====================================================================================================
850	// Loads the basic character rooster for the given account. Returns total buffer used.
851	int mmo_chars_fromsql(struct char_session_data* sd, uint8* buf)
852	{
853	SqlStmt* stmt;
854	struct mmo_charstatus p;
855	int j = 0, i;
856
857	stmt = SqlStmt_Malloc(sql_handle);
858	if( stmt == NULL )
859	{
860	SqlStmt_ShowDebug(stmt);
861	return 0;
862	}
863	memset(&p, 0, sizeof(p));
864
865	// read char data
866	if( SQL_ERROR == SqlStmt_Prepare(stmt, "SELECT "
867	"`char_id`,`char_num`,`name`,`class`,`base_level`,`job_level`,`base_exp`,`job_exp`,`zeny`,"
868	"`str`,`agi`,`vit`,`int`,`dex`,`luk`,`max_hp`,`hp`,`max_sp`,`sp`,"
869	"`status_point`,`skill_point`,`option`,`karma`,`manner`,`hair`,`hair_color`,"
870	"`clothes_color`,`weapon`,`shield`,`head_top`,`head_mid`,`head_bottom`"
871	" FROM `%s` WHERE `account_id`='%d' AND `char_num` < '%d'", char_db, sd->account_id, MAX_CHARS)
872	\|\| SQL_ERROR == SqlStmt_Execute(stmt)
873	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 0, SQLDT_INT, &p.char_id, 0, NULL, NULL)
874	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 1, SQLDT_UCHAR, &p.slot, 0, NULL, NULL)
875	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 2, SQLDT_STRING, &p.name, sizeof(p.name), NULL, NULL)
876	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 3, SQLDT_SHORT, &p.class_, 0, NULL, NULL)
877	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 4, SQLDT_UINT, &p.base_level, 0, NULL, NULL)
878	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 5, SQLDT_UINT, &p.job_level, 0, NULL, NULL)
879	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 6, SQLDT_UINT, &p.base_exp, 0, NULL, NULL)
880	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 7, SQLDT_UINT, &p.job_exp, 0, NULL, NULL)
881	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 8, SQLDT_INT, &p.zeny, 0, NULL, NULL)
882	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 9, SQLDT_SHORT, &p.str, 0, NULL, NULL)
883	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 10, SQLDT_SHORT, &p.agi, 0, NULL, NULL)
884	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 11, SQLDT_SHORT, &p.vit, 0, NULL, NULL)
885	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 12, SQLDT_SHORT, &p.int_, 0, NULL, NULL)
886	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 13, SQLDT_SHORT, &p.dex, 0, NULL, NULL)
887	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 14, SQLDT_SHORT, &p.luk, 0, NULL, NULL)
888	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 15, SQLDT_INT, &p.max_hp, 0, NULL, NULL)
889	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 16, SQLDT_INT, &p.hp, 0, NULL, NULL)
890	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 17, SQLDT_INT, &p.max_sp, 0, NULL, NULL)
891	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 18, SQLDT_INT, &p.sp, 0, NULL, NULL)
892	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 19, SQLDT_USHORT, &p.status_point, 0, NULL, NULL)
893	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 20, SQLDT_USHORT, &p.skill_point, 0, NULL, NULL)
894	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 21, SQLDT_UINT, &p.option, 0, NULL, NULL)
895	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 22, SQLDT_UCHAR, &p.karma, 0, NULL, NULL)
896	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 23, SQLDT_SHORT, &p.manner, 0, NULL, NULL)
897	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 24, SQLDT_SHORT, &p.hair, 0, NULL, NULL)
898	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 25, SQLDT_SHORT, &p.hair_color, 0, NULL, NULL)
899	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 26, SQLDT_SHORT, &p.clothes_color, 0, NULL, NULL)
900	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 27, SQLDT_SHORT, &p.weapon, 0, NULL, NULL)
901	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 28, SQLDT_SHORT, &p.shield, 0, NULL, NULL)
902	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 29, SQLDT_SHORT, &p.head_top, 0, NULL, NULL)
903	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 30, SQLDT_SHORT, &p.head_mid, 0, NULL, NULL)
904	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 31, SQLDT_SHORT, &p.head_bottom, 0, NULL, NULL)
905	)
906	{
907	SqlStmt_ShowDebug(stmt);
908	SqlStmt_Free(stmt);
909	return 0;
910	}
911	for( i = 0; i < MAX_CHARS && SQL_SUCCESS == SqlStmt_NextRow(stmt); i++ )
912	{
913	sd->found_char[i] = p.char_id;
914	j += mmo_char_tobuf(WBUFP(buf, j), &p);
915	}
916	for( ; i < MAX_CHARS; i++ )
917	sd->found_char[i] = -1;
918
919	SqlStmt_Free(stmt);
920	return j;
921	}
922
923	//=====================================================================================================
924	int mmo_char_fromsql(int char_id, struct mmo_charstatus* p, bool load_everything)
925	{
926	int i,j;
927	char t_msg[128] = "";
928	struct mmo_charstatus* cp;
929	StringBuf buf;
930	SqlStmt* stmt;
931	char last_map[MAP_NAME_LENGTH_EXT];
932	char save_map[MAP_NAME_LENGTH_EXT];
933	char point_map[MAP_NAME_LENGTH_EXT];
934	struct point tmp_point;
935	struct item tmp_item;
936	struct skill tmp_skill;
937	struct s_friend tmp_friend;
938	#ifdef HOTKEY_SAVING
939	struct hotkey tmp_hotkey;
940	int hotkey_num;
941	#endif
942
943	memset(p, 0, sizeof(struct mmo_charstatus));
944
945	if (save_log) ShowInfo("Char load request (%d)\n", char_id);
946
947	stmt = SqlStmt_Malloc(sql_handle);
948	if( stmt == NULL )
949	{
950	SqlStmt_ShowDebug(stmt);
951	return 0;
952	}
953
954	// read char data
955	if( SQL_ERROR == SqlStmt_Prepare(stmt, "SELECT "
956	"`char_id`,`account_id`,`char_num`,`name`,`class`,`base_level`,`job_level`,`base_exp`,`job_exp`,`zeny`,"
957	"`str`,`agi`,`vit`,`int`,`dex`,`luk`,`max_hp`,`hp`,`max_sp`,`sp`,"
958	"`status_point`,`skill_point`,`option`,`karma`,`manner`,`party_id`,`guild_id`,`pet_id`,`homun_id`,`hair`,"
959	"`hair_color`,`clothes_color`,`weapon`,`shield`,`head_top`,`head_mid`,`head_bottom`,`last_map`,`last_x`,`last_y`,"
960	"`save_map`,`save_x`,`save_y`,`partner_id`,`father`,`mother`,`child`,`fame`"
961	" FROM `%s` WHERE `char_id`=? LIMIT 1", char_db)
962	\|\| SQL_ERROR == SqlStmt_BindParam(stmt, 0, SQLDT_INT, &char_id, 0)
963	\|\| SQL_ERROR == SqlStmt_Execute(stmt)
964	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 0, SQLDT_INT, &p->char_id, 0, NULL, NULL)
965	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 1, SQLDT_INT, &p->account_id, 0, NULL, NULL)
966	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 2, SQLDT_UCHAR, &p->slot, 0, NULL, NULL)
967	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 3, SQLDT_STRING, &p->name, sizeof(p->name), NULL, NULL)
968	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 4, SQLDT_SHORT, &p->class_, 0, NULL, NULL)
969	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 5, SQLDT_UINT, &p->base_level, 0, NULL, NULL)
970	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 6, SQLDT_UINT, &p->job_level, 0, NULL, NULL)
971	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 7, SQLDT_UINT, &p->base_exp, 0, NULL, NULL)
972	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 8, SQLDT_UINT, &p->job_exp, 0, NULL, NULL)
973	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 9, SQLDT_INT, &p->zeny, 0, NULL, NULL)
974	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 10, SQLDT_SHORT, &p->str, 0, NULL, NULL)
975	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 11, SQLDT_SHORT, &p->agi, 0, NULL, NULL)
976	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 12, SQLDT_SHORT, &p->vit, 0, NULL, NULL)
977	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 13, SQLDT_SHORT, &p->int_, 0, NULL, NULL)
978	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 14, SQLDT_SHORT, &p->dex, 0, NULL, NULL)
979	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 15, SQLDT_SHORT, &p->luk, 0, NULL, NULL)
980	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 16, SQLDT_INT, &p->max_hp, 0, NULL, NULL)
981	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 17, SQLDT_INT, &p->hp, 0, NULL, NULL)
982	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 18, SQLDT_INT, &p->max_sp, 0, NULL, NULL)
983	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 19, SQLDT_INT, &p->sp, 0, NULL, NULL)
984	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 20, SQLDT_USHORT, &p->status_point, 0, NULL, NULL)
985	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 21, SQLDT_USHORT, &p->skill_point, 0, NULL, NULL)
986	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 22, SQLDT_UINT, &p->option, 0, NULL, NULL)
987	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 23, SQLDT_UCHAR, &p->karma, 0, NULL, NULL)
988	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 24, SQLDT_SHORT, &p->manner, 0, NULL, NULL)
989	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 25, SQLDT_INT, &p->party_id, 0, NULL, NULL)
990	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 26, SQLDT_INT, &p->guild_id, 0, NULL, NULL)
991	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 27, SQLDT_INT, &p->pet_id, 0, NULL, NULL)
992	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 28, SQLDT_INT, &p->hom_id, 0, NULL, NULL)
993	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 29, SQLDT_SHORT, &p->hair, 0, NULL, NULL)
994	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 30, SQLDT_SHORT, &p->hair_color, 0, NULL, NULL)
995	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 31, SQLDT_SHORT, &p->clothes_color, 0, NULL, NULL)
996	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 32, SQLDT_SHORT, &p->weapon, 0, NULL, NULL)
997	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 33, SQLDT_SHORT, &p->shield, 0, NULL, NULL)
998	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 34, SQLDT_SHORT, &p->head_top, 0, NULL, NULL)
999	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 35, SQLDT_SHORT, &p->head_mid, 0, NULL, NULL)
1000	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 36, SQLDT_SHORT, &p->head_bottom, 0, NULL, NULL)
1001	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 37, SQLDT_STRING, &last_map, sizeof(last_map), NULL, NULL)
1002	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 38, SQLDT_SHORT, &p->last_point.x, 0, NULL, NULL)
1003	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 39, SQLDT_SHORT, &p->last_point.y, 0, NULL, NULL)
1004	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 40, SQLDT_STRING, &save_map, sizeof(save_map), NULL, NULL)
1005	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 41, SQLDT_SHORT, &p->save_point.x, 0, NULL, NULL)
1006	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 42, SQLDT_SHORT, &p->save_point.y, 0, NULL, NULL)
1007	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 43, SQLDT_INT, &p->partner_id, 0, NULL, NULL)
1008	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 44, SQLDT_INT, &p->father, 0, NULL, NULL)
1009	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 45, SQLDT_INT, &p->mother, 0, NULL, NULL)
1010	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 46, SQLDT_INT, &p->child, 0, NULL, NULL)
1011	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 47, SQLDT_INT, &p->fame, 0, NULL, NULL) )
1012	{
1013	SqlStmt_ShowDebug(stmt);
1014	SqlStmt_Free(stmt);
1015	return 0;
1016	}
1017	if( SQL_ERROR == SqlStmt_NextRow(stmt) )
1018	{
1019	ShowError("Requested non-existant character id: %d!\n", char_id);
1020	SqlStmt_Free(stmt);
1021	return 0;
1022	}
1023	p->last_point.map = mapindex_name2id(last_map);
1024	p->save_point.map = mapindex_name2id(save_map);
1025
1026	strcat(t_msg, " status");
1027
1028	if (!load_everything) // For quick selection of data when displaying the char menu
1029	{
1030	SqlStmt_Free(stmt);
1031	return 1;
1032	}
1033
1034	//read memo data
1035	//`memo` (`memo_id`,`char_id`,`map`,`x`,`y`)
1036	if( SQL_ERROR == SqlStmt_Prepare(stmt, "SELECT `map`,`x`,`y` FROM `%s` WHERE `char_id`=? ORDER by `memo_id` LIMIT %d", memo_db, MAX_MEMOPOINTS)
1037	\|\| SQL_ERROR == SqlStmt_BindParam(stmt, 0, SQLDT_INT, &char_id, 0)
1038	\|\| SQL_ERROR == SqlStmt_Execute(stmt)
1039	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 0, SQLDT_STRING, &point_map, sizeof(point_map), NULL, NULL)
1040	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 1, SQLDT_SHORT, &tmp_point.x, 0, NULL, NULL)
1041	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 2, SQLDT_SHORT, &tmp_point.y, 0, NULL, NULL) )
1042	SqlStmt_ShowDebug(stmt);
1043
1044	for( i = 0; i < MAX_MEMOPOINTS && SQL_SUCCESS == SqlStmt_NextRow(stmt); ++i )
1045	{
1046	tmp_point.map = mapindex_name2id(point_map);
1047	memcpy(&p->memo_point[i], &tmp_point, sizeof(tmp_point));
1048	}
1049	strcat(t_msg, " memo");
1050
1051	//read inventory
1052	//`inventory` (`id`,`char_id`, `nameid`, `amount`, `equip`, `identify`, `refine`, `attribute`, `card0`, `card1`, `card2`, `card3`)
1053	StringBuf_Init(&buf);
1054	StringBuf_AppendStr(&buf, "SELECT `id`, `nameid`, `amount`, `equip`, `identify`, `refine`, `attribute`");
1055	for( i = 0; i < MAX_SLOTS; ++i )
1056	StringBuf_Printf(&buf, ", `card%d`", i);
1057	StringBuf_Printf(&buf, " FROM `%s` WHERE `char_id`=? LIMIT %d", inventory_db, MAX_INVENTORY);
1058
1059	if( SQL_ERROR == SqlStmt_PrepareStr(stmt, StringBuf_Value(&buf))
1060	\|\| SQL_ERROR == SqlStmt_BindParam(stmt, 0, SQLDT_INT, &char_id, 0)
1061	\|\| SQL_ERROR == SqlStmt_Execute(stmt)
1062	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 0, SQLDT_INT, &tmp_item.id, 0, NULL, NULL)
1063	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 1, SQLDT_SHORT, &tmp_item.nameid, 0, NULL, NULL)
1064	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 2, SQLDT_SHORT, &tmp_item.amount, 0, NULL, NULL)
1065	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 3, SQLDT_USHORT, &tmp_item.equip, 0, NULL, NULL)
1066	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 4, SQLDT_CHAR, &tmp_item.identify, 0, NULL, NULL)
1067	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 5, SQLDT_CHAR, &tmp_item.refine, 0, NULL, NULL)
1068	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 6, SQLDT_CHAR, &tmp_item.attribute, 0, NULL, NULL) )
1069	SqlStmt_ShowDebug(stmt);
1070	for( i = 0; i < MAX_SLOTS; ++i )
1071	if( SQL_ERROR == SqlStmt_BindColumn(stmt, 7+i, SQLDT_SHORT, &tmp_item.card[i], 0, NULL, NULL) )
1072	SqlStmt_ShowDebug(stmt);
1073
1074	for( i = 0; i < MAX_INVENTORY && SQL_SUCCESS == SqlStmt_NextRow(stmt); ++i )
1075	memcpy(&p->inventory[i], &tmp_item, sizeof(tmp_item));
1076	strcat(t_msg, " inventory");
1077
1078	//read cart
1079	//`cart_inventory` (`id`,`char_id`, `nameid`, `amount`, `equip`, `identify`, `refine`, `attribute`, `card0`, `card1`, `card2`, `card3`)
1080	StringBuf_Clear(&buf);
1081	StringBuf_AppendStr(&buf, "SELECT `id`, `nameid`, `amount`, `equip`, `identify`, `refine`, `attribute`");
1082	for( j = 0; j < MAX_SLOTS; ++j )
1083	StringBuf_Printf(&buf, ", `card%d`", j);
1084	StringBuf_Printf(&buf, " FROM `%s` WHERE `char_id`=? LIMIT %d", cart_db, MAX_CART);
1085
1086	if( SQL_ERROR == SqlStmt_PrepareStr(stmt, StringBuf_Value(&buf))
1087	\|\| SQL_ERROR == SqlStmt_BindParam(stmt, 0, SQLDT_INT, &char_id, 0)
1088	\|\| SQL_ERROR == SqlStmt_Execute(stmt)
1089	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 0, SQLDT_INT, &tmp_item.id, 0, NULL, NULL)
1090	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 1, SQLDT_SHORT, &tmp_item.nameid, 0, NULL, NULL)
1091	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 2, SQLDT_SHORT, &tmp_item.amount, 0, NULL, NULL)
1092	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 3, SQLDT_USHORT, &tmp_item.equip, 0, NULL, NULL)
1093	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 4, SQLDT_CHAR, &tmp_item.identify, 0, NULL, NULL)
1094	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 5, SQLDT_CHAR, &tmp_item.refine, 0, NULL, NULL)
1095	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 6, SQLDT_CHAR, &tmp_item.attribute, 0, NULL, NULL) )
1096	SqlStmt_ShowDebug(stmt);
1097	for( i = 0; i < MAX_SLOTS; ++i )
1098	if( SQL_ERROR == SqlStmt_BindColumn(stmt, 7+i, SQLDT_SHORT, &tmp_item.card[i], 0, NULL, NULL) )
1099	SqlStmt_ShowDebug(stmt);
1100
1101	for( i = 0; i < MAX_CART && SQL_SUCCESS == SqlStmt_NextRow(stmt); ++i )
1102	memcpy(&p->cart[i], &tmp_item, sizeof(tmp_item));
1103	strcat(t_msg, " cart");
1104
1105	//read skill
1106	//`skill` (`char_id`, `id`, `lv`)
1107	if( SQL_ERROR == SqlStmt_Prepare(stmt, "SELECT `id`, `lv` FROM `%s` WHERE `char_id`=? LIMIT %d", skill_db, MAX_SKILL)
1108	\|\| SQL_ERROR == SqlStmt_BindParam(stmt, 0, SQLDT_INT, &char_id, 0)
1109	\|\| SQL_ERROR == SqlStmt_Execute(stmt)
1110	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 0, SQLDT_USHORT, &tmp_skill.id, 0, NULL, NULL)
1111	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 1, SQLDT_USHORT, &tmp_skill.lv, 0, NULL, NULL) )
1112	SqlStmt_ShowDebug(stmt);
1113	tmp_skill.flag = 0;
1114
1115	for( i = 0; i < MAX_SKILL && SQL_SUCCESS == SqlStmt_NextRow(stmt); ++i )
1116	{
1117	if( tmp_skill.id < ARRAYLENGTH(p->skill) )
1118	memcpy(&p->skill[tmp_skill.id], &tmp_skill, sizeof(tmp_skill));
1119	else
1120	ShowWarning("mmo_char_fromsql: ignoring invalid skill (id=%u,lv=%u) of character %s (AID=%d,CID=%d)\n", tmp_skill.id, tmp_skill.lv, p->name, p->account_id, p->char_id);
1121	}
1122	strcat(t_msg, " skills");
1123
1124	//read friends
1125	//`friends` (`char_id`, `friend_account`, `friend_id`)
1126	if( SQL_ERROR == SqlStmt_Prepare(stmt, "SELECT c.`account_id`, c.`char_id`, c.`name` FROM `%s` c LEFT JOIN `%s` f ON f.`friend_account` = c.`account_id` AND f.`friend_id` = c.`char_id` WHERE f.`char_id`=? LIMIT %d", char_db, friend_db, MAX_FRIENDS)
1127	\|\| SQL_ERROR == SqlStmt_BindParam(stmt, 0, SQLDT_INT, &char_id, 0)
1128	\|\| SQL_ERROR == SqlStmt_Execute(stmt)
1129	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 0, SQLDT_INT, &tmp_friend.account_id, 0, NULL, NULL)
1130	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 1, SQLDT_INT, &tmp_friend.char_id, 0, NULL, NULL)
1131	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 2, SQLDT_STRING, &tmp_friend.name, sizeof(tmp_friend.name), NULL, NULL) )
1132	SqlStmt_ShowDebug(stmt);
1133
1134	for( i = 0; i < MAX_FRIENDS && SQL_SUCCESS == SqlStmt_NextRow(stmt); ++i )
1135	memcpy(&p->friends[i], &tmp_friend, sizeof(tmp_friend));
1136	strcat(t_msg, " friends");
1137
1138	#ifdef HOTKEY_SAVING
1139	//read hotkeys
1140	//`hotkey` (`char_id`, `hotkey`, `type`, `itemskill_id`, `skill_lvl`
1141	if( SQL_ERROR == SqlStmt_Prepare(stmt, "SELECT `hotkey`, `type`, `itemskill_id`, `skill_lvl` FROM `%s` WHERE `char_id`=?", hotkey_db)
1142	\|\| SQL_ERROR == SqlStmt_BindParam(stmt, 0, SQLDT_INT, &char_id, 0)
1143	\|\| SQL_ERROR == SqlStmt_Execute(stmt)
1144	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 0, SQLDT_INT, &hotkey_num, 0, NULL, NULL)
1145	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 1, SQLDT_UCHAR, &tmp_hotkey.type, 0, NULL, NULL)
1146	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 2, SQLDT_UINT, &tmp_hotkey.id, 0, NULL, NULL)
1147	\|\| SQL_ERROR == SqlStmt_BindColumn(stmt, 3, SQLDT_USHORT, &tmp_hotkey.lv, 0, NULL, NULL) )
1148	SqlStmt_ShowDebug(stmt);
1149
1150	while( SQL_SUCCESS == SqlStmt_NextRow(stmt) )
1151	{
1152	if( hotkey_num >= 0 && hotkey_num < MAX_HOTKEYS )
1153	memcpy(&p->hotkeys[hotkey_num], &tmp_hotkey, sizeof(tmp_hotkey));
1154	else
1155	ShowWarning("mmo_char_fromsql: ignoring invalid hotkey (hotkey=%d,type=%u,id=%u,lv=%u) of character %s (AID=%d,CID=%d)\n", hotkey_num, tmp_hotkey.type, tmp_hotkey.id, tmp_hotkey.lv, p->name, p->account_id, p->char_id);
1156	}
1157	strcat(t_msg, " hotkeys");
1158	#endif
1159
1160	if (save_log) ShowInfo("Loaded char (%d - %s): %s\n", char_id, p->name, t_msg); //ok. all data load successfuly!
1161	SqlStmt_Free(stmt);
1162	StringBuf_Destroy(&buf);
1163
1164	cp = (struct mmo_charstatus*)idb_ensure(char_db_, char_id, create_charstatus);
1165	memcpy(cp, p, sizeof(struct mmo_charstatus));
1166	return 1;
1167	}
1168
1169	//==========================================================================================================
1170	int mmo_char_sql_init(void)
1171	{
1172	ShowInfo("Begin Initializing.......\n");
1173	char_db_= idb_alloc(DB_OPT_RELEASE_DATA);
1174
1175	if(char_per_account == 0){
1176	ShowStatus("Chars per Account: 'Unlimited'.......\n");
1177	}else{
1178	ShowStatus("Chars per Account: '%d'.......\n", char_per_account);
1179	}
1180
1181	//the 'set offline' part is now in check_login_conn ...
1182	//if the server connects to loginserver
1183	//it will dc all off players
1184	//and send the loginserver the new state....
1185
1186	// Force all users offline in sql when starting char-server
1187	// (useful when servers crashs and don't clean the database)
1188	set_all_offline_sql();
1189
1190	ShowInfo("Finished initilizing.......\n");
1191
1192	return 0;
1193	}
1194
1195	//-----------------------------------
1196	// Function to create a new character
1197	//-----------------------------------
1198	int make_new_char_sql(struct char_session_data* sd, char* name_, int str, int agi, int vit, int int_, int dex, int luk, int slot, int hair_color, int hair_style)
1199	{
1200	char name[NAME_LENGTH];
1201	char esc_name[NAME_LENGTH*2+1];
1202	unsigned int i;
1203	int char_id;
1204
1205	safestrncpy(name, name_, NAME_LENGTH);
1206	normalize_name(name,TRIM_CHARS);
1207	Sql_EscapeStringLen(sql_handle, esc_name, name, strnlen(name, NAME_LENGTH));
1208
1209	// check length of character name
1210	if( name[0] == '\0' )
1211	return -2; // empty character name
1212
1213	// check content of character name
1214	if( remove_control_chars(name) )
1215	return -2; // control chars in name
1216
1217	// check for reserved names
1218	if( strcmpi(name, main_chat_nick) == 0 \|\| strcmpi(name, wisp_server_name) == 0 )
1219	return -1; // nick reserved for internal server messages
1220
1221	// Check Authorised letters/symbols in the name of the character
1222	if( char_name_option == 1 ) { // only letters/symbols in char_name_letters are authorised
1223	for( i = 0; i < NAME_LENGTH && name[i]; i++ )
1224	if( strchr(char_name_letters, name[i]) == NULL )
1225	return -2;
1226	} else
1227	if( char_name_option == 2 ) { // letters/symbols in char_name_letters are forbidden
1228	for( i = 0; i < NAME_LENGTH && name[i]; i++ )
1229	if( strchr(char_name_letters, name[i]) != NULL )
1230	return -2;
1231	} // else, all letters/symbols are authorised (except control char removed before)
1232
1233	// check name (already in use?)
1234	if( SQL_ERROR == Sql_Query(sql_handle, "SELECT 1 FROM `%s` WHERE `name` = '%s'", char_db, esc_name) ) {
1235	Sql_ShowDebug(sql_handle);
1236	return -2;
1237	}
1238	if( Sql_NumRows(sql_handle) > 0 )
1239	return -1; // name already exists
1240
1241	//check other inputs
1242	if((slot >= MAX_CHARS) // slots
1243	\|\| (hair_style >= 24) // hair style
1244	\|\| (hair_color >= 9) // hair color
1245	\|\| (str + agi + vit + int_ + dex + luk != 6*5 ) // stats
1246	\|\| (str < 1 \|\| str > 9 \|\| agi < 1 \|\| agi > 9 \|\| vit < 1 \|\| vit > 9 \|\| int_ < 1 \|\| int_ > 9 \|\| dex < 1 \|\| dex > 9 \|\| luk < 1 \|\| luk > 9) // individual stat values
1247	\|\| (str + int_ != 10 \|\| agi + luk != 10 \|\| vit + dex != 10) ) // pairs
1248	return -2; // invalid input
1249
1250	// check the number of already existing chars in this account
1251	if( char_per_account != 0 ) {
1252	if( SQL_ERROR == Sql_Query(sql_handle, "SELECT 1 FROM `%s` WHERE `account_id` = '%d'", char_db, sd->account_id) )
1253	Sql_ShowDebug(sql_handle);
1254	if( Sql_NumRows(sql_handle) >= char_per_account )
1255	return -2; // character account limit exceeded
1256	}
1257
1258	// check char slot
1259	if( SQL_ERROR == Sql_Query(sql_handle, "SELECT 1 FROM `%s` WHERE `account_id` = '%d' AND `char_num` = '%d'", char_db, sd->account_id, slot) )
1260	Sql_ShowDebug(sql_handle);
1261	if( Sql_NumRows(sql_handle) > 0 )
1262	return -2; // slot already in use
1263
1264	// validation success, log result
1265	if (log_char) {
1266	if( SQL_ERROR == Sql_Query(sql_handle, "INSERT INTO `%s` (`time`, `char_msg`,`account_id`,`char_num`,`name`,`str`,`agi`,`vit`,`int`,`dex`,`luk`,`hair`,`hair_color`)"
1267	"VALUES (NOW(), '%s', '%d', '%d', '%s', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d')",
1268	charlog_db, "make new char", sd->account_id, slot, esc_name, str, agi, vit, int_, dex, luk, hair_style, hair_color) )
1269	Sql_ShowDebug(sql_handle);
1270	}
1271
1272	//Insert the new char entry to the database
1273	if( SQL_ERROR == Sql_Query(sql_handle, "INSERT INTO `%s` (`account_id`, `char_num`, `name`, `zeny`, `str`, `agi`, `vit`, `int`, `dex`, `luk`, `max_hp`, `hp`,"
1274	"`max_sp`, `sp`, `hair`, `hair_color`, `last_map`, `last_x`, `last_y`, `save_map`, `save_x`, `save_y`) VALUES ("
1275	"'%d', '%d', '%s', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d','%d', '%d','%d', '%d', '%s', '%d', '%d', '%s', '%d', '%d')",
1276	char_db, sd->account_id , slot, esc_name, start_zeny, str, agi, vit, int_, dex, luk,
1277	(40 * (100 + vit)/100) , (40 * (100 + vit)/100 ), (11 * (100 + int_)/100), (11 * (100 + int_)/100), hair_style, hair_color,
1278	mapindex_id2name(start_point.map), start_point.x, start_point.y, mapindex_id2name(start_point.map), start_point.x, start_point.y) )
1279	{
1280	Sql_ShowDebug(sql_handle);
1281	return -2; //No, stop the procedure!
1282	}
1283	//Retrieve the newly auto-generated char id
1284	char_id = (int)Sql_LastInsertId(sql_handle);
1285	//Give the char the default items
1286	if (start_weapon > 0) { //add Start Weapon (Knife?)
1287	if( SQL_ERROR == Sql_Query(sql_handle, "INSERT INTO `%s` (`char_id`,`nameid`, `amount`, `identify`) VALUES ('%d', '%d', '%d', '%d')", inventory_db, char_id, start_weapon, 1, 1) )
1288	Sql_ShowDebug(sql_handle);
1289	}
1290	if (start_armor > 0) { //Add default armor (cotton shirt?)
1291	if( SQL_ERROR == Sql_Query(sql_handle, "INSERT INTO `%s` (`char_id`,`nameid`, `amount`, `identify`) VALUES ('%d', '%d', '%d', '%d')", inventory_db, char_id, start_armor, 1, 1) )
1292	Sql_ShowDebug(sql_handle);
1293	}
1294
1295	ShowInfo("Created char: account: %d, char: %d, slot: %d, name: %s\n", sd->account_id, char_id, slot, name);
1296	return char_id;
1297	}
1298
1299	/----------------------------------------------------------------------------------------------------------/
1300	/* Divorce Players */
1301	/----------------------------------------------------------------------------------------------------------/
1302	int divorce_char_sql(int partner_id1, int partner_id2)
1303	{
1304	unsigned char buf[64];
1305
1306	if( SQL_ERROR == Sql_Query(sql_handle, "UPDATE `%s` SET `partner_id`='0' WHERE `char_id`='%d' OR `char_id`='%d'", char_db, partner_id1, partner_id2) )
1307	Sql_ShowDebug(sql_handle);
1308	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE (`nameid`='%d' OR `nameid`='%d') AND (`char_id`='%d' OR `char_id`='%d')", inventory_db, WEDDING_RING_M, WEDDING_RING_F, partner_id1, partner_id2) )
1309	Sql_ShowDebug(sql_handle);
1310
1311	WBUFW(buf,0) = 0x2b12;
1312	WBUFL(buf,2) = partner_id1;
1313	WBUFL(buf,6) = partner_id2;
1314	mapif_sendall(buf,10);
1315
1316	return 0;
1317	}
1318
1319	/----------------------------------------------------------------------------------------------------------/
1320	/* Delete char - davidsiaw */
1321	/----------------------------------------------------------------------------------------------------------/
1322	/* Returns 0 if successful
1323	* Returns < 0 for error
1324	*/
1325	int delete_char_sql(int char_id)
1326	{
1327	char name[NAME_LENGTH];
1328	char esc_name[NAME_LENGTH*2+1]; //Name needs be escaped.
1329	int account_id, party_id, guild_id, hom_id, base_level, partner_id, father_id, mother_id;
1330	char* data;
1331	size_t len;
1332
1333	if( SQL_ERROR == Sql_Query(sql_handle, "SELECT `name`,`account_id`,`party_id`,`guild_id`,`base_level`,`homun_id`,`partner_id`,`father`,`mother` FROM `%s` WHERE `char_id`='%d'", char_db, char_id) )
1334	Sql_ShowDebug(sql_handle);
1335
1336	if( SQL_SUCCESS != Sql_NextRow(sql_handle) )
1337	{
1338	ShowError("delete_char_sql: Unable to fetch character data, deletion aborted.\n");
1339	Sql_FreeResult(sql_handle);
1340	return -1;
1341	}
1342
1343	Sql_GetData(sql_handle, 0, &data, &len); safestrncpy(name, data, NAME_LENGTH);
1344	Sql_GetData(sql_handle, 1, &data, NULL); account_id = atoi(data);
1345	Sql_GetData(sql_handle, 2, &data, NULL); party_id = atoi(data);
1346	Sql_GetData(sql_handle, 3, &data, NULL); guild_id = atoi(data);
1347	Sql_GetData(sql_handle, 4, &data, NULL); base_level = atoi(data);
1348	Sql_GetData(sql_handle, 5, &data, NULL); hom_id = atoi(data);
1349	Sql_GetData(sql_handle, 6, &data, NULL); partner_id = atoi(data);
1350	Sql_GetData(sql_handle, 7, &data, NULL); father_id = atoi(data);
1351	Sql_GetData(sql_handle, 8, &data, NULL); mother_id = atoi(data);
1352
1353	Sql_EscapeStringLen(sql_handle, esc_name, name, min(len, NAME_LENGTH));
1354	Sql_FreeResult(sql_handle);
1355
1356	//check for config char del condition [Lupus]
1357	if( ( char_del_level > 0 && base_level >= char_del_level )
1358	\|\| ( char_del_level < 0 && base_level <= -char_del_level )
1359	) {
1360	ShowInfo("Char deletion aborted: %s, BaseLevel: %i\n", name, base_level);
1361	return -1;
1362	}
1363
1364	/* Divorce [Wizputer] */
1365	if( partner_id )
1366	divorce_char_sql(char_id, partner_id);
1367
1368	/* De-addopt [Zephyrus] */
1369	if( father_id \|\| mother_id )
1370	{ // Char is Baby
1371	unsigned char buf[64];
1372
1373	if( SQL_ERROR == Sql_Query(sql_handle, "UPDATE `%s` SET `child`='0' WHERE `char_id`='%d' OR `char_id`='%d'", char_db, father_id, mother_id) )
1374	Sql_ShowDebug(sql_handle);
1375	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `id` = '410'AND (`char_id`='%d' OR `char_id`='%d')", skill_db, father_id, mother_id) )
1376	Sql_ShowDebug(sql_handle);
1377
1378	WBUFW(buf,0) = 0x2b25;
1379	WBUFL(buf,2) = father_id;
1380	WBUFL(buf,6) = mother_id;
1381	WBUFL(buf,10) = char_id; // Baby
1382	mapif_sendall(buf,14);
1383	}
1384
1385	//Make the character leave the party [Skotlex]
1386	if (party_id)
1387	inter_party_leave(party_id, account_id, char_id);
1388
1389	/* delete char's pet */
1390	//Delete the hatched pet if you have one...
1391	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `char_id`='%d' AND `incuvate` = '0'", pet_db, char_id) )
1392	Sql_ShowDebug(sql_handle);
1393
1394	//Delete all pets that are stored in eggs (inventory + cart)
1395	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE pet_id IN "
1396	"(SELECT card1\|card2<<2 FROM `%s` WHERE char_id = '%d' AND card0 = -256"
1397	" UNION"
1398	" SELECT card1\|card2<<2 FROM `%s` WHERE char_id = '%d' AND card0 = -256)",
1399	pet_db, inventory_db, char_id, cart_db, char_id) )
1400	Sql_ShowDebug(sql_handle);
1401
1402	/* remove homunculus */
1403	if (hom_id)
1404	mapif_homunculus_delete(hom_id);
1405
1406	/* delete char's friends list */
1407	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `char_id` = '%d'", friend_db, char_id) )
1408	Sql_ShowDebug(sql_handle);
1409
1410	/* delete char from other's friend list */
1411	//NOTE: Won't this cause problems for people who are already online? [Skotlex]
1412	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `friend_id` = '%d'", friend_db, char_id) )
1413	Sql_ShowDebug(sql_handle);
1414
1415	#ifdef HOTKEY_SAVING
1416	/* delete hotkeys */
1417	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `char_id`='%d'", hotkey_db, char_id) )
1418	Sql_ShowDebug(sql_handle);
1419	#endif
1420
1421	/* delete inventory */
1422	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `char_id`='%d'", inventory_db, char_id) )
1423	Sql_ShowDebug(sql_handle);
1424
1425	/* delete cart inventory */
1426	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `char_id`='%d'", cart_db, char_id) )
1427	Sql_ShowDebug(sql_handle);
1428
1429	/* delete memo areas */
1430	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `char_id`='%d'", memo_db, char_id) )
1431	Sql_ShowDebug(sql_handle);
1432
1433	/* delete character registry */
1434	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `type`=3 AND `char_id`='%d'", reg_db, char_id) )
1435	Sql_ShowDebug(sql_handle);
1436
1437	/* delete skills */
1438	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `char_id`='%d'", skill_db, char_id) )
1439	Sql_ShowDebug(sql_handle);
1440
1441	#ifdef ENABLE_SC_SAVING
1442	/* status changes */
1443	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `account_id` = '%d' AND `char_id`='%d'", scdata_db, account_id, char_id) )
1444	Sql_ShowDebug(sql_handle);
1445	#endif
1446
1447	if (log_char) {
1448	if( SQL_ERROR == Sql_Query(sql_handle, "INSERT INTO `%s`(`time`, `account_id`,`char_num`,`char_msg`,`name`) VALUES (NOW(), '%d', '%d', 'Deleted char (CID %d)', '%s')",
1449	charlog_db, account_id, 0, char_id, esc_name) )
1450	Sql_ShowDebug(sql_handle);
1451	}
1452
1453	/* delete character */
1454	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `char_id`='%d'", char_db, char_id) )
1455	Sql_ShowDebug(sql_handle);
1456
1457	/* No need as we used inter_guild_leave [Skotlex]
1458	// Also delete info from guildtables.
1459	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `char_id`='%d'", guild_member_db, char_id) )
1460	Sql_ShowDebug(sql_handle);
1461	*/
1462
1463	if( SQL_ERROR == Sql_Query(sql_handle, "SELECT `guild_id` FROM `%s` WHERE `master` = '%s'", guild_db, esc_name) )
1464	Sql_ShowDebug(sql_handle);
1465	else if( Sql_NumRows(sql_handle) > 0 )
1466	mapif_parse_BreakGuild(0,guild_id);
1467	else if( guild_id )
1468	inter_guild_leave(guild_id, account_id, char_id);// Leave your guild.
1469	return 0;
1470	}
1471
1472	//==========================================================================================================
1473
1474	int count_users(void)
1475	{
1476	int i, users;
1477
1478	if (login_fd > 0 && session[login_fd]){
1479	users = 0;
1480	for(i = 0; i < MAX_MAP_SERVERS; i++) {
1481	if (server[i].fd > 0) {
1482	users += server[i].users;
1483	}
1484	}
1485	return users;
1486	}
1487	return 0;
1488	}
1489
1490	/// Writes char data to the buffer in the format used by the client.
1491	/// Used in packets 0x6b (chars info) and 0x6d (new char info)
1492	/// Returns the size (106 or 108)
1493	int mmo_char_tobuf(uint8* buf, struct mmo_charstatus* p)
1494	{
1495	if( buf == NULL \|\| p == NULL )
1496	return 0;
1497
1498	WBUFL(buf,0) = p->char_id;
1499	WBUFL(buf,4) = min(p->base_exp, LONG_MAX);
1500	WBUFL(buf,8) = p->zeny;
1501	WBUFL(buf,12) = min(p->job_exp, LONG_MAX);
1502	WBUFL(buf,16) = p->job_level;
1503	WBUFL(buf,20) = 0; // probably opt1
1504	WBUFL(buf,24) = 0; // probably opt2
1505	WBUFL(buf,28) = p->option;
1506	WBUFL(buf,32) = p->karma;
1507	WBUFL(buf,36) = p->manner;
1508	WBUFW(buf,40) = min(p->status_point, SHRT_MAX);
1509	WBUFW(buf,42) = min(p->hp, SHRT_MAX);
1510	WBUFW(buf,44) = min(p->max_hp, SHRT_MAX);
1511	WBUFW(buf,46) = min(p->sp, SHRT_MAX);
1512	WBUFW(buf,48) = min(p->max_sp, SHRT_MAX);
1513	WBUFW(buf,50) = DEFAULT_WALK_SPEED; // p->speed;
1514	WBUFW(buf,52) = p->class_;
1515	WBUFW(buf,54) = p->hair;
1516	WBUFW(buf,56) = p->option&0x20 ? 0 : p->weapon; //When the weapon is sent and your option is riding, the client crashes on login!?
1517	WBUFW(buf,58) = p->base_level;
1518	WBUFW(buf,60) = min(p->skill_point, SHRT_MAX);
1519	WBUFW(buf,62) = p->head_bottom;
1520	WBUFW(buf,64) = p->shield;
1521	WBUFW(buf,66) = p->head_top;
1522	WBUFW(buf,68) = p->head_mid;
1523	WBUFW(buf,70) = p->hair_color;
1524	WBUFW(buf,72) = p->clothes_color;
1525	memcpy(WBUFP(buf,74), p->name, NAME_LENGTH);
1526	WBUFB(buf,98) = min(p->str, UCHAR_MAX);
1527	WBUFB(buf,99) = min(p->agi, UCHAR_MAX);
1528	WBUFB(buf,100) = min(p->vit, UCHAR_MAX);
1529	WBUFB(buf,101) = min(p->int_, UCHAR_MAX);
1530	WBUFB(buf,102) = min(p->dex, UCHAR_MAX);
1531	WBUFB(buf,103) = min(p->luk, UCHAR_MAX);
1532	WBUFW(buf,104) = p->slot;
1533	if (char_rename) {
1534	WBUFW(buf,106) = 1;// Rename bit (0=rename,1=no rename)
1535	return 108;
1536	} else {
1537	return 106;
1538	}
1539	}
1540
1541	int mmo_char_send006b(int fd, struct char_session_data* sd)
1542	{
1543	int j;
1544
1545	if (save_log)
1546	ShowInfo("Loading Char Data ("CL_BOLD"%d"CL_RESET")\n",sd->account_id);
1547
1548	j = 24; // offset
1549	WFIFOHEAD(fd,j + MAX_CHARS*108); // or 106(!)
1550	WFIFOW(fd,0) = 0x6b;
1551	memset(WFIFOP(fd,4), 0, 20); // unknown bytes
1552	j+=mmo_chars_fromsql(sd, WFIFOP(fd,j));
1553	WFIFOW(fd,2) = j; // packet len
1554	WFIFOSET(fd,j);
1555
1556	return 0;
1557	}
1558
1559	int char_married(int pl1, int pl2)
1560	{
1561	if( SQL_ERROR == Sql_Query(sql_handle, "SELECT `partner_id` FROM `%s` WHERE `char_id` = '%d'", char_db, pl1) )
1562	Sql_ShowDebug(sql_handle);
1563	else if( SQL_SUCCESS == Sql_NextRow(sql_handle) )
1564	{
1565	char* data;
1566
1567	Sql_GetData(sql_handle, 0, &data, NULL);
1568	if( pl2 == atoi(data) )
1569	{
1570	Sql_FreeResult(sql_handle);
1571	return 1;
1572	}
1573	}
1574	Sql_FreeResult(sql_handle);
1575	return 0;
1576	}
1577
1578	int char_child(int parent_id, int child_id)
1579	{
1580	if( SQL_ERROR == Sql_Query(sql_handle, "SELECT `child` FROM `%s` WHERE `char_id` = '%d'", char_db, parent_id) )
1581	Sql_ShowDebug(sql_handle);
1582	else if( SQL_SUCCESS == Sql_NextRow(sql_handle) )
1583	{
1584	char* data;
1585
1586	Sql_GetData(sql_handle, 0, &data, NULL);
1587	if( child_id == atoi(data) )
1588	{
1589	Sql_FreeResult(sql_handle);
1590	return 1;
1591	}
1592	}
1593	Sql_FreeResult(sql_handle);
1594	return 0;
1595	}
1596
1597	int char_family(int pl1, int pl2, int pl3)
1598	{
1599	if( SQL_ERROR == Sql_Query(sql_handle, "SELECT `char_id`,`partner_id`,`child` FROM `%s` WHERE `char_id` IN ('%d','%d','%d')", char_db, pl1, pl2, pl3) )
1600	Sql_ShowDebug(sql_handle);
1601	else while( SQL_SUCCESS == Sql_NextRow(sql_handle) )
1602	{
1603	int charid;
1604	int partnerid;
1605	int childid;
1606	char* data;
1607
1608	Sql_GetData(sql_handle, 0, &data, NULL); charid = atoi(data);
1609	Sql_GetData(sql_handle, 1, &data, NULL); partnerid = atoi(data);
1610	Sql_GetData(sql_handle, 2, &data, NULL); childid = atoi(data);
1611
1612	if( (pl1 == charid && ((pl2 == partnerid && pl3 == childid ) \|\| (pl2 == childid && pl3 == partnerid))) \|\|
1613	(pl1 == partnerid && ((pl2 == charid && pl3 == childid ) \|\| (pl2 == childid && pl3 == charid ))) \|\|
1614	(pl1 == childid && ((pl2 == charid && pl3 == partnerid) \|\| (pl2 == partnerid && pl3 == charid ))) )
1615	{
1616	Sql_FreeResult(sql_handle);
1617	return childid;
1618	}
1619	}
1620	Sql_FreeResult(sql_handle);
1621	return 0;
1622	}
1623
1624	static void char_auth_ok(int fd, struct char_session_data *sd)
1625	{
1626	struct online_char_data* character;
1627	if (max_connect_user && count_users() >= max_connect_user && isGM(sd->account_id) < gm_allow_level)
1628	{
1629	// refuse connection (over populated)
1630	WFIFOW(fd,0) = 0x6c;
1631	WFIFOW(fd,2) = 0;
1632	WFIFOSET(fd,3);
1633	return;
1634	}
1635
1636	if( online_check && (character = (struct online_char_data*)idb_get(online_char_db, sd->account_id)) != NULL )
1637	{ // check if character is not online already. [Skotlex]
1638	if (character->server > -1)
1639	{ //Character already online. KICK KICK KICK
1640	mapif_disconnectplayer(server[character->server].fd, character->account_id, character->char_id, 2);
1641	if (character->waiting_disconnect == -1)
1642	character->waiting_disconnect = add_timer(gettick()+20000, chardb_waiting_disconnect, character->account_id, 0);
1643	WFIFOW(fd,0) = 0x81;
1644	WFIFOB(fd,2) = 8;
1645	WFIFOSET(fd,3);
1646	return;
1647	}
1648	if (character->fd >= 0 && character->fd != fd)
1649	{ //There's already a connection from this account that hasn't picked a char yet.
1650	WFIFOW(fd,0) = 0x81;
1651	WFIFOB(fd,2) = 8;
1652	WFIFOSET(fd,3);
1653	return;
1654	}
1655	character->fd = fd;
1656	}
1657
1658	if (login_fd > 0) {
1659	// request to login-server to obtain e-mail/time limit
1660	WFIFOHEAD(login_fd,6);
1661	WFIFOW(login_fd,0) = 0x2716;
1662	WFIFOL(login_fd,2) = sd->account_id;
1663	WFIFOSET(login_fd,6);
1664	}
1665
1666	// mark session as 'authed'
1667	sd->auth = true;
1668
1669	// set char online on charserver
1670	set_char_charselect(sd->account_id);
1671
1672	// send characters to player
1673	mmo_char_send006b(fd, sd);
1674	}
1675
1676	int send_accounts_tologin(int tid, unsigned int tick, int id, intptr data);
1677
1678	int parse_fromlogin(int fd)
1679	{
1680	int i;
1681	struct char_session_data *sd;
1682
1683	// only login-server can have an access to here.
1684	// so, if it isn't the login-server, we disconnect the session.
1685	if( fd != login_fd )
1686	set_eof(fd);
1687
1688	if(session[fd]->flag.eof) {
1689	if (fd == login_fd) {
1690	ShowWarning("Connection to login-server lost (connection #%d).\n", fd);
1691	login_fd = -1;
1692	}
1693	do_close(fd);
1694	return 0;
1695	}
1696
1697	sd = (struct char_session_data*)session[fd]->session_data;
1698
1699	while(RFIFOREST(fd) >= 2)
1700	{
1701	uint16 command = RFIFOW(fd,0);
1702
1703	switch( command )
1704	{
1705
1706	// acknowledgement of connect-to-loginserver request
1707	case 0x2711:
1708	if (RFIFOREST(fd) < 3)
1709	return 0;
1710
1711	if (RFIFOB(fd,2)) {
1712	//printf("connect login server error : %d\n", RFIFOB(fd, 2));
1713	ShowError("Can not connect to login-server.\n");
1714	ShowError("The server communication passwords (default s1/p1) are probably invalid.\n");
1715	ShowError("Also, please make sure your login db has the correct communication username/passwords and the gender of the account is S.\n");
1716	ShowError("The communication passwords are set in map_athena.conf and char_athena.conf\n");
1717	}else {
1718	ShowStatus("Connected to login-server (connection #%d).\n", fd);
1719
1720	//Send online accounts to login server.
1721	send_accounts_tologin(-1, gettick(), 0, 0);
1722
1723	// if no map-server already connected, display a message...
1724	ARR_FIND( 0, MAX_MAP_SERVERS, i, server[i].fd > 0 && server[i].map[0] );
1725	if( i == MAX_MAP_SERVERS )
1726	ShowStatus("Awaiting maps from map-server.\n");
1727	}
1728	RFIFOSKIP(fd,3);
1729	break;
1730
1731	// acknowledgement of account authentication request
1732	case 0x2713:
1733	if (RFIFOREST(fd) < 59)
1734	return 0;
1735	{
1736	int account_id = RFIFOL(fd,2);
1737	int login_id1 = RFIFOL(fd,6);
1738	int login_id2 = RFIFOL(fd,10);
1739	bool result = RFIFOB(fd,14);
1740	const char* email = (const char*)RFIFOP(fd,15);
1741	time_t expiration_time = (time_t)RFIFOL(fd,55);
1742
1743	// find the session with this account id
1744	ARR_FIND( 0, fd_max, i, session[i] && (sd = (struct char_session_data*)session[i]->session_data) &&
1745	sd->account_id == account_id && sd->login_id1 == login_id1 && sd->login_id2 == login_id2 );
1746	if( i < fd_max )
1747	{
1748	if( result ) { // failure
1749	WFIFOHEAD(i,3);
1750	WFIFOW(i,0) = 0x6c;
1751	WFIFOB(i,2) = 0x42;
1752	WFIFOSET(i,3);
1753	} else { // success
1754	memcpy(sd->email, email, 40);
1755	sd->expiration_time = expiration_time;
1756	char_auth_ok(i, sd);
1757	}
1758	}
1759	}
1760	RFIFOSKIP(fd,59);
1761	break;
1762
1763	// acknowledgement of e-mail/limited time request
1764	case 0x2717:
1765	if (RFIFOREST(fd) < 50)
1766	return 0;
1767
1768	// find the session with this account id
1769	ARR_FIND( 0, fd_max, i, session[i] && (sd = (struct char_session_data*)session[i]->session_data) && sd->account_id == RFIFOL(fd,2) );
1770	if( i < fd_max )
1771	{
1772	memcpy(sd->email, RFIFOP(fd,6), 40);
1773	sd->expiration_time = (time_t)RFIFOL(fd,46);
1774	}
1775	RFIFOSKIP(fd,50);
1776	break;
1777
1778	// login-server alive packet
1779	case 0x2718:
1780	if (RFIFOREST(fd) < 2)
1781	return 0;
1782	RFIFOSKIP(fd,2);
1783	break;
1784
1785	// changesex reply
1786	case 0x2723:
1787	if (RFIFOREST(fd) < 7)
1788	return 0;
1789	{
1790	unsigned char buf[16];
1791
1792	int acc = RFIFOL(fd,2);
1793	int sex = RFIFOB(fd,6);
1794	RFIFOSKIP(fd,7);
1795
1796	if( acc > 0 )
1797	{
1798	int char_id[MAX_CHARS];
1799	int class_[MAX_CHARS];
1800	int guild_id[MAX_CHARS];
1801	int num;
1802	int i;
1803	char* data;
1804
1805	struct auth_node* node = (struct auth_node*)idb_get(auth_db, acc);
1806	if( node != NULL )
1807	node->sex = sex;
1808
1809	// get characters
1810	if( SQL_ERROR == Sql_Query(sql_handle, "SELECT `char_id`,`class`,`guild_id` FROM `%s` WHERE `account_id` = '%d'", char_db, acc) )
1811	Sql_ShowDebug(sql_handle);
1812	for( i = 0; i < MAX_CHARS && SQL_SUCCESS == Sql_NextRow(sql_handle); ++i )
1813	{
1814	Sql_GetData(sql_handle, 0, &data, NULL); char_id[i] = atoi(data);
1815	Sql_GetData(sql_handle, 1, &data, NULL); class_[i] = atoi(data);
1816	Sql_GetData(sql_handle, 2, &data, NULL); guild_id[i] = atoi(data);
1817	}
1818	num = i;
1819	for( i = 0; i < num; ++i )
1820	{
1821	if( class_[i] == JOB_BARD \|\| class_[i] == JOB_DANCER \|\|
1822	class_[i] == JOB_CLOWN \|\| class_[i] == JOB_GYPSY \|\|
1823	class_[i] == JOB_BABY_BARD \|\| class_[i] == JOB_BABY_DANCER )
1824	{
1825	// job modification
1826	if( class_[i] == JOB_BARD \|\| class_[i] == JOB_DANCER )
1827	class_[i] = (sex ? JOB_BARD : JOB_DANCER);
1828	else if( class_[i] == JOB_CLOWN \|\| class_[i] == JOB_GYPSY )
1829	class_[i] = (sex ? JOB_CLOWN : JOB_GYPSY);
1830	else if( class_[i] == JOB_BABY_BARD \|\| class_[i] == JOB_BABY_DANCER )
1831	class_[i] = (sex ? JOB_BABY_BARD : JOB_BABY_DANCER);
1832	// remove specifical skills of classes 19,20 4020,4021 and 4042,4043
1833	if( SQL_ERROR == Sql_Query(sql_handle, "UPDATE `%s` SET `skill_point` = `skill_point` +"
1834	" (SELECT SUM(lv) FROM `%s` WHERE `char_id` = '%d' AND `id` >= '315' AND `id` <= '330' AND `lv` > '0')"
1835	" WHERE `char_id` = '%d'",
1836	char_db, skill_db, char_id[i], char_id[i]) )
1837	Sql_ShowDebug(sql_handle);
1838	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `char_id` = '%d' AND `id` >= '315' AND `id` <= '330'", skill_db, char_id[i]) )
1839	Sql_ShowDebug(sql_handle);
1840	}
1841	// to avoid any problem with equipment and invalid sex, equipment is unequiped.
1842	if( SQL_ERROR == Sql_Query(sql_handle, "UPDATE `%s` SET `equip` = '0' WHERE `char_id` = '%d'", inventory_db, char_id[i]) )
1843	Sql_ShowDebug(sql_handle);
1844	if( SQL_ERROR == Sql_Query(sql_handle, "UPDATE `%s` SET `class`='%d', `weapon`='0', `shield`='0', `head_top`='0', `head_mid`='0', `head_bottom`='0' WHERE `char_id`='%d'", char_db, class_[i], char_id[i]) )
1845	Sql_ShowDebug(sql_handle);
1846
1847	if( guild_id[i] )// If there is a guild, update the guild_member data [Skotlex]
1848	inter_guild_sex_changed(guild_id[i], acc, char_id[i], sex);
1849	}
1850	Sql_FreeResult(sql_handle);
1851	}
1852
1853	// disconnect player if online on char-server
1854	ARR_FIND( 0, fd_max, i, session[i] && (sd = (struct char_session_data*)session[i]->session_data) && sd->account_id == acc );
1855	if( i < fd_max )
1856	set_eof(i);
1857
1858	// notify all mapservers about this change
1859	WBUFW(buf,0) = 0x2b0d;
1860	WBUFL(buf,2) = acc;
1861	WBUFB(buf,6) = sex;
1862	mapif_sendall(buf, 7);
1863	}
1864	break;
1865
1866	// reply to an account_reg2 registry request
1867	case 0x2729:
1868	if (RFIFOREST(fd) < 4 \|\| RFIFOREST(fd) < RFIFOW(fd,2))
1869	return 0;
1870
1871	{ //Receive account_reg2 registry, forward to map servers.
1872	unsigned char buf[ACCOUNT_REG2_NUM*(256+32+2)+16];
1873	memcpy(buf,RFIFOP(fd,0), RFIFOW(fd,2));
1874	WBUFW(buf,0) = 0x3804; //Map server can now receive all kinds of reg values with the same packet. [Skotlex]
1875	mapif_sendall(buf, WBUFW(buf,2));
1876	}
1877	RFIFOSKIP(fd, RFIFOW(fd,2));
1878	break;
1879
1880	// State change of account/ban notification (from login-server)
1881	case 0x2731:
1882	if (RFIFOREST(fd) < 11)
1883	return 0;
1884
1885	{ // send to all map-servers to disconnect the player
1886	unsigned char buf[11];
1887	WBUFW(buf,0) = 0x2b14;
1888	WBUFL(buf,2) = RFIFOL(fd,2);
1889	WBUFB(buf,6) = RFIFOB(fd,6); // 0: change of statut, 1: ban
1890	WBUFL(buf,7) = RFIFOL(fd,7); // status or final date of a banishment
1891	mapif_sendall(buf, 11);
1892	}
1893	// disconnect player if online on char-server
1894	ARR_FIND( 0, fd_max, i, session[i] && (sd = (struct char_session_data*)session[i]->session_data) && sd->account_id == RFIFOL(fd,2) );
1895	if( i < fd_max )
1896	set_eof(i);
1897
1898	RFIFOSKIP(fd,11);
1899	break;
1900
1901	// gm account information from login server
1902	case 0x2732:
1903	if (RFIFOREST(fd) < 4 \|\| RFIFOREST(fd) < RFIFOW(fd,2))
1904	return 0;
1905
1906	if(!char_gm_read) {
1907	unsigned char buf[32000]; //FIXME: this will crash
1908	if (gm_account != NULL)
1909	aFree(gm_account);
1910	gm_account = (struct gm_account)aCalloc(sizeof(struct gm_account) ((RFIFOW(fd,2) - 4) / 5), 1);
1911	GM_num = 0;
1912	for (i = 4; i < RFIFOW(fd,2); i = i + 5) {
1913	gm_account[GM_num].account_id = RFIFOL(fd,i);
1914	gm_account[GM_num].level = (int)RFIFOB(fd,i+4);
1915	//printf("GM account: %d -> level %d\n", gm_account[GM_num].account_id, gm_account[GM_num].level);
1916	GM_num++;
1917	}
1918	ShowStatus("From login-server: receiving information of %d GM accounts.\n", GM_num);
1919	// send new gm acccounts level to map-servers
1920	memcpy(buf, RFIFOP(fd,0), RFIFOW(fd,2));
1921	WBUFW(buf,0) = 0x2b15;
1922	mapif_sendall(buf, RFIFOW(fd,2));
1923	}
1924
1925	RFIFOSKIP(fd,RFIFOW(fd,2));
1926	break;
1927
1928	// Login server request to kick a character out. [Skotlex]
1929	case 0x2734:
1930	if (RFIFOREST(fd) < 6)
1931	return 0;
1932	{
1933	int aid = RFIFOL(fd,2);
1934	struct online_char_data* character = (struct online_char_data*)idb_get(online_char_db, aid);
1935	RFIFOSKIP(fd,6);
1936	if( character != NULL )
1937	{// account is already marked as online!
1938	if( character->server > -1 )
1939	{ //Kick it from the map server it is on.
1940	mapif_disconnectplayer(server[character->server].fd, character->account_id, character->char_id, 2);
1941	if (character->waiting_disconnect == -1)
1942	character->waiting_disconnect = add_timer(gettick()+AUTH_TIMEOUT, chardb_waiting_disconnect, character->account_id, 0);
1943	}
1944	else
1945	{// Manual kick from char server.
1946	struct char_session_data *tsd;
1947	int i;
1948	ARR_FIND( 0, fd_max, i, session[i] && (tsd = (struct char_session_data*)session[i]->session_data) && tsd->account_id == aid );
1949	if( i < fd_max )
1950	{
1951	WFIFOHEAD(i,3);
1952	WFIFOW(i,0) = 0x81;
1953	WFIFOB(i,2) = 2; // "Someone has already logged in with this id"
1954	WFIFOSET(i,3);
1955	set_eof(i);
1956	}
1957	else //Shouldn't happen, but just in case.
1958	set_char_offline(-1, aid);
1959	}
1960	}
1961	}
1962	break;
1963
1964	// ip address update signal from login server
1965	case 0x2735:
1966	{
1967	unsigned char buf[2];
1968	uint32 new_ip = 0;
1969
1970	WBUFW(buf,0) = 0x2b1e;
1971	mapif_sendall(buf, 2);
1972
1973	new_ip = host2ip(login_ip_str);
1974	if (new_ip && new_ip != login_ip) //Update login ip, too.
1975	login_ip = new_ip;
1976
1977	new_ip = host2ip(char_ip_str);
1978	if (new_ip && new_ip != char_ip)
1979	{ //Update ip.
1980	char_ip = new_ip;
1981	ShowInfo("Updating IP for [%s].\n", char_ip_str);
1982	// notify login server about the change
1983	WFIFOHEAD(fd,6);
1984	WFIFOW(fd,0) = 0x2736;
1985	WFIFOL(fd,2) = htonl(char_ip);
1986	WFIFOSET(fd,6);
1987	}
1988	}
1989
1990	RFIFOSKIP(fd,2);
1991	break;
1992
1993	default:
1994	ShowError("Unknown packet 0x%04x received from login server, disconnecting.\n", command);
1995	set_eof(fd);
1996	return 0;
1997	}
1998	}
1999
2000	RFIFOFLUSH(fd);
2001	return 0;
2002	}
2003
2004	int request_accreg2(int account_id, int char_id)
2005	{
2006	if (login_fd > 0) {
2007	WFIFOHEAD(login_fd,10);
2008	WFIFOW(login_fd,0) = 0x272e;
2009	WFIFOL(login_fd,2) = account_id;
2010	WFIFOL(login_fd,6) = char_id;
2011	WFIFOSET(login_fd,10);
2012	return 1;
2013	}
2014	return 0;
2015	}
2016
2017	//Send packet forward to login-server for account saving
2018	int save_accreg2(unsigned char* buf, int len)
2019	{
2020	if (login_fd > 0) {
2021	WFIFOHEAD(login_fd,len+4);
2022	memcpy(WFIFOP(login_fd,4), buf, len);
2023	WFIFOW(login_fd,0) = 0x2728;
2024	WFIFOW(login_fd,2) = len+4;
2025	WFIFOSET(login_fd,len+4);
2026	return 1;
2027	}
2028	return 0;
2029	}
2030
2031	void char_read_fame_list(void)
2032	{
2033	int i;
2034	char* data;
2035	size_t len;
2036
2037	// Empty ranking lists
2038	memset(smith_fame_list, 0, sizeof(smith_fame_list));
2039	memset(chemist_fame_list, 0, sizeof(chemist_fame_list));
2040	memset(taekwon_fame_list, 0, sizeof(taekwon_fame_list));
2041	// Build Blacksmith ranking list
2042	if( SQL_ERROR == Sql_Query(sql_handle, "SELECT `char_id`,`fame`,`name` FROM `%s` WHERE `fame`>0 AND (`class`='%d' OR `class`='%d' OR `class`='%d') ORDER BY `fame` DESC LIMIT 0,%d", char_db, JOB_BLACKSMITH, JOB_WHITESMITH, JOB_BABY_BLACKSMITH, fame_list_size_smith) )
2043	Sql_ShowDebug(sql_handle);
2044	for( i = 0; i < fame_list_size_smith && SQL_SUCCESS == Sql_NextRow(sql_handle); ++i )
2045	{
2046	// char_id
2047	Sql_GetData(sql_handle, 0, &data, NULL);
2048	smith_fame_list[i].id = atoi(data);
2049	// fame
2050	Sql_GetData(sql_handle, 1, &data, &len);
2051	smith_fame_list[i].fame = atoi(data);
2052	// name
2053	Sql_GetData(sql_handle, 2, &data, &len);
2054	memcpy(smith_fame_list[i].name, data, min(len, NAME_LENGTH));
2055	}
2056	// Build Alchemist ranking list
2057	if( SQL_ERROR == Sql_Query(sql_handle, "SELECT `char_id`,`fame`,`name` FROM `%s` WHERE `fame`>0 AND (`class`='%d' OR `class`='%d' OR `class`='%d') ORDER BY `fame` DESC LIMIT 0,%d", char_db, JOB_ALCHEMIST, JOB_CREATOR, JOB_BABY_ALCHEMIST, fame_list_size_chemist) )
2058	Sql_ShowDebug(sql_handle);
2059	for( i = 0; i < fame_list_size_chemist && SQL_SUCCESS == Sql_NextRow(sql_handle); ++i )
2060	{
2061	// char_id
2062	Sql_GetData(sql_handle, 0, &data, NULL);
2063	chemist_fame_list[i].id = atoi(data);
2064	// fame
2065	Sql_GetData(sql_handle, 1, &data, &len);
2066	chemist_fame_list[i].fame = atoi(data);
2067	// name
2068	Sql_GetData(sql_handle, 2, &data, &len);
2069	memcpy(chemist_fame_list[i].name, data, min(len, NAME_LENGTH));
2070	}
2071	// Build Taekwon ranking list
2072	if( SQL_ERROR == Sql_Query(sql_handle, "SELECT `char_id`,`fame`,`name` FROM `%s` WHERE `fame`>0 AND (`class`='%d') ORDER BY `fame` DESC LIMIT 0,%d", char_db, JOB_TAEKWON, fame_list_size_taekwon) )
2073	Sql_ShowDebug(sql_handle);
2074	for( i = 0; i < fame_list_size_taekwon && SQL_SUCCESS == Sql_NextRow(sql_handle); ++i )
2075	{
2076	// char_id
2077	Sql_GetData(sql_handle, 0, &data, NULL);
2078	taekwon_fame_list[i].id = atoi(data);
2079	// fame
2080	Sql_GetData(sql_handle, 1, &data, &len);
2081	taekwon_fame_list[i].fame = atoi(data);
2082	// name
2083	Sql_GetData(sql_handle, 2, &data, &len);
2084	memcpy(taekwon_fame_list[i].name, data, min(len, NAME_LENGTH));
2085	}
2086	Sql_FreeResult(sql_handle);
2087	}
2088
2089	// Send map-servers the fame ranking lists
2090	int char_send_fame_list(int fd)
2091	{
2092	int i, len = 8;
2093	unsigned char buf[32000];
2094
2095	WBUFW(buf,0) = 0x2b1b;
2096
2097	for(i = 0; i < fame_list_size_smith && smith_fame_list[i].id; i++) {
2098	memcpy(WBUFP(buf, len), &smith_fame_list[i], sizeof(struct fame_list));
2099	len += sizeof(struct fame_list);
2100	}
2101	// add blacksmith's block length
2102	WBUFW(buf, 6) = len;
2103
2104	for(i = 0; i < fame_list_size_chemist && chemist_fame_list[i].id; i++) {
2105	memcpy(WBUFP(buf, len), &chemist_fame_list[i], sizeof(struct fame_list));
2106	len += sizeof(struct fame_list);
2107	}
2108	// add alchemist's block length
2109	WBUFW(buf, 4) = len;
2110
2111	for(i = 0; i < fame_list_size_taekwon && taekwon_fame_list[i].id; i++) {
2112	memcpy(WBUFP(buf, len), &taekwon_fame_list[i], sizeof(struct fame_list));
2113	len += sizeof(struct fame_list);
2114	}
2115	// add total packet length
2116	WBUFW(buf, 2) = len;
2117
2118	if (fd != -1)
2119	mapif_send(fd, buf, len);
2120	else
2121	mapif_sendall(buf, len);
2122	return 0;
2123	}
2124
2125	void char_update_fame_list(int type, int index, int fame)
2126	{
2127	unsigned char buf[8];
2128	WBUFW(buf,0) = 0x2b22;
2129	WBUFB(buf,2) = type;
2130	WBUFB(buf,3) = index;
2131	WBUFL(buf,4) = fame;
2132	mapif_sendall(buf, 8);
2133	}
2134
2135	//Loads a character's name and stores it in the buffer given (must be NAME_LENGTH in size)
2136	//Returns 1 on found, 0 on not found (buffer is filled with Unknown char name)
2137	int char_loadName(int char_id, char* name)
2138	{
2139	char* data;
2140	size_t len;
2141
2142	if( SQL_ERROR == Sql_Query(sql_handle, "SELECT `name` FROM `%s` WHERE `char_id`='%d'", char_db, char_id) )
2143	Sql_ShowDebug(sql_handle);
2144	else if( SQL_SUCCESS == Sql_NextRow(sql_handle) )
2145	{
2146	Sql_GetData(sql_handle, 0, &data, &len);
2147	memset(name, 0, NAME_LENGTH);
2148	memcpy(name, data, min(len, NAME_LENGTH));
2149	return 1;
2150	}
2151	else
2152	{
2153	memcpy(name, unknown_char_name, NAME_LENGTH);
2154	}
2155	return 0;
2156	}
2157
2158	int search_mapserver(unsigned short map, uint32 ip, uint16 port);
2159
2160	int parse_frommap(int fd)
2161	{
2162	int i = 0, j = 0;
2163	int id;
2164
2165	// Sometimes fd=0, and it will cause server crash. Don't know why. :(
2166	if (fd <= 0) {
2167	ShowError("parse_frommap error fd=%d\n", fd);
2168	return 0;
2169	}
2170
2171	ARR_FIND( 0, MAX_MAP_SERVERS, id, server[id].fd == fd );
2172	if(id == MAX_MAP_SERVERS)
2173	set_eof(fd);
2174	if(session[fd]->flag.eof) {
2175	if (id < MAX_MAP_SERVERS) {
2176	unsigned char buf[16384];
2177	ShowStatus("Map-server %d (session #%d) has disconnected.\n", id, fd);
2178	//Notify other map servers that this one is gone. [Skotlex]
2179	WBUFW(buf,0) = 0x2b20;
2180	WBUFL(buf,4) = htonl(server[id].ip);
2181	WBUFW(buf,8) = htons(server[id].port);
2182	j = 0;
2183	for(i = 0; i < MAX_MAP_PER_SERVER; i++)
2184	if (server[id].map[i])
2185	WBUFW(buf,10+(j++)*4) = server[id].map[i];
2186	if (j > 0) {
2187	WBUFW(buf,2) = j * 4 + 10;
2188	mapif_sendallwos(fd, buf, WBUFW(buf,2));
2189	}
2190	memset(&server[id], 0, sizeof(struct mmo_map_server));
2191	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `ragsrvinfo` WHERE `index`='%d'", server[id].fd) )
2192	Sql_ShowDebug(sql_handle);
2193	server[id].fd = -1;
2194	online_char_db->foreach(online_char_db,char_db_setoffline,id); //Tag relevant chars as 'in disconnected' server.
2195	}
2196	do_close(fd);
2197	return 0;
2198	}
2199
2200	while(RFIFOREST(fd) >= 2)
2201	{
2202	switch(RFIFOW(fd, 0))
2203	{
2204
2205	case 0x2af7: // request from map-server to reload GM accounts. Transmission to login-server
2206	if(char_gm_read) //Re-read gm accounts.
2207	read_gm_account();
2208	//Send to login request to reload gm accounts.
2209	else if (login_fd > 0) { // don't send request if no login-server
2210	WFIFOHEAD(login_fd,2);
2211	WFIFOW(login_fd,0) = 0x2709;
2212	WFIFOSET(login_fd,2);
2213	}
2214	RFIFOSKIP(fd,2);
2215	break;
2216
2217	case 0x2afa: // Receiving map names list from the map-server
2218	if (RFIFOREST(fd) < 4 \|\| RFIFOREST(fd) < RFIFOW(fd,2))
2219	return 0;
2220
2221	memset(server[id].map, 0, sizeof(server[id].map));
2222	j = 0;
2223	for(i = 4; i < RFIFOW(fd,2); i += 4) {
2224	server[id].map[j] = RFIFOW(fd,i);
2225	j++;
2226	}
2227
2228	ShowStatus("Map-Server %d connected: %d maps, from IP %d.%d.%d.%d port %d.\n",
2229	id, j, CONVIP(server[id].ip), server[id].port);
2230	ShowStatus("Map-server %d loading complete.\n", id);
2231
2232	// send name for wisp to player
2233	WFIFOHEAD(fd, 3 + NAME_LENGTH);
2234	WFIFOW(fd,0) = 0x2afb;
2235	WFIFOB(fd,2) = 0;
2236	memcpy(WFIFOP(fd,3), wisp_server_name, NAME_LENGTH);
2237	WFIFOSET(fd,3+NAME_LENGTH);
2238
2239	char_send_fame_list(fd); //Send fame list.
2240
2241	{
2242	unsigned char buf[16384];
2243	int x;
2244	if (j == 0) {
2245	ShowWarning("Map-server %d has NO maps.\n", id);
2246	} else {
2247	// Transmitting maps information to the other map-servers
2248	WBUFW(buf,0) = 0x2b04;
2249	WBUFW(buf,2) = j * 4 + 10;
2250	WBUFL(buf,4) = htonl(server[id].ip);
2251	WBUFW(buf,8) = htons(server[id].port);
2252	memcpy(WBUFP(buf,10), RFIFOP(fd,4), j * 4);
2253	mapif_sendallwos(fd, buf, WBUFW(buf,2));
2254	}
2255	// Transmitting the maps of the other map-servers to the new map-server
2256	for(x = 0; x < MAX_MAP_SERVERS; x++) {
2257	if (server[x].fd > 0 && x != id) {
2258	WFIFOHEAD(fd,10 +4*MAX_MAP_PER_SERVER);
2259	WFIFOW(fd,0) = 0x2b04;
2260	WFIFOL(fd,4) = htonl(server[x].ip);
2261	WFIFOW(fd,8) = htons(server[x].port);
2262	j = 0;
2263	for(i = 0; i < MAX_MAP_PER_SERVER; i++)
2264	if (server[x].map[i])
2265	WFIFOW(fd,10+(j++)*4) = server[x].map[i];
2266	if (j > 0) {
2267	WFIFOW(fd,2) = j * 4 + 10;
2268	WFIFOSET(fd,WFIFOW(fd,2));
2269	}
2270	}
2271	}
2272	}
2273	RFIFOSKIP(fd,RFIFOW(fd,2));
2274	break;
2275
2276	case 0x2afc: //Packet command is now used for sc_data request. [Skotlex]
2277	if (RFIFOREST(fd) < 10)
2278	return 0;
2279	{
2280	#ifdef ENABLE_SC_SAVING
2281	int aid, cid;
2282	aid = RFIFOL(fd,2);
2283	cid = RFIFOL(fd,6);
2284	if( SQL_ERROR == Sql_Query(sql_handle, "SELECT type, tick, val1, val2, val3, val4 from `%s` WHERE `account_id` = '%d' AND `char_id`='%d'",
2285	scdata_db, aid, cid) )
2286	{
2287	Sql_ShowDebug(sql_handle);
2288	break;
2289	}
2290	if( Sql_NumRows(sql_handle) > 0 )
2291	{
2292	struct status_change_data scdata;
2293	int count;
2294	char* data;
2295
2296	WFIFOHEAD(fd,14+50*sizeof(struct status_change_data));
2297	WFIFOW(fd,0) = 0x2b1d;
2298	WFIFOL(fd,4) = aid;
2299	WFIFOL(fd,8) = cid;
2300	for( count = 0; count < 50 && SQL_SUCCESS == Sql_NextRow(sql_handle); ++count )
2301	{
2302	Sql_GetData(sql_handle, 0, &data, NULL); scdata.type = atoi(data);
2303	Sql_GetData(sql_handle, 1, &data, NULL); scdata.tick = atoi(data);
2304	Sql_GetData(sql_handle, 2, &data, NULL); scdata.val1 = atoi(data);
2305	Sql_GetData(sql_handle, 3, &data, NULL); scdata.val2 = atoi(data);
2306	Sql_GetData(sql_handle, 4, &data, NULL); scdata.val3 = atoi(data);
2307	Sql_GetData(sql_handle, 5, &data, NULL); scdata.val4 = atoi(data);
2308	memcpy(WFIFOP(fd, 14+count*sizeof(struct status_change_data)), &scdata, sizeof(struct status_change_data));
2309	}
2310	if (count >= 50)
2311	ShowWarning("Too many status changes for %d:%d, some of them were not loaded.\n", aid, cid);
2312	if (count > 0)
2313	{
2314	WFIFOW(fd,2) = 14 + count*sizeof(struct status_change_data);
2315	WFIFOW(fd,12) = count;
2316	WFIFOSET(fd,WFIFOW(fd,2));
2317
2318	//Clear the data once loaded.
2319	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `account_id` = '%d' AND `char_id`='%d'", scdata_db, aid, cid) )
2320	Sql_ShowDebug(sql_handle);
2321	}
2322	}
2323	Sql_FreeResult(sql_handle);
2324	#endif
2325	RFIFOSKIP(fd, 10);
2326	}
2327	break;
2328
2329	case 0x2afe: //set MAP user count
2330	if (RFIFOREST(fd) < 4)
2331	return 0;
2332	if (RFIFOW(fd,2) != server[id].users) {
2333	server[id].users = RFIFOW(fd,2);
2334	ShowInfo("User Count: %d (Server: %d)\n", server[id].users, id);
2335	}
2336	RFIFOSKIP(fd, 4);
2337	break;
2338
2339	case 0x2aff: //set MAP users
2340	if (RFIFOREST(fd) < 6 \|\| RFIFOREST(fd) < RFIFOW(fd,2))
2341	return 0;
2342	{
2343	//TODO: When data mismatches memory, update guild/party online/offline states.
2344	int i, aid, cid;
2345	struct online_char_data* character;
2346
2347	online_char_db->foreach(online_char_db,char_db_setoffline,id); //Set all chars from this server as 'unknown'
2348	server[id].users = RFIFOW(fd,4);
2349	for(i = 0; i < server[id].users; i++) {
2350	aid = RFIFOL(fd,6+i*8);
2351	cid = RFIFOL(fd,6+i*8+4);
2352	character = (struct online_char_data*)idb_ensure(online_char_db, aid, create_online_char_data);
2353	if (character->server > -1 && character->server != id)
2354	{
2355	ShowNotice("Set map user: Character (%d:%d) marked on map server %d, but map server %d claims to have (%d:%d) online!\n",
2356	character->account_id, character->char_id, character->server, id, aid, cid);
2357	mapif_disconnectplayer(server[character->server].fd, character->account_id, character->char_id, 2);
2358	}
2359	character->server = id;
2360	character->char_id = cid;
2361	}
2362	//If any chars remain in -2, they will be cleaned in the cleanup timer.
2363	RFIFOSKIP(fd,RFIFOW(fd,2));
2364	}
2365	break;
2366
2367	case 0x2b01: // Receive character data from map-server for saving
2368	if (RFIFOREST(fd) < 4 \|\| RFIFOREST(fd) < RFIFOW(fd,2))
2369	return 0;
2370	{
2371	int aid = RFIFOL(fd,4), cid = RFIFOL(fd,8), size = RFIFOW(fd,2);
2372	struct online_char_data* character;
2373	if (size - 13 != sizeof(struct mmo_charstatus))
2374	{
2375	ShowError("parse_from_map (save-char): Size mismatch! %d != %d\n", size-13, sizeof(struct mmo_charstatus));
2376	RFIFOSKIP(fd,size);
2377	break;
2378	}
2379	//Check account only if this ain't final save. Final-save goes through because of the char-map reconnect
2380	if (RFIFOB(fd,12) \|\| (
2381	(character = (struct online_char_data*)idb_get(online_char_db, aid)) != NULL &&
2382	character->char_id == cid))
2383	{
2384	struct mmo_charstatus char_dat;
2385	memcpy(&char_dat, RFIFOP(fd,13), sizeof(struct mmo_charstatus));
2386	mmo_char_tosql(cid, &char_dat);
2387	} else { //This may be valid on char-server reconnection, when re-sending characters that already logged off.
2388	ShowError("parse_from_map (save-char): Received data for non-existant/offline character (%d:%d).\n", aid, cid);
2389	set_char_online(id, cid, aid);
2390	}
2391
2392	if (RFIFOB(fd,12))
2393	{ //Flag? Set character offline after saving [Skotlex]
2394	set_char_offline(cid, aid);
2395	WFIFOHEAD(fd,10);
2396	WFIFOW(fd,0) = 0x2b21; //Save ack only needed on final save.
2397	WFIFOL(fd,2) = aid;
2398	WFIFOL(fd,6) = cid;
2399	WFIFOSET(fd,10);
2400	}
2401	RFIFOSKIP(fd,size);
2402	}
2403	break;
2404
2405	case 0x2b02: // req char selection
2406	if( RFIFOREST(fd) < 18 )
2407	return 0;
2408	{
2409	struct auth_node* node;
2410
2411	int account_id = RFIFOL(fd,2);
2412	uint32 login_id1 = RFIFOL(fd,6);
2413	uint32 login_id2 = RFIFOL(fd,10);
2414	uint32 ip = RFIFOL(fd,14);
2415	RFIFOSKIP(fd,18);
2416
2417	// create temporary auth entry
2418	CREATE(node, struct auth_node, 1);
2419	node->account_id = account_id;
2420	node->char_id = 0;
2421	node->login_id1 = login_id1;
2422	node->login_id2 = login_id2;
2423	//node->sex = 0;
2424	node->ip = ntohl(ip);
2425	node->expiration_time = 0; // unlimited/unknown time by default (not display in map-server)
2426	idb_put(auth_db, account_id, node);
2427
2428	//Set char to "@ char select" in online db [Kevin]
2429	set_char_charselect(account_id);
2430
2431	WFIFOHEAD(fd,7);
2432	WFIFOW(fd,0) = 0x2b03;
2433	WFIFOL(fd,2) = account_id;
2434	WFIFOB(fd,6) = 0;
2435	WFIFOSET(fd,7);
2436	}
2437	break;
2438
2439	case 0x2b05: // request "change map server"
2440	if (RFIFOREST(fd) < 35)
2441	return 0;
2442	{
2443	int map_id, map_fd = -1;
2444	struct online_char_data* data;
2445	struct mmo_charstatus* char_data;
2446	struct mmo_charstatus char_dat;
2447
2448	map_id = search_mapserver(RFIFOW(fd,18), ntohl(RFIFOL(fd,24)), ntohs(RFIFOW(fd,28))); //Locate mapserver by ip and port.
2449	if (map_id >= 0)
2450	map_fd = server[map_id].fd;
2451	//Char should just had been saved before this packet, so this should be safe. [Skotlex]
2452	char_data = (struct mmo_charstatus*)uidb_get(char_db_,RFIFOL(fd,14));
2453	if (char_data == NULL)
2454	{ //Really shouldn't happen.
2455	mmo_char_fromsql(RFIFOL(fd,14), &char_dat, true);
2456	char_data = (struct mmo_charstatus*)uidb_get(char_db_,RFIFOL(fd,14));
2457	}
2458	//Tell the new map server about this player using Kevin's new auth packet. [Skotlex]
2459	if (map_fd >= 0 && session[map_fd] && char_data)
2460	{ //Send the map server the auth of this player.
2461	struct auth_node* node;
2462
2463	//Update the "last map" as this is where the player must be spawned on the new map server.
2464	char_data->last_point.map = RFIFOW(fd,18);
2465	char_data->last_point.x = RFIFOW(fd,20);
2466	char_data->last_point.y = RFIFOW(fd,22);
2467	char_data->sex = RFIFOB(fd,30);
2468
2469	#if 0
2470	// the map-server must request it [FlavioJS]
2471	WFIFOHEAD(map_fd, 20 + sizeof(struct mmo_charstatus));
2472	WFIFOW(map_fd,0) = 0x2afd;
2473	WFIFOW(map_fd,2) = 20 + sizeof(struct mmo_charstatus);
2474	WFIFOL(map_fd,4) = RFIFOL(fd,2); //Account ID
2475	WFIFOL(map_fd,8) = RFIFOL(fd,6); //Login1
2476	WFIFOL(map_fd,16) = RFIFOL(fd,10); //Login2
2477	WFIFOL(map_fd,12) = (unsigned long)0; //TODO: expiration_time, how do I figure it out right now?
2478	memcpy(WFIFOP(map_fd,20), char_data, sizeof(struct mmo_charstatus));
2479	WFIFOSET(map_fd, WFIFOW(map_fd,2));
2480	#endif
2481
2482	// create temporary auth entry
2483	CREATE(node, struct auth_node, 1);
2484	node->account_id = RFIFOL(fd,2);
2485	node->char_id = RFIFOL(fd,14);
2486	node->login_id1 = RFIFOL(fd,6);
2487	node->login_id2 = RFIFOL(fd,10);
2488	node->sex = RFIFOB(fd,30);
2489	node->expiration_time = 0; // FIXME
2490	node->ip = ntohl(RFIFOL(fd,31));
2491	idb_put(auth_db, RFIFOL(fd,2), node);
2492
2493	data = (struct online_char_data*)idb_ensure(online_char_db, RFIFOL(fd,2), create_online_char_data);
2494	data->char_id = char_data->char_id;
2495	data->server = map_id; //Update server where char is.
2496
2497	//Reply with an ack.
2498	WFIFOHEAD(fd,30);
2499	WFIFOW(fd,0) = 0x2b06;
2500	memcpy(WFIFOP(fd,2), RFIFOP(fd,2), 28);
2501	WFIFOSET(fd,30);
2502	} else { //Reply with nak
2503	WFIFOHEAD(fd,30);
2504	WFIFOW(fd,0) = 0x2b06;
2505	memcpy(WFIFOP(fd,2), RFIFOP(fd,2), 28);
2506	WFIFOL(fd,6) = 0; //Set login1 to 0.
2507	WFIFOSET(fd,30);
2508	}
2509	RFIFOSKIP(fd,35);
2510	}
2511	break;
2512
2513	case 0x2b08: // char name request
2514	if (RFIFOREST(fd) < 6)
2515	return 0;
2516
2517	WFIFOHEAD(fd,30);
2518	WFIFOW(fd,0) = 0x2b09;
2519	WFIFOL(fd,2) = RFIFOL(fd,2);
2520	char_loadName((int)RFIFOL(fd,2), (char*)WFIFOP(fd,6));
2521	WFIFOSET(fd,30);
2522
2523	RFIFOSKIP(fd,6);
2524	break;
2525
2526	case 0x2b0c: // Map server send information to change an email of an account -> login-server
2527	if (RFIFOREST(fd) < 86)
2528	return 0;
2529	if (login_fd > 0) { // don't send request if no login-server
2530	WFIFOHEAD(login_fd,86);
2531	memcpy(WFIFOP(login_fd,0), RFIFOP(fd,0),86); // 0x2722 <account_id>.L <actual_e-mail>.40B <new_e-mail>.40B
2532	WFIFOW(login_fd,0) = 0x2722;
2533	WFIFOSET(login_fd,86);
2534	}
2535	RFIFOSKIP(fd, 86);
2536	break;
2537
2538	case 0x2b0e: // Request from map-server to change an account's status (will just be forwarded to login server)
2539	if (RFIFOREST(fd) < 44)
2540	return 0;
2541	{
2542	int result = 0; // 0-login-server request done, 1-player not found, 2-gm level too low, 3-login-server offline
2543	char esc_name[NAME_LENGTH*2+1];
2544
2545	int acc = RFIFOL(fd,2); // account_id of who ask (-1 if server itself made this request)
2546	const char* name = (char*)RFIFOP(fd,6); // name of the target character
2547	int type = RFIFOW(fd,30); // type of operation: 1-block, 2-ban, 3-unblock, 4-unban
2548	short year = RFIFOW(fd,32);
2549	short month = RFIFOW(fd,34);
2550	short day = RFIFOW(fd,36);
2551	short hour = RFIFOW(fd,38);
2552	short minute = RFIFOW(fd,40);
2553	short second = RFIFOW(fd,42);
2554	RFIFOSKIP(fd,44);
2555
2556	Sql_EscapeStringLen(sql_handle, esc_name, name, strnlen(name, NAME_LENGTH));
2557	if( SQL_ERROR == Sql_Query(sql_handle, "SELECT `account_id`,`name` FROM `%s` WHERE `name` = '%s'", char_db, esc_name) )
2558	Sql_ShowDebug(sql_handle);
2559	else
2560	if( Sql_NumRows(sql_handle) == 0 )
2561	{
2562	result = 1; // 1-player not found
2563	}
2564	else
2565	if( SQL_SUCCESS != Sql_NextRow(sql_handle) )
2566	Sql_ShowDebug(sql_handle);
2567	//FIXME: set proper result value?
2568	else
2569	{
2570	char name[NAME_LENGTH];
2571	int account_id;
2572	char* data;
2573
2574	Sql_GetData(sql_handle, 0, &data, NULL); account_id = atoi(data);
2575	Sql_GetData(sql_handle, 1, &data, NULL); safestrncpy(name, data, sizeof(name));
2576
2577	if( login_fd <= 0 )
2578	result = 3; // 3-login-server offline
2579	else
2580	if( acc != -1 && isGM(acc) < isGM(account_id) )
2581	result = 2; // 2-gm level too low
2582	else
2583	switch( type ) {
2584	case 1: // block
2585	WFIFOHEAD(login_fd,10);
2586	WFIFOW(login_fd,0) = 0x2724;
2587	WFIFOL(login_fd,2) = account_id;
2588	WFIFOL(login_fd,6) = 5; // new account status
2589	WFIFOSET(login_fd,10);
2590	break;
2591	case 2: // ban
2592	WFIFOHEAD(login_fd,18);
2593	WFIFOW(login_fd, 0) = 0x2725;
2594	WFIFOL(login_fd, 2) = account_id;
2595	WFIFOW(login_fd, 6) = year;
2596	WFIFOW(login_fd, 8) = month;
2597	WFIFOW(login_fd,10) = day;
2598	WFIFOW(login_fd,12) = hour;
2599	WFIFOW(login_fd,14) = minute;
2600	WFIFOW(login_fd,16) = second;
2601	WFIFOSET(login_fd,18);
2602	break;
2603	case 3: // unblock
2604	WFIFOHEAD(login_fd,10);
2605	WFIFOW(login_fd,0) = 0x2724;
2606	WFIFOL(login_fd,2) = account_id;
2607	WFIFOL(login_fd,6) = 0; // new account status
2608	WFIFOSET(login_fd,10);
2609	break;
2610	case 4: // unban
2611	WFIFOHEAD(login_fd,6);
2612	WFIFOW(login_fd,0) = 0x272a;
2613	WFIFOL(login_fd,2) = account_id;
2614	WFIFOSET(login_fd,6);
2615	break;
2616	case 5: // changesex
2617	WFIFOHEAD(login_fd,6);
2618	WFIFOW(login_fd,0) = 0x2727;
2619	WFIFOL(login_fd,2) = account_id;
2620	WFIFOSET(login_fd,6);
2621	break;
2622	}
2623	}
2624
2625	Sql_FreeResult(sql_handle);
2626
2627	// send answer if a player ask, not if the server ask
2628	if( acc != -1 && type != 5) { // Don't send answer for changesex
2629	WFIFOHEAD(fd,34);
2630	WFIFOW(fd, 0) = 0x2b0f;
2631	WFIFOL(fd, 2) = acc;
2632	safestrncpy((char*)WFIFOP(fd,6), name, NAME_LENGTH);
2633	WFIFOW(fd,30) = type;
2634	WFIFOW(fd,32) = result;
2635	WFIFOSET(fd,34);
2636	}
2637	}
2638	break;
2639
2640	case 0x2b10: // Update and send fame ranking list
2641	if (RFIFOREST(fd) < 11)
2642	return 0;
2643	{
2644	int cid = RFIFOL(fd, 2);
2645	int fame = RFIFOL(fd, 6);
2646	char type = RFIFOB(fd, 10);
2647	int size;
2648	struct fame_list* list;
2649	int player_pos;
2650	int fame_pos;
2651
2652	switch(type)
2653	{
2654	case 1: size = fame_list_size_smith; list = smith_fame_list; break;
2655	case 2: size = fame_list_size_chemist; list = chemist_fame_list; break;
2656	case 3: size = fame_list_size_taekwon; list = taekwon_fame_list; break;
2657	default: size = 0; list = NULL; break;
2658	}
2659
2660	ARR_FIND(0, size, player_pos, list[player_pos].id == cid);// position of the player
2661	ARR_FIND(0, size, fame_pos, list[fame_pos].fame <= fame);// where the player should be
2662
2663	if( player_pos == size && fame_pos == size )
2664	;// not on list and not enough fame to get on it
2665	else if( fame_pos == player_pos )
2666	{// same position
2667	list[player_pos].fame = fame;
2668	char_update_fame_list(type, player_pos, fame);
2669	}
2670	else
2671	{// move in the list
2672	if( player_pos == size )
2673	{// new ranker - not in the list
2674	ARR_MOVE(size - 1, fame_pos, list, struct fame_list);
2675	list[fame_pos].id = cid;
2676	list[fame_pos].fame = fame;
2677	char_loadName(cid, list[fame_pos].name);
2678	}
2679	else
2680	{// already in the list
2681	if( fame_pos == size )
2682	--fame_pos;// move to the end of the list
2683	ARR_MOVE(player_pos, fame_pos, list, struct fame_list);
2684	list[fame_pos].fame = fame;
2685	}
2686	char_send_fame_list(-1);
2687	}
2688
2689	RFIFOSKIP(fd,11);
2690	}
2691	break;
2692
2693	// Divorce chars
2694	case 0x2b11:
2695	if( RFIFOREST(fd) < 10 )
2696	return 0;
2697
2698	divorce_char_sql(RFIFOL(fd,2), RFIFOL(fd,6));
2699	RFIFOSKIP(fd,10);
2700	break;
2701
2702	case 0x2b16: // Receive rates [Wizputer]
2703	if (RFIFOREST(fd) < 6 \|\| RFIFOREST(fd) < RFIFOW(fd,8))
2704	return 0;
2705	{
2706	char motd[256];
2707	char esc_motd[sizeof(motd)*2+1];
2708	char esc_server_name[sizeof(server_name)*2+1];
2709
2710	strncpy(motd, (char*)RFIFOP(fd,10), 255); //First copy it to make sure the motd fits.
2711	motd[255] = '\0';
2712	Sql_EscapeString(sql_handle, esc_motd, motd);
2713	Sql_EscapeString(sql_handle, esc_server_name, server_name);
2714
2715	if( SQL_ERROR == Sql_Query(sql_handle, "INSERT INTO `ragsrvinfo` SET `index`='%d',`name`='%s',`exp`='%d',`jexp`='%d',`drop`='%d',`motd`='%s'",
2716	fd, esc_server_name, RFIFOW(fd,2), RFIFOW(fd,4), RFIFOW(fd,6), esc_motd) )
2717	Sql_ShowDebug(sql_handle);
2718	RFIFOSKIP(fd,RFIFOW(fd,8));
2719	}
2720	break;
2721
2722	case 0x2b17: // Character disconnected set online 0 [Wizputer]
2723	if (RFIFOREST(fd) < 6)
2724	return 0;
2725	set_char_offline(RFIFOL(fd,2),RFIFOL(fd,6));
2726	RFIFOSKIP(fd,10);
2727	break;
2728
2729	case 0x2b18: // Reset all chars to offline [Wizputer]
2730	set_all_offline(id);
2731	RFIFOSKIP(fd,2);
2732	break;
2733
2734	case 0x2b19: // Character set online [Wizputer]
2735	if (RFIFOREST(fd) < 10)
2736	return 0;
2737	set_char_online(id, RFIFOL(fd,2),RFIFOL(fd,6));
2738	RFIFOSKIP(fd,10);
2739	break;
2740
2741	case 0x2b1a: // Build and send fame ranking lists [DracoRPG]
2742	if (RFIFOREST(fd) < 2)
2743	return 0;
2744	char_read_fame_list();
2745	char_send_fame_list(-1);
2746	RFIFOSKIP(fd,2);
2747	break;
2748
2749	case 0x2b1c: //Request to save status change data. [Skotlex]
2750	if (RFIFOREST(fd) < 4 \|\| RFIFOREST(fd) < RFIFOW(fd,2))
2751	return 0;
2752	{
2753	#ifdef ENABLE_SC_SAVING
2754	int count, aid, cid;
2755
2756	aid = RFIFOL(fd, 4);
2757	cid = RFIFOL(fd, 8);
2758	count = RFIFOW(fd, 12);
2759
2760	if( count > 0 )
2761	{
2762	struct status_change_data data;
2763	StringBuf buf;
2764	int i;
2765
2766	StringBuf_Init(&buf);
2767	StringBuf_Printf(&buf, "INSERT INTO `%s` (`account_id`, `char_id`, `type`, `tick`, `val1`, `val2`, `val3`, `val4`) VALUES ", scdata_db);
2768	for( i = 0; i < count; ++i )
2769	{
2770	memcpy (&data, RFIFOP(fd, 14+i*sizeof(struct status_change_data)), sizeof(struct status_change_data));
2771	if( i > 0 )
2772	StringBuf_AppendStr(&buf, ", ");
2773	StringBuf_Printf(&buf, "('%d','%d','%hu','%d','%d','%d','%d','%d')", aid, cid,
2774	data.type, data.tick, data.val1, data.val2, data.val3, data.val4);
2775	}
2776	if( SQL_ERROR == Sql_QueryStr(sql_handle, StringBuf_Value(&buf)) )
2777	Sql_ShowDebug(sql_handle);
2778	StringBuf_Destroy(&buf);
2779	}
2780	#endif
2781	RFIFOSKIP(fd, RFIFOW(fd, 2));
2782	}
2783	break;
2784
2785	case 0x2b23: // map-server alive packet
2786	WFIFOHEAD(fd,2);
2787	WFIFOW(fd,0) = 0x2b24;
2788	WFIFOSET(fd,2);
2789	RFIFOSKIP(fd,2);
2790	break;
2791
2792	case 0x2b26: // auth request from map-server
2793	if (RFIFOREST(fd) < 19)
2794	return 0;
2795
2796	{
2797	int account_id;
2798	int char_id;
2799	int login_id1;
2800	char sex;
2801	uint32 ip;
2802	struct auth_node* node;
2803	struct mmo_charstatus* cd;
2804	struct mmo_charstatus char_dat;
2805
2806	account_id = RFIFOL(fd,2);
2807	char_id = RFIFOL(fd,6);
2808	login_id1 = RFIFOL(fd,10);
2809	sex = RFIFOB(fd,14);
2810	ip = ntohl(RFIFOL(fd,15));
2811	RFIFOSKIP(fd,19);
2812
2813	node = (struct auth_node*)idb_get(auth_db, account_id);
2814	cd = (struct mmo_charstatus*)uidb_get(char_db_,char_id);
2815	if( cd == NULL )
2816	{ //Really shouldn't happen.
2817	mmo_char_fromsql(char_id, &char_dat, true);
2818	cd = (struct mmo_charstatus*)uidb_get(char_db_,char_id);
2819	}
2820	if( node != NULL && cd != NULL &&
2821	node->account_id == account_id &&
2822	node->char_id == char_id &&
2823	node->login_id1 == login_id1 &&
2824	node->sex == sex &&
2825	node->ip == ip )
2826	{// auth ok
2827	cd->sex = sex;
2828
2829	WFIFOHEAD(fd,20 + sizeof(struct mmo_charstatus));
2830	WFIFOW(fd,0) = 0x2afd;
2831	WFIFOW(fd,2) = 20 + sizeof(struct mmo_charstatus);
2832	WFIFOL(fd,4) = account_id;
2833	WFIFOL(fd,8) = login_id1;
2834	WFIFOL(fd,12) = (uint32)node->expiration_time; // FIXME: will wrap to negative after "19-Jan-2038, 03:14:07 AM GMT"
2835	WFIFOL(fd,16) = node->login_id2;
2836	memcpy(WFIFOP(fd,20), cd, sizeof(struct mmo_charstatus));
2837	WFIFOSET(fd, WFIFOW(fd,2));
2838
2839	// only use the auth once and mark user online
2840	idb_remove(auth_db, account_id);
2841	set_char_online(id, char_id, account_id);
2842	}
2843	else
2844	{// auth failed
2845	WFIFOHEAD(fd,19);
2846	WFIFOW(fd,0) = 0x2b27;
2847	WFIFOL(fd,2) = account_id;
2848	WFIFOL(fd,6) = char_id;
2849	WFIFOL(fd,10) = login_id1;
2850	WFIFOB(fd,14) = sex;
2851	WFIFOL(fd,15) = htonl(ip);
2852	WFIFOSET(fd,19);
2853	}
2854	}
2855	break;
2856
2857	case 0x2736: // ip address update
2858	if (RFIFOREST(fd) < 6) return 0;
2859	server[id].ip = ntohl(RFIFOL(fd, 2));
2860	ShowInfo("Updated IP address of map-server #%d to %d.%d.%d.%d.\n", id, CONVIP(server[id].ip));
2861	RFIFOSKIP(fd,6);
2862	break;
2863
2864	default:
2865	{
2866	// inter server - packet
2867	int r = inter_parse_frommap(fd);
2868	if (r == 1) break; // processed
2869	if (r == 2) return 0; // need more packet
2870
2871	// no inter server packet. no char server packet -> disconnect
2872	ShowError("Unknown packet 0x%04x from map server, disconnecting.\n", RFIFOW(fd,0));
2873	set_eof(fd);
2874	return 0;
2875	}
2876	} // switch
2877	} // while
2878
2879	return 0;
2880	}
2881
2882	// Searches for the mapserver that has a given map (and optionally ip/port, if not -1).
2883	// If found, returns the server's index in the 'server' array (otherwise returns -1).
2884	int search_mapserver(unsigned short map, uint32 ip, uint16 port)
2885	{
2886	int i, j;
2887
2888	for(i = 0; i < MAX_MAP_SERVERS; i++)
2889	{
2890	if (server[i].fd > 0
2891	&& (ip == (uint32)-1 \|\| server[i].ip == ip)
2892	&& (port == (uint16)-1 \|\| server[i].port == port))
2893	{
2894	for (j = 0; server[i].map[j]; j++)
2895	if (server[i].map[j] == map)
2896	return i;
2897	}
2898	}
2899
2900	return -1;
2901	}
2902
2903	int char_mapif_init(int fd)
2904	{
2905	return inter_mapif_init(fd);
2906	}
2907
2908	//--------------------------------------------
2909	// Test to know if an IP come from LAN or WAN.
2910	//--------------------------------------------
2911	int lan_subnetcheck(uint32 ip)
2912	{
2913	int i;
2914	ARR_FIND( 0, subnet_count, i, (subnet[i].char_ip & subnet[i].mask) == (ip & subnet[i].mask) );
2915	if( i < subnet_count ) {
2916	ShowInfo("Subnet check [%u.%u.%u.%u]: Matches "CL_CYAN"%u.%u.%u.%u/%u.%u.%u.%u"CL_RESET"\n", CONVIP(ip), CONVIP(subnet[i].char_ip & subnet[i].mask), CONVIP(subnet[i].mask));
2917	return subnet[i].char_ip;
2918	} else {
2919	ShowInfo("Subnet check [%u.%u.%u.%u]: "CL_CYAN"WAN"CL_RESET"\n", CONVIP(ip));
2920	return 0;
2921	}
2922	}
2923
2924	int parse_char(int fd)
2925	{
2926	int i, ch = 0;
2927	char email[40];
2928	unsigned short cmd;
2929	int map_fd;
2930	struct char_session_data* sd;
2931	uint32 ipl = session[fd]->client_addr;
2932
2933	sd = (struct char_session_data*)session[fd]->session_data;
2934
2935	// disconnect any player if no login-server.
2936	if(login_fd < 0)
2937	set_eof(fd);
2938
2939	if(session[fd]->flag.eof)
2940	{
2941	if( sd != NULL && sd->auth )
2942	{ // already authed client
2943	struct online_char_data* data = (struct online_char_data*)idb_get(online_char_db, sd->account_id);
2944	if( data == NULL \|\| data->server == -1) //If it is not in any server, send it offline. [Skotlex]
2945	set_char_offline(-1,sd->account_id);
2946	if( data != NULL && data->fd == fd)
2947	data->fd = -1;
2948	}
2949	do_close(fd);
2950	return 0;
2951	}
2952
2953	while( RFIFOREST(fd) >= 2 )
2954	{
2955	//For use in packets that depend on an sd being present [Skotlex]
2956	#define FIFOSD_CHECK(rest) { if(RFIFOREST(fd) < rest) return 0; if (sd==NULL \|\| !sd->auth) { RFIFOSKIP(fd,rest); return 0; } }
2957
2958	cmd = RFIFOW(fd,0);
2959	switch( cmd )
2960	{
2961
2962	// request to connect
2963	// 0065 <account id>.L <login id1>.L <login id2>.L <???>.W <sex>.B
2964	case 0x65:
2965	if( RFIFOREST(fd) < 17 )
2966	return 0;
2967	{
2968	struct auth_node* node;
2969
2970	int account_id = RFIFOL(fd,2);
2971	uint32 login_id1 = RFIFOL(fd,6);
2972	uint32 login_id2 = RFIFOL(fd,10);
2973	int sex = RFIFOB(fd,16);
2974	RFIFOSKIP(fd,17);
2975
2976	ShowInfo("request connect - account_id:%d/login_id1:%d/login_id2:%d\n", account_id, login_id1, login_id2);
2977
2978	if (sd) {
2979	//Received again auth packet for already authentified account?? Discard it.
2980	//TODO: Perhaps log this as a hack attempt?
2981	//TODO: and perhaps send back a reply?
2982	break;
2983	}
2984
2985	CREATE(session[fd]->session_data, struct char_session_data, 1);
2986	sd = (struct char_session_data*)session[fd]->session_data;
2987	sd->expiration_time = 0; // unknown or unlimited (not displaying on map-server)
2988	sd->account_id = account_id;
2989	sd->login_id1 = login_id1;
2990	sd->login_id2 = login_id2;
2991	sd->sex = sex;
2992	sd->auth = false; // not authed yet
2993
2994	// send back account_id
2995	WFIFOHEAD(fd,4);
2996	WFIFOL(fd,0) = account_id;
2997	WFIFOSET(fd,4);
2998
2999	// search authentification
3000	node = (struct auth_node*)idb_get(auth_db, account_id);
3001	if( node != NULL &&
3002	node->account_id == account_id &&
3003	node->login_id1 == login_id1 &&
3004	node->login_id2 == login_id2 &&
3005	node->ip == ipl )
3006	{// authentication found (coming from map server)
3007	idb_remove(auth_db, account_id);
3008	char_auth_ok(fd, sd);
3009	}
3010	else
3011	{// authentication not found (coming from login server)
3012	if (login_fd > 0) { // don't send request if no login-server
3013	WFIFOHEAD(login_fd,19);
3014	WFIFOW(login_fd,0) = 0x2712; // ask login-server to authentify an account
3015	WFIFOL(login_fd,2) = sd->account_id;
3016	WFIFOL(login_fd,6) = sd->login_id1;
3017	WFIFOL(login_fd,10) = sd->login_id2;
3018	WFIFOB(login_fd,14) = sd->sex;
3019	WFIFOL(login_fd,15) = htonl(ipl);
3020	WFIFOSET(login_fd,19);
3021	} else { // if no login-server, we must refuse connection
3022	WFIFOHEAD(fd,3);
3023	WFIFOW(fd,0) = 0x6c;
3024	WFIFOB(fd,2) = 0;
3025	WFIFOSET(fd,3);
3026	}
3027	}
3028	}
3029	break;
3030
3031	// char select
3032	case 0x66:
3033	FIFOSD_CHECK(3);
3034	{
3035	struct mmo_charstatus char_dat;
3036	struct mmo_charstatus * cp;
3037	char* data;
3038	int char_id;
3039	uint32 subnet_map_ip;
3040	struct auth_node* node;
3041
3042	int slot = RFIFOB(fd,2);
3043	RFIFOSKIP(fd,3);
3044
3045	if ( SQL_SUCCESS != Sql_Query(sql_handle, "SELECT `char_id` FROM `%s` WHERE `account_id`='%d' AND `char_num`='%d'", char_db, sd->account_id, slot)
3046	\|\| SQL_SUCCESS != Sql_NextRow(sql_handle)
3047	\|\| SQL_SUCCESS != Sql_GetData(sql_handle, 0, &data, NULL) )
3048	{
3049	//Not found?? May be forged packet.
3050	Sql_ShowDebug(sql_handle);
3051	Sql_FreeResult(sql_handle);
3052	//TODO: perhaps add some reply? (otherwise it hangs the client)
3053	break;
3054	}
3055
3056	char_id = atoi(data);
3057	Sql_FreeResult(sql_handle);
3058	mmo_char_fromsql(char_id, &char_dat, true);
3059
3060	//Have to switch over to the DB instance otherwise data won't propagate [Kevin]
3061	cp = (struct mmo_charstatus *)idb_get(char_db_, char_id);
3062	cp->sex = sd->sex;
3063
3064	if (log_char) {
3065	char esc_name[NAME_LENGTH*2+1];
3066
3067	Sql_EscapeStringLen(sql_handle, esc_name, char_dat.name, strnlen(char_dat.name, NAME_LENGTH));
3068	if( SQL_ERROR == Sql_Query(sql_handle, "INSERT INTO `%s`(`time`, `account_id`,`char_num`,`name`) VALUES (NOW(), '%d', '%d', '%s')",
3069	charlog_db, sd->account_id, slot, esc_name) )
3070	Sql_ShowDebug(sql_handle);
3071	}
3072	ShowInfo("Selected char: (Account %d: %d - %s)\n", sd->account_id, slot, char_dat.name);
3073
3074	// searching map server
3075	i = search_mapserver(char_dat.last_point.map, -1, -1);
3076
3077	// if map is not found, we check major cities
3078	if (i < 0) {
3079	unsigned short j;
3080	//First check that there's actually a map server online.
3081	ARR_FIND( 0, MAX_MAP_SERVERS, j, server[j].fd >= 0 && server[j].map[0] );
3082	if (j == MAX_MAP_SERVERS) {
3083	ShowInfo("Connection Closed. No map servers available.\n");
3084	WFIFOHEAD(fd,3);
3085	WFIFOW(fd,0) = 0x81;
3086	WFIFOB(fd,2) = 1; // 01 = Server closed
3087	WFIFOSET(fd,3);
3088	break;
3089	}
3090	if ((i = search_mapserver((j=mapindex_name2id(MAP_PRONTERA)),-1,-1)) >= 0) {
3091	cp->last_point.x = 273;
3092	cp->last_point.y = 354;
3093	} else if ((i = search_mapserver((j=mapindex_name2id(MAP_GEFFEN)),-1,-1)) >= 0) {
3094	cp->last_point.x = 120;
3095	cp->last_point.y = 100;
3096	} else if ((i = search_mapserver((j=mapindex_name2id(MAP_MORROC)),-1,-1)) >= 0) {
3097	cp->last_point.x = 160;
3098	cp->last_point.y = 94;
3099	} else if ((i = search_mapserver((j=mapindex_name2id(MAP_ALBERTA)),-1,-1)) >= 0) {
3100	cp->last_point.x = 116;
3101	cp->last_point.y = 57;
3102	} else if ((i = search_mapserver((j=mapindex_name2id(MAP_PAYON)),-1,-1)) >= 0) {
3103	cp->last_point.x = 87;
3104	cp->last_point.y = 117;
3105	} else if ((i = search_mapserver((j=mapindex_name2id(MAP_IZLUDE)),-1,-1)) >= 0) {
3106	cp->last_point.x = 94;
3107	cp->last_point.y = 103;
3108	} else {
3109	ShowInfo("Connection Closed. No map server available that has a major city, and unable to find map-server for '%s'.\n", mapindex_id2name(char_dat.last_point.map));
3110	WFIFOHEAD(fd,3);
3111	WFIFOW(fd,0) = 0x81;
3112	WFIFOB(fd,2) = 1; // 01 = Server closed
3113	WFIFOSET(fd,3);
3114	break;
3115	}
3116	ShowWarning("Unable to find map-server for '%s', sending to major city '%s'.\n", mapindex_id2name(char_dat.last_point.map), mapindex_id2name(j));
3117	cp->last_point.map = j;
3118	}
3119
3120	//Send NEW auth packet [Kevin]
3121	//FIXME: is this case even possible? [ultramage]
3122	if ((map_fd = server[i].fd) < 1 \|\| session[map_fd] == NULL)
3123	{
3124	ShowError("parse_char: Attempting to write to invalid session %d! Map Server #%d disconnected.\n", map_fd, i);
3125	server[i].fd = -1;
3126	memset(&server[i], 0, sizeof(struct mmo_map_server));
3127	//Send server closed.
3128	WFIFOHEAD(fd,3);
3129	WFIFOW(fd,0) = 0x81;
3130	WFIFOB(fd,2) = 1; // 01 = Server closed
3131	WFIFOSET(fd,3);
3132	break;
3133	}
3134
3135	//Send player to map
3136	WFIFOHEAD(fd,28);
3137	WFIFOW(fd,0) = 0x71;
3138	WFIFOL(fd,2) = cp->char_id;
3139	mapindex_getmapname_ext(mapindex_id2name(cp->last_point.map), (char*)WFIFOP(fd,6));
3140
3141	// Advanced subnet check [LuzZza]
3142	subnet_map_ip = lan_subnetcheck(ipl);
3143	WFIFOL(fd,22) = htonl((subnet_map_ip) ? subnet_map_ip : server[i].ip);
3144	WFIFOW(fd,26) = ntows(htons(server[i].port)); // [!] LE byte order here [!]
3145	WFIFOSET(fd,28);
3146
3147	// create temporary auth entry
3148	CREATE(node, struct auth_node, 1);
3149	node->account_id = sd->account_id;
3150	node->char_id = cp->char_id;
3151	node->login_id1 = sd->login_id1;
3152	node->login_id2 = sd->login_id2;
3153	node->sex = sd->sex;
3154	node->expiration_time = sd->expiration_time;
3155	node->ip = ipl;
3156	idb_put(auth_db, sd->account_id, node);
3157
3158	set_char_online(-2,node->char_id,sd->account_id);
3159
3160	}
3161	break;
3162
3163	// create new char
3164	// S 0067 <name>.24B <str>.B <agi>.B <vit>.B <int>.B <dex>.B <luk>.B <slot>.B <hair color>.W <hair style>.W
3165	case 0x67:
3166	FIFOSD_CHECK(37);
3167
3168	if( !char_new ) //turn character creation on/off [Kevin]
3169	i = -2;
3170	else
3171	i = make_new_char_sql(sd, (char*)RFIFOP(fd,2),RFIFOB(fd,26),RFIFOB(fd,27),RFIFOB(fd,28),RFIFOB(fd,29),RFIFOB(fd,30),RFIFOB(fd,31),RFIFOB(fd,32),RFIFOW(fd,33),RFIFOW(fd,35));
3172
3173	//'Charname already exists' (-1), 'Char creation denied' (-2) and 'You are underaged' (-3)
3174	if (i < 0)
3175	{
3176	WFIFOHEAD(fd,3);
3177	WFIFOW(fd,0) = 0x6e;
3178	switch (i) {
3179	case -1: WFIFOB(fd,2) = 0x00; break;
3180	case -2: WFIFOB(fd,2) = 0x02; break;
3181	case -3: WFIFOB(fd,2) = 0x01; break;
3182	}
3183	WFIFOSET(fd,3);
3184	RFIFOSKIP(fd,37);
3185	break;
3186	}
3187	else
3188	{
3189	int len;
3190	// retrieve data
3191	struct mmo_charstatus char_dat;
3192	mmo_char_fromsql(i, &char_dat, false); //Only the short data is needed.
3193
3194	// send to player
3195	WFIFOHEAD(fd,110);
3196	WFIFOW(fd,0) = 0x6d;
3197	len = 2 + mmo_char_tobuf(WFIFOP(fd,2), &char_dat);
3198	WFIFOSET(fd,len);
3199
3200	// add new entry to the chars list
3201	ARR_FIND( 0, MAX_CHARS, ch, sd->found_char[ch] == -1 );
3202	if( ch < MAX_CHARS )
3203	sd->found_char[ch] = i; // the char_id of the new char
3204	}
3205
3206	RFIFOSKIP(fd,37);
3207	break;
3208
3209	// delete char
3210	case 0x68:
3211	// 2004-04-19aSakexe+ langtype 12 char deletion packet
3212	case 0x1fb:
3213	if (cmd == 0x68) FIFOSD_CHECK(46);
3214	if (cmd == 0x1fb) FIFOSD_CHECK(56);
3215	{
3216	int cid = RFIFOL(fd,2);
3217
3218	WFIFOHEAD(fd,46);
3219	ShowInfo(CL_RED"Request Char Deletion: "CL_GREEN"%d (%d)"CL_RESET"\n", sd->account_id, cid);
3220	memcpy(email, RFIFOP(fd,6), 40);
3221	RFIFOSKIP(fd,RFIFOREST(fd)); // hack to make the other deletion packet work
3222
3223	// Check if e-mail is correct
3224	if(strcmpi(email, sd->email) && //email does not matches and
3225	(
3226	strcmp("a@a.com", sd->email) \|\| //it is not default email, or
3227	(strcmp("a@a.com", email) && strcmp("", email)) //email sent does not matches default
3228	)) { //Fail
3229	WFIFOHEAD(fd,3);
3230	WFIFOW(fd,0) = 0x70;
3231	WFIFOB(fd,2) = 0; // 00 = Incorrect Email address
3232	WFIFOSET(fd,3);
3233	break;
3234	}
3235
3236	// check if this char exists
3237	ARR_FIND( 0, MAX_CHARS, i, sd->found_char[i] == cid );
3238	if( i == MAX_CHARS )
3239	{ // Such a character does not exist in the account
3240	WFIFOHEAD(fd,3);
3241	WFIFOW(fd,0) = 0x70;
3242	WFIFOB(fd,2) = 0;
3243	WFIFOSET(fd,3);
3244	break;
3245	}
3246
3247	// remove char from list and compact it
3248	for(ch = i; ch < MAX_CHARS-1; ch++)
3249	sd->found_char[ch] = sd->found_char[ch+1];
3250	sd->found_char[MAX_CHARS-1] = -1;
3251
3252	/* Delete character */
3253	if(delete_char_sql(cid)<0){
3254	//can't delete the char
3255	//either SQL error or can't delete by some CONFIG conditions
3256	//del fail
3257	WFIFOW(fd, 0) = 0x70;
3258	WFIFOB(fd, 2) = 0;
3259	WFIFOSET(fd, 3);
3260	break;
3261	}
3262	/* Char successfully deleted.*/
3263	WFIFOHEAD(fd,2);
3264	WFIFOW(fd,0) = 0x6f;
3265	WFIFOSET(fd,2);
3266	}
3267	break;
3268
3269	// client keep-alive packet (every 12 seconds)
3270	// R 0187 <account ID>.l
3271	case 0x187:
3272	if (RFIFOREST(fd) < 6)
3273	return 0;
3274	RFIFOSKIP(fd,6);
3275	break;
3276
3277	// char rename request
3278	// R 028d <account ID>.l <char ID>.l <new name>.24B
3279	case 0x28d:
3280	FIFOSD_CHECK(34);
3281	//not implemented
3282	RFIFOSKIP(fd,34);
3283	break;
3284
3285	// log in as map-server
3286	case 0x2af8:
3287	if (RFIFOREST(fd) < 60)
3288	return 0;
3289	{
3290	char* l_user = (char*)RFIFOP(fd,2);
3291	char* l_pass = (char*)RFIFOP(fd,26);
3292	l_user[23] = '\0';
3293	l_pass[23] = '\0';
3294	ARR_FIND( 0, MAX_MAP_SERVERS, i, server[i].fd <= 0 );
3295	if (i == MAX_MAP_SERVERS \|\| strcmp(l_user, userid) \|\| strcmp(l_pass, passwd)) {
3296	WFIFOHEAD(fd,3);
3297	WFIFOW(fd,0) = 0x2af9;
3298	WFIFOB(fd,2) = 3;
3299	WFIFOSET(fd,3);
3300	} else {
3301	WFIFOHEAD(fd,3);
3302	WFIFOW(fd,0) = 0x2af9;
3303	WFIFOB(fd,2) = 0;
3304	WFIFOSET(fd,3);
3305
3306	server[i].fd = fd;
3307	server[i].ip = ntohl(RFIFOL(fd,54));
3308	server[i].port = ntohs(RFIFOW(fd,58));
3309	server[i].users = 0;
3310	memset(server[i].map, 0, sizeof(server[i].map));
3311	session[fd]->func_parse = parse_frommap;
3312	session[fd]->flag.server = 1;
3313	realloc_fifo(fd, FIFOSIZE_SERVERLINK, FIFOSIZE_SERVERLINK);
3314	char_mapif_init(fd);
3315	// send gm acccounts level to map-servers
3316	WFIFOHEAD(fd,4+5*GM_num);
3317	WFIFOW(fd,0) = 0x2b15;
3318	for(i = 0; i < GM_num; i++) {
3319	WFIFOL(fd,4+5*i) = gm_account[i].account_id;
3320	WFIFOB(fd,4+5*i+4) = (unsigned char)gm_account[i].level;
3321	}
3322	WFIFOW(fd,2) = 4+5*GM_num;
3323	WFIFOSET(fd,WFIFOW(fd,2));
3324	}
3325
3326	RFIFOSKIP(fd,60);
3327	}
3328	return 0; // avoid processing of followup packets here
3329
3330	// Athena info get
3331	case 0x7530:
3332	WFIFOHEAD(fd,10);
3333	WFIFOW(fd,0) = 0x7531;
3334	WFIFOB(fd,2) = ATHENA_MAJOR_VERSION;
3335	WFIFOB(fd,3) = ATHENA_MINOR_VERSION;
3336	WFIFOB(fd,4) = ATHENA_REVISION;
3337	WFIFOB(fd,5) = ATHENA_RELEASE_FLAG;
3338	WFIFOB(fd,6) = ATHENA_OFFICIAL_FLAG;
3339	WFIFOB(fd,7) = ATHENA_SERVER_INTER \| ATHENA_SERVER_CHAR;
3340	WFIFOW(fd,8) = ATHENA_MOD_VERSION;
3341	WFIFOSET(fd,10);
3342
3343	RFIFOSKIP(fd,2);
3344	break;
3345
3346	// unknown packet received
3347	default:
3348	ShowError("parse_char: Received unknown packet "CL_WHITE"0x%x"CL_RESET" from ip '"CL_WHITE"%s"CL_RESET"'! Disconnecting!\n", RFIFOW(fd,0), ip2str(ipl, NULL));
3349	set_eof(fd);
3350	return 0;
3351	}
3352	}
3353
3354	RFIFOFLUSH(fd);
3355	return 0;
3356	}
3357
3358	// Console Command Parser [Wizputer]
3359	int parse_console(char* buf)
3360	{
3361	char command[256];
3362
3363	memset(command, 0, sizeof(command));
3364
3365	sscanf(buf, "%[^\n]", command);
3366
3367	//login_log("Console command :%s\n", command);
3368
3369	if( strcmpi("shutdown", command) == 0 \|\|
3370	strcmpi("exit", command) == 0 \|\|
3371	strcmpi("quit", command) == 0 \|\|
3372	strcmpi("end", command) == 0 )
3373	runflag = 0;
3374	else if( strcmpi("alive", command) == 0 \|\|
3375	strcmpi("status", command) == 0 )
3376	ShowInfo(CL_CYAN"Console: "CL_BOLD"I'm Alive."CL_RESET"\n");
3377	else if( strcmpi("help", command) == 0 ){
3378	ShowInfo(CL_BOLD"Help of commands:"CL_RESET"\n");
3379	ShowInfo(" To shutdown the server:\n");
3380	ShowInfo(" 'shutdown\|exit\|qui\|end'\n");
3381	ShowInfo(" To know if server is alive:\n");
3382	ShowInfo(" 'alive\|status'\n");
3383	}
3384
3385	return 0;
3386	}
3387
3388	// MAP send all
3389	int mapif_sendall(unsigned char *buf, unsigned int len)
3390	{
3391	int i, c;
3392
3393	c = 0;
3394	for(i = 0; i < MAX_MAP_SERVERS; i++) {
3395	int fd;
3396	if ((fd = server[i].fd) > 0) {
3397	WFIFOHEAD(fd,len);
3398	memcpy(WFIFOP(fd,0), buf, len);
3399	WFIFOSET(fd,len);
3400	c++;
3401	}
3402	}
3403
3404	return c;
3405	}
3406
3407	int mapif_sendallwos(int sfd, unsigned char *buf, unsigned int len)
3408	{
3409	int i, c;
3410
3411	c = 0;
3412	for(i = 0; i < MAX_MAP_SERVERS; i++) {
3413	int fd;
3414	if ((fd = server[i].fd) > 0 && fd != sfd) {
3415	WFIFOHEAD(fd,len);
3416	memcpy(WFIFOP(fd,0), buf, len);
3417	WFIFOSET(fd,len);
3418	c++;
3419	}
3420	}
3421
3422	return c;
3423	}
3424
3425	int mapif_send(int fd, unsigned char *buf, unsigned int len)
3426	{
3427	int i;
3428
3429	if (fd >= 0) {
3430	ARR_FIND( 0, MAX_MAP_SERVERS, i, fd == server[i].fd );
3431	if( i < MAX_MAP_SERVERS )
3432	{
3433	WFIFOHEAD(fd,len);
3434	memcpy(WFIFOP(fd,0), buf, len);
3435	WFIFOSET(fd,len);
3436	return 1;
3437	}
3438	}
3439	return 0;
3440	}
3441
3442	int broadcast_user_count(int tid, unsigned int tick, int id, intptr data)
3443	{
3444	uint8 buf[6];
3445	int users = count_users();
3446
3447	// only send an update when needed
3448	static int prev_users = 0;
3449	if( prev_users == users )
3450	return 0;
3451	prev_users = users;
3452
3453	if( login_fd > 0 && session[login_fd] )
3454	{
3455	// send number of user to login server
3456	WFIFOHEAD(login_fd,6);
3457	WFIFOW(login_fd,0) = 0x2714;
3458	WFIFOL(login_fd,2) = users;
3459	WFIFOSET(login_fd,6);
3460	}
3461
3462	// send number of players to all map-servers
3463	WBUFW(buf,0) = 0x2b00;
3464	WBUFL(buf,2) = users;
3465	mapif_sendall(buf,6);
3466
3467	return 0;
3468	}
3469
3470	/// load this char's account id into the 'online accounts' packet
3471	static int send_accounts_tologin_sub(DBKey key, void* data, va_list ap)
3472	{
3473	struct online_char_data* character = (struct online_char_data*)data;
3474	int* i = va_arg(ap, int*);
3475
3476	if(character->server > -1)
3477	{
3478	WFIFOL(login_fd,8+(i)4) = character->account_id;
3479	(*i)++;
3480	return 1;
3481	}
3482	return 0;
3483	}
3484
3485	int send_accounts_tologin(int tid, unsigned int tick, int id, intptr data)
3486	{
3487	if (login_fd > 0 && session[login_fd])
3488	{
3489	// send account list to login server
3490	int users = online_char_db->size(online_char_db);
3491	int i = 0;
3492
3493	WFIFOHEAD(login_fd,8+users*4);
3494	WFIFOW(login_fd,0) = 0x272d;
3495	online_char_db->foreach(online_char_db, send_accounts_tologin_sub, &i, users);
3496	WFIFOW(login_fd,2) = 8+ i*4;
3497	WFIFOL(login_fd,4) = i;
3498	WFIFOSET(login_fd,WFIFOW(login_fd,2));
3499	}
3500	return 0;
3501	}
3502
3503	int check_connect_login_server(int tid, unsigned int tick, int id, intptr data)
3504	{
3505	if (login_fd > 0 && session[login_fd] != NULL)
3506	return 0;
3507
3508	ShowInfo("Attempt to connect to login-server...\n");
3509	login_fd = make_connection(login_ip, login_port);
3510	if (login_fd == -1)
3511	{ //Try again later. [Skotlex]
3512	login_fd = 0;
3513	return 0;
3514	}
3515	session[login_fd]->func_parse = parse_fromlogin;
3516	session[login_fd]->flag.server = 1;
3517	realloc_fifo(login_fd, FIFOSIZE_SERVERLINK, FIFOSIZE_SERVERLINK);
3518
3519	WFIFOHEAD(login_fd,86);
3520	WFIFOW(login_fd,0) = 0x2710;
3521	memcpy(WFIFOP(login_fd,2), userid, 24);
3522	memcpy(WFIFOP(login_fd,26), passwd, 24);
3523	WFIFOL(login_fd,50) = 0;
3524	WFIFOL(login_fd,54) = htonl(char_ip);
3525	WFIFOL(login_fd,58) = htons(char_port);
3526	memcpy(WFIFOP(login_fd,60), server_name, 20);
3527	WFIFOW(login_fd,80) = 0;
3528	WFIFOW(login_fd,82) = char_maintenance;
3529	WFIFOW(login_fd,84) = char_new_display; //only display (New) if they want to [Kevin]
3530	WFIFOSET(login_fd,86);
3531
3532	return 1;
3533	}
3534
3535	// sends a ping packet to login server (will receive pong 0x2718)
3536	int ping_login_server(int tid, unsigned int tick, int id, intptr data)
3537	{
3538	if (login_fd > 0 && session[login_fd] != NULL)
3539	{
3540	WFIFOHEAD(login_fd,2);
3541	WFIFOW(login_fd,0) = 0x2719;
3542	WFIFOSET(login_fd,2);
3543	}
3544	return 0;
3545	}
3546
3547	//------------------------------------------------
3548	//Invoked 15 seconds after mapif_disconnectplayer in case the map server doesn't
3549	//replies/disconnect the player we tried to kick. [Skotlex]
3550	//------------------------------------------------
3551	static int chardb_waiting_disconnect(int tid, unsigned int tick, int id, intptr data)
3552	{
3553	struct online_char_data* character;
3554	if ((character = (struct online_char_data*)idb_get(online_char_db, id)) != NULL && character->waiting_disconnect == tid)
3555	{ //Mark it offline due to timeout.
3556	character->waiting_disconnect = -1;
3557	set_char_offline(character->char_id, character->account_id);
3558	}
3559	return 0;
3560	}
3561
3562	static int online_data_cleanup_sub(DBKey key, void *data, va_list ap)
3563	{
3564	struct online_char_data character= (struct online_char_data)data;
3565	if (character->fd != -1)
3566	return 0; //Still connected
3567	if (character->server == -2) //Unknown server.. set them offline
3568	set_char_offline(character->char_id, character->account_id);
3569	if (character->server < 0)
3570	//Free data from players that have not been online for a while.
3571	db_remove(online_char_db, key);
3572	return 0;
3573	}
3574
3575	static int online_data_cleanup(int tid, unsigned int tick, int id, intptr data)
3576	{
3577	online_char_db->foreach(online_char_db, online_data_cleanup_sub);
3578	return 0;
3579	}
3580
3581	//----------------------------------
3582	// Reading Lan Support configuration
3583	// Rewrote: Anvanced subnet check [LuzZza]
3584	//----------------------------------
3585	int char_lan_config_read(const char *lancfgName)
3586	{
3587	FILE *fp;
3588	int line_num = 0;
3589	char line[1024], w1[64], w2[64], w3[64], w4[64];
3590
3591	if((fp = fopen(lancfgName, "r")) == NULL) {
3592	ShowWarning("LAN Support configuration file is not found: %s\n", lancfgName);
3593	return 1;
3594	}
3595
3596	ShowInfo("Reading the configuration file %s...\n", lancfgName);
3597
3598	while(fgets(line, sizeof(line), fp))
3599	{
3600	line_num++;
3601	if ((line[0] == '/' && line[1] == '/') \|\| line[0] == '\n' \|\| line[1] == '\n')
3602	continue;
3603
3604	if(sscanf(line,"%[^:]: %[^:]:%[^:]:%[^\r\n]", w1, w2, w3, w4) != 4) {
3605
3606	ShowWarning("Error syntax of configuration file %s in line %d.\n", lancfgName, line_num);
3607	continue;
3608	}
3609
3610	remove_control_chars(w1);
3611	remove_control_chars(w2);
3612	remove_control_chars(w3);
3613	remove_control_chars(w4);
3614
3615	if( strcmpi(w1, "subnet") == 0 )
3616	{
3617	subnet[subnet_count].mask = str2ip(w2);
3618	subnet[subnet_count].char_ip = str2ip(w3);
3619	subnet[subnet_count].map_ip = str2ip(w4);
3620
3621	if( (subnet[subnet_count].char_ip & subnet[subnet_count].mask) != (subnet[subnet_count].map_ip & subnet[subnet_count].mask) )
3622	{
3623	ShowError("%s: Configuration Error: The char server (%s) and map server (%s) belong to different subnetworks!\n", lancfgName, w3, w4);
3624	continue;
3625	}
3626
3627	subnet_count++;
3628	}
3629	}
3630
3631	ShowStatus("Read information about %d subnetworks.\n", subnet_count);
3632
3633	fclose(fp);
3634	return 0;
3635	}
3636	#endif //TXT_SQL_CONVERT
3637
3638	void sql_config_read(const char* cfgName)
3639	{
3640	char line[1024], w1[1024], w2[1024];
3641	FILE* fp;
3642
3643	ShowInfo("Reading file %s...\n", cfgName);
3644
3645	if ((fp = fopen(cfgName, "r")) == NULL) {
3646	ShowError("file not found: %s\n", cfgName);
3647	return;
3648	}
3649
3650	while(fgets(line, sizeof(line), fp))
3651	{
3652	if(line[0] == '/' && line[1] == '/')
3653	continue;
3654
3655	if (sscanf(line, "%[^:]: %[^\r\n]", w1, w2) != 2)
3656	continue;
3657
3658	if(!strcmpi(w1,"char_db"))
3659	strcpy(char_db,w2);
3660	#ifndef TXT_SQL_CONVERT
3661	else if(!strcmpi(w1,"gm_read_method"))
3662	char_gm_read = config_switch(w2);
3663	//custom columns for login database
3664	else if(!strcmpi(w1,"login_db"))
3665	strcpy(login_db,w2);
3666	else if(!strcmpi(w1,"login_db_level"))
3667	strcpy(login_db_level,w2);
3668	else if(!strcmpi(w1,"login_db_account_id"))
3669	strcpy(login_db_account_id,w2);
3670	else if(!strcmpi(w1,"lowest_gm_level")) {
3671	lowest_gm_level = atoi(w2);
3672	ShowStatus("set lowest_gm_level : %s\n", w2);
3673	}
3674	#endif
3675	else if(!strcmpi(w1,"scdata_db"))
3676	strcpy(scdata_db,w2);
3677	else if(!strcmpi(w1,"cart_db"))
3678	strcpy(cart_db,w2);
3679	else if(!strcmpi(w1,"inventory_db"))
3680	strcpy(inventory_db, w2);
3681	else if(!strcmpi(w1,"charlog_db"))
3682	strcpy(charlog_db,w2);
3683	else if(!strcmpi(w1,"storage_db"))
3684	strcpy(storage_db,w2);
3685	else if(!strcmpi(w1,"reg_db"))
3686	strcpy(reg_db,w2);
3687	else if(!strcmpi(w1,"skill_db"))
3688	strcpy(skill_db,w2);
3689	else if(!strcmpi(w1,"interlog_db"))
3690	strcpy(interlog_db,w2);
3691	else if(!strcmpi(w1,"memo_db"))
3692	strcpy(memo_db,w2);
3693	else if(!strcmpi(w1,"guild_db"))
3694	strcpy(guild_db,w2);
3695	else if(!strcmpi(w1,"guild_alliance_db"))
3696	strcpy(guild_alliance_db,w2);
3697	else if(!strcmpi(w1,"guild_castle_db"))
3698	strcpy(guild_castle_db,w2);
3699	else if(!strcmpi(w1,"guild_expulsion_db"))
3700	strcpy(guild_expulsion_db,w2);
3701	else if(!strcmpi(w1,"guild_member_db"))
3702	strcpy(guild_member_db,w2);
3703	else if(!strcmpi(w1,"guild_skill_db"))
3704	strcpy(guild_skill_db,w2);
3705	else if(!strcmpi(w1,"guild_position_db"))
3706	strcpy(guild_position_db,w2);
3707	else if(!strcmpi(w1,"guild_storage_db"))
3708	strcpy(guild_storage_db,w2);
3709	else if(!strcmpi(w1,"party_db"))
3710	strcpy(party_db,w2);
3711	else if(!strcmpi(w1,"pet_db"))
3712	strcpy(pet_db,w2);
3713	else if(!strcmpi(w1,"mail_db"))
3714	strcpy(mail_db,w2);
3715	else if(!strcmpi(w1,"auction_db"))
3716	strcpy(auction_db,w2);
3717	else if(!strcmpi(w1,"friend_db"))
3718	strcpy(friend_db,w2);
3719	else if(!strcmpi(w1,"hotkey_db"))
3720	strcpy(hotkey_db,w2);
3721	#ifndef TXT_SQL_CONVERT
3722	else if(!strcmpi(w1,"db_path"))
3723	strcpy(db_path,w2);
3724	#endif
3725	//support the import command, just like any other config
3726	else if(!strcmpi(w1,"import"))
3727	sql_config_read(w2);
3728	}
3729	fclose(fp);
3730	ShowInfo("Done reading %s.\n", cfgName);
3731	}
3732	#ifndef TXT_SQL_CONVERT
3733
3734	int char_config_read(const char* cfgName)
3735	{
3736	char line[1024], w1[1024], w2[1024];
3737	FILE* fp = fopen(cfgName, "r");
3738
3739	if (fp == NULL) {
3740	ShowError("Configuration file not found: %s.\n", cfgName);
3741	return 1;
3742	}
3743
3744	ShowInfo("Reading configuration file %s...\n", cfgName);
3745	while(fgets(line, sizeof(line), fp))
3746	{
3747	if (line[0] == '/' && line[1] == '/')
3748	continue;
3749
3750	if (sscanf(line, "%[^:]: %[^\r\n]", w1, w2) != 2)
3751	continue;
3752
3753	remove_control_chars(w1);
3754	remove_control_chars(w2);
3755	if(strcmpi(w1,"timestamp_format") == 0) {
3756	strncpy(timestamp_format, w2, 20);
3757	} else if(strcmpi(w1,"console_silent")==0){
3758	ShowInfo("Console Silent Setting: %d\n", atoi(w2));
3759	msg_silent = atoi(w2);
3760	} else if(strcmpi(w1,"stdout_with_ansisequence")==0){
3761	stdout_with_ansisequence = config_switch(w2);
3762	} else if (strcmpi(w1, "userid") == 0) {
3763	strncpy(userid, w2, 24);
3764	} else if (strcmpi(w1, "passwd") == 0) {
3765	strncpy(passwd, w2, 24);
3766	} else if (strcmpi(w1, "server_name") == 0) {
3767	strncpy(server_name, w2, 20);
3768	server_name[sizeof(server_name) - 1] = '\0';
3769	ShowStatus("%s server has been initialized\n", w2);
3770	} else if (strcmpi(w1, "wisp_server_name") == 0) {
3771	if (strlen(w2) >= 4) {
3772	memcpy(wisp_server_name, w2, sizeof(wisp_server_name));
3773	wisp_server_name[sizeof(wisp_server_name) - 1] = '\0';
3774	}
3775	} else if (strcmpi(w1, "login_ip") == 0) {
3776	char ip_str[16];
3777	login_ip = host2ip(w2);
3778	if (login_ip) {
3779	strncpy(login_ip_str, w2, sizeof(login_ip_str));
3780	ShowStatus("Login server IP address : %s -> %s\n", w2, ip2str(login_ip, ip_str));
3781	}
3782	} else if (strcmpi(w1, "login_port") == 0) {
3783	login_port = atoi(w2);
3784	} else if (strcmpi(w1, "char_ip") == 0) {
3785	char ip_str[16];
3786	char_ip = host2ip(w2);
3787	if (char_ip){
3788	strncpy(char_ip_str, w2, sizeof(char_ip_str));
3789	ShowStatus("Character server IP address : %s -> %s\n", w2, ip2str(char_ip, ip_str));
3790	}
3791	} else if (strcmpi(w1, "bind_ip") == 0) {
3792	char ip_str[16];
3793	bind_ip = host2ip(w2);
3794	if (bind_ip) {
3795	strncpy(bind_ip_str, w2, sizeof(bind_ip_str));
3796	ShowStatus("Character server binding IP address : %s -> %s\n", w2, ip2str(bind_ip, ip_str));
3797	}
3798	} else if (strcmpi(w1, "char_port") == 0) {
3799	char_port = atoi(w2);
3800	} else if (strcmpi(w1, "char_maintenance") == 0) {
3801	char_maintenance = atoi(w2);
3802	} else if (strcmpi(w1, "char_new") == 0) {
3803	char_new = (bool)atoi(w2);
3804	} else if (strcmpi(w1, "char_new_display") == 0) {
3805	char_new_display = atoi(w2);
3806	} else if (strcmpi(w1, "max_connect_user") == 0) {
3807	max_connect_user = atoi(w2);
3808	if (max_connect_user < 0)
3809	max_connect_user = 0; // unlimited online players
3810	} else if(strcmpi(w1, "gm_allow_level") == 0) {
3811	gm_allow_level = atoi(w2);
3812	if(gm_allow_level < 0)
3813	gm_allow_level = 99;
3814	} else if (strcmpi(w1, "online_check") == 0) {
3815	online_check = config_switch(w2);
3816	} else if (strcmpi(w1, "autosave_time") == 0) {
3817	autosave_interval = atoi(w2)*1000;
3818	if (autosave_interval <= 0)
3819	autosave_interval = DEFAULT_AUTOSAVE_INTERVAL;
3820	} else if (strcmpi(w1, "save_log") == 0) {
3821	save_log = config_switch(w2);
3822	} else if (strcmpi(w1, "start_point") == 0) {
3823	char map[MAP_NAME_LENGTH_EXT];
3824	int x, y;
3825	if (sscanf(w2, "%15[^,],%d,%d", map, &x, &y) < 3)
3826	continue;
3827	start_point.map = mapindex_name2id(map);
3828	if (!start_point.map)
3829	ShowError("Specified start_point %s not found in map-index cache.\n", map);
3830	start_point.x = x;
3831	start_point.y = y;
3832	} else if (strcmpi(w1, "start_zeny") == 0) {
3833	start_zeny = atoi(w2);
3834	if (start_zeny < 0)
3835	start_zeny = 0;
3836	} else if (strcmpi(w1, "start_weapon") == 0) {
3837	start_weapon = atoi(w2);
3838	if (start_weapon < 0)
3839	start_weapon = 0;
3840	} else if (strcmpi(w1, "start_armor") == 0) {
3841	start_armor = atoi(w2);
3842	if (start_armor < 0)
3843	start_armor = 0;
3844	} else if(strcmpi(w1,"log_char")==0) { //log char or not [devil]
3845	log_char = atoi(w2);
3846	} else if (strcmpi(w1, "unknown_char_name") == 0) {
3847	strcpy(unknown_char_name, w2);
3848	unknown_char_name[NAME_LENGTH-1] = '\0';
3849	} else if (strcmpi(w1, "name_ignoring_case") == 0) {
3850	name_ignoring_case = config_switch(w2);
3851	} else if (strcmpi(w1, "char_name_option") == 0) {
3852	char_name_option = atoi(w2);
3853	} else if (strcmpi(w1, "char_name_letters") == 0) {
3854	strcpy(char_name_letters, w2);
3855	} else if (strcmpi(w1, "char_rename") == 0) {
3856	char_rename = config_switch(w2);
3857	} else if (strcmpi(w1, "chars_per_account") == 0) { //maxchars per account [Sirius]
3858	char_per_account = atoi(w2);
3859	} else if (strcmpi(w1, "char_del_level") == 0) { //disable/enable char deletion by its level condition [Lupus]
3860	char_del_level = atoi(w2);
3861	} else if (strcmpi(w1, "console") == 0) {
3862	console = config_switch(w2);
3863	} else if (strcmpi(w1, "fame_list_alchemist") == 0) {
3864	fame_list_size_chemist = atoi(w2);
3865	if (fame_list_size_chemist > MAX_FAME_LIST) {
3866	ShowWarning("Max fame list size is %d (fame_list_alchemist)\n", MAX_FAME_LIST);
3867	fame_list_size_chemist = MAX_FAME_LIST;
3868	}
3869	} else if (strcmpi(w1, "fame_list_blacksmith") == 0) {
3870	fame_list_size_smith = atoi(w2);
3871	if (fame_list_size_smith > MAX_FAME_LIST) {
3872	ShowWarning("Max fame list size is %d (fame_list_blacksmith)\n", MAX_FAME_LIST);
3873	fame_list_size_smith = MAX_FAME_LIST;
3874	}
3875	} else if (strcmpi(w1, "fame_list_taekwon") == 0) {
3876	fame_list_size_taekwon = atoi(w2);
3877	if (fame_list_size_taekwon > MAX_FAME_LIST) {
3878	ShowWarning("Max fame list size is %d (fame_list_taekwon)\n", MAX_FAME_LIST);
3879	fame_list_size_taekwon = MAX_FAME_LIST;
3880	}
3881	} else if (strcmpi(w1, "guild_exp_rate") == 0) {
3882	guild_exp_rate = atoi(w2);
3883	} else if (strcmpi(w1, "import") == 0) {
3884	char_config_read(w2);
3885	}
3886	}
3887	fclose(fp);
3888
3889	ShowInfo("Done reading %s.\n", cfgName);
3890	return 0;
3891	}
3892
3893	void do_final(void)
3894	{
3895	ShowInfo("Doing final stage...\n");
3896	//check SQL save progress.
3897	//wait until save char complete
3898
3899	set_all_offline(-1);
3900	set_all_offline_sql();
3901
3902	inter_final();
3903
3904	flush_fifos();
3905
3906	mapindex_final();
3907
3908	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `ragsrvinfo") )
3909	Sql_ShowDebug(sql_handle);
3910
3911	if(gm_account) {
3912	aFree(gm_account);
3913	gm_account = 0;
3914	}
3915
3916	if (login_fd > 0)
3917	do_close(login_fd);
3918	if (char_fd > 0)
3919	do_close(char_fd);
3920	char_db_->destroy(char_db_, NULL);
3921	online_char_db->destroy(online_char_db, NULL);
3922	auth_db->destroy(auth_db, NULL);
3923
3924	Sql_Free(sql_handle);
3925	if( lsql_handle )
3926	Sql_Free(lsql_handle);
3927
3928	ShowInfo("ok! all done...\n");
3929	}
3930
3931	//------------------------------
3932	// Function called when the server
3933	// has received a crash signal.
3934	//------------------------------
3935	void do_abort(void)
3936	{
3937	}
3938
3939	void set_server_type(void)
3940	{
3941	SERVER_TYPE = ATHENA_SERVER_CHAR;
3942	}
3943
3944	int do_init(int argc, char **argv)
3945	{
3946	int i;
3947
3948	for(i = 0; i < MAX_MAP_SERVERS; i++) {
3949	memset(&server[i], 0, sizeof(struct mmo_map_server));
3950	server[i].fd = -1;
3951	}
3952
3953	//Read map indexes
3954	mapindex_init();
3955	start_point.map = mapindex_name2id("new_zone01");
3956
3957	char_config_read((argc < 2) ? CHAR_CONF_NAME : argv[1]);
3958	char_lan_config_read((argc > 3) ? argv[3] : LAN_CONF_NAME);
3959	sql_config_read(SQL_CONF_NAME);
3960
3961	if (strcmp(userid, "s1")==0 && strcmp(passwd, "p1")==0) {
3962	ShowError("Using the default user/password s1/p1 is NOT RECOMMENDED.\n");
3963	ShowNotice("Please edit your 'login' table to create a proper inter-server user/password (gender 'S')\n");
3964	ShowNotice("And then change the user/password to use in conf/char_athena.conf (or conf/import/char_conf.txt)\n");
3965	}
3966
3967	ShowInfo("Finished reading the char-server configuration.\n");
3968
3969	inter_init_sql((argc > 2) ? argv[2] : inter_cfgName); // inter server ÃÊ±âÈ
3970	ShowInfo("Finished reading the inter-server configuration.\n");
3971
3972	ShowInfo("Initializing char server.\n");
3973	auth_db = idb_alloc(DB_OPT_RELEASE_DATA);
3974	online_char_db = idb_alloc(DB_OPT_RELEASE_DATA);
3975	mmo_char_sql_init();
3976	char_read_fame_list(); //Read fame lists.
3977	if(char_gm_read)
3978	read_gm_account();
3979	ShowInfo("char server initialized.\n");
3980
3981	set_defaultparse(parse_char);
3982
3983	if ((naddr_ != 0) && (!login_ip \|\| !char_ip))
3984	{
3985	char ip_str[16];
3986	ip2str(addr_[0], ip_str);
3987
3988	if (naddr_ > 1)
3989	ShowStatus("Multiple interfaces detected.. using %s as our IP address\n", ip_str);
3990	else
3991	ShowStatus("Defaulting to %s as our IP address\n", ip_str);
3992	if (!login_ip) {
3993	strcpy(login_ip_str, ip_str);
3994	login_ip = str2ip(login_ip_str);
3995	}
3996	if (!char_ip) {
3997	strcpy(char_ip_str, ip_str);
3998	char_ip = str2ip(char_ip_str);
3999	}
4000	}
4001
4002	// establish char-login connection if not present
4003	add_timer_func_list(check_connect_login_server, "check_connect_login_server");
4004	add_timer_interval(gettick() + 1000, check_connect_login_server, 0, 0, 10 * 1000);
4005
4006	// keep the char-login connection alive
4007	add_timer_func_list(ping_login_server, "ping_login_server");
4008	add_timer_interval(gettick() + 1000, ping_login_server, 0, 0, ((int)stall_time-2) * 1000);
4009
4010	// periodically update the overall user count on all mapservers + login server
4011	add_timer_func_list(broadcast_user_count, "broadcast_user_count");
4012	add_timer_interval(gettick() + 1000, broadcast_user_count, 0, 0, 5 * 1000);
4013
4014	// send a list of all online account IDs to login server
4015	add_timer_func_list(send_accounts_tologin, "send_accounts_tologin");
4016	add_timer_interval(gettick() + 1000, send_accounts_tologin, 0, 0, 3600 * 1000); //Sync online accounts every hour.
4017
4018	// ???
4019	add_timer_func_list(chardb_waiting_disconnect, "chardb_waiting_disconnect");
4020
4021	// ???
4022	add_timer_func_list(online_data_cleanup, "online_data_cleanup");
4023	add_timer_interval(gettick() + 1000, online_data_cleanup, 0, 0, 600 * 1000);
4024
4025	if( console )
4026	{
4027	//##TODO invoke a CONSOLE_START plugin event
4028	}
4029
4030	//Cleaning the tables for NULL entrys @ startup [Sirius]
4031	//Chardb clean
4032	ShowInfo("Cleaning the '%s' table...\n", char_db);
4033	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `account_id` = '0'", char_db) )
4034	Sql_ShowDebug(sql_handle);
4035
4036	//guilddb clean
4037	ShowInfo("Cleaning the '%s' table...\n", guild_db);
4038	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `guild_lv` = '0' AND `max_member` = '0' AND `exp` = '0' AND `next_exp` = '0' AND `average_lv` = '0'", guild_db) )
4039	Sql_ShowDebug(sql_handle);
4040
4041	//guildmemberdb clean
4042	ShowInfo("Cleaning the '%s' table...\n", guild_member_db);
4043	if( SQL_ERROR == Sql_Query(sql_handle, "DELETE FROM `%s` WHERE `guild_id` = '0' AND `account_id` = '0' AND `char_id` = '0'", guild_member_db) )
4044	Sql_ShowDebug(sql_handle);
4045
4046	ShowInfo("End of char server initilization function.\n");
4047
4048	ShowInfo("open port %d.....\n",char_port);
4049	char_fd = make_listen_bind(bind_ip, char_port);
4050	ShowStatus("The char-server is "CL_GREEN"ready"CL_RESET" (Server is listening on the port %d).\n\n", char_port);
4051
4052	return 0;
4053	}
4054
4055	#endif //TXT_SQL_CONVERT

Note: See TracBrowser for help on using the browser.

Context Navigation

root/src/char_sql/char.c @ 23

Download in other formats: