// Copyright (c) Athena Dev Teams - Licensed under GNU GPL // For more information, see LICENCE in the main folder #include #ifdef _WIN32 #include #else #include #include #include #endif #include #include #include #include #include #include #include #include "../common/cbasetypes.h" #include "../common/utils.h" #include "../common/strlib.h" #include "../common/showmsg.h" #include "../common/db.h" #include "../common/malloc.h" #include "itemdb.h" #include "inter.h" #include "int_guild.h" #include "int_homun.h" #include "char.h" #ifndef TXT_SQL_CONVERT static struct dbt *char_db_; #endif char char_db[256] = "char"; char scdata_db[256] = "sc_data"; char cart_db[256] = "cart_inventory"; char inventory_db[256] = "inventory"; char charlog_db[256] = "charlog"; char storage_db[256] = "storage"; char interlog_db[256] = "interlog"; char reg_db[256] = "global_reg_value"; char skill_db[256] = "skill"; char memo_db[256] = "memo"; char guild_db[256] = "guild"; char guild_alliance_db[256] = "guild_alliance"; char guild_castle_db[256] = "guild_castle"; char guild_expulsion_db[256] = "guild_expulsion"; char guild_member_db[256] = "guild_member"; char guild_position_db[256] = "guild_position"; char guild_skill_db[256] = "guild_skill"; char guild_storage_db[256] = "guild_storage"; char party_db[256] = "party"; char pet_db[256] = "pet"; char friend_db[256] = "friends"; #ifdef TXT_SQL_CONVERT int save_log = 0; //Have the logs be off by default when converting #else int save_log = 1; int db_use_sqldbs; char login_db[256] = "login"; char login_db_account_id[32] = "account_id"; char login_db_level[32] = "level"; int lowest_gm_level = 1; char *SQL_CONF_NAME = "conf/inter_athena.conf"; struct mmo_map_server{ uint32 ip; uint16 port; int users; unsigned short map[MAX_MAP_PER_SERVER]; } server[MAX_MAP_SERVERS]; int server_fd[MAX_MAP_SERVERS]; int login_fd, char_fd; char userid[24]; char passwd[24]; char server_name[20]; char wisp_server_name[NAME_LENGTH] = "Server"; char login_ip_str[128]; uint32 login_ip = 0; uint16 login_port = 6900; char char_ip_str[128]; uint32 char_ip = 0; char bind_ip_str[128]; uint32 bind_ip = INADDR_ANY; uint16 char_port = 6121; int char_maintenance = 0; int char_new; int char_new_display; int name_ignoring_case = 0; // Allow or not identical name for characters but with a different case by [Yor] 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] char char_name_letters[1024] = ""; // list of letters/symbols used to authorise or not a name of a character. by [Yor] //The following are characters that are trimmed regardless because they cause confusion and problems on the servers. [Skotlex] #define TRIM_CHARS "\032\t\x0A\x0D " int char_per_account = 0; //Maximum charas per account (default unlimited) [Sirius] int char_del_level = 0; //From which level u can delete character [Lupus] int log_char = 1; // loggin char or not [devil] int log_inter = 1; // loggin inter or not [devil] // Advanced subnet check [LuzZza] struct _subnet { uint32 subnet; uint32 mask; uint32 char_ip; uint32 map_ip; } subnet[16]; int subnet_count = 0; char unknown_char_name[NAME_LENGTH] = "Unknown"; char db_path[1024]="db"; //These are used to aid the map server in identifying valid clients. [Skotlex] static int max_account_id = DEFAULT_MAX_ACCOUNT_ID, max_char_id = DEFAULT_MAX_CHAR_ID; 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] struct char_session_data{ int account_id, login_id1, login_id2, sex; int found_char[MAX_CHARS]; char email[40]; // e-mail (default: a@a.com) by [Yor] time_t connect_until_time; // # of seconds 1/1/1970 (timestamp): Validity limit of the account (0 = unlimited) }; #define AUTH_FIFO_SIZE 256 struct { int account_id, char_id, login_id1, login_id2; uint32 ip; int delflag; int sex; time_t connect_until_time; // # of seconds 1/1/1970 (timestamp): Validity limit of the account (0 = unlimited) } auth_fifo[AUTH_FIFO_SIZE]; int auth_fifo_pos = 0; struct mmo_charstatus char_dat; int char_num,char_max; int max_connect_user = 0; int gm_allow_level = 99; int autosave_interval = DEFAULT_AUTOSAVE_INTERVAL; int start_zeny = 0; int start_weapon = 1201; int start_armor = 2301; int guild_exp_rate = 100; //Custom limits for the fame lists. [Skotlex] int fame_list_size_chemist = MAX_FAME_LIST; int fame_list_size_smith = MAX_FAME_LIST; int fame_list_size_taekwon = MAX_FAME_LIST; // Char-server-side stored fame lists [DracoRPG] struct fame_list smith_fame_list[MAX_FAME_LIST]; struct fame_list chemist_fame_list[MAX_FAME_LIST]; struct fame_list taekwon_fame_list[MAX_FAME_LIST]; // check for exit signal // 0 is saving complete // other is char_id unsigned int save_flag = 0; // start point (you can reset point on conf file) struct point start_point = { 0, 53, 111 }; bool char_gm_read = false; struct gm_account *gm_account = NULL; int GM_num = 0; int console = 0; //Structure for holding in memory which characters are online on the map servers connected. struct online_char_data { int account_id; int char_id; int fd; int waiting_disconnect; short server; }; struct dbt *online_char_db; //Holds all online characters. #ifndef SQL_DEBUG #define mysql_query(_x, _y) mysql_real_query(_x, _y, strlen(_y)) //supports ' in names and runs faster [Kevin] #else #define mysql_query(_x, _y) debug_mysql_query(__FILE__, __LINE__, _x, _y) #endif static int chardb_waiting_disconnect(int tid, unsigned int tick, int id, int data); static void * create_online_char_data(DBKey key, va_list args) { struct online_char_data* character; character = aCalloc(1, sizeof(struct online_char_data)); character->account_id = key.i; character->char_id = -1; character->server = -1; character->fd = -1; character->waiting_disconnect = -1; return character; } //------------------------------------------------- // Set Character online/offline [Wizputer] //------------------------------------------------- void set_char_online(int map_id, int char_id, int account_id) { struct online_char_data* character; if ( char_id != 99 ) { sprintf(tmp_sql, "UPDATE `%s` SET `online`='1' WHERE `char_id`='%d'",char_db,char_id); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } if (max_account_id < account_id || max_char_id < char_id) { //Notify map-server of the new max IDs [Skotlex] if (account_id > max_account_id) max_account_id = account_id; if (char_id > max_char_id) max_char_id = char_id; mapif_send_maxid(max_account_id, max_char_id); } } character = idb_ensure(online_char_db, account_id, create_online_char_data); if (online_check && character->char_id != -1 && character->server > -1 && character->server != map_id) { //char == 99 <- Character logging in, so someone has logged in while one //char is still on map-server, so kick him out, but don't print "error" //as this is normal behaviour. [Skotlex] if (char_id != 99) ShowNotice("set_char_online: Character %d:%d marked in map server %d, but map server %d claims to have (%d:%d) online!\n", character->account_id, character->char_id, character->server, map_id, account_id, char_id); mapif_disconnectplayer(server_fd[character->server], character->account_id, character->char_id, 2); } character->char_id = (char_id==99)?-1:char_id; character->server = (char_id==99)?-1:map_id; if(character->waiting_disconnect != -1){ delete_timer(character->waiting_disconnect, chardb_waiting_disconnect); character->waiting_disconnect = -1; } if (char_id != 99) { //Set char online in guild cache. If char is in memory, use the guild id on it, otherwise seek it. struct mmo_charstatus *cp; cp = idb_get(char_db_,char_id); inter_guild_CharOnline(char_id, cp?cp->guild_id:-1); } if (login_fd > 0 && !session[login_fd]->eof) { WFIFOHEAD(login_fd,6); WFIFOW(login_fd,0) = 0x272b; WFIFOL(login_fd,2) = account_id; WFIFOSET(login_fd,6); } } void set_char_offline(int char_id, int account_id) { struct mmo_charstatus *cp; struct online_char_data* character; if ( char_id == 99 ) sprintf(tmp_sql,"UPDATE `%s` SET `online`='0' WHERE `account_id`='%d'", char_db, account_id); else { cp = idb_get(char_db_,char_id); inter_guild_CharOffline(char_id, cp?cp->guild_id:-1); if (cp) idb_remove(char_db_,char_id); sprintf(tmp_sql,"UPDATE `%s` SET `online`='0' WHERE `char_id`='%d'", char_db, char_id); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } } if ((character = idb_get(online_char_db, account_id)) != NULL) { //We don't free yet to avoid aCalloc/aFree spamming during char change. [Skotlex] character->char_id = -1; character->server = -1; if(character->waiting_disconnect != -1){ delete_timer(character->waiting_disconnect, chardb_waiting_disconnect); character->waiting_disconnect = -1; } } if (login_fd > 0 && !session[login_fd]->eof) { WFIFOHEAD(login_fd,6); WFIFOW(login_fd,0) = 0x272c; WFIFOL(login_fd,2) = account_id; WFIFOSET(login_fd,6); } } static int char_db_setoffline(DBKey key, void* data, va_list ap) { struct online_char_data* character = (struct online_char_data*)data; int server = va_arg(ap, int); if (server == -1) { character->char_id = -1; character->server = -1; if(character->waiting_disconnect != -1){ delete_timer(character->waiting_disconnect, chardb_waiting_disconnect); character->waiting_disconnect = -1; } } else if (character->server == server) character->server = -2; //In some map server that we aren't connected to. return 0; } static int char_db_kickoffline(DBKey key, void* data, va_list ap) { struct online_char_data* character = (struct online_char_data*)data; int server = va_arg(ap, int); if (server > -1 && character->server != server) return 0; //Kick out any connected characters, and set them offline as appropiate. if (character->server > -1) mapif_disconnectplayer(server_fd[character->server], character->account_id, character->char_id, 1); else if (character->waiting_disconnect == -1) set_char_offline(character->char_id, character->account_id); else return 0; return 1; } void set_all_offline(int id) { if (id < 0) ShowNotice("Sending all users offline.\n"); else ShowNotice("Sending users of map-server %d offline.\n",id); online_char_db->foreach(online_char_db,char_db_kickoffline,id); if (id >= 0 || login_fd <= 0 || session[login_fd]->eof) return; //Tell login-server to also mark all our characters as offline. WFIFOHEAD(login_fd,2); WFIFOW(login_fd,0) = 0x2737; WFIFOSET(login_fd,2); } void set_all_offline_sql(void) { //Set all players to 'OFFLINE' sprintf(tmp_sql, "UPDATE `%s` SET `online` = '0'", char_db); if(mysql_query(&mysql_handle, tmp_sql)){ ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sprintf(tmp_sql, "UPDATE `%s` SET `online` = '0'", guild_member_db); if(mysql_query(&mysql_handle, tmp_sql)){ ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sprintf(tmp_sql, "UPDATE `%s` SET `connect_member` = '0'", guild_db); if(mysql_query(&mysql_handle, tmp_sql)){ ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } } //---------------------------------------------------------------------- // Determine if an account (id) is a GM account // and returns its level (or 0 if it isn't a GM account or if not found) //---------------------------------------------------------------------- // Removed since nothing GM related goes on in the char server [CLOWNISIUS] int isGM(int account_id) { int i; for(i = 0; i < GM_num; i++) if (gm_account[i].account_id == account_id) return gm_account[i].level; return 0; } void read_gm_account(void) { if(!char_gm_read) return; if (gm_account != NULL) aFree(gm_account); GM_num = 0; sprintf(tmp_sql, "SELECT `%s`,`%s` FROM `%s` WHERE `%s`>='%d'",login_db_account_id,login_db_level,login_db,login_db_level,lowest_gm_level); if (mysql_query(&lmysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&lmysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } lsql_res = mysql_store_result(&lmysql_handle); if (lsql_res) { gm_account = (struct gm_account*)aCalloc(sizeof(struct gm_account) * (size_t)mysql_num_rows(lsql_res), 1); while ((lsql_row = mysql_fetch_row(lsql_res))) { gm_account[GM_num].account_id = atoi(lsql_row[0]); gm_account[GM_num].level = atoi(lsql_row[1]); GM_num++; } } mysql_free_result(lsql_res); mapif_send_gmaccounts(); } #endif //TXT_SQL_CONVERT int compare_item(struct item *a, struct item *b) { if(a->id == b->id && a->nameid == b->nameid && a->amount == b->amount && a->equip == b->equip && a->identify == b->identify && a->refine == b->refine && a->attribute == b->attribute) { int i; for (i=0; icard[i]==b->card[i]; i++); return (i == MAX_SLOTS); } return 0; } #ifndef TXT_SQL_CONVERT static void* create_charstatus(DBKey key, va_list args) { struct mmo_charstatus *cp; cp = (struct mmo_charstatus *) aCalloc(1,sizeof(struct mmo_charstatus)); cp->char_id = key.i; return cp; } #endif //TXT_SQL_CONVERT int mmo_char_tosql(int char_id, struct mmo_charstatus *p){ int i=0,j; int count = 0; int diff = 0; char *tmp_ptr; //Building a single query should be more efficient than running //multiple queries for each thing about to be saved, right? [Skotlex] char save_status[128]; //For displaying save information. [Skotlex] struct mmo_charstatus *cp; struct itemtmp mapitem[MAX_GUILD_STORAGE]; if (char_id!=p->char_id) return 0; #ifndef TXT_SQL_CONVERT cp = idb_ensure(char_db_, char_id, create_charstatus); #else cp = aCalloc(1, sizeof(struct mmo_charstatus)); #endif memset(save_status, 0, sizeof(save_status)); diff = 0; //map inventory data for(i=0;iinventory[i], &cp->inventory[i])) diff = 1; if(p->inventory[i].nameid>0){ mapitem[count].flag=0; mapitem[count].id = p->inventory[i].id; mapitem[count].nameid=p->inventory[i].nameid; mapitem[count].amount = p->inventory[i].amount; mapitem[count].equip = p->inventory[i].equip; mapitem[count].identify = p->inventory[i].identify; mapitem[count].refine = p->inventory[i].refine; mapitem[count].attribute = p->inventory[i].attribute; for (j=0; jinventory[i].card[j]; count++; } } //printf("- Save item data to MySQL!\n"); if (diff) if (!memitemdata_to_sql(mapitem, count, p->char_id,TABLE_INVENTORY)) strcat(save_status, " inventory"); count = 0; diff = 0; //map cart data for(i=0;icart[i], &cp->cart[i])) diff = 1; if(p->cart[i].nameid>0){ mapitem[count].flag=0; mapitem[count].id = p->cart[i].id; mapitem[count].nameid=p->cart[i].nameid; mapitem[count].amount = p->cart[i].amount; mapitem[count].equip = p->cart[i].equip; mapitem[count].identify = p->cart[i].identify; mapitem[count].refine = p->cart[i].refine; mapitem[count].attribute = p->cart[i].attribute; for (j=0; jcart[i].card[j]; count++; } } if (diff) if (!memitemdata_to_sql(mapitem, count, p->char_id,TABLE_CART)) strcat(save_status, " cart"); #ifdef TXT_SQL_CONVERT { //Insert the barebones to then update the rest. char t_name[NAME_LENGTH*2]; jstrescapecpy(t_name, p->name); sprintf(tmp_sql, "REPLACE INTO `%s` (`account_id`, `char_num`, `name`) VALUES ('%d', '%d', '%s')", char_db, p->account_id, p->char_num, t_name); if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } else strcat(save_status, " creation"); } #endif if ( (p->base_exp != cp->base_exp) || (p->base_level != cp->base_level) || (p->job_level != cp->job_level) || (p->job_exp != cp->job_exp) || (p->zeny != cp->zeny) || (p->last_point.x != cp->last_point.x) || (p->last_point.y != cp->last_point.y) || (p->max_hp != cp->max_hp) || (p->hp != cp->hp) || (p->max_sp != cp->max_sp) || (p->sp != cp->sp) || (p->status_point != cp->status_point) || (p->skill_point != cp->skill_point) || (p->str != cp->str) || (p->agi != cp->agi) || (p->vit != cp->vit) || (p->int_ != cp->int_) || (p->dex != cp->dex) || (p->luk != cp->luk) || (p->option != cp->option) || (p->party_id != cp->party_id) || (p->guild_id != cp->guild_id) || (p->pet_id != cp->pet_id) || (p->weapon != cp->weapon) || (p->hom_id != cp->hom_id) || (p->shield != cp->shield) || (p->head_top != cp->head_top) || (p->head_mid != cp->head_mid) || (p->head_bottom != cp->head_bottom) ) { //Save status sprintf(tmp_sql ,"UPDATE `%s` SET `base_level`='%d', `job_level`='%d'," "`base_exp`='%u', `job_exp`='%u', `zeny`='%d'," "`max_hp`='%d',`hp`='%d',`max_sp`='%d',`sp`='%d',`status_point`='%d',`skill_point`='%d'," "`str`='%d',`agi`='%d',`vit`='%d',`int`='%d',`dex`='%d',`luk`='%d'," "`option`='%d',`party_id`='%d',`guild_id`='%d',`pet_id`='%d',`homun_id`='%d'," //[orn] add homun_id (homunculus id) "`weapon`='%d',`shield`='%d',`head_top`='%d',`head_mid`='%d',`head_bottom`='%d'," "`last_map`='%s',`last_x`='%d',`last_y`='%d',`save_map`='%s',`save_x`='%d',`save_y`='%d'" " WHERE `account_id`='%d' AND `char_id` = '%d'", char_db, p->base_level, p->job_level, p->base_exp, p->job_exp, p->zeny, p->max_hp, p->hp, p->max_sp, p->sp, p->status_point, p->skill_point, p->str, p->agi, p->vit, p->int_, p->dex, p->luk, p->option, p->party_id, p->guild_id, p->pet_id, p->hom_id, //[orn] add homun_id (homunculus id) p->weapon, p->shield, p->head_top, p->head_mid, p->head_bottom, mapindex_id2name(p->last_point.map), p->last_point.x, p->last_point.y, mapindex_id2name(p->save_point.map), p->save_point.x, p->save_point.y, p->account_id, p->char_id ); if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } else strcat(save_status, " status"); } //Values that will seldom change (to speed up saving) if ( (p->hair != cp->hair) || (p->hair_color != cp->hair_color) || (p->clothes_color != cp->clothes_color) || (p->class_ != cp->class_) || (p->partner_id != cp->partner_id) || (p->father != cp->father) || (p->mother != cp->mother) || (p->child != cp->child) || (p->karma != cp->karma) || (p->manner != cp->manner) || (p->fame != cp->fame) ) { sprintf(tmp_sql ,"UPDATE `%s` SET `class`='%d'," "`hair`='%d',`hair_color`='%d',`clothes_color`='%d'," "`partner_id`='%d', `father`='%d', `mother`='%d', `child`='%d'," "`karma`='%d',`manner`='%d', `fame`='%d'" " WHERE `account_id`='%d' AND `char_id` = '%d'", char_db, p->class_, p->hair, p->hair_color, p->clothes_color, p->partner_id, p->father, p->mother, p->child, p->karma, p->manner, p->fame, p->account_id, p->char_id ); if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } else strcat(save_status, " status2"); } diff = 0; for(i=0;imemo_point[i].map == cp->memo_point[i].map && p->memo_point[i].x == cp->memo_point[i].x && p->memo_point[i].y == cp->memo_point[i].y) continue; diff = 1; break; } if (diff) { //Save memo //`memo` (`memo_id`,`char_id`,`map`,`x`,`y`) sprintf(tmp_sql,"DELETE FROM `%s` WHERE `char_id`='%d'",memo_db, p->char_id); if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } //insert here. tmp_ptr = tmp_sql; tmp_ptr += sprintf(tmp_ptr, "INSERT INTO `%s`(`char_id`,`map`,`x`,`y`) VALUES ", memo_db); count = 0; for(i=0;imemo_point[i].map){ tmp_ptr += sprintf(tmp_ptr,"('%d', '%s', '%d', '%d'),", char_id, mapindex_id2name(p->memo_point[i].map), p->memo_point[i].x, p->memo_point[i].y); count++; } } if (count) { //Dangerous? Only if none of the above sprintf worked. [Skotlex] tmp_ptr[-1] = '\0'; //Remove the trailing comma. if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } else strcat(save_status, " memo"); } else //Memo Points cleared (how is this possible?). strcat(save_status, " memo"); } diff = 0; for(i=0;iskill[i].lv != 0) && (p->skill[i].id == 0)) p->skill[i].id = i; // Fix skill tree if((p->skill[i].id != cp->skill[i].id) || (p->skill[i].lv != cp->skill[i].lv) || (p->skill[i].flag != cp->skill[i].flag)) { diff = 1; break; } } if (diff) { //Save skills //`skill` (`char_id`, `id`, `lv`) sprintf(tmp_sql,"DELETE FROM `%s` WHERE `char_id`='%d'",skill_db, p->char_id); if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } tmp_ptr = tmp_sql; tmp_ptr += sprintf(tmp_ptr,"INSERT INTO `%s`(`char_id`,`id`,`lv`) VALUES ", skill_db); count = 0; //insert here. for(i=0;iskill[i].id && p->skill[i].flag!=1) { tmp_ptr += sprintf(tmp_ptr,"('%d','%d','%d'),", char_id, p->skill[i].id, (p->skill[i].flag==0)?p->skill[i].lv:p->skill[i].flag-2); count++; } } if (count) { tmp_ptr[-1] = '\0'; //Remove trailing comma. if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } else strcat(save_status, " skills"); } else //Skills removed (reset?) strcat(save_status, " skills"); } diff = 0; for(i = 0; i < MAX_FRIENDS; i++){ if(p->friends[i].char_id != cp->friends[i].char_id || p->friends[i].account_id != cp->friends[i].account_id){ diff = 1; break; } } if(diff == 1) { //Save friends sprintf(tmp_sql, "DELETE FROM `%s` WHERE `char_id`='%d'", friend_db, char_id); if(mysql_query(&mysql_handle, tmp_sql)){ ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } tmp_ptr = tmp_sql; tmp_ptr += sprintf(tmp_ptr, "INSERT INTO `%s` (`char_id`, `friend_account`, `friend_id`) VALUES ", friend_db); count = 0; for(i = 0; i < MAX_FRIENDS; i++){ if(p->friends[i].char_id > 0) { tmp_ptr += sprintf(tmp_ptr, "('%d','%d','%d'),", char_id, p->friends[i].account_id, p->friends[i].char_id); count++; } } if (count) { tmp_ptr[-1] = '\0'; //Remove the last comma. [Skotlex] if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } else strcat(save_status, " friends"); } else //Friend list cleared. strcat(save_status, " friends"); } if (save_status[0]!='\0' && save_log) ShowInfo("Saved char %d - %s:%s.\n", char_id, p->name, save_status); #ifndef TXT_SQL_CONVERT memcpy(cp, p, sizeof(struct mmo_charstatus)); #else aFree(cp); #endif return 0; } // [Ilpalazzo-sama] int memitemdata_to_sql(struct itemtmp mapitem[], int count, int char_id, int tableswitch) { int i,j, flag, id; char *tablename; char selectoption[16]; char * str_p = tmp_sql; switch (tableswitch) { case TABLE_INVENTORY: tablename = inventory_db; // no need for sprintf here as *_db are char*. sprintf(selectoption,"char_id"); break; case TABLE_CART: tablename = cart_db; sprintf(selectoption,"char_id"); break; case TABLE_STORAGE: tablename = storage_db; sprintf(selectoption,"account_id"); break; case TABLE_GUILD_STORAGE: tablename = guild_storage_db; sprintf(selectoption,"guild_id"); break; default: ShowError("Invalid table name!\n"); return 1; } //=======================================mysql database data > memory=============================================== str_p += sprintf(str_p, "SELECT `id`, `nameid`, `amount`, `equip`, `identify`, `refine`, `attribute`"); for (j=0; j SQL =============================== #ifndef TXT_SQL_CONVERT if(!itemdb_isequip(mapitem[i].nameid)) { //Quick update of stackable items. Update Qty and Equip should be enough, but in case we are also updating identify sprintf(tmp_sql,"UPDATE `%s` SET `equip`='%d', `identify`='%d', `amount`='%d' WHERE `id`='%d' LIMIT 1", tablename, mapitem[i].equip, mapitem[i].identify,mapitem[i].amount, id); if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } } else #endif //TXT_SQL_CONVERT { //Equipment or Misc item, just update all fields. str_p = tmp_sql; str_p += sprintf(str_p,"UPDATE `%s` SET `equip`='%d', `identify`='%d', `refine`='%d',`attribute`='%d'", tablename, mapitem[i].equip, mapitem[i].identify, mapitem[i].refine, mapitem[i].attribute); for(j=0; jchar_id = char_id; if (save_log) ShowInfo("Char load request (%d)\n", char_id); //`char`( `char_id`,`account_id`,`char_num`,`name`,`class`,`base_level`,`job_level`,`base_exp`,`job_exp`,`zeny`, //9 //`str`,`agi`,`vit`,`int`,`dex`,`luk`, //15 //`max_hp`,`hp`,`max_sp`,`sp`,`status_point`,`skill_point`, //21 //`option`,`karma`,`manner`,`party_id`,`guild_id`,`pet_id`, //27 //`hair`,`hair_color`,`clothes_color`,`weapon`,`shield`,`head_top`,`head_mid`,`head_bottom`, //35 //`last_map`,`last_x`,`last_y`,`save_map`,`save_x`,`save_y`) //splite 2 parts. cause veeeery long SQL syntax sprintf(tmp_sql, "SELECT `char_id`,`account_id`,`char_num`,`name`,`class`,`base_level`,`job_level`,`base_exp`,`job_exp`,`zeny`," "`str`,`agi`,`vit`,`int`,`dex`,`luk`, `max_hp`,`hp`,`max_sp`,`sp`,`status_point`,`skill_point` FROM `%s` WHERE `char_id` = '%d'",char_db, char_id); // TBR if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result(&mysql_handle); if (sql_res) { sql_row = mysql_fetch_row(sql_res); if (!sql_row) { //Just how does this happens? [Skotlex] ShowError("Requested non-existant character id: %d!\n", char_id); return 0; } p->char_id = char_id; p->account_id = atoi(sql_row[1]); p->char_num = atoi(sql_row[2]); strcpy(p->name, sql_row[3]); p->class_ = atoi(sql_row[4]); p->base_level = atoi(sql_row[5]); p->job_level = atoi(sql_row[6]); exp = atof(sql_row[7]); p->base_exp = exp<0?0:(exp>UINT_MAX?UINT_MAX:(unsigned int)exp); exp = atof(sql_row[8]); p->job_exp = exp<0?0:(exp>UINT_MAX?UINT_MAX:(unsigned int)exp); p->zeny = atoi(sql_row[9]); p->str = atoi(sql_row[10]); p->agi = atoi(sql_row[11]); p->vit = atoi(sql_row[12]); p->int_ = atoi(sql_row[13]); p->dex = atoi(sql_row[14]); p->luk = atoi(sql_row[15]); p->max_hp = atoi(sql_row[16]); p->hp = atoi(sql_row[17]); p->max_sp = atoi(sql_row[18]); p->sp = atoi(sql_row[19]); p->status_point = atoi(sql_row[20]) > USHRT_MAX ? USHRT_MAX : atoi(sql_row[20]); p->skill_point = atoi(sql_row[21]) > USHRT_MAX ? USHRT_MAX : atoi(sql_row[21]); //free mysql result. mysql_free_result(sql_res); strcat (t_msg, " status"); } else ShowError("Load char failed (%d - table %s).\n", char_id, char_db); //Error?! ERRRRRR WHAT THAT SAY!? sprintf(tmp_sql, "SELECT `option`,`karma`,`manner`,`party_id`,`guild_id`,`pet_id`,`hair`,`hair_color`," "`clothes_color`,`weapon`,`shield`,`head_top`,`head_mid`,`head_bottom`," "`last_map`,`last_x`,`last_y`,`save_map`,`save_x`,`save_y`, `partner_id`, `father`, `mother`, `child`, `fame`, `homun_id`" //[orn] homun_id "FROM `%s` WHERE `char_id` = '%d'",char_db, char_id); // TBR if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result(&mysql_handle); sql_row = sql_res?mysql_fetch_row(sql_res):NULL; if (sql_row) { p->option = atoi(sql_row[0]); p->karma = atoi(sql_row[1]); p->manner = atoi(sql_row[2]); p->party_id = atoi(sql_row[3]); p->guild_id = atoi(sql_row[4]); p->pet_id = atoi(sql_row[5]); p->hair = atoi(sql_row[6]); p->hair_color = atoi(sql_row[7]); p->clothes_color = atoi(sql_row[8]); p->weapon = atoi(sql_row[9]); p->shield = atoi(sql_row[10]); p->head_top = atoi(sql_row[11]); p->head_mid = atoi(sql_row[12]); p->head_bottom = atoi(sql_row[13]); p->last_point.map = mapindex_name2id(sql_row[14]); p->last_point.x = atoi(sql_row[15]); p->last_point.y = atoi(sql_row[16]); p->save_point.map = mapindex_name2id(sql_row[17]); p->save_point.x = atoi(sql_row[18]); p->save_point.y = atoi(sql_row[19]); p->partner_id = atoi(sql_row[20]); p->father = atoi(sql_row[21]); p->mother = atoi(sql_row[22]); p->child = atoi(sql_row[23]); p->fame = atoi(sql_row[24]); p->hom_id = atoi(sql_row[25]); //[orn] homunculus id strcat (t_msg, " status2"); } else ShowError("Char load failed (%d - table %s)\n", char_id, char_db); //Error?! ERRRRRR WHAT THAT SAY!? //free mysql result. if (sql_res) mysql_free_result(sql_res); //read memo data //`memo` (`memo_id`,`char_id`,`map`,`x`,`y`) sprintf(tmp_sql, "SELECT `map`,`x`,`y` FROM `%s` WHERE `char_id`='%d' ORDER by `memo_id`",memo_db, char_id); // TBR if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result(&mysql_handle); if (sql_res) { for(i=0;(sql_row = mysql_fetch_row(sql_res));i++){ p->memo_point[i].map = mapindex_name2id(sql_row[0]); p->memo_point[i].x=atoi(sql_row[1]); p->memo_point[i].y=atoi(sql_row[2]); //i ++; } mysql_free_result(sql_res); strcat (t_msg, " memo"); } //read inventory //`inventory` (`id`,`char_id`, `nameid`, `amount`, `equip`, `identify`, `refine`, `attribute`, `card0`, `card1`, `card2`, `card3`) str_p += sprintf(str_p, "SELECT `id`, `nameid`, `amount`, `equip`, `identify`, `refine`, `attribute`"); for (j=0; jinventory[i].id = atoi(sql_row[0]); p->inventory[i].nameid = atoi(sql_row[1]); p->inventory[i].amount = atoi(sql_row[2]); p->inventory[i].equip = atoi(sql_row[3]); p->inventory[i].identify = atoi(sql_row[4]); p->inventory[i].refine = atoi(sql_row[5]); p->inventory[i].attribute = atoi(sql_row[6]); for (j=0; jinventory[i].card[j] = atoi(sql_row[7+j]); } mysql_free_result(sql_res); strcat (t_msg, " inventory"); } //read cart. //`cart_inventory` (`id`,`char_id`, `nameid`, `amount`, `equip`, `identify`, `refine`, `attribute`, `card0`, `card1`, `card2`, `card3`) str_p = tmp_sql; str_p += sprintf(str_p, "SELECT `id`, `nameid`, `amount`, `equip`, `identify`, `refine`, `attribute`"); for (j=0; jcart[i].id = atoi(sql_row[0]); p->cart[i].nameid = atoi(sql_row[1]); p->cart[i].amount = atoi(sql_row[2]); p->cart[i].equip = atoi(sql_row[3]); p->cart[i].identify = atoi(sql_row[4]); p->cart[i].refine = atoi(sql_row[5]); p->cart[i].attribute = atoi(sql_row[6]); for(j=0; jcart[i].card[j] = atoi(sql_row[7+j]); } mysql_free_result(sql_res); strcat (t_msg, " cart"); } //read skill //`skill` (`char_id`, `id`, `lv`) sprintf(tmp_sql, "SELECT `id`, `lv` FROM `%s` WHERE `char_id`='%d'",skill_db, char_id); // TBR if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result(&mysql_handle); if (sql_res) { for(i=0;(sql_row = mysql_fetch_row(sql_res));i++){ n = atoi(sql_row[0]); p->skill[n].id = n; //memory!? shit!. p->skill[n].lv = atoi(sql_row[1]); } mysql_free_result(sql_res); strcat (t_msg, " skills"); } /* Global-reg loading is now handled by the inter-server. //global_reg //`global_reg_value` (`char_id`, `str`, `value`) sprintf(tmp_sql, "SELECT `str`, `value` FROM `%s` WHERE `type`=3 AND `char_id`='%d'",reg_db, char_id); // TBR if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } i = 0; sql_res = mysql_store_result(&mysql_handle); if (sql_res) { for(i=0;(sql_row = mysql_fetch_row(sql_res));i++){ strcpy (p->global_reg[i].str, sql_row[0]); strcpy (p->global_reg[i].value, sql_row[1]); } mysql_free_result(sql_res); strcat (t_msg, " reg_values"); } p->global_reg_num=i; */ //Shamelessly stolen from its_sparky (ie: thanks) and then assimilated by [Skotlex] //Friend list sprintf(tmp_sql, "SELECT f.friend_account, f.friend_id, c.name FROM `%s` f LEFT JOIN `%s` c ON f.friend_account=c.account_id AND f.friend_id=c.char_id WHERE f.char_id='%d'", friend_db, char_db, char_id); if(mysql_query(&mysql_handle, tmp_sql)){ ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result(&mysql_handle); if(sql_res) { for(i = 0; (sql_row = mysql_fetch_row(sql_res)) && ifriends[i].account_id = atoi(sql_row[0]); p->friends[i].char_id = atoi(sql_row[1]); strncpy(p->friends[i].name, sql_row[2], NAME_LENGTH-1); //The -1 is to avoid losing the ending \0 [Skotlex] } } } mysql_free_result(sql_res); strcat (t_msg, " friends"); } if (save_log) ShowInfo("Loaded char (%d - %s): %s\n", char_id, p->name, t_msg); //ok. all data load successfuly! cp = idb_ensure(char_db_, char_id, create_charstatus); memcpy(cp, p, sizeof(struct mmo_charstatus)); return 1; } // For quick selection of data when displaying the char menu. [Skotlex] // int mmo_char_fromsql_short(int char_id, struct mmo_charstatus *p){ char t_msg[128]; double exp; memset(p, 0, sizeof(struct mmo_charstatus)); t_msg[0]= '\0'; p->char_id = char_id; // ShowInfo("Quick Char load request (%d)\n", char_id); //`char`( `char_id`,`account_id`,`char_num`,`name`,`class`,`base_level`,`job_level`,`base_exp`,`job_exp`,`zeny`, //9 //`str`,`agi`,`vit`,`int`,`dex`,`luk`, //15 //`max_hp`,`hp`,`max_sp`,`sp`,`status_point`,`skill_point`, //21 //`option`,`karma`,`manner`,`party_id`,`guild_id`,`pet_id`, //27 //`hair`,`hair_color`,`clothes_color`,`weapon`,`shield`,`head_top`,`head_mid`,`head_bottom`, //35 //`last_map`,`last_x`,`last_y`,`save_map`,`save_x`,`save_y`) //splite 2 parts. cause veeeery long SQL syntax sprintf(tmp_sql, "SELECT `char_id`,`account_id`,`char_num`,`name`,`class`,`base_level`,`job_level`,`base_exp`,`job_exp`,`zeny`," "`str`,`agi`,`vit`,`int`,`dex`,`luk`, `max_hp`,`hp`,`max_sp`,`sp`,`status_point`,`skill_point` FROM `%s` WHERE `char_id` = '%d'",char_db, char_id); // TBR if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result(&mysql_handle); if (sql_res) { sql_row = mysql_fetch_row(sql_res); if (!sql_row) { //Just how does this happens? [Skotlex] ShowError("Requested non-existant character id: %d!\n", char_id); mysql_free_result(sql_res); return 0; } p->char_id = char_id; p->account_id = atoi(sql_row[1]); p->char_num = atoi(sql_row[2]); strcpy(p->name, sql_row[3]); p->class_ = atoi(sql_row[4]); p->base_level = atoi(sql_row[5]); p->job_level = atoi(sql_row[6]); exp = atof(sql_row[7]); p->base_exp = exp<0?0:(exp>UINT_MAX?UINT_MAX:(unsigned int)exp); exp = atof(sql_row[8]); p->job_exp = exp<0?0:(exp>UINT_MAX?UINT_MAX:(unsigned int)exp); p->zeny = atoi(sql_row[9]); p->str = atoi(sql_row[10]); p->agi = atoi(sql_row[11]); p->vit = atoi(sql_row[12]); p->int_ = atoi(sql_row[13]); p->dex = atoi(sql_row[14]); p->luk = atoi(sql_row[15]); p->max_hp = atoi(sql_row[16]); p->hp = atoi(sql_row[17]); p->max_sp = atoi(sql_row[18]); p->sp = atoi(sql_row[19]); p->status_point = atoi(sql_row[20]) > USHRT_MAX ? USHRT_MAX : atoi(sql_row[20]); p->skill_point = atoi(sql_row[21]) > USHRT_MAX ? USHRT_MAX : atoi(sql_row[21]); //free mysql result. mysql_free_result(sql_res); strcat (t_msg, " status"); } else ShowError("Load char failed (%d - table %s).\n", char_id, char_db); //Error?! ERRRRRR WHAT THAT SAY!? sprintf(tmp_sql, "SELECT `option`,`karma`,`manner`,`hair`,`hair_color`," "`clothes_color`,`weapon`,`shield`,`head_top`,`head_mid`,`head_bottom`" "FROM `%s` WHERE `char_id` = '%d'",char_db, char_id); // TBR if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result(&mysql_handle); sql_row = sql_res?mysql_fetch_row(sql_res):NULL; if (sql_row) { p->option = atoi(sql_row[0]); p->karma = atoi(sql_row[1]); p->manner = atoi(sql_row[2]); p->hair = atoi(sql_row[3]); p->hair_color = atoi(sql_row[4]); p->clothes_color = atoi(sql_row[5]); p->weapon = atoi(sql_row[6]); p->shield = atoi(sql_row[7]); p->head_top = atoi(sql_row[8]); p->head_mid = atoi(sql_row[9]); p->head_bottom = atoi(sql_row[10]); strcat (t_msg, " status2"); } else ShowError("Char load failed (%d - table %s)\n", char_id, char_db); //Error?! ERRRRRR WHAT THAT SAY!? //free mysql result. if (sql_res) mysql_free_result(sql_res); // if (save_log) //Too much spam :/ // ShowInfo("Quick Loaded char (%d - %s): %s\n", char_id, p->name, t_msg); //ok. all data load successfuly! return 1; } //========================================================================================================== int mmo_char_sql_init(void) { ShowInfo("Begin Initializing.......\n"); char_db_= db_alloc(__FILE__,__LINE__,DB_INT,DB_OPT_RELEASE_DATA, sizeof(int)); // memory initialize memset(&char_dat, 0, sizeof(struct mmo_charstatus)); if(char_per_account == 0){ ShowStatus("Chars per Account: 'Unlimited'.......\n"); }else{ ShowStatus("Chars per Account: '%d'.......\n", char_per_account); } //the 'set offline' part is now in check_login_conn ... //if the server connects to loginserver //it will dc all off players //and send the loginserver the new state.... // Force all users offline in sql when starting char-server // (useful when servers crashs and don't clean the database) set_all_offline_sql(); ShowInfo("Finished initilizing.......\n"); return 0; } //========================================================================================================== int make_new_char_sql(int fd, unsigned char *dat) { struct char_session_data *sd; char name[NAME_LENGTH]; char t_name[NAME_LENGTH*2]; unsigned int i; // Used in for loop and comparing with strlen, safe to be unsigned. [Lance] int char_id, temp; strncpy(name, dat, NAME_LENGTH); name[NAME_LENGTH-1] = '\0'; //Always terminate string. normalize_name(name,TRIM_CHARS); //Normalize character name. [Skotlex] jstrescapecpy(t_name, name); // disabled until fixed >.> // Note: escape characters should be added to jstrescape()! //mysql_real_escape_string(&mysql_handle, t_name, t_name_temp, sizeof(t_name_temp)); if (!session_isValid(fd) || !(sd = (struct char_session_data*)session[fd]->session_data)) return -2; ShowInfo("New character request (%d)\n", sd->account_id); //check name != main chat nick [LuzZza] if(strcmpi(name, main_chat_nick) == 0) { ShowInfo("Create char failed (%d): this nick (%s) reserved for mainchat messages.\n", sd->account_id, name); return -2; } //check for charcount (maxchars) :) if(char_per_account != 0){ sprintf(tmp_sql, "SELECT `account_id` FROM `%s` WHERE `account_id` = '%d'", char_db, sd->account_id); if(mysql_query(&mysql_handle, tmp_sql)){ ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result(&mysql_handle); if(sql_res){ //ok temp = (int)mysql_num_rows(sql_res); if(temp >= char_per_account){ //hehe .. limit exceeded :P ShowInfo("Create char failed (%d): charlimit exceeded.\n", sd->account_id); mysql_free_result(sql_res); return -2; } mysql_free_result(sql_res); } } // Check Authorised letters/symbols in the name of the character if (char_name_option == 1) { // only letters/symbols in char_name_letters are authorised for (i = 0; i < NAME_LENGTH && name[i]; i++) if (strchr(char_name_letters, name[i]) == NULL) return -2; } else if (char_name_option == 2) { // letters/symbols in char_name_letters are forbidden for (i = 0; i < NAME_LENGTH && name[i]; i++) if (strchr(char_name_letters, name[i]) != NULL) return -2; } // else, all letters/symbols are authorised (except control char removed before) //check stat error if ((dat[24]+dat[25]+dat[26]+dat[27]+dat[28]+dat[29]!=6*5 ) || // stats (dat[30] >= MAX_CHARS) || // slots (dat[30] can not be negativ) (dat[33] <= 0) || (dat[33] >= 24) || // hair style (dat[31] >= 9)) { // hair color (dat[31] can not be negativ) if (log_char) { // char.log to charlog sprintf(tmp_sql,"INSERT INTO `%s` (`time`, `char_msg`,`account_id`,`char_num`,`name`,`str`,`agi`,`vit`,`int`,`dex`,`luk`,`hair`,`hair_color`)" "VALUES (NOW(), '%s', '%d', '%d', '%s', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d')", charlog_db,"make new char error", sd->account_id, dat[30], t_name, dat[24], dat[25], dat[26], dat[27], dat[28], dat[29], dat[33], dat[31]); //query if(mysql_query(&mysql_handle, tmp_sql)){ ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } } ShowWarning("Create char failed (%d): stats error (bot cheat?!)\n", sd->account_id); return -2; } // for now we have checked: stat points used <31, char slot is less then 9, hair style/color values are acceptable // check individual stat value for(i = 24; i <= 29; i++) { if (dat[i] < 1 || dat[i] > 9) { if (log_char) { // char.log to charlog sprintf(tmp_sql,"INSERT INTO `%s` (`time`, `char_msg`,`account_id`,`char_num`,`name`,`str`,`agi`,`vit`,`int`,`dex`,`luk`,`hair`,`hair_color`)" "VALUES (NOW(), '%s', '%d', '%d', '%s', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d')", charlog_db,"make new char error", sd->account_id, dat[30], t_name, dat[24], dat[25], dat[26], dat[27], dat[28], dat[29], dat[33], dat[31]); //query if(mysql_query(&mysql_handle, tmp_sql)){ ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } } ShowWarning("Create char failed (%d): stats error (bot cheat?!)\n", sd->account_id); return -2; } } // now we know that every stat has proper value but we have to check if str/int agi/luk vit/dex pairs are correct if( ((dat[24]+dat[27]) > 10) || ((dat[25]+dat[29]) > 10) || ((dat[26]+dat[28]) > 10) ) { if (log_char) { // char.log to charlog sprintf(tmp_sql,"INSERT INTO `%s` (`time`, `char_msg`,`account_id`,`char_num`,`name`,`str`,`agi`,`vit`,`int`,`dex`,`luk`,`hair`,`hair_color`)" "VALUES (NOW(), '%s', '%d', '%d', '%s', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d')", charlog_db,"make new char error", sd->account_id, dat[30], t_name, dat[24], dat[25], dat[26], dat[27], dat[28], dat[29], dat[33], dat[31]); //query if(mysql_query(&mysql_handle, tmp_sql)){ ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } } ShowWarning("Create char failed (%d): stats error (bot cheat?!)\n", sd->account_id); return -2; } // now when we have passed all stat checks if (log_char) { // char.log to charlog sprintf(tmp_sql,"INSERT INTO `%s`(`time`, `char_msg`,`account_id`,`char_num`,`name`,`str`,`agi`,`vit`,`int`,`dex`,`luk`,`hair`,`hair_color`)" "VALUES (NOW(), '%s', '%d', '%d', '%s', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d')", charlog_db,"make new char", sd->account_id, dat[30], t_name, dat[24], dat[25], dat[26], dat[27], dat[28], dat[29], dat[33], dat[31]); //query if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } } //printf("make new char %d-%d %s %d, %d, %d, %d, %d, %d - %d, %d" RETCODE, // fd, dat[30], dat, dat[24], dat[25], dat[26], dat[27], dat[28], dat[29], dat[33], dat[31]); //Check Name (already in use?) sprintf(tmp_sql, "SELECT 1 FROM `%s` WHERE `name` = '%s'",char_db, t_name); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); return -2; } sql_res = mysql_store_result(&mysql_handle); if(sql_res){ temp = (int)mysql_num_rows(sql_res); mysql_free_result(sql_res); if (temp > 0) { ShowInfo("Create char failed: charname already in use\n"); return -1; } } // check char slot. sprintf(tmp_sql, "SELECT `account_id`, `char_num` FROM `%s` WHERE `account_id` = '%d' AND `char_num` = '%d'",char_db, sd->account_id, dat[30]); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result(&mysql_handle); if(sql_res){ temp = (int)mysql_num_rows(sql_res); mysql_free_result(sql_res); if (temp > 0) { ShowWarning("Create char failed (%d, slot: %d), slot already in use\n", sd->account_id, dat[30]); return -2; } } //New Querys [Sirius] //Insert the char to the 'chardb' ^^ sprintf(tmp_sql, "INSERT INTO `%s` (`account_id`, `char_num`, `name`, `zeny`, `str`, `agi`, `vit`, `int`, `dex`, `luk`, `max_hp`, `hp`," "`max_sp`, `sp`, `hair`, `hair_color`, `last_map`, `last_x`, `last_y`, `save_map`, `save_x`, `save_y`) VALUES (" "'%d', '%d', '%s', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d', '%d','%d', '%d','%d', '%d', '%s', '%d', '%d', '%s', '%d', '%d')", char_db, sd->account_id , dat[30] , t_name, start_zeny, dat[24], dat[25], dat[26], dat[27], dat[28], dat[29], (40 * (100 + dat[26])/100) , (40 * (100 + dat[26])/100 ), (11 * (100 + dat[27])/100), (11 * (100 + dat[27])/100), dat[33], dat[31], mapindex_id2name(start_point.map), start_point.x, start_point.y, mapindex_id2name(start_point.map), start_point.x, start_point.y); if(mysql_query(&mysql_handle, tmp_sql)){ ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); return -2; //No, stop the procedure! } //Now we need the charid from sql! if(mysql_field_count(&mysql_handle) == 0 && mysql_insert_id(&mysql_handle) > 0) char_id = (int)mysql_insert_id(&mysql_handle); else { //delete the char ..(no trash in DB!) but how is this possible? sprintf(tmp_sql, "DELETE FROM `%s` WHERE `account_id` = '%d' AND `char_num` = '%d' AND `name` = '%s'", char_db, sd->account_id, dat[30], t_name); if(mysql_query(&mysql_handle, tmp_sql)){ ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } return -2; //XD end of the (World? :P) .. charcreate (denied) } //Give the char the default items //`inventory` (`id`,`char_id`, `nameid`, `amount`, `equip`, `identify`, `refine`, `attribute`, `card0`, `card1`, `card2`, `card3`) if (start_weapon > 0) { //add Start Weapon (Knife?) sprintf(tmp_sql,"INSERT INTO `%s` (`char_id`,`nameid`, `amount`, `equip`, `identify`) VALUES ('%d', '%d', '%d', '%d', '%d')", inventory_db, char_id, start_weapon,1,0x02,1); if (mysql_query(&mysql_handle, tmp_sql)){ ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } } if (start_armor > 0) { //Add default armor (cotton shirt?) sprintf(tmp_sql,"INSERT INTO `%s` (`char_id`,`nameid`, `amount`, `equip`, `identify`) VALUES ('%d', '%d', '%d', '%d', '%d')", inventory_db, char_id, start_armor,1,0x10,1); if (mysql_query(&mysql_handle, tmp_sql)){ ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } } ShowInfo("Created char: account: %d, char: %d, slot: %d, name: %s\n", sd->account_id, char_id, dat[30], name); return char_id; } /*----------------------------------------------------------------------------------------------------------*/ /* Delete char - davidsiaw */ /*----------------------------------------------------------------------------------------------------------*/ /* Returns 0 if successful * Returns < 0 for error */ int delete_char_sql(int char_id, int partner_id) { char char_name[NAME_LENGTH], t_name[NAME_LENGTH*2]; //Name needs be escaped. int account_id, party_id, guild_id, hom_id, char_base_level; sprintf(tmp_sql, "SELECT `name`,`account_id`,`party_id`,`guild_id`,`base_level`,`homun_id` FROM `%s` WHERE `char_id`='%d'",char_db, char_id); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result(&mysql_handle); if(sql_res) sql_row = mysql_fetch_row(sql_res); if (sql_res == NULL || sql_row == NULL) { ShowError("delete_char_sql: Unable to fetch character data, deletion aborted.\n"); if (sql_res) mysql_free_result(sql_res); return -1; } strncpy(char_name, sql_row[0], NAME_LENGTH); char_name[NAME_LENGTH-1] = '\0'; jstrescapecpy(t_name, char_name); //Escape string for sql use... [Skotlex] account_id = atoi(sql_row[1]); party_id = atoi(sql_row[2]); guild_id = atoi(sql_row[3]); char_base_level = atoi(sql_row[4]); hom_id = atoi(sql_row[5]); mysql_free_result(sql_res); //Let's free this as soon as possible to avoid problems later on. //check for config char del condition [Lupus] if( ( char_del_level > 0 && char_base_level >= char_del_level ) || ( char_del_level < 0 && char_base_level <= -char_del_level ) ) { ShowInfo("Char deletion aborted: %s, BaseLevel: %i\n",char_name,char_base_level); return -1; } /* Divorce [Wizputer] */ if (partner_id) { sprintf(tmp_sql,"UPDATE `%s` SET `partner_id`='0' WHERE `char_id`='%d'",char_db,partner_id); if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sprintf(tmp_sql,"DELETE FROM `%s` WHERE (`nameid`='%d' OR `nameid`='%d') AND `char_id`='%d'",inventory_db,WEDDING_RING_M,WEDDING_RING_F,partner_id); if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } } //Make the character leave the party [Skotlex] if (party_id) inter_party_leave(party_id, account_id, char_id); /* delete char's pet */ //Delete the hatched pet if you have one... sprintf(tmp_sql,"DELETE FROM `%s` WHERE `char_id`='%d' AND `incuvate` = '0'",pet_db, char_id); if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } // Komurka's suggested way to clear pets, modified by [Skotlex] (because I always personalize what I do :X) //Removing pets that are in the char's inventory.... { //NOTE: The syntax for multi-table deletes is a bit changed between 4.0 and 4.1 regarding aliases, so we have to consider the version... [Skotlex] //Since we only care about the major and minor version, a double conversion is good enough. (4.1.20 -> 4.10000) double mysql_version = atof(mysql_get_server_info(&mysql_handle)); sprintf(tmp_sql, "delete FROM `%s` USING `%s` as c LEFT JOIN `%s` as i ON c.char_id = i.char_id, `%s` as p WHERE c.char_id = '%d' AND i.card0 = -256 AND p.pet_id = (i.card1|(i.card2<<2))", (mysql_version<4.1?pet_db:"p"), char_db, inventory_db, pet_db, char_id); if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } //Removing pets that are in the char's cart.... sprintf(tmp_sql, "delete FROM `%s` USING `%s` as c LEFT JOIN `%s` as i ON c.char_id = i.char_id, `%s` as p WHERE c.char_id = '%d' AND i.card0 = -256 AND p.pet_id = (i.card1|(i.card2<<2))", (mysql_version<4.1?pet_db:"p"), char_db, cart_db, pet_db, char_id); if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } } /* remove homunculus */ if (hom_id) inter_delete_homunculus(hom_id); /* delete char's friends list */ sprintf(tmp_sql, "DELETE FROM `%s` WHERE `char_id` = '%d'",friend_db, char_id); if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } /* delete char from other's friend list */ //NOTE: Won't this cause problems for people who are already online? [Skotlex] sprintf(tmp_sql, "DELETE FROM `%s` WHERE `friend_id` = '%d'",friend_db, char_id); if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } /* delete inventory */ sprintf(tmp_sql,"DELETE FROM `%s` WHERE `char_id`='%d'",inventory_db, char_id); if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } /* delete cart inventory */ sprintf(tmp_sql,"DELETE FROM `%s` WHERE `char_id`='%d'",cart_db, char_id); if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } /* delete memo areas */ sprintf(tmp_sql,"DELETE FROM `%s` WHERE `char_id`='%d'",memo_db, char_id); if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } /* delete character registry */ sprintf(tmp_sql,"DELETE FROM `%s` WHERE `type`=3 AND `char_id`='%d'",reg_db, char_id); if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } /* delete skills */ sprintf(tmp_sql,"DELETE FROM `%s` WHERE `char_id`='%d'",skill_db, char_id); if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } #ifdef ENABLE_SC_SAVING /* status changes */ sprintf(tmp_sql, "DELETE FROM `%s` WHERE `account_id` = '%d' AND `char_id`='%d'", scdata_db, account_id, char_id); if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } #endif if (log_char) { sprintf(tmp_sql,"INSERT INTO `%s`(`time`, `account_id`,`char_num`,`char_msg`,`name`) VALUES (NOW(), '%d', '%d', 'Deleted char (CID %d)', '%s')", charlog_db, account_id, 0, char_id, t_name); //query if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } } /* delete character */ sprintf(tmp_sql,"DELETE FROM `%s` WHERE `char_id`='%d'",char_db, char_id); if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } /* No need as we used inter_guild_leave [Skotlex] // Also delete info from guildtables. sprintf(tmp_sql,"DELETE FROM `%s` WHERE `char_id`='%d'",guild_member_db, char_id); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } */ sprintf(tmp_sql, "SELECT `guild_id` FROM `%s` WHERE `master` = '%s'", guild_db, t_name); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } else { sql_res = mysql_store_result(&mysql_handle); if (sql_res == NULL) { if (mysql_errno(&mysql_handle) != 0) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } return -1; } else { int rows = (int)mysql_num_rows(sql_res); mysql_free_result(sql_res); if (rows > 0) { mapif_parse_BreakGuild(0,guild_id); } else if (guild_id) //Leave your guild. inter_guild_leave(guild_id, account_id, char_id); } } return 0; } //========================================================================================================== int count_users(void) { int i, users; if (login_fd > 0 && session[login_fd]){ users = 0; for(i = 0; i < MAX_MAP_SERVERS; i++) { if (server_fd[i] > 0) { users += server[i].users; } } return users; } return 0; } /// Writes char data to the buffer in the format used by the client. /// Used in packets 0x6b (chars info) and 0x6d (new char info) /// Returns the size (106 or 108) int mmo_char_tobuf(uint8* buf, struct mmo_charstatus *p) { if( buf == NULL || p == NULL ) return 0; WBUFL(buf,0) = p->char_id; WBUFL(buf,4) = p->base_exp>LONG_MAX?LONG_MAX:p->base_exp; WBUFL(buf,8) = p->zeny; WBUFL(buf,12) = p->job_exp>LONG_MAX?LONG_MAX:p->job_exp; WBUFL(buf,16) = p->job_level; WBUFL(buf,20) = 0;// probably opt1 WBUFL(buf,24) = 0;// probably opt2 WBUFL(buf,28) = p->option; WBUFL(buf,32) = p->karma; WBUFL(buf,36) = p->manner; WBUFW(buf,40) = (p->status_point > SHRT_MAX) ? SHRT_MAX : p->status_point; WBUFW(buf,42) = (p->hp > SHRT_MAX) ? SHRT_MAX : p->hp; WBUFW(buf,44) = (p->max_hp > SHRT_MAX) ? SHRT_MAX : p->max_hp; WBUFW(buf,46) = (p->sp > SHRT_MAX) ? SHRT_MAX : p->sp; WBUFW(buf,48) = (p->max_sp > SHRT_MAX) ? SHRT_MAX : p->max_sp; WBUFW(buf,50) = DEFAULT_WALK_SPEED; // p->speed; WBUFW(buf,52) = p->class_; WBUFW(buf,54) = p->hair; WBUFW(buf,56) = p->option&0x20 ? 0 : p->weapon; //When the weapon is sent and your option is riding, the client crashes on login!? WBUFW(buf,58) = p->base_level; WBUFW(buf,60) = (p->skill_point > SHRT_MAX) ? SHRT_MAX : p->skill_point; WBUFW(buf,62) = p->head_bottom; WBUFW(buf,64) = p->shield; WBUFW(buf,66) = p->head_top; WBUFW(buf,68) = p->head_mid; WBUFW(buf,70) = p->hair_color; WBUFW(buf,72) = p->clothes_color; memcpy(WBUFP(buf,74), p->name, NAME_LENGTH); WBUFB(buf,98) = (p->str > UCHAR_MAX) ? UCHAR_MAX : p->str; WBUFB(buf,99) = (p->agi > UCHAR_MAX) ? UCHAR_MAX : p->agi; WBUFB(buf,100) = (p->vit > UCHAR_MAX) ? UCHAR_MAX : p->vit; WBUFB(buf,101) = (p->int_ > UCHAR_MAX) ? UCHAR_MAX : p->int_; WBUFB(buf,102) = (p->dex > UCHAR_MAX) ? UCHAR_MAX : p->dex; WBUFB(buf,103) = (p->luk > UCHAR_MAX) ? UCHAR_MAX : p->luk; //Updated packet structure with rename-button included. Credits to Sara-chan #if PACKETVER > 7 WBUFW(buf,104) = p->char_num; WBUFW(buf,106) = 1;// Rename bit (0=rename,1=no rename) return 108; #else WBUFB(buf,104) = p->char_num; return 106; #endif } int mmo_char_send006b(int fd, struct char_session_data *sd) { int i, j, found_num = 0; set_char_online(-1, 99,sd->account_id); //search char. sprintf(tmp_sql, "SELECT `char_id` FROM `%s` WHERE `account_id` = '%d' AND `char_num` < '%d'",char_db, sd->account_id, MAX_CHARS); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result(&mysql_handle); if (sql_res) { found_num = (int)mysql_num_rows(sql_res); // ShowInfo("number of chars: %d\n", found_num); i = 0; while((sql_row = mysql_fetch_row(sql_res))) { sd->found_char[i] = atoi(sql_row[0]); i++; } mysql_free_result(sql_res); } for(i = found_num; i < MAX_CHARS; i++) sd->found_char[i] = -1; if (save_log) ShowInfo("Loading Char Data ("CL_BOLD"%d"CL_RESET")\n",sd->account_id); j = 24;// offset { WFIFOHEAD(fd, j + found_num*108); WFIFOW(fd,0) = 0x6b; memset(WFIFOP(fd,4), 0, 20);// unknown bytes for(i = 0; i < found_num; i++) { mmo_char_fromsql_short(sd->found_char[i], &char_dat); j += mmo_char_tobuf(WFIFOP(fd,j), &char_dat); } WFIFOW(fd,2) = j;// packet len WFIFOSET(fd,j); } return 0; } static void char_auth_ok(int fd, struct char_session_data *sd) { struct online_char_data* character; if (max_connect_user && count_users() >= max_connect_user && isGM(sd->account_id) < gm_allow_level) { // refuse connection (over populated) WFIFOW(fd,0) = 0x6c; WFIFOW(fd,2) = 0; WFIFOSET(fd,3); return; } if (online_check && (character = idb_get(online_char_db, sd->account_id))) { // check if character is not online already. [Skotlex] if (character->server > -1) { //Character already online. KICK KICK KICK mapif_disconnectplayer(server_fd[character->server], character->account_id, character->char_id, 2); if (character->waiting_disconnect == -1) character->waiting_disconnect = add_timer(gettick()+20000, chardb_waiting_disconnect, character->account_id, 0); WFIFOW(fd,0) = 0x81; WFIFOB(fd,2) = 8; WFIFOSET(fd,3); return; } if (character->fd >= 0 && character->fd != fd) { //There's already a connection from this account that hasn't picked a char yet. WFIFOW(fd,0) = 0x81; WFIFOB(fd,2) = 8; WFIFOSET(fd,3); return; } character->fd = fd; } if (login_fd > 0) { // request to login-server to obtain e-mail/time limit WFIFOHEAD(login_fd,6); WFIFOW(login_fd,0) = 0x2716; WFIFOL(login_fd,2) = sd->account_id; WFIFOSET(login_fd,6); } // send characters to player mmo_char_send006b(fd, sd); } int send_accounts_tologin(int tid, unsigned int tick, int id, int data); int parse_tologin(int fd) { int i; struct char_session_data *sd; RFIFOHEAD(fd); // only login-server can have an access to here. // so, if it isn't the login-server, we disconnect the session. //session eof check! if(fd != login_fd) session[fd]->eof = 1; if(session[fd]->eof) { if (fd == login_fd) { ShowWarning("Connection to login-server lost (connection #%d).\n", fd); login_fd = -1; } do_close(fd); return 0; } sd = (struct char_session_data*)session[fd]->session_data; // hehe. no need to set user limit on SQL version. :P // but char limitation is good way to maintain server. :D while(RFIFOREST(fd) >= 2) { // printf("parse_tologin : %d %d %x\n", fd, RFIFOREST(fd), RFIFOW(fd, 0)); switch(RFIFOW(fd, 0)){ case 0x2711: if (RFIFOREST(fd) < 3) return 0; if (RFIFOB(fd, 2)) { //printf("connect login server error : %d\n", RFIFOB(fd, 2)); ShowError("Can not connect to login-server.\n"); ShowError("The server communication passwords (default s1/p1) are probably invalid.\n"); ShowError("Also, please make sure your login db has the correct communication username/passwords and the gender of the account is S.\n"); ShowError("The communication passwords are set in map_athena.conf and char_athena.conf\n"); return 0; //exit(1); //fixed for server shutdown. }else { ShowStatus("Connected to login-server (connection #%d).\n", fd); //Send online accounts to login server. send_accounts_tologin(-1, gettick(), 0, 0); // if no map-server already connected, display a message... for(i = 0; i < MAX_MAP_SERVERS; i++) if (server_fd[i] > 0 && server[i].map[0]) // if map-server online and at least 1 map break; if (i == MAX_MAP_SERVERS) ShowStatus("Awaiting maps from map-server.\n"); } RFIFOSKIP(fd, 3); break; case 0x2713: if(RFIFOREST(fd)<51) return 0; for(i = 0; i < fd_max && !( session[i] && (sd = (struct char_session_data*)session[i]->session_data) && sd->account_id == RFIFOL(fd,2)) ; i++); if (i < fd_max) { if (RFIFOB(fd,6) != 0) { WFIFOHEAD(i,3); WFIFOW(i,0) = 0x6c; WFIFOB(i,2) = 0x42; WFIFOSET(i,3); } else { sd->connect_until_time = (time_t)RFIFOL(fd,47); memcpy(sd->email, RFIFOP(fd, 7), 40); char_auth_ok(i, sd); } } RFIFOSKIP(fd,51); break; case 0x2717: if (RFIFOREST(fd) < 50) return 0; for(i = 0; i < fd_max; i++) { if (session[i] && (sd = (struct char_session_data*)session[i]->session_data)) { if (sd->account_id == RFIFOL(fd,2)) { memcpy(sd->email, RFIFOP(fd, 6), 40); sd->connect_until_time = (time_t)RFIFOL(fd,46); break; } } } RFIFOSKIP(fd,50); break; // login-server alive packet case 0x2718: if (RFIFOREST(fd) < 2) return 0; RFIFOSKIP(fd,2); break; // Receiving authentification from Freya-type login server (to avoid char->login->char) case 0x2719: if (RFIFOREST(fd) < 18) return 0; // to conserv a maximum of authentification, search if account is already authentified and replace it // that will reduce multiple connection too for(i = 0; i < AUTH_FIFO_SIZE; i++) if (auth_fifo[i].account_id == RFIFOL(fd,2)) break; // if not found, use next value if (i == AUTH_FIFO_SIZE) { if (auth_fifo_pos >= AUTH_FIFO_SIZE) auth_fifo_pos = 0; i = auth_fifo_pos; auth_fifo_pos++; } //printf("auth_fifo set (auth #%d) - account: %d, secure: %08x-%08x\n", i, RFIFOL(fd,2), RFIFOL(fd,6), RFIFOL(fd,10)); auth_fifo[i].account_id = RFIFOL(fd,2); auth_fifo[i].char_id = 0; auth_fifo[i].login_id1 = RFIFOL(fd,6); auth_fifo[i].login_id2 = RFIFOL(fd,10); auth_fifo[i].delflag = 2; // 0: auth_fifo canceled/void, 2: auth_fifo received from login/map server in memory, 1: connection authentified auth_fifo[i].connect_until_time = 0; // unlimited/unknown time by default (not display in map-server) auth_fifo[i].ip = ntohl(RFIFOL(fd,14)); RFIFOSKIP(fd,18); break; case 0x2721: // gm reply. I don't want to support this function. if (RFIFOREST(fd) < 10) return 0; RFIFOSKIP(fd, 10); /* Note that this is the code from char-txt! Even uncommenting it will not work. printf("0x2721:GM reply\n"); { int oldacc, newacc; unsigned char buf[64]; if (RFIFOREST(fd) < 10) return 0; oldacc = RFIFOL(fd, 2); newacc = RFIFOL(fd, 6); RFIFOSKIP(fd, 10); if (newacc > 0) { for(i=0;i map\n"); } */ break; case 0x2723: // changesex reply (modified by [Yor]) if (RFIFOREST(fd) < 7) return 0; { int acc, sex; unsigned char buf[16]; MYSQL_RES* sql_res2; acc = RFIFOL(fd,2); sex = RFIFOB(fd,6); RFIFOSKIP(fd, 7); if (acc > 0) { sprintf(tmp_sql, "SELECT `char_id`,`class`,`skill_point`,`guild_id` FROM `%s` WHERE `account_id` = '%d'",char_db, acc); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res2 = mysql_store_result(&mysql_handle); while(sql_res2 && (sql_row = mysql_fetch_row(sql_res2))) { int char_id, guild_id, jobclass, skill_point, class_; char_id = atoi(sql_row[0]); jobclass = atoi(sql_row[1]); skill_point = atoi(sql_row[2]); guild_id = atoi(sql_row[3]); class_ = jobclass; if (jobclass == JOB_BARD || jobclass == JOB_DANCER || jobclass == JOB_CLOWN || jobclass == JOB_GYPSY || jobclass == JOB_BABY_BARD || jobclass == JOB_BABY_DANCER) { // job modification if (jobclass == JOB_BARD || jobclass == JOB_DANCER) { class_ = (sex) ? JOB_BARD : JOB_DANCER; } else if (jobclass == JOB_CLOWN || jobclass == JOB_GYPSY) { class_ = (sex) ? JOB_CLOWN : JOB_GYPSY; } else if (jobclass == JOB_BABY_BARD || jobclass == JOB_BABY_DANCER) { class_ = (sex) ? JOB_BABY_BARD : JOB_BABY_DANCER; } // remove specifical skills of classes 19,20 4020,4021 and 4042,4043 sprintf(tmp_sql, "SELECT `lv` FROM `%s` WHERE `char_id` = '%d' AND `id` >= '315' AND `id` <= '330'",skill_db, char_id); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result(&mysql_handle); if (sql_res) { while(( sql_row = mysql_fetch_row(sql_res))) { skill_point += atoi(sql_row[0]); } mysql_free_result(sql_res); } sprintf(tmp_sql, "DELETE FROM `%s` WHERE `char_id` = '%d' AND `id` >= '315' AND `id` <= '330'",skill_db, char_id); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } } // to avoid any problem with equipment and invalid sex, equipment is unequiped. sprintf(tmp_sql, "UPDATE `%s` SET `equip` = '0' WHERE `char_id` = '%d'",inventory_db, char_id); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sprintf(tmp_sql, "UPDATE `%s` SET `class`='%d' , `skill_point`='%d' , `weapon`='0' , `shield`='0' , `head_top`='0' , `head_mid`='0' , `head_bottom`='0' WHERE `char_id` = '%d'",char_db, class_, skill_point, char_id); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } if (guild_id) //If there is a guild, update the guild_member data [Skotlex] inter_guild_sex_changed(guild_id, acc, char_id, sex); } if (sql_res2) mysql_free_result(sql_res2); } // disconnect player if online on char-server for(i = 0; i < fd_max; i++) { if (session[i] && (sd = (struct char_session_data*)session[i]->session_data)) { if (sd->account_id == acc) { session[i]->eof = 1; break; } } } WBUFW(buf,0) = 0x2b0d; WBUFL(buf,2) = acc; WBUFB(buf,6) = sex; mapif_sendall(buf, 7); } break; // account_reg2変更通知 case 0x2729: if (RFIFOREST(fd) < 4 || RFIFOREST(fd) < RFIFOW(fd,2)) return 0; { //Receive account_reg2 registry, forward to map servers. unsigned char buf[ACCOUNT_REG2_NUM*(256+32+2)+16]; memcpy(buf,RFIFOP(fd,0), RFIFOW(fd,2)); // WBUFW(buf,0) = 0x2b11; WBUFW(buf,0) = 0x3804; //Map server can now receive all kinds of reg values with the same packet. [Skotlex] mapif_sendall(buf, WBUFW(buf,2)); RFIFOSKIP(fd, RFIFOW(fd,2)); } break; // State change of account/ban notification (from login-server) by [Yor] case 0x2731: if (RFIFOREST(fd) < 11) return 0; // send to all map-servers to disconnect the player { unsigned char buf[16]; WBUFW(buf,0) = 0x2b14; WBUFL(buf,2) = RFIFOL(fd,2); WBUFB(buf,6) = RFIFOB(fd,6); // 0: change of statut, 1: ban WBUFL(buf,7) = RFIFOL(fd,7); // status or final date of a banishment mapif_sendall(buf, 11); } // disconnect player if online on char-server for(i = 0; i < fd_max; i++) { if (session[i] && (sd = (struct char_session_data*)session[i]->session_data)) { if (sd->account_id == RFIFOL(fd,2)) { session[i]->eof = 1; break; } } } RFIFOSKIP(fd,11); break; case 0x2732: if (RFIFOREST(fd) < 4 || RFIFOREST(fd) < RFIFOW(fd,2)) return 0; if(!char_gm_read) { unsigned char buf[32000]; if (gm_account != NULL) aFree(gm_account); gm_account = (struct gm_account*)aCalloc(sizeof(struct gm_account) * ((RFIFOW(fd,2) - 4) / 5), 1); GM_num = 0; for (i = 4; i < RFIFOW(fd,2); i = i + 5) { gm_account[GM_num].account_id = RFIFOL(fd,i); gm_account[GM_num].level = (int)RFIFOB(fd,i+4); //printf("GM account: %d -> level %d\n", gm_account[GM_num].account_id, gm_account[GM_num].level); GM_num++; } ShowStatus("From login-server: receiving information of %d GM accounts.\n", GM_num); // send new gm acccounts level to map-servers memcpy(buf, RFIFOP(fd,0), RFIFOW(fd,2)); WBUFW(buf,0) = 0x2b15; mapif_sendall(buf, RFIFOW(fd,2)); } RFIFOSKIP(fd,RFIFOW(fd,2)); break; // Receive GM accounts [Freya login server packet by Yor] case 0x2733: // add test here to remember that the login-server is Freya-type // sprintf (login_server_type, "Freya"); if (RFIFOREST(fd) < 7) return 0; { int new_level = 0; for(i = 0; i < GM_num; i++) if (gm_account[i].account_id == RFIFOL(fd,2)) { if (gm_account[i].level != (int)RFIFOB(fd,6)) { gm_account[i].level = (int)RFIFOB(fd,6); new_level = 1; } break; } // if not found, add it if (i == GM_num) { // limited to 4000, because we send information to char-servers (more than 4000 GM accounts???) // int (id) + int (level) = 8 bytes * 4000 = 32k (limit of packets in windows) if (((int)RFIFOB(fd,6)) > 0 && GM_num < 4000) { if (GM_num == 0) { gm_account = (struct gm_account*)aMalloc(sizeof(struct gm_account)); } else { gm_account = (struct gm_account*)aRealloc(gm_account, sizeof(struct gm_account) * (GM_num + 1)); } gm_account[GM_num].account_id = RFIFOL(fd,2); gm_account[GM_num].level = (int)RFIFOB(fd,6); new_level = 1; GM_num++; if (GM_num >= 4000) ShowWarning("4000 GM accounts found. Next GM accounts are not readed.\n"); } } if (new_level == 1) { ShowStatus("From login-server: receiving GM account information (%d: level %d).\n", RFIFOL(fd,2), (int)RFIFOB(fd,6)); mapif_send_gmaccounts(); //create_online_files(); // not change online file for only 1 player (in next timer, that will be done // send gm acccounts level to map-servers } } RFIFOSKIP(fd,7); break; //Login server request to kick a character out. [Skotlex] case 0x2734: if (RFIFOREST(fd) < 6) return 0; { struct online_char_data* character; int aid = RFIFOL(fd,2); if ((character = idb_get(online_char_db, aid)) != NULL) { //Kick out this player. if (character->server > -1) { //Kick it from the map server it is on. mapif_disconnectplayer(server_fd[character->server], character->account_id, character->char_id, 2); if (character->waiting_disconnect == -1) character->waiting_disconnect = add_timer(gettick()+15000, chardb_waiting_disconnect, character->account_id, 0); } else { //Manual kick from char server. struct char_session_data *tsd; int i; for(i = 0; i < fd_max; i++) { if (session[i] && (tsd = (struct char_session_data*)session[i]->session_data) && tsd->account_id == aid) { WFIFOHEAD(i,3); WFIFOW(i,0) = 0x81; WFIFOB(i,2) = 2; WFIFOSET(i,3); break; } } if (i == fd_max) //Shouldn't happen, but just in case. set_char_offline(99, aid); } } RFIFOSKIP(fd,6); } break; case 0x2735: { unsigned char buf[2]; uint32 new_ip = 0; RFIFOSKIP(fd,2); WBUFW(buf,0) = 0x2b1e; mapif_sendall(buf, 2); new_ip = host2ip(login_ip_str); if (new_ip && new_ip != login_ip) //Update login ip, too. login_ip = new_ip; new_ip = host2ip(char_ip_str); if (new_ip && new_ip != char_ip) { //Update ip. char_ip = new_ip; ShowInfo("Updating IP for [%s].\n", char_ip_str); WFIFOHEAD(fd,6); WFIFOW(fd,0) = 0x2736; WFIFOL(fd,2) = htonl(char_ip); WFIFOSET(fd,6); } break; } default: ShowError("Unknown packet 0x%04x from login server, disconnecting.\n", RFIFOW(fd, 0)); session[fd]->eof = 1; return 0; } } RFIFOFLUSH(fd); return 0; } int request_accreg2(int account_id, int char_id) { if (login_fd > 0) { WFIFOHEAD(login_fd,10); WFIFOW(login_fd,0) = 0x272e; WFIFOL(login_fd,2) = account_id; WFIFOL(login_fd,6) = char_id; WFIFOSET(login_fd,10); return 1; } return 0; } //Send packet forward to login-server for account saving int save_accreg2(unsigned char* buf, int len) { if (login_fd > 0) { WFIFOHEAD(login_fd,len+4); memcpy(WFIFOP(login_fd,4), buf, len); WFIFOW(login_fd,0) = 0x2728; WFIFOW(login_fd,2) = len+4; WFIFOSET(login_fd,len+4); return 1; } return 0; } void char_read_fame_list(void) { int i; struct fame_list fame_item; // Empty ranking lists memset(smith_fame_list, 0, sizeof(smith_fame_list)); memset(chemist_fame_list, 0, sizeof(chemist_fame_list)); memset(taekwon_fame_list, 0, sizeof(taekwon_fame_list)); // Build Blacksmith ranking list sprintf(tmp_sql, "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); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result(&mysql_handle); if (sql_res) { i = 0; while((sql_row = mysql_fetch_row(sql_res))) { fame_item.id = atoi(sql_row[0]); fame_item.fame = atoi(sql_row[1]); strncpy(fame_item.name, sql_row[2], NAME_LENGTH); memcpy(&smith_fame_list[i], &fame_item, sizeof(struct fame_list)); if (++i == fame_list_size_smith) break; } mysql_free_result(sql_res); } // Build Alchemist ranking list sprintf(tmp_sql, "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); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result(&mysql_handle); if (sql_res) { i = 0; while((sql_row = mysql_fetch_row(sql_res))) { fame_item.id = atoi(sql_row[0]); fame_item.fame = atoi(sql_row[1]); strncpy(fame_item.name, sql_row[2], NAME_LENGTH); memcpy(&chemist_fame_list[i], &fame_item, sizeof(struct fame_list)); if (++i == fame_list_size_chemist) break; } mysql_free_result(sql_res); } // Build Taekwon ranking list sprintf(tmp_sql, "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); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result(&mysql_handle); if (sql_res) { i = 0; while((sql_row = mysql_fetch_row(sql_res))) { fame_item.id = atoi(sql_row[0]); fame_item.fame = atoi(sql_row[1]); strncpy(fame_item.name, sql_row[2], NAME_LENGTH); memcpy(&taekwon_fame_list[i], &fame_item, sizeof(struct fame_list)); if (++i == fame_list_size_taekwon) break; } mysql_free_result(sql_res); } } // Send map-servers the fame ranking lists int char_send_fame_list(int fd) { int i, len = 8; unsigned char buf[32000]; WBUFW(buf,0) = 0x2b1b; for(i = 0; i < fame_list_size_smith && smith_fame_list[i].id; i++) { memcpy(WBUFP(buf, len), &smith_fame_list[i], sizeof(struct fame_list)); len += sizeof(struct fame_list); } // add blacksmith's block length WBUFW(buf, 6) = len; for(i = 0; i < fame_list_size_chemist && chemist_fame_list[i].id; i++) { memcpy(WBUFP(buf, len), &chemist_fame_list[i], sizeof(struct fame_list)); len += sizeof(struct fame_list); } // add alchemist's block length WBUFW(buf, 4) = len; for(i = 0; i < fame_list_size_taekwon && taekwon_fame_list[i].id; i++) { memcpy(WBUFP(buf, len), &taekwon_fame_list[i], sizeof(struct fame_list)); len += sizeof(struct fame_list); } // add total packet length WBUFW(buf, 2) = len; if (fd != -1) mapif_send(fd, buf, len); else mapif_sendall(buf, len); return 0; } void char_update_fame_list(int type, int index, int fame) { char buf[9]; WBUFW(buf,0) = 0x2b22; WBUFB(buf,2) = type; WBUFB(buf,3) = index; WBUFL(buf,4) = fame; mapif_sendall(buf, 8); } int search_mapserver(unsigned short map, uint32 ip, uint16 port); //Loads a character's name and stores it in the buffer given (must be NAME_LENGTH in size) //Returns 1 on found, 0 on not found (buffer is filled with Unknown char name) int char_loadName(int char_id, char* name) { sprintf(tmp_sql, "SELECT `name` FROM `%s` WHERE `char_id`='%d'", char_db, char_id); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result(&mysql_handle); sql_row = sql_res?mysql_fetch_row(sql_res):NULL; if (sql_row) memcpy(name, sql_row[0], NAME_LENGTH); else memcpy(name, unknown_char_name, NAME_LENGTH); if (sql_res) mysql_free_result(sql_res); return sql_row?1:0; } int parse_frommap(int fd) { int i = 0, j = 0; int id; RFIFOHEAD(fd); // Sometimes fd=0, and it will cause server crash. Don't know why. :( if (fd <= 0) { ShowError("parse_frommap error fd=%d\n", fd); return 0; } for(id = 0; id < MAX_MAP_SERVERS; id++) if (server_fd[id] == fd) break; if(id == MAX_MAP_SERVERS) session[fd]->eof = 1; if(session[fd]->eof) { if (id < MAX_MAP_SERVERS) { unsigned char buf[16384]; ShowStatus("Map-server %d (session #%d) has disconnected.\n", id, fd); //Notify other map servers that this one is gone. [Skotlex] WBUFW(buf,0) = 0x2b20; WBUFL(buf,4) = htonl(server[id].ip); WBUFW(buf,8) = htons(server[id].port); j = 0; for(i = 0; i < MAX_MAP_PER_SERVER; i++) if (server[id].map[i]) WBUFW(buf,10+(j++)*4) = server[id].map[i]; if (j > 0) { WBUFW(buf,2) = j * 4 + 10; mapif_sendallwos(fd, buf, WBUFW(buf,2)); } memset(&server[id], 0, sizeof(struct mmo_map_server)); sprintf(tmp_sql, "DELETE FROM `ragsrvinfo` WHERE `index`='%d'", server_fd[id]); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } server_fd[id] = -1; online_char_db->foreach(online_char_db,char_db_setoffline,id); //Tag relevant chars as 'in disconnected' server. } do_close(fd); return 0; } while(RFIFOREST(fd) >= 2) { switch(RFIFOW(fd, 0)) { case 0x2718: // map-server alive packet RFIFOSKIP(fd,2); break; case 0x2af7: // request from map-server to reload GM accounts. Transmission to login-server RFIFOSKIP(fd,2); if(char_gm_read) //Re-read gm accounts. read_gm_account(); //Send to login request to reload gm accounts. else if (login_fd > 0) { // don't send request if no login-server WFIFOHEAD(login_fd,2); WFIFOW(login_fd,0) = 0x2709; WFIFOSET(login_fd,2); } break; case 0x2afa: // Receiving map names list from the map-server if (RFIFOREST(fd) < 4 || RFIFOREST(fd) < RFIFOW(fd,2)) return 0; WFIFOHEAD(fd,3+NAME_LENGTH); memset(server[id].map, 0, sizeof(server[id].map)); j = 0; for(i = 4; i < RFIFOW(fd,2); i += 4) { server[id].map[j] = RFIFOW(fd,i); j++; } ShowStatus("Map-Server %d connected: %d maps, from IP %d.%d.%d.%d port %d.\n", id, j, CONVIP(server[id].ip), server[id].port); ShowStatus("Map-server %d loading complete.\n", id); if (max_account_id != DEFAULT_MAX_ACCOUNT_ID || max_char_id != DEFAULT_MAX_CHAR_ID) mapif_send_maxid(max_account_id, max_char_id); //Send the current max ids to the server to keep in sync [Skotlex] WFIFOW(fd,0) = 0x2afb; WFIFOB(fd,2) = 0; memcpy(WFIFOP(fd,3), wisp_server_name, NAME_LENGTH); // name for wisp to player WFIFOSET(fd,3+NAME_LENGTH); char_send_fame_list(fd); //Send fame list. { unsigned char buf[16384]; int x; if (j == 0) { ShowWarning("Map-server %d has NO maps.\n", id); } else { // Transmitting maps information to the other map-servers WBUFW(buf,0) = 0x2b04; WBUFW(buf,2) = j * 4 + 10; WBUFL(buf,4) = htonl(server[id].ip); WBUFW(buf,8) = htons(server[id].port); memcpy(WBUFP(buf,10), RFIFOP(fd,4), j * 4); mapif_sendallwos(fd, buf, WBUFW(buf,2)); } // Transmitting the maps of the other map-servers to the new map-server for(x = 0; x < MAX_MAP_SERVERS; x++) { if (server_fd[x] > 0 && x != id) { WFIFOHEAD(fd,10 +4*MAX_MAP_PER_SERVER); WFIFOW(fd,0) = 0x2b04; WFIFOL(fd,4) = htonl(server[x].ip); WFIFOW(fd,8) = htons(server[x].port); j = 0; for(i = 0; i < MAX_MAP_PER_SERVER; i++) if (server[x].map[i]) WFIFOW(fd,10+(j++)*4) = server[x].map[i]; if (j > 0) { WFIFOW(fd,2) = j * 4 + 10; WFIFOSET(fd,WFIFOW(fd,2)); } } } } RFIFOSKIP(fd,RFIFOW(fd,2)); break; case 0x2afc: //Packet command is now used for sc_data request. [Skotlex] if (RFIFOREST(fd) < 10) return 0; { int aid, cid; aid = RFIFOL(fd,2); cid = RFIFOL(fd,6); RFIFOSKIP(fd, 10); #ifdef ENABLE_SC_SAVING sprintf(tmp_sql, "SELECT type, tick, val1, val2, val3, val4 from `%s` WHERE `account_id` = '%d' AND `char_id`='%d'", scdata_db, aid, cid); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); break; } sql_res = mysql_store_result(&mysql_handle); if (sql_res) { struct status_change_data data; int count = 0; WFIFOHEAD(fd,14+50*sizeof(struct status_change_data)); WFIFOW(fd,0) = 0x2b1d; WFIFOL(fd,4) = aid; WFIFOL(fd,8) = cid; while((sql_row = mysql_fetch_row(sql_res)) && count < 50) { data.type = atoi(sql_row[0]); data.tick = atoi(sql_row[1]); data.val1 = atoi(sql_row[2]); data.val2 = atoi(sql_row[3]); data.val3 = atoi(sql_row[4]); data.val4 = atoi(sql_row[5]); memcpy(WFIFOP(fd, 14+count*sizeof(struct status_change_data)), &data, sizeof(struct status_change_data)); count++; } if (count >= 50) ShowWarning("Too many status changes for %d:%d, some of them were not loaded.\n", aid, cid); mysql_free_result(sql_res); if (count > 0) { WFIFOW(fd,2) = 14 + count*sizeof(struct status_change_data); WFIFOW(fd,12) = count; WFIFOSET(fd,WFIFOW(fd,2)); //Clear the data once loaded. sprintf(tmp_sql, "DELETE FROM `%s` WHERE `account_id` = '%d' AND `char_id`='%d'", scdata_db, aid, cid); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } } } #endif break; } case 0x2afe: //set MAP user count if (RFIFOREST(fd) < 4) return 0; if (RFIFOW(fd,2) != server[id].users) { server[id].users = RFIFOW(fd,2); ShowInfo("User Count: %d (Server: %d)\n", server[id].users, id); } RFIFOSKIP(fd, 4); break; case 0x2aff: //set MAP users if (RFIFOREST(fd) < 6 || RFIFOREST(fd) < RFIFOW(fd,2)) return 0; { //TODO: When data mismatches memory, update guild/party online/offline states. int i, aid, cid; struct online_char_data* character; online_char_db->foreach(online_char_db,char_db_setoffline,id); //Set all chars from this server as 'unknown' server[id].users = RFIFOW(fd,4); for(i = 0; i < server[id].users; i++) { aid = RFIFOL(fd,6+i*8); cid = RFIFOL(fd,6+i*8+4); character = idb_ensure(online_char_db, aid, create_online_char_data); if (character->server > -1 && character->server != id) { ShowNotice("Set map user: Character (%d:%d) marked on map server %d, but map server %d claims to have (%d:%d) online!\n", character->account_id, character->char_id, character->server, id, aid, cid); mapif_disconnectplayer(server_fd[character->server], character->account_id, character->char_id, 2); } character->server = id; character->char_id = cid; } //If any chars remain in -2, they will be cleaned in the cleanup timer. RFIFOSKIP(fd,RFIFOW(fd,2)); break; } case 0x2b01: // Receive character data from map-server for saving if (RFIFOREST(fd) < 4 || RFIFOREST(fd) < RFIFOW(fd,2)) return 0; { int aid = RFIFOL(fd,4), cid = RFIFOL(fd,8), size = RFIFOW(fd,2); struct online_char_data* character; if (size - 13 != sizeof(struct mmo_charstatus)) { ShowError("parse_from_map (save-char): Size mismatch! %d != %d\n", size-13, sizeof(struct mmo_charstatus)); RFIFOSKIP(fd,size); break; } //Check account only if this ain't final save. Final-save goes through because of the char-map reconnect if (RFIFOB(fd,12) || ( (character = idb_get(online_char_db, aid)) != NULL && character->char_id == cid)) { memcpy(&char_dat, RFIFOP(fd,13), sizeof(struct mmo_charstatus)); mmo_char_tosql(cid, &char_dat); } else { //This may be valid on char-server reconnection, when re-sending characters that already logged off. ShowError("parse_from_map (save-char): Received data for non-existant/offline character (%d:%d).\n", aid, cid); set_char_online(id, cid, aid); } if (RFIFOB(fd,12)) { //Flag? Set character offline after saving [Skotlex] set_char_offline(cid, aid); WFIFOHEAD(fd,10); WFIFOW(fd,0) = 0x2b21; //Save ack only needed on final save. WFIFOL(fd,2) = aid; WFIFOL(fd,6) = cid; WFIFOSET(fd,10); } RFIFOSKIP(fd,size); break; } case 0x2b02: // req char selection if (RFIFOREST(fd) < 18) return 0; if (auth_fifo_pos >= AUTH_FIFO_SIZE) auth_fifo_pos = 0; auth_fifo[auth_fifo_pos].account_id = RFIFOL(fd,2); auth_fifo[auth_fifo_pos].char_id = 0; auth_fifo[auth_fifo_pos].login_id1 = RFIFOL(fd,6); auth_fifo[auth_fifo_pos].login_id2 = RFIFOL(fd,10); auth_fifo[auth_fifo_pos].delflag = 2; auth_fifo[auth_fifo_pos].connect_until_time = 0; // unlimited/unknown time by default (not display in map-server) auth_fifo[auth_fifo_pos].ip = ntohl(RFIFOL(fd,14)); auth_fifo_pos++; { WFIFOHEAD(fd,7); WFIFOW(fd,0) = 0x2b03; WFIFOL(fd,2) = RFIFOL(fd, 2); WFIFOB(fd,6) = 0; WFIFOSET(fd,7); } RFIFOSKIP(fd,18); break; case 0x2b05: // request "change map server" if (RFIFOREST(fd) < 35) return 0; { unsigned short name; int map_id, map_fd = -1; struct online_char_data* data; struct mmo_charstatus* char_data; name = RFIFOW(fd,18); map_id = search_mapserver(name, ntohl(RFIFOL(fd,24)), ntohs(RFIFOW(fd,28))); //Locate mapserver by ip and port. if (map_id >= 0) map_fd = server_fd[map_id]; //Char should just had been saved before this packet, so this should be safe. [Skotlex] char_data = uidb_get(char_db_,RFIFOL(fd,14)); if (char_data == NULL) { //Really shouldn't happen. mmo_char_fromsql(RFIFOL(fd,14), &char_dat); char_data = &char_dat; } //Tell the new map server about this player using Kevin's new auth packet. [Skotlex] if (map_fd>=0 && session[map_fd] && char_data) { //Send the map server the auth of this player. //Update the "last map" as this is where the player must be spawned on the new map server. WFIFOHEAD(fd,30); WFIFOHEAD(map_fd,20 + sizeof(struct mmo_charstatus)); char_data->last_point.map = RFIFOW(fd,18); char_data->last_point.x = RFIFOW(fd,20); char_data->last_point.y = RFIFOW(fd,22); char_data->sex = RFIFOB(fd,30); WFIFOW(map_fd,0) = 0x2afd; WFIFOW(map_fd,2) = 20 + sizeof(struct mmo_charstatus); WFIFOL(map_fd,4) = RFIFOL(fd,2); //Account ID WFIFOL(map_fd,8) = RFIFOL(fd,6); //Login1 WFIFOL(map_fd,16) = RFIFOL(fd,10); //Login2 WFIFOL(map_fd,12) = (unsigned long)0; //TODO: connect_until_time, how do I figure it out right now? memcpy(WFIFOP(map_fd,20), char_data, sizeof(struct mmo_charstatus)); WFIFOSET(map_fd, WFIFOW(map_fd,2)); data = idb_ensure(online_char_db, RFIFOL(fd, 2), create_online_char_data); data->char_id = char_data->char_id; data->server = map_id; //Update server where char is. //Reply with an ack. WFIFOW(fd,0) = 0x2b06; memcpy(WFIFOP(fd,2), RFIFOP(fd,2), 28); WFIFOSET(fd,30); } else { //Reply with nak WFIFOHEAD(fd,30); WFIFOW(fd,0) = 0x2b06; memcpy(WFIFOP(fd,2), RFIFOP(fd,2), 28); WFIFOL(fd,6) = 0; //Set login1 to 0. WFIFOSET(fd,30); } RFIFOSKIP(fd,35); } break; case 0x2b08: // char name check if (RFIFOREST(fd) < 6) return 0; { char name[NAME_LENGTH]; WFIFOHEAD(fd,30); char_loadName((int)RFIFOL(fd,2), name); WFIFOW(fd,0) = 0x2b09; WFIFOL(fd,2) = RFIFOL(fd,2); memcpy(WFIFOP(fd,6), name, NAME_LENGTH); WFIFOSET(fd,30); RFIFOSKIP(fd,6); } break; case 0x2b0a: // request to become GM if (RFIFOREST(fd) < 4 || RFIFOREST(fd) < RFIFOW(fd,2)) return 0; /* memcpy(WFIFOP(login_fd,2),RFIFOP(fd,2),RFIFOW(fd,2)-2); WFIFOW(login_fd,0)=0x2720; WFIFOSET(login_fd,RFIFOW(fd,2)); // printf("char : change gm -> login %d %s %d\n", RFIFOL(fd, 4), RFIFOP(fd, 8), RFIFOW(fd, 2)); */ ShowWarning("packet 0x2ba (become GM) is not supported by the Char-Server.\n"); RFIFOSKIP(fd, RFIFOW(fd, 2)); break; case 0x2b0c: // Map server send information to change an email of an account -> login-server if (RFIFOREST(fd) < 86) return 0; if (login_fd > 0) { // don't send request if no login-server WFIFOHEAD(login_fd,86); memcpy(WFIFOP(login_fd,0), RFIFOP(fd,0),86); // 0x2722 .L .40B .40B WFIFOW(login_fd,0) = 0x2722; WFIFOSET(login_fd,86); } RFIFOSKIP(fd, 86); break; case 0x2b0e: // Request from map-server to change a char's status (all operations are transmitted to login-server) if (RFIFOREST(fd) < 44) return 0; { char character_name[NAME_LENGTH], t_name[NAME_LENGTH*2]; int acc = RFIFOL(fd,2); // account_id of who ask (-1 if nobody) WFIFOHEAD(fd,34); memcpy(character_name, RFIFOP(fd,6), NAME_LENGTH); character_name[NAME_LENGTH-1] = '\0'; jstrescapecpy(t_name, character_name); //Escape string for sql use... [Skotlex] // prepare answer WFIFOW(fd,0) = 0x2b0f; // answer WFIFOL(fd,2) = acc; // who want do operation WFIFOW(fd,30) = RFIFOW(fd, 30); // type of operation: 1-block, 2-ban, 3-unblock, 4-unban sprintf(tmp_sql, "SELECT `account_id`,`name` FROM `%s` WHERE `name` = '%s'",char_db, t_name); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result(&mysql_handle); if (sql_res) { if (mysql_num_rows(sql_res)) { sql_row = mysql_fetch_row(sql_res); memcpy(WFIFOP(fd,6), sql_row[1], NAME_LENGTH); // put correct name if found WFIFOW(fd,32) = 0; // answer: 0-login-server resquest done, 1-player not found, 2-gm level too low, 3-login-server offline switch(RFIFOW(fd, 30)) { case 1: // block if (acc == -1 || isGM(acc) >= isGM(atoi(sql_row[0]))) { if (login_fd > 0) { // don't send request if no login-server WFIFOHEAD(login_fd,10); WFIFOW(login_fd,0) = 0x2724; WFIFOL(login_fd,2) = atoi(sql_row[0]); // account value WFIFOL(login_fd,6) = 5; // status of the account WFIFOSET(login_fd,10); } else WFIFOW(fd,32) = 3; // answer: 0-login-server resquest done, 1-player not found, 2-gm level too low, 3-login-server offline } else WFIFOW(fd,32) = 2; // answer: 0-login-server resquest done, 1-player not found, 2-gm level too low, 3-login-server offline break; case 2: // ban if (acc == -1 || isGM(acc) >= isGM(atoi(sql_row[0]))) { if (login_fd > 0) { // don't send request if no login-server WFIFOHEAD(login_fd,18); WFIFOW(login_fd, 0) = 0x2725; WFIFOL(login_fd, 2) = atoi(sql_row[0]); // account value WFIFOW(login_fd, 6) = RFIFOW(fd,32); // year WFIFOW(login_fd, 8) = RFIFOW(fd,34); // month WFIFOW(login_fd,10) = RFIFOW(fd,36); // day WFIFOW(login_fd,12) = RFIFOW(fd,38); // hour WFIFOW(login_fd,14) = RFIFOW(fd,40); // minute WFIFOW(login_fd,16) = RFIFOW(fd,42); // second WFIFOSET(login_fd,18); } else WFIFOW(fd,32) = 3; // answer: 0-login-server resquest done, 1-player not found, 2-gm level too low, 3-login-server offline } else WFIFOW(fd,32) = 2; // answer: 0-login-server resquest done, 1-player not found, 2-gm level too low, 3-login-server offline break; case 3: // unblock if (acc == -1 || isGM(acc) >= isGM(atoi(sql_row[0]))) { if (login_fd > 0) { // don't send request if no login-server WFIFOHEAD(login_fd,10); WFIFOW(login_fd,0) = 0x2724; WFIFOL(login_fd,2) = atoi(sql_row[0]); // account value WFIFOL(login_fd,6) = 0; // status of the account WFIFOSET(login_fd,10); } else WFIFOW(fd,32) = 3; // answer: 0-login-server resquest done, 1-player not found, 2-gm level too low, 3-login-server offline } else WFIFOW(fd,32) = 2; // answer: 0-login-server resquest done, 1-player not found, 2-gm level too low, 3-login-server offline break; case 4: // unban if (acc == -1 || isGM(acc) >= isGM(atoi(sql_row[0]))) { if (login_fd > 0) { // don't send request if no login-server WFIFOHEAD(login_fd,6); WFIFOW(login_fd,0) = 0x272a; WFIFOL(login_fd,2) = atoi(sql_row[0]); // account value WFIFOSET(login_fd,6); } else WFIFOW(fd,32) = 3; // answer: 0-login-server resquest done, 1-player not found, 2-gm level too low, 3-login-server offline } else WFIFOW(fd,32) = 2; // answer: 0-login-server resquest done, 1-player not found, 2-gm level too low, 3-login-server offline break; case 5: // changesex if (acc == -1 || isGM(acc) >= isGM(atoi(sql_row[0]))) { if (login_fd > 0) { // don't send request if no login-server WFIFOHEAD(login_fd,6); WFIFOW(login_fd,0) = 0x2727; WFIFOL(login_fd,2) = atoi(sql_row[0]); // account value WFIFOSET(login_fd,6); } else WFIFOW(fd,32) = 3; // answer: 0-login-server resquest done, 1-player not found, 2-gm level too low, 3-login-server offline } else WFIFOW(fd,32) = 2; // answer: 0-login-server resquest done, 1-player not found, 2-gm level too low, 3-login-server offline break; } } else { // character name not found memcpy(WFIFOP(fd,6), character_name, NAME_LENGTH); WFIFOW(fd,32) = 1; // answer: 0-login-server resquest done, 1-player not found, 2-gm level too low, 3-login-server offline } // send answer if a player ask, not if the server ask if (acc != -1) { WFIFOSET(fd, 34); } mysql_free_result(sql_res); } } RFIFOSKIP(fd, 44); break; // case 0x2b0f: Not used anymore, available for future use case 0x2b10: // Update and send fame ranking list if (RFIFOREST(fd) < 12) return 0; { int cid = RFIFOL(fd, 2); int fame = RFIFOL(fd, 6); char type = RFIFOB(fd, 10); char pos = RFIFOB(fd, 11); int size; struct fame_list *list = NULL; RFIFOSKIP(fd,12); switch(type) { case 1: size = fame_list_size_smith; list = smith_fame_list; break; case 2: size = fame_list_size_chemist; list = chemist_fame_list; break; case 3: size = fame_list_size_taekwon; list = taekwon_fame_list; break; default: size = 0; break; } if(!size) break; //No list. if(pos) { pos--; //Convert from pos to index. if( (pos == 0 || fame < list[pos-1].fame) && (pos == size-1 || fame > list[pos+1].fame) ) { //No change in order. list[(int)pos].fame = fame; char_update_fame_list(type, pos, fame); break; } // If the player's already in the list, remove the entry and shift the following ones 1 step up memmove(list+pos, list+pos+1, (size-pos-1) * sizeof(struct fame_list)); //Clear out last entry. list[size-1].id = 0; list[size-1].fame = 0; } // Find the position where the player has to be inserted for(i = 0; i < size && fame < list[i].fame; i++); if(i >= size) break; //Out of ranking. // When found someone with less or as much fame, insert just above memmove(list+i+1, list+i, (size-i-1) * sizeof(struct fame_list)); list[i].id = cid; list[i].fame = fame; // Look for the player's name char_loadName(list[i].id, list[i].name); char_send_fame_list(-1); } break; case 0x2b16: // Receive rates [Wizputer] if (RFIFOREST(fd) < 6 || RFIFOREST(fd) < RFIFOW(fd,8)) return 0; { char motd[256], t_name[2*sizeof(char)*sizeof(server_name)+1], t_motd[512]; //Required for jstrescapecpy [Skotlex] strncpy(motd, RFIFOP(fd,10), 255); //First copy it to make sure the motd fits. motd[255]='\0'; jstrescapecpy(t_motd,motd); jstrescapecpy(t_name,server_name); sprintf(tmp_sql, "INSERT INTO `ragsrvinfo` SET `index`='%d',`name`='%s',`exp`='%d',`jexp`='%d',`drop`='%d',`motd`='%s'", fd, t_name, RFIFOW(fd,2), RFIFOW(fd,4), RFIFOW(fd,6), t_motd); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } RFIFOSKIP(fd,RFIFOW(fd,8)); break; } case 0x2b17: // Character disconnected set online 0 [Wizputer] if (RFIFOREST(fd) < 6) return 0; set_char_offline(RFIFOL(fd,2),RFIFOL(fd,6)); RFIFOSKIP(fd,10); break; case 0x2b18: // Reset all chars to offline [Wizputer] set_all_offline(id); RFIFOSKIP(fd,2); break; case 0x2b19: // Character set online [Wizputer] if (RFIFOREST(fd) < 6) return 0; set_char_online(id, RFIFOL(fd,2),RFIFOL(fd,6)); RFIFOSKIP(fd,10); break; case 0x2b1a: // Build and send fame ranking lists [DracoRPG] if (RFIFOREST(fd) < 2) return 0; char_read_fame_list(); char_send_fame_list(-1); RFIFOSKIP(fd,2); break; case 0x2b1c: //Request saving sc_data of a player. [Skotlex] if (RFIFOREST(fd) < 4 || RFIFOREST(fd) < RFIFOW(fd,2)) return 0; { #ifdef ENABLE_SC_SAVING int count, aid, cid, i; struct status_change_data data; char *p = tmp_sql; aid = RFIFOL(fd, 4); cid = RFIFOL(fd, 8); count = RFIFOW(fd, 12); p+= sprintf(p, "INSERT INTO `%s` (`account_id`, `char_id`, `type`, `tick`, `val1`, `val2`, `val3`, `val4`) VALUES ", scdata_db); for (i = 0; i < count; i++) { memcpy (&data, RFIFOP(fd, 14+i*sizeof(struct status_change_data)), sizeof(struct status_change_data)); p += sprintf (p, " ('%d','%d','%hu','%d','%d','%d','%d','%d'),", aid, cid, data.type, data.tick, data.val1, data.val2, data.val3, data.val4); } if (count > 0) { *--p = '\0'; //Remove final comma. if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } } #endif RFIFOSKIP(fd, RFIFOW(fd, 2)); break; } case 0x2736: // ip address update if (RFIFOREST(fd) < 6) return 0; server[id].ip = ntohl(RFIFOL(fd, 2)); ShowInfo("Updated IP address of map-server #%d to %d.%d.%d.%d.\n", id, CONVIP(server[id].ip)); RFIFOSKIP(fd,6); break; default: // inter server - packet { int r = inter_parse_frommap(fd); if (r == 1) break; // processed if (r == 2) return 0; // need more packet } // no inter server packet. no char server packet -> disconnect ShowError("Unknown packet 0x%04x from map server, disconnecting.\n", RFIFOW(fd,0)); session[fd]->eof = 1; return 0; } } return 0; } int search_mapserver(unsigned short map, uint32 ip, uint16 port) { int i, j; for(i = 0; i < MAX_MAP_SERVERS; i++) if (server_fd[i] > 0) for (j = 0; server[i].map[j]; j++) if (server[i].map[j] == map) { if (ip != (uint32)-1 && server[i].ip != ip) continue; if (port != (uint16)-1 && server[i].port != port) continue; return i; } return -1; } int char_mapif_init(int fd) { return inter_mapif_init(fd); } //-------------------------------------------- // Test to know if an IP come from LAN or WAN. //-------------------------------------------- int lan_subnetcheck(uint32 ip) { int i; for(i = 0; i < subnet_count; i++) { if((subnet[i].subnet & subnet[i].mask) == (ip & subnet[i].mask)) { 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].subnet), CONVIP(subnet[i].mask)); return subnet[i].map_ip; } } ShowInfo("Subnet check [%u.%u.%u.%u]: "CL_CYAN"WAN"CL_RESET"\n", CONVIP(ip)); return 0; } int parse_char(int fd) { int i, ch = 0; char email[40]; unsigned char buf[64]; unsigned short cmd; int map_fd; struct char_session_data *sd; uint32 ipl = session[fd]->client_addr; RFIFOHEAD(fd); sd = (struct char_session_data*)session[fd]->session_data; if(login_fd < 0) session[fd]->eof = 1; if(session[fd]->eof) { // disconnect any player (already connected to char-server or coming back from map-server) if login-server is diconnected. if (fd == login_fd) login_fd = -1; if (sd != NULL) { struct online_char_data* data = idb_get(online_char_db, sd->account_id); if (!data || data->server== -1) //If it is not in any server, send it offline. [Skotlex] set_char_offline(99,sd->account_id); if (data && data->fd == fd) data->fd = -1; } do_close(fd); return 0; } while(RFIFOREST(fd) >= 2) { cmd = RFIFOW(fd,0); // crc32のスキップ用 if( sd==NULL && // 未ログインor管理パケット RFIFOREST(fd)>=4 && // 最低バイト数制限 ＆ 0x7530,0x7532管理パケ除去 RFIFOREST(fd)<=21 && // 最大バイト数制限 ＆ サーバーログイン除去 cmd!=0x20b && // md5通知パケット除去 (RFIFOREST(fd)<6 || RFIFOW(fd,4)==0x65) ){ // 次に何かパケットが来てるなら、接続でないとだめ RFIFOSKIP(fd,4); cmd = RFIFOW(fd,0); ShowDebug("parse_char : %d crc32 skipped\n",fd); if(RFIFOREST(fd)==0) return 0; } //For use in packets that depend on an sd being present [Skotlex] #define FIFOSD_CHECK(rest) { if(RFIFOREST(fd) < rest) return 0; if (sd==NULL) { RFIFOSKIP(fd,rest); return 0; } } switch(cmd){ case 0x20b: //20040622 encryption ragexe correspondence if (RFIFOREST(fd) < 19) return 0; RFIFOSKIP(fd,19); break; case 0x65: // request to connect ShowInfo("request connect - account_id:%d/login_id1:%d/login_id2:%d\n", RFIFOL(fd, 2), RFIFOL(fd, 6), RFIFOL(fd, 10)); if (RFIFOREST(fd) < 17) return 0; { WFIFOHEAD(fd,4); if (sd) { //Received again auth packet for already authentified account?? Discard it. //TODO: Perhaps log this as a hack attempt? RFIFOSKIP(fd,17); break; } CREATE(session[fd]->session_data, struct char_session_data, 1); sd = (struct char_session_data*)session[fd]->session_data; sd->connect_until_time = 0; // unknow or illimited (not displaying on map-server) sd->account_id = RFIFOL(fd,2); sd->login_id1 = RFIFOL(fd,6); sd->login_id2 = RFIFOL(fd,10); sd->sex = RFIFOB(fd,16); // send back account_id WFIFOL(fd,0) = RFIFOL(fd,2); WFIFOSET(fd,4); // search authentification for(i = 0; i < AUTH_FIFO_SIZE && !( auth_fifo[i].account_id == sd->account_id && auth_fifo[i].login_id1 == sd->login_id1 && auth_fifo[i].login_id2 == sd->login_id2 && // relate to the versions higher than 18 auth_fifo[i].ip == session[fd]->client_addr && auth_fifo[i].delflag == 2) ; i++); if (i < AUTH_FIFO_SIZE) { auth_fifo[i].delflag = 1; char_auth_ok(fd, sd); } else { // authentication not found if (login_fd > 0) { // don't send request if no login-server WFIFOHEAD(login_fd,19); WFIFOW(login_fd,0) = 0x2712; // ask login-server to authentify an account WFIFOL(login_fd,2) = sd->account_id; WFIFOL(login_fd,6) = sd->login_id1; WFIFOL(login_fd,10) = sd->login_id2; WFIFOB(login_fd,14) = sd->sex; WFIFOL(login_fd,15) = htonl(session[fd]->client_addr); WFIFOSET(login_fd,19); } else { // if no login-server, we must refuse connection WFIFOHEAD(fd,3); WFIFOW(fd,0) = 0x6c; WFIFOB(fd,2) = 0; WFIFOSET(fd,3); } } } RFIFOSKIP(fd, 17); break; case 0x66: // char select FIFOSD_CHECK(3); sprintf(tmp_sql, "SELECT `char_id` FROM `%s` WHERE `account_id`='%d' AND `char_num`='%d'",char_db, sd->account_id, RFIFOB(fd, 2)); RFIFOSKIP(fd, 3); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result(&mysql_handle); sql_row = sql_res?mysql_fetch_row(sql_res):NULL; if (sql_row) { int char_id = atoi(sql_row[0]); mysql_free_result(sql_res); //Free'd as soon as possible mmo_char_fromsql(char_id, &char_dat); char_dat.sex = sd->sex; } else { mysql_free_result(sql_res); break; } if (log_char) { char escaped_name[NAME_LENGTH*2]; sprintf(tmp_sql,"INSERT INTO `%s`(`time`, `account_id`,`char_num`,`name`) VALUES (NOW(), '%d', '%d', '%s')", charlog_db, sd->account_id, RFIFOB(fd, 2), jstrescapecpy(escaped_name, char_dat.name)); //query if(mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } } ShowInfo("Selected char: (Account %d: %d - %s)" RETCODE, sd->account_id, RFIFOB(fd, 2), char_dat.name); // searching map server i = search_mapserver(char_dat.last_point.map, -1, -1); // if map is not found, we check major cities if (i < 0) { unsigned short j; //First check that there's actually a map server online. for(j = 0; j < MAX_MAP_SERVERS; j++) if (server_fd[j] >= 0 && server[j].map[0]) break; if (j == MAX_MAP_SERVERS) { ShowInfo("Connection Closed. No map servers available.\n"); WFIFOHEAD(fd,3); WFIFOW(fd,0) = 0x81; WFIFOB(fd,2) = 1; // 01 = Server closed WFIFOSET(fd,3); break; } if ((i = search_mapserver((j=mapindex_name2id(MAP_PRONTERA)),-1,-1)) >= 0) { char_dat.last_point.x = 273; char_dat.last_point.y = 354; } else if ((i = search_mapserver((j=mapindex_name2id(MAP_GEFFEN)),-1,-1)) >= 0) { char_dat.last_point.x = 120; char_dat.last_point.y = 100; } else if ((i = search_mapserver((j=mapindex_name2id(MAP_MORROC)),-1,-1)) >= 0) { char_dat.last_point.x = 160; char_dat.last_point.y = 94; } else if ((i = search_mapserver((j=mapindex_name2id(MAP_ALBERTA)),-1,-1)) >= 0) { char_dat.last_point.x = 116; char_dat.last_point.y = 57; } else if ((i = search_mapserver((j=mapindex_name2id(MAP_PAYON)),-1,-1)) >= 0) { char_dat.last_point.x = 87; char_dat.last_point.y = 117; } else if ((i = search_mapserver((j=mapindex_name2id(MAP_IZLUDE)),-1,-1)) >= 0) { char_dat.last_point.x = 94; char_dat.last_point.y = 103; } else { 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)); WFIFOHEAD(fd,3); WFIFOW(fd,0) = 0x81; WFIFOB(fd,2) = 1; // 01 = Server closed WFIFOSET(fd,3); break; } ShowWarning("Unable to find map-server for '%s', sending to major city '%s'.\n", mapindex_id2name(char_dat.last_point.map), mapindex_id2name(j)); char_dat.last_point.map = j; } { //Send player to map. uint32 subnet_map_ip; char map_name[MAP_NAME_LENGTH_EXT]; snprintf(map_name, MAP_NAME_LENGTH_EXT, "%s.gat", mapindex_id2name(char_dat.last_point.map)); WFIFOHEAD(fd,28); WFIFOW(fd,0) = 0x71; WFIFOL(fd,2) = char_dat.char_id; memcpy(WFIFOP(fd,6), map_name, MAP_NAME_LENGTH_EXT); // Advanced subnet check [LuzZza] subnet_map_ip = lan_subnetcheck(ipl); WFIFOL(fd,22) = htonl((subnet_map_ip) ? subnet_map_ip : server[i].ip); WFIFOW(fd,26) = ntows(htons(server[i].port)); // [!] LE byte order here [!] WFIFOSET(fd,28); } if (auth_fifo_pos >= AUTH_FIFO_SIZE) auth_fifo_pos = 0; auth_fifo[auth_fifo_pos].account_id = sd->account_id; auth_fifo[auth_fifo_pos].char_id = char_dat.char_id; auth_fifo[auth_fifo_pos].login_id1 = sd->login_id1; auth_fifo[auth_fifo_pos].login_id2 = sd->login_id2; auth_fifo[auth_fifo_pos].delflag = 0; auth_fifo[auth_fifo_pos].sex = sd->sex; auth_fifo[auth_fifo_pos].connect_until_time = sd->connect_until_time; auth_fifo[auth_fifo_pos].ip = session[fd]->client_addr; //Send NEW auth packet [Kevin] if ((map_fd = server_fd[i]) < 1 || session[map_fd] == NULL) { WFIFOHEAD(fd,3); ShowError("parse_char: Attempting to write to invalid session %d! Map Server #%d disconnected.\n", map_fd, i); server_fd[i] = -1; memset(&server[i], 0, sizeof(struct mmo_map_server)); //Send server closed. WFIFOW(fd,0) = 0x81; WFIFOB(fd,2) = 1; // 01 = Server closed WFIFOSET(fd,3); break; } { //Send auth ok to map server WFIFOHEAD(map_fd,20 + sizeof(struct mmo_charstatus)); WFIFOW(map_fd,0) = 0x2afd; WFIFOW(map_fd,2) = 20 + sizeof(struct mmo_charstatus); WFIFOL(map_fd,4) = auth_fifo[auth_fifo_pos].account_id; WFIFOL(map_fd,8) = auth_fifo[auth_fifo_pos].login_id1; WFIFOL(map_fd,16) = auth_fifo[auth_fifo_pos].login_id2; WFIFOL(map_fd,12) = (unsigned long)auth_fifo[auth_fifo_pos].connect_until_time; memcpy(WFIFOP(map_fd,20), &char_dat, sizeof(struct mmo_charstatus)); WFIFOSET(map_fd, WFIFOW(map_fd,2)); } set_char_online(i, auth_fifo[auth_fifo_pos].char_id, auth_fifo[auth_fifo_pos].account_id); auth_fifo_pos++; break; case 0x67: // make new FIFOSD_CHECK(37); if(char_new == 0) //turn character creation on/off [Kevin] i = -2; else i = make_new_char_sql(fd, RFIFOP(fd,2)); //'Charname already exists' (-1), 'Char creation denied' (-2) and 'You are underaged' (-3) if (i < 0) { WFIFOHEAD(fd,3); WFIFOW(fd,0) = 0x6e; switch (i) { case -1: WFIFOB(fd,2) = 0x00; break; case -2: WFIFOB(fd,2) = 0x02; break; case -3: WFIFOB(fd,2) = 0x01; break; } WFIFOSET(fd,3); RFIFOSKIP(fd,37); break; } { //Send to player. int len; WFIFOHEAD(fd,110); WFIFOW(fd,0) = 0x6d; mmo_char_fromsql_short(i, &char_dat); //Only the short data is needed. len = 2 + mmo_char_tobuf(WFIFOP(fd,2), &char_dat); WFIFOSET(fd,len); RFIFOSKIP(fd,37); } //to do for(ch = 0; ch < MAX_CHARS; ch++) { if (sd->found_char[ch] == -1) { sd->found_char[ch] = char_dat.char_id; break; } } break; case 0x68: // delete char FIFOSD_CHECK(46); { int cid = RFIFOL(fd,2); WFIFOHEAD(fd,46); ShowInfo(CL_RED" Request Char Deletion:"CL_GREEN"%d (%d)"CL_RESET"\n", sd->account_id, cid); memcpy(email, RFIFOP(fd,6), 40); RFIFOSKIP(fd,46); // Check if e-mail is correct if(strcmpi(email, sd->email) && //email does not matches and ( strcmp("a@a.com", sd->email) || //it is not default email, or (strcmp("a@a.com", email) && strcmp("", email)) //email sent does not matches default )) { //Fail WFIFOW(fd, 0) = 0x70; WFIFOB(fd, 2) = 0; // 00 = Incorrect Email address WFIFOSET(fd, 3); break; } for(i = 0; i < MAX_CHARS; i++) { if (sd->found_char[i] == cid) { for(ch = i; ch < MAX_CHARS-1; ch++) sd->found_char[ch] = sd->found_char[ch+1]; sd->found_char[MAX_CHARS-1] = -1; break; } } if (i == MAX_CHARS) { // Such a character does not exist in the account WFIFOW(fd,0) = 0x70; WFIFOB(fd,2) = 0; WFIFOSET(fd,3); break; } /* Grab the partner id */ sprintf(tmp_sql, "SELECT `partner_id` FROM `%s` WHERE `char_id`='%d'",char_db, cid); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result(&mysql_handle); if(sql_res) { int char_pid=0; sql_row = mysql_fetch_row(sql_res); if (sql_row) char_pid = atoi(sql_row[0]); mysql_free_result(sql_res); /* Delete character and partner (if any) */ if(delete_char_sql(cid, char_pid)<0){ //can't delete the char //either SQL error or can't delete by some CONFIG conditions //del fail WFIFOW(fd, 0) = 0x70; WFIFOB(fd, 2) = 0; WFIFOSET(fd, 3); break; } if (char_pid != 0) { /* If there is partner, tell map server to do divorce */ WBUFW(buf,0) = 0x2b12; WBUFL(buf,2) = cid; WBUFL(buf,6) = char_pid; mapif_sendall(buf,10); } } /* Char successfully deleted.*/ WFIFOW(fd,0) = 0x6f; WFIFOSET(fd,2); break; } case 0x2af8: // login as map-server if (RFIFOREST(fd) < 60) return 0; { char *l_user = RFIFOP(fd,2); char *l_pass = RFIFOP(fd,26); WFIFOHEAD(fd,4+5*GM_num); l_user[23] = '\0'; l_pass[23] = '\0'; WFIFOW(fd,0) = 0x2af9; for(i = 0; i < MAX_MAP_SERVERS; i++) { if (server_fd[i] <= 0) break; } if (i == MAX_MAP_SERVERS || strcmp(l_user, userid) || strcmp(l_pass, passwd)) { WFIFOB(fd,2) = 3; WFIFOSET(fd,3); RFIFOSKIP(fd,60); } else { int len; WFIFOB(fd,2) = 0; WFIFOSET(fd,3); session[fd]->func_parse = parse_frommap; server_fd[i] = fd; server[i].ip = ntohl(RFIFOL(fd, 54)); server[i].port = ntohs(RFIFOW(fd, 58)); server[i].users = 0; memset(server[i].map, 0, sizeof(server[i].map)); RFIFOSKIP(fd,60); realloc_fifo(fd, FIFOSIZE_SERVERLINK, FIFOSIZE_SERVERLINK); char_mapif_init(fd); // send gm acccounts level to map-servers len = 4; WFIFOW(fd,0) = 0x2b15; for(i = 0; i < GM_num; i++) { WFIFOL(fd,len) = gm_account[i].account_id; WFIFOB(fd,len+4) = (unsigned char)gm_account[i].level; len += 5; } WFIFOW(fd,2) = len; WFIFOSET(fd,len); } break; } case 0x187: // Alive? if (RFIFOREST(fd) < 6) return 0; RFIFOSKIP(fd, 6); break; case 0x7530: // Athena info get { WFIFOHEAD(fd,10); WFIFOW(fd,0) = 0x7531; WFIFOB(fd,2) = ATHENA_MAJOR_VERSION; WFIFOB(fd,3) = ATHENA_MINOR_VERSION; WFIFOB(fd,4) = ATHENA_REVISION; WFIFOB(fd,5) = ATHENA_RELEASE_FLAG; WFIFOB(fd,6) = ATHENA_OFFICIAL_FLAG; WFIFOB(fd,7) = ATHENA_SERVER_INTER | ATHENA_SERVER_CHAR; WFIFOW(fd,8) = ATHENA_MOD_VERSION; WFIFOSET(fd,10); RFIFOSKIP(fd,2); return 0; } case 0x7532: // disconnect(default also disconnect) default: session[fd]->eof = 1; return 0; } } RFIFOFLUSH(fd); return 0; } // Console Command Parser [Wizputer] int parse_console(char* buf) { char command[256]; memset(command, 0, sizeof(command)); sscanf(buf, "%[^\n]", command); //login_log("Console command :%s" RETCODE, command); if( strcmpi("shutdown", command) == 0 || strcmpi("exit", command) == 0 || strcmpi("quit", command) == 0 || strcmpi("end", command) == 0 ) runflag = 0; else if( strcmpi("alive", command) == 0 || strcmpi("status", command) == 0 ) ShowInfo(CL_CYAN"Console: "CL_BOLD"I'm Alive."CL_RESET"\n"); else if( strcmpi("help", command) == 0 ){ printf(CL_BOLD"Help of commands:"CL_RESET"\n"); printf(" To shutdown the server:\n"); printf(" 'shutdown|exit|qui|end'\n"); printf(" To know if server is alive:\n"); printf(" 'alive|status'\n"); } return 0; } // MAP send all int mapif_sendall(unsigned char *buf, unsigned int len) { int i, c; c = 0; for(i = 0; i < MAX_MAP_SERVERS; i++) { int fd; if ((fd = server_fd[i]) > 0) { WFIFOHEAD(fd,len); memcpy(WFIFOP(fd,0), buf, len); WFIFOSET(fd,len); c++; } } return c; } int mapif_sendallwos(int sfd, unsigned char *buf, unsigned int len) { int i, c; c = 0; for(i = 0; i < MAX_MAP_SERVERS; i++) { int fd; if ((fd = server_fd[i]) > 0 && fd != sfd) { WFIFOHEAD(fd,len); memcpy(WFIFOP(fd,0), buf, len); WFIFOSET(fd,len); c++; } } return c; } int mapif_send(int fd, unsigned char *buf, unsigned int len) { int i; if (fd >= 0) { for(i = 0; i < MAX_MAP_SERVERS; i++) { if (fd == server_fd[i]) { WFIFOHEAD(fd,len); memcpy(WFIFOP(fd,0), buf, len); WFIFOSET(fd,len); return 1; } } } return 0; } int send_users_tologin(int tid, unsigned int tick, int id, int data) { int users = count_users(); unsigned char buf[16]; if (login_fd > 0 && session[login_fd]) { // send number of user to login server WFIFOHEAD(login_fd,6); WFIFOW(login_fd,0) = 0x2714; WFIFOL(login_fd,2) = users; WFIFOSET(login_fd,6); } // send number of players to all map-servers WBUFW(buf,0) = 0x2b00; WBUFL(buf,2) = users; mapif_sendall(buf, 6); return 0; } static int send_accounts_tologin_sub(DBKey key, void* data, va_list ap) { struct online_char_data* character = (struct online_char_data*)data; int *i = va_arg(ap, int*); int count = va_arg(ap, int); if ((*i) >= count) return 0; //This is an error that shouldn't happen.... if(character->server > -1) { WFIFOHEAD(login_fd,8+count*4); WFIFOL(login_fd,8+(*i)*4) =character->account_id; (*i)++; return 1; } return 0; } int send_accounts_tologin(int tid, unsigned int tick, int id, int data) { int users = count_users(), i=0; if (login_fd > 0 && session[login_fd]) { // send account list to login server WFIFOHEAD(login_fd,8+users*4); WFIFOW(login_fd,0) = 0x272d; WFIFOL(login_fd,4) = users; online_char_db->foreach(online_char_db, send_accounts_tologin_sub, &i, users); WFIFOW(login_fd,2) = 8+ i*4; WFIFOSET(login_fd,WFIFOW(login_fd,2)); } return 0; } int check_connect_login_server(int tid, unsigned int tick, int id, int data) { if (login_fd > 0 && session[login_fd] != NULL) return 0; ShowInfo("Attempt to connect to login-server...\n"); login_fd = make_connection(login_ip, login_port); if (login_fd == -1) { //Try again later. [Skotlex] login_fd = 0; return 0; } session[login_fd]->func_parse = parse_tologin; realloc_fifo(login_fd, FIFOSIZE_SERVERLINK, FIFOSIZE_SERVERLINK); { WFIFOHEAD(login_fd,86); WFIFOW(login_fd,0) = 0x2710; memcpy(WFIFOP(login_fd,2), userid, 24); memcpy(WFIFOP(login_fd,26), passwd, 24); WFIFOL(login_fd,50) = 0; WFIFOL(login_fd,54) = htonl(char_ip); WFIFOL(login_fd,58) = htons(char_port); memcpy(WFIFOP(login_fd,60), server_name, 20); WFIFOW(login_fd,80) = 0; WFIFOW(login_fd,82) = char_maintenance; WFIFOW(login_fd,84) = char_new_display; //only display (New) if they want to [Kevin] WFIFOSET(login_fd,86); } return 1; } //------------------------------------------------ //Invoked 15 seconds after mapif_disconnectplayer in case the map server doesn't //replies/disconnect the player we tried to kick. [Skotlex] //------------------------------------------------ static int chardb_waiting_disconnect(int tid, unsigned int tick, int id, int data) { struct online_char_data* character; if ((character = idb_get(online_char_db, id)) != NULL && character->waiting_disconnect == tid) { //Mark it offline due to timeout. character->waiting_disconnect = -1; set_char_offline(character->char_id, character->account_id); } return 0; } //---------------------------------- // Reading Lan Support configuration // Rewrote: Anvanced subnet check [LuzZza] //---------------------------------- int char_lan_config_read(const char *lancfgName) { FILE *fp; int line_num = 0; char line[1024], w1[64], w2[64], w3[64], w4[64]; if((fp = fopen(lancfgName, "r")) == NULL) { ShowWarning("LAN Support configuration file is not found: %s\n", lancfgName); return 1; } ShowInfo("Reading the configuration file %s...\n", lancfgName); while(fgets(line, sizeof(line)-1, fp)) { line_num++; if ((line[0] == '/' && line[1] == '/') || line[0] == '\n' || line[1] == '\n') continue; line[sizeof(line)-1] = '\0'; if(sscanf(line,"%[^:]: %[^:]:%[^:]:%[^\r\n]", w1, w2, w3, w4) != 4) { ShowWarning("Error syntax of configuration file %s in line %d.\n", lancfgName, line_num); continue; } remove_control_chars(w1); remove_control_chars(w2); remove_control_chars(w3); remove_control_chars(w4); if(strcmpi(w1, "subnet") == 0) { subnet[subnet_count].mask = ntohl(inet_addr(w2)); subnet[subnet_count].char_ip = ntohl(inet_addr(w3)); subnet[subnet_count].map_ip = ntohl(inet_addr(w4)); subnet[subnet_count].subnet = subnet[subnet_count].char_ip&subnet[subnet_count].mask; if (subnet[subnet_count].subnet != (subnet[subnet_count].map_ip&subnet[subnet_count].mask)) { ShowError("%s: Configuration Error: The char server (%s) and map server (%s) belong to different subnetworks!\n", lancfgName, w3, w4); continue; } subnet_count++; } ShowStatus("Read information about %d subnetworks.\n", subnet_count); } fclose(fp); return 0; } #endif //TXT_SQL_CONVERT void sql_config_read(const char *cfgName){ /* Kalaspuff, to get login_db */ char line[1024], w1[1024], w2[1024]; FILE *fp; ShowInfo("Reading file %s...\n", cfgName); if ((fp = fopen(cfgName, "r")) == NULL) { ShowFatalError("file not found: %s\n", cfgName); exit(1); } while(fgets(line, sizeof(line)-1, fp)){ if(line[0] == '/' && line[1] == '/') continue; if (sscanf(line, "%[^:]: %[^\r\n]", w1, w2) != 2) continue; if(strcmpi(w1,"char_db")==0){ strcpy(char_db,w2); #ifndef TXT_SQL_CONVERT } else if(strcmpi(w1, "gm_read_method") == 0) { if(atoi(w2) != 0) char_gm_read = true; else char_gm_read = false; //custom columns for login database }else if(strcmpi(w1,"login_db")==0){ strcpy(login_db, w2); }else if(strcmpi(w1,"login_db_level")==0){ strcpy(login_db_level,w2); }else if(strcmpi(w1,"login_db_account_id")==0){ strcpy(login_db_account_id,w2); }else if(strcmpi(w1,"lowest_gm_level")==0){ lowest_gm_level = atoi(w2); ShowStatus("set lowest_gm_level : %s\n",w2); #endif }else if(strcmpi(w1,"scdata_db")==0){ strcpy(scdata_db,w2); }else if(strcmpi(w1,"cart_db")==0){ strcpy(cart_db,w2); }else if(strcmpi(w1,"inventory_db")==0){ strcpy(inventory_db,w2); }else if(strcmpi(w1,"charlog_db")==0){ strcpy(charlog_db,w2); }else if(strcmpi(w1,"storage_db")==0){ strcpy(storage_db,w2); }else if(strcmpi(w1,"reg_db")==0){ strcpy(reg_db,w2); }else if(strcmpi(w1,"skill_db")==0){ strcpy(skill_db,w2); }else if(strcmpi(w1,"interlog_db")==0){ strcpy(interlog_db,w2); }else if(strcmpi(w1,"memo_db")==0){ strcpy(memo_db,w2); }else if(strcmpi(w1,"guild_db")==0){ strcpy(guild_db,w2); }else if(strcmpi(w1,"guild_alliance_db")==0){ strcpy(guild_alliance_db,w2); }else if(strcmpi(w1,"guild_castle_db")==0){ strcpy(guild_castle_db,w2); }else if(strcmpi(w1,"guild_expulsion_db")==0){ strcpy(guild_expulsion_db,w2); }else if(strcmpi(w1,"guild_member_db")==0){ strcpy(guild_member_db,w2); }else if(strcmpi(w1,"guild_skill_db")==0){ strcpy(guild_skill_db,w2); }else if(strcmpi(w1,"guild_position_db")==0){ strcpy(guild_position_db,w2); }else if(strcmpi(w1,"guild_storage_db")==0){ strcpy(guild_storage_db,w2); }else if(strcmpi(w1,"party_db")==0){ strcpy(party_db,w2); }else if(strcmpi(w1,"pet_db")==0){ strcpy(pet_db,w2); }else if(strcmpi(w1,"friend_db")==0){ strcpy(friend_db,w2); #ifndef TXT_SQL_CONVERT }else if(strcmpi(w1,"db_path")==0){ strcpy(db_path,w2); //Map server option to use SQL db or not }else if(strcmpi(w1,"use_sql_db")==0){ // added for sql item_db read for char server [Valaris] db_use_sqldbs = config_switch(w2); ShowStatus("Using SQL dbs: %s\n",w2); }else if(strcmpi(w1,"item_db_db")==0){ strcpy(item_db_db,w2); }else if(strcmpi(w1,"item_db2_db")==0){ strcpy(item_db2_db,w2); #endif //support the import command, just like any other config }else if(strcmpi(w1,"import")==0){ sql_config_read(w2); } } fclose(fp); ShowInfo("done reading %s.\n", cfgName); } #ifndef TXT_SQL_CONVERT int char_config_read(const char *cfgName) { char line[1024], w1[1024], w2[1024]; FILE* fp = fopen(cfgName, "r"); if (fp == NULL) { ShowFatalError("Configuration file not found: %s.\n", cfgName); exit(1); } ShowInfo("Reading configuration file %s...\n", cfgName); while(fgets(line, sizeof(line)-1, fp)) { if (line[0] == '/' && line[1] == '/') continue; line[sizeof(line)-1] = '\0'; if (sscanf(line, "%[^:]: %[^\r\n]", w1, w2) != 2) continue; remove_control_chars(w1); remove_control_chars(w2); if(strcmpi(w1,"timestamp_format") == 0) { strncpy(timestamp_format, w2, 20); } else if(strcmpi(w1,"console_silent")==0){ ShowInfo("Console Silent Setting: %d\n", atoi(w2)); msg_silent = atoi(w2); } else if(strcmpi(w1,"stdout_with_ansisequence")==0){ stdout_with_ansisequence = config_switch(w2); } else if (strcmpi(w1, "userid") == 0) { strncpy(userid, w2, 24); } else if (strcmpi(w1, "passwd") == 0) { strncpy(passwd, w2, 24); } else if (strcmpi(w1, "server_name") == 0) { strncpy(server_name, w2, 20); server_name[sizeof(server_name) - 1] = '\0'; ShowStatus("%s server has been initialized\n", w2); } else if (strcmpi(w1, "wisp_server_name") == 0) { if (strlen(w2) >= 4) { memcpy(wisp_server_name, w2, sizeof(wisp_server_name)); wisp_server_name[sizeof(wisp_server_name) - 1] = '\0'; } } else if (strcmpi(w1, "login_ip") == 0) { char ip_str[16]; login_ip = host2ip(w2); if (login_ip) { strncpy(login_ip_str, w2, sizeof(login_ip_str)); ShowStatus("Login server IP address : %s -> %s\n", w2, ip2str(login_ip, ip_str)); } } else if (strcmpi(w1, "login_port") == 0) { login_port = atoi(w2); } else if (strcmpi(w1, "char_ip") == 0) { char ip_str[16]; char_ip = host2ip(w2); if (char_ip){ strncpy(char_ip_str, w2, sizeof(char_ip_str)); ShowStatus("Character server IP address : %s -> %s\n", w2, ip2str(char_ip, ip_str)); } } else if (strcmpi(w1, "bind_ip") == 0) { char ip_str[16]; bind_ip = host2ip(w2); if (bind_ip) { strncpy(bind_ip_str, w2, sizeof(bind_ip_str)); ShowStatus("Character server binding IP address : %s -> %s\n", w2, ip2str(bind_ip, ip_str)); } } else if (strcmpi(w1, "char_port") == 0) { char_port = atoi(w2); } else if (strcmpi(w1, "char_maintenance") == 0) { char_maintenance = atoi(w2); } else if (strcmpi(w1, "char_new")==0){ char_new = atoi(w2); } else if (strcmpi(w1, "char_new_display")==0){ char_new_display = atoi(w2); } else if (strcmpi(w1, "max_connect_user") == 0) { max_connect_user = atoi(w2); if (max_connect_user < 0) max_connect_user = 0; // unlimited online players } else if(strcmpi(w1, "gm_allow_level") == 0) { gm_allow_level = atoi(w2); if(gm_allow_level < 0) gm_allow_level = 99; } else if (strcmpi(w1, "online_check") == 0) { online_check = config_switch(w2); } else if (strcmpi(w1, "autosave_time") == 0) { autosave_interval = atoi(w2)*1000; if (autosave_interval <= 0) autosave_interval = DEFAULT_AUTOSAVE_INTERVAL; } else if (strcmpi(w1, "save_log") == 0) { save_log = config_switch(w2); } else if (strcmpi(w1, "start_point") == 0) { char map[MAP_NAME_LENGTH_EXT]; int x, y; if (sscanf(w2, "%15[^,],%d,%d", map, &x, &y) < 3) continue; start_point.map = mapindex_name2id(map); if (!start_point.map) ShowError("Specified start_point %s not found in map-index cache.\n", map); start_point.x = x; start_point.y = y; } else if (strcmpi(w1, "start_zeny") == 0) { start_zeny = atoi(w2); if (start_zeny < 0) start_zeny = 0; } else if (strcmpi(w1, "start_weapon") == 0) { start_weapon = atoi(w2); if (start_weapon < 0) start_weapon = 0; } else if (strcmpi(w1, "start_armor") == 0) { start_armor = atoi(w2); if (start_armor < 0) start_armor = 0; } else if(strcmpi(w1,"log_char")==0) { //log char or not [devil] log_char = atoi(w2); } else if (strcmpi(w1, "unknown_char_name") == 0) { strcpy(unknown_char_name, w2); unknown_char_name[NAME_LENGTH-1] = '\0'; } else if (strcmpi(w1, "name_ignoring_case") == 0) { name_ignoring_case = config_switch(w2); } else if (strcmpi(w1, "char_name_option") == 0) { char_name_option = atoi(w2); } else if (strcmpi(w1, "char_name_letters") == 0) { strcpy(char_name_letters, w2); } else if (strcmpi(w1, "chars_per_account") == 0) { //maxchars per account [Sirius] char_per_account = atoi(w2); } else if (strcmpi(w1, "char_del_level") == 0) { //disable/enable char deletion by its level condition [Lupus] char_del_level = atoi(w2); } else if (strcmpi(w1, "console") == 0) { if(strcmpi(w2,"on") == 0 || strcmpi(w2,"yes") == 0 ) console = 1; } else if (strcmpi(w1, "fame_list_alchemist") == 0) { fame_list_size_chemist = atoi(w2); if (fame_list_size_chemist > MAX_FAME_LIST) { ShowWarning("Max fame list size is %d (fame_list_alchemist)\n", MAX_FAME_LIST); fame_list_size_chemist = MAX_FAME_LIST; } } else if (strcmpi(w1, "fame_list_blacksmith") == 0) { fame_list_size_smith = atoi(w2); if (fame_list_size_smith > MAX_FAME_LIST) { ShowWarning("Max fame list size is %d (fame_list_blacksmith)\n", MAX_FAME_LIST); fame_list_size_smith = MAX_FAME_LIST; } } else if (strcmpi(w1, "fame_list_taekwon") == 0) { fame_list_size_taekwon = atoi(w2); if (fame_list_size_taekwon > MAX_FAME_LIST) { ShowWarning("Max fame list size is %d (fame_list_taekwon)\n", MAX_FAME_LIST); fame_list_size_taekwon = MAX_FAME_LIST; } } else if (strcmpi(w1, "guild_exp_rate") == 0) { guild_exp_rate = atoi(w2); } else if (strcmpi(w1, "import") == 0) { char_config_read(w2); } } fclose(fp); ShowInfo("Done reading %s.\n", cfgName); return 0; } void do_final(void) { ShowInfo("Doing final stage...\n"); //inter_save(); do_final_itemdb(); //check SQL save progress. //wait until save char complete set_all_offline(-1); set_all_offline_sql(); inter_final(); flush_fifos(); mapindex_final(); sprintf(tmp_sql,"DELETE FROM `ragsrvinfo"); if (mysql_query(&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } if(gm_account) { aFree(gm_account); gm_account = 0; } if (login_fd > 0) do_close(login_fd); if (char_fd > 0) do_close(char_fd); char_db_->destroy(char_db_, NULL); online_char_db->destroy(online_char_db, NULL); mysql_close(&mysql_handle); if(char_gm_read) mysql_close(&lmysql_handle); ShowInfo("ok! all done...\n"); } //------------------------------ // Function called when the server // has received a crash signal. //------------------------------ void do_abort(void) { } void set_server_type(void) { SERVER_TYPE = ATHENA_SERVER_CHAR; } static int online_data_cleanup_sub(DBKey key, void *data, va_list ap) { struct online_char_data *character= (struct online_char_data*)data; if (character->server == -2) //Unknown server.. set them offline set_char_offline(character->char_id, character->account_id); if (character->server < 0) //Free data from players that have not been online for a while. db_remove(online_char_db, key); return 0; } static int online_data_cleanup(int tid, unsigned int tick, int id, int data) { online_char_db->foreach(online_char_db, online_data_cleanup_sub); return 0; } int do_init(int argc, char **argv) { int i; for(i = 0; i < MAX_MAP_SERVERS; i++) { memset(&server[i], 0, sizeof(struct mmo_map_server)); server_fd[i] = -1; } //Read map indexes mapindex_init(); start_point.map = mapindex_name2id("new_zone01"); char_config_read((argc < 2) ? CHAR_CONF_NAME : argv[1]); char_lan_config_read((argc > 3) ? argv[3] : LAN_CONF_NAME); sql_config_read(SQL_CONF_NAME); if (strcmp(userid, "s1")==0 && strcmp(passwd, "p1")==0) { ShowError("Using the default user/password s1/p1 is NOT RECOMMENDED.\n"); ShowNotice("Please edit your 'login' table to create a proper inter-server user/password (gender 'S')\n"); ShowNotice("And then change the user/password to use in conf/char_athena.conf (or conf/import/char_conf.txt)\n"); } ShowInfo("Finished reading the char-server configuration.\n"); inter_init_sql((argc > 2) ? argv[2] : inter_cfgName); // inter server ﾃﾊｱ篳ｭ ShowInfo("Finished reading the inter-server configuration.\n"); //Read ItemDB do_init_itemdb(); ShowInfo("Initializing char server.\n"); online_char_db = db_alloc(__FILE__,__LINE__,DB_INT,DB_OPT_RELEASE_DATA,sizeof(int)); mmo_char_sql_init(); ShowInfo("char server initialized.\n"); // ShowDebug("set parser -> parse_char()...\n"); set_defaultparse(parse_char); // ShowDebug("set terminate function -> do_final().....\n"); if ((naddr_ != 0) && (!login_ip || !char_ip)) { char ip_str[16]; ip2str(addr_[0], ip_str); if (naddr_ > 1) ShowStatus("Multiple interfaces detected.. using %s as our IP address\n", ip_str); else ShowStatus("Defaulting to %s as our IP address\n", ip_str); if (!login_ip) { strcpy(login_ip_str, ip_str); login_ip = ntohl(inet_addr(login_ip_str)); } if (!char_ip) { strcpy(char_ip_str, ip_str); char_ip = ntohl(inet_addr(char_ip_str)); } } ShowInfo("open port %d.....\n",char_port); char_fd = make_listen_bind(bind_ip, char_port); add_timer_func_list(check_connect_login_server, "check_connect_login_server"); add_timer_func_list(send_users_tologin, "send_users_tologin"); add_timer_func_list(send_accounts_tologin, "send_accounts_tologin"); add_timer_func_list(chardb_waiting_disconnect, "chardb_waiting_disconnect"); add_timer_func_list(online_data_cleanup, "online_data_cleanup"); add_timer_interval(gettick() + 600*1000, online_data_cleanup, 0, 0, 600 * 1000); // send ALIVE PING to login server. add_timer_interval(gettick() + 10, check_connect_login_server, 0, 0, 10 * 1000); // send USER COUNT PING to login server. add_timer_interval(gettick() + 10, send_users_tologin, 0, 0, 5 * 1000); add_timer_interval(gettick() + 3600*1000, send_accounts_tologin, 0, 0, 3600 * 1000); //Sync online accounts every hour. char_read_fame_list(); //Read fame lists. if(char_gm_read) read_gm_account(); if( console ) { //##TODO invoke a CONSOLE_START plugin event } //Cleaning the tables for NULL entrys @ startup [Sirius] //Chardb clean ShowInfo("Cleaning the '%s' table...\n", char_db); sprintf(tmp_sql,"DELETE FROM `%s` WHERE `account_id` = '0'", char_db); if(mysql_query(&mysql_handle, tmp_sql)){ ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } //guilddb clean ShowInfo("Cleaning the '%s' table...\n", guild_db); sprintf(tmp_sql,"DELETE FROM `%s` WHERE `guild_lv` = '0' AND `max_member` = '0' AND `exp` = '0' AND `next_exp` = '0' AND `average_lv` = '0'", guild_db); if(mysql_query(&mysql_handle, tmp_sql)){ ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } //guildmemberdb clean ShowInfo("Cleaning the '%s' table...\n", guild_member_db); sprintf(tmp_sql,"DELETE FROM `%s` WHERE `guild_id` = '0' AND `account_id` = '0' AND `char_id` = '0'", guild_member_db); if(mysql_query(&mysql_handle, tmp_sql)){ ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } ShowInfo("End of char server initilization function.\n"); ShowStatus("The char-server is "CL_GREEN"ready"CL_RESET" (Server is listening on the port %d).\n\n", char_port); return 0; } #undef mysql_query int debug_mysql_query(char *file, int line, void *mysql, const char *q) { #ifdef TWILIGHT ShowDebug("sql: %s:%d# %s\n", file, line, q); #endif return mysql_query((MYSQL *) mysql, q); } int char_child(int parent_id, int child_id) { int tmp_id = 0; sprintf (tmp_sql, "SELECT `child` FROM `%s` WHERE `char_id` = '%d'", char_db, parent_id); if (mysql_query (&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result (&mysql_handle); sql_row = sql_res?mysql_fetch_row (sql_res):NULL; if (sql_row) tmp_id = atoi (sql_row[0]); else ShowError("CHAR: child Failed!\n"); if (sql_res) mysql_free_result (sql_res); if ( tmp_id == child_id ) return 1; else return 0; } int char_married(int pl1,int pl2) { int tmp_id = 0; sprintf (tmp_sql, "SELECT `partner_id` FROM `%s` WHERE `char_id` = '%d'", char_db, pl1); if (mysql_query (&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); } sql_res = mysql_store_result (&mysql_handle); sql_row = sql_res?mysql_fetch_row (sql_res):NULL; if (sql_row) tmp_id = atoi (sql_row[0]); else ShowError("CHAR: married Failed!\n"); if (sql_res) mysql_free_result (sql_res); if ( tmp_id == pl2 ) return 1; else return 0; } int char_family(int pl1,int pl2,int pl3) { int charid, partnerid, childid; sprintf (tmp_sql, "SELECT `char_id`,`partner_id`,`child` FROM `%s` WHERE `char_id` IN ('%d','%d','%d')", char_db, pl1, pl2, pl3); if (mysql_query (&mysql_handle, tmp_sql)) { ShowSQL("DB error - %s\n",mysql_error(&mysql_handle)); ShowDebug("at %s:%d - %s\n", __FILE__,__LINE__,tmp_sql); return 0; } sql_res = mysql_store_result (&mysql_handle); if (!sql_res) return 0; while((sql_row = mysql_fetch_row(sql_res))) { charid = atoi(sql_row[0]); partnerid = atoi(sql_row[1]); childid = atoi(sql_row[2]); if (charid == pl1) { if ((pl2 == partnerid && pl3 == childid) || (pl3 == partnerid && pl2 == childid) ) { mysql_free_result (sql_res); return childid; } } if(charid == pl2) { if ((pl1 == partnerid && pl3 == childid) || (pl3 == partnerid && pl1 == childid) ) { mysql_free_result (sql_res); return childid; } } if(charid == pl3) { if ((pl1 == partnerid && pl2 == childid) || (pl2 == partnerid && pl1 == childid) ) { mysql_free_result (sql_res); return childid; } } } mysql_free_result (sql_res); return 0; } #endif //TXT_SQL_CONVERT