From 8338483dd4c41bc9831bebc9d6dc1808247fc497 Mon Sep 17 00:00:00 2001 From: Andrei Karas Date: Fri, 7 Nov 2014 17:38:31 +0300 Subject: Add most functions from char.c to interfaces. Introduced interfaces: chr, mapif, loginif. --- src/char/Makefile.in | 4 +- src/char/char.c | 852 ++++++++++++++++++++++++++++--------------------- src/char/char.h | 194 ++++++++++- src/char/int_auction.c | 3 +- src/char/int_guild.c | 33 +- src/char/int_mail.c | 3 +- src/char/int_party.c | 21 +- src/char/int_storage.c | 10 +- src/char/inter.c | 21 +- src/char/loginif.c | 45 +++ src/char/loginif.h | 29 ++ src/char/mapif.c | 45 +++ src/char/mapif.h | 29 ++ 13 files changed, 868 insertions(+), 421 deletions(-) create mode 100644 src/char/loginif.c create mode 100644 src/char/loginif.h create mode 100644 src/char/mapif.c create mode 100644 src/char/mapif.h diff --git a/src/char/Makefile.in b/src/char/Makefile.in index d591a5370..446af8d4f 100644 --- a/src/char/Makefile.in +++ b/src/char/Makefile.in @@ -22,11 +22,11 @@ MT19937AR_OBJ = $(MT19937AR_D)/mt19937ar.o MT19937AR_H = $(MT19937AR_D)/mt19937ar.h MT19937AR_INCLUDE = -I$(MT19937AR_D) -CHAR_C = char.c HPMchar.c inter.c int_auction.c int_elemental.c int_guild.c \ +CHAR_C = char.c HPMchar.c loginif.c mapif.c inter.c int_auction.c int_elemental.c int_guild.c \ int_homun.c int_mail.c int_mercenary.c int_party.c int_pet.c \ int_quest.c int_storage.c pincode.c CHAR_OBJ = $(addprefix obj_sql/, $(patsubst %.c,%.o,$(CHAR_C))) -CHAR_H = char.h HPMchar.h inter.h int_auction.h int_elemental.h int_guild.h \ +CHAR_H = char.h HPMchar.h loginif.h mapif.h inter.h int_auction.h int_elemental.h int_guild.h \ int_homun.h int_mail.h int_mercenary.h int_party.h int_pet.h \ int_quest.h int_storage.h pincode.h diff --git a/src/char/char.c b/src/char/char.c index 55cee9fd2..b4dd60e6d 100644 --- a/src/char/char.c +++ b/src/char/char.c @@ -23,6 +23,8 @@ #include "int_party.h" #include "int_storage.h" #include "inter.h" +#include "loginif.h" +#include "mapif.h" #include "pincode.h" #include "../common/HPM.h" #include "../common/cbasetypes.h" @@ -80,6 +82,8 @@ char acc_reg_str_db[32] = "acc_reg_str_db"; char char_reg_str_db[32] = "char_reg_str_db"; char char_reg_num_db[32] = "char_reg_num_db"; +struct char_interface char_s; + // show loading/saving messages int save_log = 1; @@ -130,7 +134,7 @@ int char_del_delay = 86400; int log_char = 1; // logging char or not [devil] int log_inter = 1; // logging inter or not [devil] -int char_aegis_delete = 0; // Verify if char is in guild/party or char and reacts as Aegis does (doesn't allow deletion), see char_delete2_req for more information +int char_aegis_delete = 0; // Verify if char is in guild/party or char and reacts as Aegis does (doesn't allow deletion), see chr->delete2_req for more information // Advanced subnet check [LuzZza] struct s_subnet { @@ -172,27 +176,12 @@ unsigned short skillid2idx[MAX_SKILL_ID]; //----------------------------------------------------- #define AUTH_TIMEOUT 30000 -struct char_auth_node { - int account_id; - int char_id; - uint32 login_id1; - uint32 login_id2; - uint32 ip; - int sex; - time_t expiration_time; // # of seconds 1/1/1970 (timestamp): Validity limit of the account (0 = unlimited) - int group_id; - unsigned changing_mapservers : 1; -}; - static DBMap* auth_db; // int account_id -> struct char_auth_node* //----------------------------------------------------- // Online User Database //----------------------------------------------------- -static int char_waiting_disconnect(int tid, int64 tick, int id, intptr_t data); -int char_delete_char_sql(int char_id); - /** * @see DBCreateData */ @@ -229,7 +218,7 @@ void char_set_char_charselect(int account_id) { struct online_char_data* character; - character = (struct online_char_data*)idb_ensure(online_char_db, account_id, char_create_online_char_data); + character = (struct online_char_data*)idb_ensure(online_char_db, account_id, chr->create_online_char_data); if( character->server > -1 ) if( server[character->server].users > 0 ) // Prevent this value from going negative. @@ -241,12 +230,12 @@ void char_set_char_charselect(int account_id) character->pincode_enable = *pincode->charselect + *pincode->enabled; if(character->waiting_disconnect != INVALID_TIMER) { - timer->delete(character->waiting_disconnect, char_waiting_disconnect); + timer->delete(character->waiting_disconnect, chr->waiting_disconnect); character->waiting_disconnect = INVALID_TIMER; } if (login_fd > 0 && !session[login_fd]->flag.eof) - char_set_account_online(account_id); + chr->set_account_online(account_id); } void char_set_char_online(int map_id, int char_id, int account_id) @@ -259,10 +248,10 @@ void char_set_char_online(int map_id, int char_id, int account_id) Sql_ShowDebug(sql_handle); //Check to see for online conflicts - character = (struct online_char_data*)idb_ensure(online_char_db, account_id, char_create_online_char_data); + character = (struct online_char_data*)idb_ensure(online_char_db, account_id, chr->create_online_char_data); if( character->char_id != -1 && character->server > -1 && character->server != map_id ) { - ShowNotice("char_set_char_online: Character %d:%d marked in map server %d, but map server %d claims to have (%d:%d) online!\n", + ShowNotice("chr->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[character->server].fd, character->account_id, character->char_id, 2); } @@ -276,7 +265,7 @@ void char_set_char_online(int map_id, int char_id, int account_id) //Get rid of disconnect timer if(character->waiting_disconnect != INVALID_TIMER) { - timer->delete(character->waiting_disconnect, char_waiting_disconnect); + timer->delete(character->waiting_disconnect, chr->waiting_disconnect); character->waiting_disconnect = INVALID_TIMER; } @@ -286,7 +275,7 @@ void char_set_char_online(int map_id, int char_id, int account_id) //Notify login server if (login_fd > 0 && !session[login_fd]->flag.eof) - char_set_account_online(account_id); + chr->set_account_online(account_id); } void char_set_char_offline(int char_id, int account_id) @@ -316,7 +305,7 @@ void char_set_char_offline(int char_id, int account_id) server[character->server].users--; if(character->waiting_disconnect != INVALID_TIMER){ - timer->delete(character->waiting_disconnect, char_waiting_disconnect); + timer->delete(character->waiting_disconnect, chr->waiting_disconnect); character->waiting_disconnect = INVALID_TIMER; } @@ -332,7 +321,7 @@ void char_set_char_offline(int char_id, int account_id) //Remove char if 1- Set all offline, or 2- character is no longer connected to char-server. if (login_fd > 0 && !session[login_fd]->flag.eof && (char_id == -1 || character == NULL || character->fd == -1)) - char_set_account_offline(account_id); + chr->set_account_offline(account_id); } /** @@ -346,7 +335,7 @@ static int char_db_setoffline(DBKey key, DBData *data, va_list ap) character->char_id = -1; character->server = -1; if(character->waiting_disconnect != INVALID_TIMER){ - timer->delete(character->waiting_disconnect, char_waiting_disconnect); + timer->delete(character->waiting_disconnect, chr->waiting_disconnect); character->waiting_disconnect = INVALID_TIMER; } } else if (character->server == server_id) @@ -369,14 +358,14 @@ static int char_db_kickoffline(DBKey key, DBData *data, va_list ap) if (character->server > -1) mapif_disconnectplayer(server[character->server].fd, character->account_id, character->char_id, 1); else if (character->waiting_disconnect == INVALID_TIMER) - char_set_char_offline(character->char_id, character->account_id); + chr->set_char_offline(character->char_id, character->account_id); else return 0; // fail return 1; } -void char_set_login_all_offline() +void char_set_login_all_offline(void) { //Tell login-server to also mark all our characters as offline. WFIFOHEAD(login_fd,2); @@ -390,11 +379,11 @@ void char_set_all_offline(int id) 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); + online_char_db->foreach(online_char_db,chr->db_kickoffline,id); if (id >= 0 || login_fd <= 0 || session[login_fd]->flag.eof) return; - char_set_login_all_offline(); + chr->set_login_all_offline(); } void char_set_all_offline_sql(void) @@ -419,8 +408,6 @@ static DBData char_create_charstatus(DBKey key, va_list args) return DB->ptr2data(cp); } -int char_inventory_to_sql(const struct item items[], int max, int id); - int char_mmo_char_tosql(int char_id, struct mmo_charstatus* p) { int i = 0; @@ -433,14 +420,14 @@ int char_mmo_char_tosql(int char_id, struct mmo_charstatus* p) if (char_id!=p->char_id) return 0; - cp = idb_ensure(char_db_, char_id, char_create_charstatus); + cp = idb_ensure(char_db_, char_id, chr->create_charstatus); StrBuf->Init(&buf); memset(save_status, 0, sizeof(save_status)); //map inventory data if( memcmp(p->inventory, cp->inventory, sizeof(p->inventory)) ) { - if (!char_inventory_to_sql(p->inventory, MAX_INVENTORY, p->char_id)) + if (!chr->inventory_to_sql(p->inventory, MAX_INVENTORY, p->char_id)) strcat(save_status, " inventory"); else errors++; @@ -448,7 +435,7 @@ int char_mmo_char_tosql(int char_id, struct mmo_charstatus* p) //map cart data if( memcmp(p->cart, cp->cart, sizeof(p->cart)) ) { - if (!char_memitemdata_to_sql(p->cart, MAX_CART, p->char_id, TABLE_CART)) + if (!chr->memitemdata_to_sql(p->cart, MAX_CART, p->char_id, TABLE_CART)) strcat(save_status, " cart"); else errors++; @@ -456,7 +443,7 @@ int char_mmo_char_tosql(int char_id, struct mmo_charstatus* p) //map storage data if( memcmp(p->storage.items, cp->storage.items, sizeof(p->storage.items)) ) { - if (!char_memitemdata_to_sql(p->storage.items, MAX_STORAGE, p->account_id, TABLE_STORAGE)) + if (!chr->memitemdata_to_sql(p->storage.items, MAX_STORAGE, p->account_id, TABLE_STORAGE)) strcat(save_status, " storage"); else errors++; @@ -866,7 +853,7 @@ int char_memitemdata_to_sql(const struct item items[], int max, int id, int tabl return errors; } -/* pretty much a copy of char_memitemdata_to_sql except it handles inventory_db exclusively, +/* pretty much a copy of chr->memitemdata_to_sql except it handles inventory_db exclusively, * - this is required because inventory db is the only one with the 'favorite' column. */ int char_inventory_to_sql(const struct item items[], int max, int id) { StringBuf buf; @@ -1005,9 +992,6 @@ int char_inventory_to_sql(const struct item items[], int max, int id) { return errors; } - -int char_mmo_char_tobuf(uint8* buf, struct mmo_charstatus* p); - //===================================================================================================== // Loads the basic character rooster for the given account. Returns total buffer used. int char_mmo_chars_fromsql(struct char_session_data* sd, uint8* buf) @@ -1102,7 +1086,7 @@ int char_mmo_chars_fromsql(struct char_session_data* sd, uint8* buf) p.sex = 99; break; } - j += char_mmo_char_tobuf(WBUFP(buf, j), &p); + j += chr->mmo_char_tobuf(WBUFP(buf, j), &p); } memset(sd->new_name,0,sizeof(sd->new_name)); @@ -1367,7 +1351,7 @@ int char_mmo_char_fromsql(int char_id, struct mmo_charstatus* p, bool load_every if( skillid2idx[tmp_skill.id] ) memcpy(&p->skill[skillid2idx[tmp_skill.id]], &tmp_skill, sizeof(tmp_skill)); else - ShowWarning("char_mmo_char_fromsql: ignoring invalid skill (id=%u,lv=%u) of character %s (AID=%d,CID=%d)\n", tmp_skill.id, tmp_skill.lv, p->name, p->account_id, p->char_id); + ShowWarning("chr->mmo_char_fromsql: ignoring invalid skill (id=%u,lv=%u) of character %s (AID=%d,CID=%d)\n", tmp_skill.id, tmp_skill.lv, p->name, p->account_id, p->char_id); } strcat(t_msg, " skills"); @@ -1404,7 +1388,7 @@ int char_mmo_char_fromsql(int char_id, struct mmo_charstatus* p, bool load_every if( hotkey_num >= 0 && hotkey_num < MAX_HOTKEYS ) memcpy(&p->hotkeys[hotkey_num], &tmp_hotkey, sizeof(tmp_hotkey)); else - ShowWarning("char_mmo_char_fromsql: ignoring invalid hotkey (hotkey=%d,type=%u,id=%u,lv=%u) of character %s (AID=%d,CID=%d)\n", hotkey_num, tmp_hotkey.type, tmp_hotkey.id, tmp_hotkey.lv, p->name, p->account_id, p->char_id); + ShowWarning("chr->mmo_char_fromsql: ignoring invalid hotkey (hotkey=%d,type=%u,id=%u,lv=%u) of character %s (AID=%d,CID=%d)\n", hotkey_num, tmp_hotkey.type, tmp_hotkey.id, tmp_hotkey.lv, p->name, p->account_id, p->char_id); } strcat(t_msg, " hotkeys"); #endif @@ -1439,7 +1423,7 @@ int char_mmo_char_fromsql(int char_id, struct mmo_charstatus* p, bool load_every if( opt & OPT_SHOW_EQUIP ) p->show_equip = true; - cp = idb_ensure(char_db_, char_id, char_create_charstatus); + cp = idb_ensure(char_db_, char_id, chr->create_charstatus); memcpy(cp, p, sizeof(struct mmo_charstatus)); return 1; } @@ -1456,10 +1440,11 @@ int char_mmo_char_sql_init(void) // Force all users offline in sql when starting char-server // (useful when servers crashes and don't clean the database) - char_set_all_offline_sql(); + chr->set_all_offline_sql(); return 0; } + /* [Ind/Hercules] - special thanks to Yommy for providing the packet structure/data */ bool char_char_slotchange(struct char_session_data *sd, int fd, unsigned short from, unsigned short to) { struct mmo_charstatus char_dat; @@ -1468,7 +1453,7 @@ bool char_char_slotchange(struct char_session_data *sd, int fd, unsigned short f if( from > MAX_CHARS || to > MAX_CHARS || ( sd->char_slots && to > sd->char_slots ) || sd->found_char[from] <= 0 ) return false; - if( !char_mmo_char_fromsql(sd->found_char[from], &char_dat, false) ) // Only the short data is needed. + if( !chr->mmo_char_fromsql(sd->found_char[from], &char_dat, false) ) // Only the short data is needed. return false; if( char_dat.slotchange == 0 ) @@ -1520,7 +1505,7 @@ int char_rename_char_sql(struct char_session_data *sd, int char_id) if( sd->new_name[0] == 0 ) // Not ready for rename return 2; - if( !char_mmo_char_fromsql(char_id, &char_dat, false) ) // Only the short data is needed. + if( !chr->mmo_char_fromsql(char_id, &char_dat, false) ) // Only the short data is needed. return 2; if( char_dat.rename == 0 ) @@ -1622,13 +1607,7 @@ int char_check_char_name(char * name, char * esc_name) * -5: 'Symbols in Character Names are forbidden' * char_id: Success **/ -#if PACKETVER >= 20120307 -int char_make_new_char_sql(struct char_session_data* sd, char* name_, int slot, int hair_color, int hair_style) { - int str = 1, agi = 1, vit = 1, int_ = 1, dex = 1, luk = 1; -#else int char_make_new_char_sql(struct char_session_data* sd, char* name_, int str, int agi, int vit, int int_, int dex, int luk, int slot, int hair_color, int hair_style) { -#endif - char name[NAME_LENGTH]; char esc_name[NAME_LENGTH*2+1]; int char_id, flag, k, l; @@ -1637,7 +1616,7 @@ int char_make_new_char_sql(struct char_session_data* sd, char* name_, int str, i normalize_name(name,TRIM_CHARS); SQL->EscapeStringLen(sql_handle, esc_name, name, strnlen(name, NAME_LENGTH)); - flag = char_check_char_name(name,esc_name); + flag = chr->check_char_name(name,esc_name); if( flag < 0 ) return flag; @@ -1742,7 +1721,7 @@ int char_divorce_char_sql(int partner_id1, int partner_id2) WBUFW(buf,0) = 0x2b12; WBUFL(buf,2) = partner_id1; WBUFL(buf,6) = partner_id2; - mapif_sendall(buf,10); + mapif->sendall(buf,10); return 0; } @@ -1766,7 +1745,7 @@ int char_delete_char_sql(int char_id) if( SQL_SUCCESS != SQL->NextRow(sql_handle) ) { - ShowError("char_delete_char_sql: Unable to fetch character data, deletion aborted.\n"); + ShowError("chr->delete_char_sql: Unable to fetch character data, deletion aborted.\n"); SQL->FreeResult(sql_handle); return -1; } @@ -1797,7 +1776,7 @@ int char_delete_char_sql(int char_id) /* Divorce [Wizputer] */ if( partner_id ) - char_divorce_char_sql(char_id, partner_id); + chr->divorce_char_sql(char_id, partner_id); /* De-addopt [Zephyrus] */ if( father_id || mother_id ) @@ -1813,7 +1792,7 @@ int char_delete_char_sql(int char_id) WBUFL(buf,2) = father_id; WBUFL(buf,6) = mother_id; WBUFL(buf,10) = char_id; // Baby - mapif_sendall(buf,14); + mapif->sendall(buf,14); } //Make the character leave the party [Skotlex] @@ -2033,9 +2012,10 @@ int char_mmo_char_tobuf(uint8* buffer, struct mmo_charstatus* p) { void char_mmo_char_send099d(int fd, struct char_session_data *sd) { WFIFOHEAD(fd,4 + (MAX_CHARS*MAX_CHAR_BUF)); WFIFOW(fd,0) = 0x99d; - WFIFOW(fd,2) = char_mmo_chars_fromsql(sd, WFIFOP(fd,4)) + 4; + WFIFOW(fd,2) = chr->mmo_chars_fromsql(sd, WFIFOP(fd,4)) + 4; WFIFOSET(fd,WFIFOW(fd,2)); } + /* Sends character ban list */ /* Made Possible by Yommy~! <3 */ void char_mmo_char_send_ban_list(int fd, struct char_session_data *sd) { @@ -2074,7 +2054,7 @@ void char_mmo_char_send_ban_list(int fd, struct char_session_data *sd) { WFIFOSET(fd, WFIFOW(fd, 2)); } } -int char_mmo_char_send_characters(int fd, struct char_session_data* sd); + //---------------------------------------- // [Ind/Hercules] notify client about charselect window data //---------------------------------------- @@ -2112,7 +2092,7 @@ int char_mmo_char_send_characters(int fd, struct char_session_data* sd) WFIFOB(fd,6) = MAX_CHARS; // Premium slots. AKA any existent chars past sd->char_slots but within MAX_CHARS will show a 'Premium Service' in red #endif memset(WFIFOP(fd,4 + offset), 0, 20); // unknown bytes - j+=char_mmo_chars_fromsql(sd, WFIFOP(fd,j)); + j+=chr->mmo_chars_fromsql(sd, WFIFOP(fd,j)); WFIFOW(fd,2) = j; // packet len WFIFOSET(fd,j); @@ -2224,44 +2204,40 @@ static void char_auth_ok(int fd, struct char_session_data *sd) { //Character already online. KICK KICK KICK mapif_disconnectplayer(server[character->server].fd, character->account_id, character->char_id, 2); if (character->waiting_disconnect == INVALID_TIMER) - character->waiting_disconnect = timer->add(timer->gettick()+20000, char_waiting_disconnect, character->account_id, 0); + character->waiting_disconnect = timer->add(timer->gettick()+20000, chr->waiting_disconnect, character->account_id, 0); if (character) character->pincode_enable = -1; - char_authfail_fd(fd, 8); + chr->authfail_fd(fd, 8); return; } if (character->fd >= 0 && character->fd != fd) { //There's already a connection from this account that hasn't picked a char yet. - char_authfail_fd(fd, 8); + chr->authfail_fd(fd, 8); return; } character->fd = fd; } if (login_fd > 0) { - char_request_account_data(sd->account_id); + chr->request_account_data(sd->account_id); } // mark session as 'authed' sd->auth = true; // set char online on charserver - char_set_char_charselect(sd->account_id); + chr->set_char_charselect(sd->account_id); // continues when account data is received... } -int char_send_accounts_tologin(int tid, int64 tick, int id, intptr_t data); -void mapif_server_reset(int id); - - /// Resets all the data. void loginif_reset(void) { int id; // TODO kick everyone out and reset everything or wait for connect and try to reacquire locks [FlavioJS] for( id = 0; id < ARRAYLENGTH(server); ++id ) - mapif_server_reset(id); + mapif->server_reset(id); flush_fifos(); exit(EXIT_FAILURE); } @@ -2290,10 +2266,10 @@ void loginif_on_ready(void) { int i; - loginif_check_shutdown(); + loginif->check_shutdown(); //Send online accounts to login server. - char_send_accounts_tologin(INVALID_TIMER, timer->gettick(), 0, 0); + chr->send_accounts_tologin(INVALID_TIMER, timer->gettick(), 0, 0); // if no map-server already connected, display a message... ARR_FIND( 0, ARRAYLENGTH(server), i, server[i].fd > 0 && server[i].map ); @@ -2320,7 +2296,7 @@ int char_parse_fromlogin_connection_state(int fd) return 1; } else { ShowStatus("Connected to login-server (connection #%d).\n", fd); - loginif_on_ready(); + loginif->on_ready(); } RFIFOSKIP(fd,3); return 0; @@ -2361,18 +2337,18 @@ void char_parse_fromlogin_auth_state(int fd) case 0:// ok /* restrictions apply */ if( char_server_type == CST_MAINTENANCE && group_id < char_maintenance_min_group_id ) { - char_auth_error(client_fd, 0); + chr->auth_error(client_fd, 0); break; } /* the client will already deny this request, this check is to avoid someone bypassing. */ if( char_server_type == CST_PAYING && (time_t)expiration_time < time(NULL) ) { - char_auth_error(client_fd, 0); + chr->auth_error(client_fd, 0); break; } - char_auth_ok(client_fd, sd); + chr->auth_ok(client_fd, sd); break; case 1:// auth failed - char_auth_error(client_fd, 0); + chr->auth_error(client_fd, 0); break; } } @@ -2397,21 +2373,21 @@ void char_parse_fromlogin_account_data(int fd) safestrncpy(sd->birthdate, (const char*)RFIFOP(fd,52), sizeof(sd->birthdate)); safestrncpy(sd->pincode, (const char*)RFIFOP(fd,63), sizeof(sd->pincode)); sd->pincode_change = RFIFOL(fd,68); - // continued from char_auth_ok... + // continued from chr->auth_ok... if( (max_connect_user == 0 && sd->group_id != gm_allow_group) || - ( max_connect_user > 0 && char_count_users() >= max_connect_user && sd->group_id != gm_allow_group ) ) { + ( max_connect_user > 0 && chr->count_users() >= max_connect_user && sd->group_id != gm_allow_group ) ) { // refuse connection (over populated) - char_auth_error(i, 0); + chr->auth_error(i, 0); } else { // send characters to player #if PACKETVER >= 20130000 - char_mmo_char_send_slots_info(i, sd); - char_mmo_char_send_characters(i, sd); + chr->mmo_char_send_slots_info(i, sd); + chr->mmo_char_send_characters(i, sd); #else - char_mmo_char_send_characters(i, sd); + chr->mmo_char_send_characters(i, sd); #endif #if PACKETVER >= 20060819 - char_mmo_char_send_ban_list(i, sd); + chr->mmo_char_send_ban_list(i, sd); #endif #if PACKETVER >= 20110309 pincode->handle(i, sd); @@ -2434,7 +2410,7 @@ void char_changesex(int account_id, int sex) WBUFW(buf,0) = 0x2b0d; WBUFL(buf,2) = account_id; WBUFB(buf,6) = sex; - mapif_sendall(buf, 7); + mapif->sendall(buf, 7); } int char_parse_fromlogin_changesex_reply(int fd) @@ -2514,17 +2490,17 @@ int char_parse_fromlogin_changesex_reply(int fd) SQL->FreeResult(sql_handle); // disconnect player if online on char-server - char_disconnect_player(acc); + chr->disconnect_player(acc); // notify all mapservers about this change - char_changesex(acc, sex); + chr->changesex(acc, sex); return 0; } void char_parse_fromlogin_account_reg2(int fd) { //Receive account_reg2 registry, forward to map servers. - mapif_sendall(RFIFOP(fd, 0), RFIFOW(fd,2)); + mapif->sendall(RFIFOP(fd, 0), RFIFOW(fd,2)); RFIFOSKIP(fd, RFIFOW(fd,2)); } @@ -2536,14 +2512,14 @@ void mapif_ban(int id, unsigned int flag, int status) WBUFL(buf,2) = id; WBUFB(buf,6) = flag; // 0: change of status, 1: ban WBUFL(buf,7) = status; // status or final date of a banishment - mapif_sendall(buf, 11); + mapif->sendall(buf, 11); } void char_parse_fromlogin_ban(int fd) { - mapif_ban(RFIFOL(fd,2), RFIFOB(fd,6), RFIFOL(fd,7)); + mapif->ban(RFIFOL(fd,2), RFIFOB(fd,6), RFIFOL(fd,7)); // disconnect player if online on char-server - char_disconnect_player(RFIFOL(fd,2)); + chr->disconnect_player(RFIFOL(fd,2)); RFIFOSKIP(fd,11); } @@ -2558,7 +2534,7 @@ void char_parse_fromlogin_kick(int fd) { //Kick it from the map server it is on. mapif_disconnectplayer(server[character->server].fd, character->account_id, character->char_id, 2); if (character->waiting_disconnect == INVALID_TIMER) - character->waiting_disconnect = timer->add(timer->gettick()+AUTH_TIMEOUT, char_waiting_disconnect, character->account_id, 0); + character->waiting_disconnect = timer->add(timer->gettick()+AUTH_TIMEOUT, chr->waiting_disconnect, character->account_id, 0); } else {// Manual kick from char server. @@ -2567,11 +2543,11 @@ void char_parse_fromlogin_kick(int fd) ARR_FIND( 0, sockt->fd_max, i, session[i] && (tsd = (struct char_session_data*)session[i]->session_data) && tsd->account_id == aid ); if( i < sockt->fd_max ) { - char_authfail_fd(i, 2); + chr->authfail_fd(i, 2); set_eof(i); } else // still moving to the map-server - char_set_char_offline(-1, aid); + chr->set_char_offline(-1, aid); } } idb_remove(auth_db, aid);// reject auth attempts from map-server @@ -2591,7 +2567,7 @@ void char_parse_fromlogin_update_ip(int fd) uint32 new_ip = 0; WBUFW(buf,0) = 0x2b1e; - mapif_sendall(buf, 2); + mapif->sendall(buf, 2); new_ip = host2ip(login_ip_str); if (new_ip && new_ip != login_ip) @@ -2603,7 +2579,7 @@ void char_parse_fromlogin_update_ip(int fd) char_ip = new_ip; ShowInfo("Updating IP for [%s].\n", char_ip_str); // notify login server about the change - char_update_ip(fd); + chr->update_ip(fd); } RFIFOSKIP(fd,2); } @@ -2627,7 +2603,7 @@ void char_parse_fromlogin_accinfo2_ok(int fd) int char_parse_fromlogin(int fd) { // only process data from the login-server if( fd != login_fd ) { - ShowDebug("char_parse_fromlogin: Disconnecting invalid session #%d (is not the login-server)\n", fd); + ShowDebug("chr->parse_fromlogin: Disconnecting invalid session #%d (is not the login-server)\n", fd); do_close(fd); return 0; } @@ -2635,14 +2611,14 @@ int char_parse_fromlogin(int fd) { if( session[fd]->flag.eof ) { do_close(fd); login_fd = -1; - loginif_on_disconnect(); + loginif->on_disconnect(); return 0; } else if ( session[fd]->flag.ping ) {/* we've reached stall time */ if( DIFF_TICK(sockt->last_tick, session[fd]->rdata_tick) > (sockt->stall_time * 2) ) {/* we can't wait any longer */ set_eof(fd); return 0; } else if( session[fd]->flag.ping != 2 ) { /* we haven't sent ping out yet */ - char_ping_login_server(fd); + chr->ping_login_server(fd); session[fd]->flag.ping = 2; } } @@ -2662,7 +2638,7 @@ int char_parse_fromlogin(int fd) { case 0x2711: if (RFIFOREST(fd) < 3) return 0; - if (char_parse_fromlogin_connection_state(fd)) + if (chr->parse_fromlogin_connection_state(fd)) return 0; break; @@ -2671,7 +2647,7 @@ int char_parse_fromlogin(int fd) { if (RFIFOREST(fd) < 33) return 0; { - char_parse_fromlogin_auth_state(fd); + chr->parse_fromlogin_auth_state(fd); } break; @@ -2679,7 +2655,7 @@ int char_parse_fromlogin(int fd) { { if (RFIFOREST(fd) < 72) return 0; - char_parse_fromlogin_account_data(fd); + chr->parse_fromlogin_account_data(fd); } break; @@ -2687,7 +2663,7 @@ int char_parse_fromlogin(int fd) { case 0x2718: if (RFIFOREST(fd) < 2) return 0; - char_parse_fromlogin_login_pong(fd); + chr->parse_fromlogin_login_pong(fd); break; // changesex reply @@ -2695,7 +2671,7 @@ int char_parse_fromlogin(int fd) { if (RFIFOREST(fd) < 7) return 0; { - if (char_parse_fromlogin_changesex_reply(fd)) + if (chr->parse_fromlogin_changesex_reply(fd)) return 0; } break; @@ -2704,14 +2680,14 @@ int char_parse_fromlogin(int fd) { case 0x3804: if (RFIFOREST(fd) < 4 || RFIFOREST(fd) < RFIFOW(fd,2)) return 0; - char_parse_fromlogin_account_reg2(fd); + chr->parse_fromlogin_account_reg2(fd); break; // State change of account/ban notification (from login-server) case 0x2731: if (RFIFOREST(fd) < 11) return 0; - char_parse_fromlogin_ban(fd); + chr->parse_fromlogin_ban(fd); break; // Login server request to kick a character out. [Skotlex] @@ -2719,14 +2695,14 @@ int char_parse_fromlogin(int fd) { if (RFIFOREST(fd) < 6) return 0; { - char_parse_fromlogin_kick(fd); + chr->parse_fromlogin_kick(fd); } break; // ip address update signal from login server case 0x2735: { - char_parse_fromlogin_update_ip(fd); + chr->parse_fromlogin_update_ip(fd); } break; @@ -2734,14 +2710,14 @@ int char_parse_fromlogin(int fd) { if (RFIFOREST(fd) < 18) return 0; - char_parse_fromlogin_accinfo2_failed(fd); + chr->parse_fromlogin_accinfo2_failed(fd); break; case 0x2737: // Successful accinfo lookup to forward to mapserver if (RFIFOREST(fd) < 183) return 0; - char_parse_fromlogin_accinfo2_ok(fd); + chr->parse_fromlogin_accinfo2_ok(fd); break; default: @@ -2755,17 +2731,15 @@ int char_parse_fromlogin(int fd) { return 0; } -int char_check_connect_login_server(int tid, int64 tick, int id, intptr_t data); - void do_init_loginif(void) { // establish char-login connection if not present - timer->add_func_list(char_check_connect_login_server, "char_check_connect_login_server"); - timer->add_interval(timer->gettick() + 1000, char_check_connect_login_server, 0, 0, 10 * 1000); + timer->add_func_list(chr->check_connect_login_server, "chr->check_connect_login_server"); + timer->add_interval(timer->gettick() + 1000, chr->check_connect_login_server, 0, 0, 10 * 1000); // send a list of all online account IDs to login server - timer->add_func_list(char_send_accounts_tologin, "char_send_accounts_tologin"); - timer->add_interval(timer->gettick() + 1000, char_send_accounts_tologin, 0, 0, 3600 * 1000); //Sync online accounts every hour + timer->add_func_list(chr->send_accounts_tologin, "chr->send_accounts_tologin"); + timer->add_interval(timer->gettick() + 1000, chr->send_accounts_tologin, 0, 0, 3600 * 1000); //Sync online accounts every hour } void do_final_loginif(void) @@ -2789,8 +2763,9 @@ int char_request_accreg2(int account_id, int char_id) } return 0; } + /** - * Handles global account reg saving that continues with char_global_accreg_to_login_add and global_accreg_to_send + * Handles global account reg saving that continues with chr->global_accreg_to_login_add and global_accreg_to_send **/ void char_global_accreg_to_login_start (int account_id, int char_id) { WFIFOHEAD(login_fd, 60000 + 300); @@ -2800,14 +2775,16 @@ void char_global_accreg_to_login_start (int account_id, int char_id) { WFIFOL(login_fd,8) = char_id; WFIFOW(login_fd,12) = 0;/* count */ } + /** - * Completes global account reg saving that starts char_global_accreg_to_login_start and continues with char_global_accreg_to_login_add + * Completes global account reg saving that starts chr->global_accreg_to_login_start and continues with chr->global_accreg_to_login_add **/ void char_global_accreg_to_login_send (void) { WFIFOSET(login_fd, WFIFOW(login_fd,2)); } + /** - * Handles global account reg saving that starts char_global_accreg_to_login_start and ends with global_accreg_to_send + * Handles global account reg saving that starts chr->global_accreg_to_login_start and ends with global_accreg_to_send **/ void char_global_accreg_to_login_add (const char *key, unsigned int index, intptr_t val, bool is_string) { int nlen = WFIFOW(login_fd, 2); @@ -2855,10 +2832,11 @@ void char_global_accreg_to_login_add (const char *key, unsigned int index, intpt WFIFOW(login_fd, 2) = nlen; if( WFIFOW(login_fd, 2) > 60000 ) { int account_id = WFIFOL(login_fd,4), char_id = WFIFOL(login_fd,8); - char_global_accreg_to_login_send(); - char_global_accreg_to_login_start(account_id,char_id);/* prepare next */ + chr->global_accreg_to_login_send(); + chr->global_accreg_to_login_start(account_id,char_id);/* prepare next */ } } + void char_read_fame_list(void) { int i; char* data; @@ -2945,9 +2923,9 @@ int char_send_fame_list(int fd) { WBUFW(buf, 2) = len; if (fd != -1) - mapif_send(fd, buf, len); + mapif->send(fd, buf, len); else - mapif_sendall(buf, len); + mapif->sendall(buf, len); return 0; } @@ -2958,7 +2936,7 @@ void char_update_fame_list(int type, int index, int fame) { WBUFB(buf,2) = type; WBUFB(buf,3) = index; WBUFL(buf,4) = fame; - mapif_sendall(buf, 8); + mapif->sendall(buf, 8); } //Loads a character's name and stores it in the buffer given (must be NAME_LENGTH in size) @@ -2983,9 +2961,6 @@ int char_loadName(int char_id, char* name) return 0; } -int char_search_mapserver(unsigned short map, uint32 ip, uint16 port); - - /// Initializes a server structure. void mapif_server_init(int id) { @@ -2993,7 +2968,6 @@ void mapif_server_init(int id) server[id].fd = -1; } - /// Destroys a server structure. void mapif_server_destroy(int id) { @@ -3021,21 +2995,20 @@ void mapif_server_reset(int id) 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)); + mapif->sendallwos(fd, buf, WBUFW(buf,2)); } if( SQL_ERROR == SQL->Query(sql_handle, "DELETE FROM `%s` WHERE `index`='%d'", ragsrvinfo_db, server[id].fd) ) Sql_ShowDebug(sql_handle); - online_char_db->foreach(online_char_db,char_db_setoffline,id); //Tag relevant chars as 'in disconnected' server. - mapif_server_destroy(id); - mapif_server_init(id); + online_char_db->foreach(online_char_db,chr->db_setoffline,id); //Tag relevant chars as 'in disconnected' server. + mapif->server_destroy(id); + mapif->server_init(id); } - /// Called when the connection to a Map Server is disconnected. void mapif_on_disconnect(int id) { ShowStatus("Map-server #%d has disconnected.\n", id); - mapif_server_reset(id); + mapif->server_reset(id); } void mapif_on_parse_accinfo(int account_id, int u_fd, int u_aid, int u_group, int map_fd) { @@ -3094,7 +3067,7 @@ void char_send_maps(int fd, int id, int j) 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)); + mapif->sendallwos(fd, buf, WBUFW(buf,2)); } // Transmitting the maps of the other map-servers to the new map-server for(x = 0; x < ARRAYLENGTH(server); x++) { @@ -3135,9 +3108,9 @@ void char_parse_frommap_map_names(int fd, int id) ShowStatus("Map-server %d loading complete.\n", id); // send name for wisp to player - char_map_received_ok(fd); - char_send_fame_list(fd); //Send fame list. - char_send_maps(fd, id, j); + chr->map_received_ok(fd); + chr->send_fame_list(fd); //Send fame list. + chr->send_maps(fd, id, j); RFIFOSKIP(fd,RFIFOW(fd,2)); } @@ -3200,7 +3173,7 @@ void char_parse_frommap_request_scdata(int fd) #ifdef ENABLE_SC_SAVING int aid = RFIFOL(fd,2); int cid = RFIFOL(fd,6); - char_send_scdata(fd, aid, cid); + chr->send_scdata(fd, aid, cid); #endif RFIFOSKIP(fd, 10); } @@ -3221,12 +3194,12 @@ void char_parse_frommap_set_users(int fd, int id) struct online_char_data* character; server[id].users = RFIFOW(fd,4); - online_char_db->foreach(online_char_db,char_db_setoffline,id); //Set all chars from this server as 'unknown' + online_char_db->foreach(online_char_db,chr->db_setoffline,id); //Set all chars from this server as 'unknown' int i; 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, char_create_online_char_data); + character = idb_ensure(online_char_db, aid, chr->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", @@ -3266,16 +3239,16 @@ void char_parse_frommap_save_character(int fd, int id) { struct mmo_charstatus char_dat; memcpy(&char_dat, RFIFOP(fd,13), sizeof(struct mmo_charstatus)); - char_mmo_char_tosql(cid, &char_dat); + chr->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-existing/offline character (%d:%d).\n", aid, cid); - char_set_char_online(id, cid, aid); + chr->set_char_online(id, cid, aid); } if (RFIFOB(fd,12)) { //Flag, set character offline after saving. [Skotlex] - char_set_char_offline(cid, aid); - char_save_character_ack(fd, aid, cid); + chr->set_char_offline(cid, aid); + chr->save_character_ack(fd, aid, cid); } RFIFOSKIP(fd,size); } @@ -3302,7 +3275,7 @@ void char_parse_frommap_char_select_req(int fd) if( runflag != CHARSERVER_ST_RUNNING ) { - char_select_ack(fd, account_id, 0); + chr->select_ack(fd, account_id, 0); } else { @@ -3323,8 +3296,8 @@ void char_parse_frommap_char_select_req(int fd) idb_put(auth_db, account_id, node); //Set char to "@ char select" in online db [Kevin] - char_set_char_charselect(account_id); - char_select_ack(fd, account_id, 1); + chr->set_char_charselect(account_id); + chr->select_ack(fd, account_id, 1); } } @@ -3343,14 +3316,14 @@ void char_parse_frommap_change_map_server(int fd) int map_id, map_fd = -1; struct mmo_charstatus* char_data; - map_id = char_search_mapserver(RFIFOW(fd,18), ntohl(RFIFOL(fd,24)), ntohs(RFIFOW(fd,28))); //Locate mapserver by ip and port. + map_id = chr->search_mapserver(RFIFOW(fd,18), ntohl(RFIFOL(fd,24)), ntohs(RFIFOW(fd,28))); //Locate mapserver by ip and port. if (map_id >= 0) map_fd = server[map_id].fd; //Char should just had been saved before this packet, so this should be safe. [Skotlex] char_data = (struct mmo_charstatus*)uidb_get(char_db_,RFIFOL(fd,14)); if (char_data == NULL) { //Really shouldn't happen. struct mmo_charstatus char_dat; - char_mmo_char_fromsql(RFIFOL(fd,14), &char_dat, true); + chr->mmo_char_fromsql(RFIFOL(fd,14), &char_dat, true); char_data = (struct mmo_charstatus*)uidb_get(char_db_,RFIFOL(fd,14)); } @@ -3380,14 +3353,14 @@ void char_parse_frommap_change_map_server(int fd) node->changing_mapservers = 1; idb_put(auth_db, RFIFOL(fd,2), node); - data = idb_ensure(online_char_db, RFIFOL(fd,2), char_create_online_char_data); + data = idb_ensure(online_char_db, RFIFOL(fd,2), chr->create_online_char_data); data->char_id = char_data->char_id; data->server = map_id; //Update server where char is. //Reply with an ack. - char_change_map_server_ack(fd, RFIFOP(fd,2), true); + chr->change_map_server_ack(fd, RFIFOP(fd,2), true); } else { //Reply with nak - char_change_map_server_ack(fd, RFIFOP(fd,2), false); + chr->change_map_server_ack(fd, RFIFOP(fd,2), false); } RFIFOSKIP(fd,39); } @@ -3408,13 +3381,13 @@ void char_char_name_ack(int fd, int char_id) WFIFOHEAD(fd,30); WFIFOW(fd,0) = 0x2b09; WFIFOL(fd,2) = char_id; - char_loadName(char_id, (char*)WFIFOP(fd,6)); + chr->loadName(char_id, (char*)WFIFOP(fd,6)); WFIFOSET(fd,30); } void char_parse_frommap_char_name_request(int fd) { - char_char_name_ack(fd, RFIFOL(fd,2)); + chr->char_name_ack(fd, RFIFOL(fd,2)); RFIFOSKIP(fd,6); } @@ -3475,7 +3448,7 @@ void mapif_char_ban(int char_id, time_t timestamp) WBUFL(buf,2) = char_id; WBUFB(buf,6) = 2; WBUFL(buf,7) = (unsigned int)timestamp; - mapif_sendall(buf, 11); + mapif->sendall(buf, 11); } void char_ban(int account_id, int char_id, time_t *unban_time, short year, short month, short day, short hour, short minute, short second) @@ -3513,9 +3486,9 @@ void char_ban(int account_id, int char_id, time_t *unban_time, short year, short // condition applies; send to all map-servers to disconnect the player if( timestamp > time(NULL) ) { - mapif_char_ban(char_id, timestamp); + mapif->char_ban(char_id, timestamp); // disconnect player if online on char-server - char_disconnect_player(account_id); + chr->disconnect_player(account_id); } } @@ -3582,28 +3555,28 @@ void char_parse_frommap_change_account(int fd) else { switch( type ) { case 1: // block - loginif_block_account(account_id, 5); + loginif->block_account(account_id, 5); break; case 2: // ban - loginif_ban_account(account_id, year, month, day, hour, minute, second); + loginif->ban_account(account_id, year, month, day, hour, minute, second); break; case 3: // unblock - loginif_block_account(account_id, 0); + loginif->block_account(account_id, 0); break; case 4: // unban - loginif_unban_account(account_id); + loginif->unban_account(account_id); break; case 5: // changesex - loginif_changesex(account_id); + loginif->changesex(account_id); break; case 6: //char ban /* handled by char server, so no redirection */ { - char_ban(account_id, char_id, &unban_time, year, month, day, hour, minute, second); + chr->ban(account_id, char_id, &unban_time, year, month, day, hour, minute, second); } break; case 7: //char unban - char_unban(char_id, &result); + chr->unban(char_id, &result); break; } @@ -3614,7 +3587,7 @@ void char_parse_frommap_change_account(int fd) // send answer if a player ask, not if the server ask if( acc != -1 && type != 5 ) { // Don't send answer for changesex - char_ask_name_ack(fd, acc, name, type, result); + chr->ask_name_ack(fd, acc, name, type, result); } } @@ -3643,7 +3616,7 @@ void char_parse_frommap_fame_list(int fd) else if( fame_pos == player_pos ) { // same position list[player_pos].fame = fame; - char_update_fame_list(type, player_pos, fame); + chr->update_fame_list(type, player_pos, fame); } else { // move in the list if( player_pos == size ) { @@ -3651,7 +3624,7 @@ void char_parse_frommap_fame_list(int fd) ARR_MOVE(size - 1, fame_pos, list, struct fame_list); list[fame_pos].id = cid; list[fame_pos].fame = fame; - char_loadName(cid, list[fame_pos].name); + chr->loadName(cid, list[fame_pos].name); } else { // already in the list if( fame_pos == size ) @@ -3659,7 +3632,7 @@ void char_parse_frommap_fame_list(int fd) ARR_MOVE(player_pos, fame_pos, list, struct fame_list); list[fame_pos].fame = fame; } - char_send_fame_list(-1); + chr->send_fame_list(-1); } RFIFOSKIP(fd,11); @@ -3667,7 +3640,7 @@ void char_parse_frommap_fame_list(int fd) void char_parse_frommap_divorce_char(int fd) { - char_divorce_char_sql(RFIFOL(fd,2), RFIFOL(fd,6)); + chr->divorce_char_sql(RFIFOL(fd,2), RFIFOL(fd,6)); RFIFOSKIP(fd,10); } @@ -3687,26 +3660,26 @@ void char_parse_frommap_ragsrvinfo(int fd) void char_parse_frommap_set_char_offline(int fd) { - char_set_char_offline(RFIFOL(fd,2),RFIFOL(fd,6)); + chr->set_char_offline(RFIFOL(fd,2),RFIFOL(fd,6)); RFIFOSKIP(fd,10); } void char_parse_frommap_set_all_offline(int fd, int id) { - char_set_all_offline(id); + chr->set_all_offline(id); RFIFOSKIP(fd,2); } void char_parse_frommap_set_char_online(int fd, int id) { - char_set_char_online(id, RFIFOL(fd,2),RFIFOL(fd,6)); + chr->set_char_online(id, RFIFOL(fd,2),RFIFOL(fd,6)); RFIFOSKIP(fd,10); } void char_parse_frommap_build_fame_list(int fd) { - char_read_fame_list(); - char_send_fame_list(-1); + chr->read_fame_list(); + chr->send_fame_list(-1); RFIFOSKIP(fd,2); } @@ -3754,7 +3727,7 @@ void char_send_pong(int fd) void char_parse_frommap_ping(int fd) { - char_send_pong(fd); + chr->send_pong(fd); RFIFOSKIP(fd,2); } @@ -3812,15 +3785,15 @@ void char_parse_frommap_auth_request(int fd, int id) struct mmo_charstatus* cd = (struct mmo_charstatus*)uidb_get(char_db_,char_id); if( cd == NULL ) { //Really shouldn't happen. - char_mmo_char_fromsql(char_id, &char_dat, true); + chr->mmo_char_fromsql(char_id, &char_dat, true); cd = (struct mmo_charstatus*)uidb_get(char_db_,char_id); } if( runflag == CHARSERVER_ST_RUNNING && cd && standalone ) { cd->sex = sex; - char_map_auth_ok(fd, account_id, NULL, cd); - char_set_char_online(id, char_id, account_id); + chr->map_auth_ok(fd, account_id, NULL, cd); + chr->set_char_online(id, char_id, account_id); return; } @@ -3836,14 +3809,14 @@ void char_parse_frommap_auth_request(int fd, int id) if( cd->sex == 99 ) cd->sex = sex; - char_map_auth_ok(fd, account_id, node, cd); + chr->map_auth_ok(fd, account_id, node, cd); // only use the auth once and mark user online idb_remove(auth_db, account_id); - char_set_char_online(id, char_id, account_id); + chr->set_char_online(id, char_id, account_id); } else {// auth failed - char_map_auth_failed(fd, account_id, char_id, login_id1, sex, ip); + chr->map_auth_failed(fd, account_id, char_id, login_id1, sex, ip); } } @@ -3925,14 +3898,14 @@ int char_parse_frommap(int fd) ARR_FIND( 0, ARRAYLENGTH(server), id, server[id].fd == fd ); if( id == ARRAYLENGTH(server) ) {// not a map server - ShowDebug("char_parse_frommap: Disconnecting invalid session #%d (is not a map-server)\n", fd); + ShowDebug("chr->parse_frommap: Disconnecting invalid session #%d (is not a map-server)\n", fd); do_close(fd); return 0; } if( session[fd]->flag.eof ) { do_close(fd); server[id].fd = -1; - mapif_on_disconnect(id); + mapif->on_disconnect(id); return 0; } @@ -3950,39 +3923,39 @@ int char_parse_frommap(int fd) case 0x2b0a: if( RFIFOREST(fd) < RFIFOW(fd, 2) ) return 0; - char_parse_frommap_datasync(fd); + chr->parse_frommap_datasync(fd); break; case 0x2b0b: if( RFIFOREST(fd) < RFIFOW(fd, 2) ) return 0; - char_parse_frommap_skillid2idx(fd); + chr->parse_frommap_skillid2idx(fd); break; case 0x2afa: // Receiving map names list from the map-server if (RFIFOREST(fd) < 4 || RFIFOREST(fd) < RFIFOW(fd,2)) return 0; - char_parse_frommap_map_names(fd, id); + chr->parse_frommap_map_names(fd, id); break; case 0x2afc: //Packet command is now used for sc_data request. [Skotlex] if (RFIFOREST(fd) < 10) return 0; { - char_parse_frommap_request_scdata(fd); + chr->parse_frommap_request_scdata(fd); } break; case 0x2afe: //set MAP user count if (RFIFOREST(fd) < 4) return 0; - char_parse_frommap_set_users_count(fd, id); + chr->parse_frommap_set_users_count(fd, id); break; case 0x2aff: //set MAP users if (RFIFOREST(fd) < 6 || RFIFOREST(fd) < RFIFOW(fd,2)) return 0; { - char_parse_frommap_set_users(fd, id); + chr->parse_frommap_set_users(fd, id); } break; @@ -3990,7 +3963,7 @@ int char_parse_frommap(int fd) if (RFIFOREST(fd) < 4 || RFIFOREST(fd) < RFIFOW(fd,2)) return 0; { - char_parse_frommap_save_character(fd, id); + chr->parse_frommap_save_character(fd, id); } break; @@ -3999,7 +3972,7 @@ int char_parse_frommap(int fd) if( RFIFOREST(fd) < 22 ) return 0; { - char_parse_frommap_char_select_req(fd); + chr->parse_frommap_char_select_req(fd); } break; @@ -4007,7 +3980,7 @@ int char_parse_frommap(int fd) if (RFIFOREST(fd) < 39) return 0; { - char_parse_frommap_change_map_server(fd); + chr->parse_frommap_change_map_server(fd); } break; @@ -4015,7 +3988,7 @@ int char_parse_frommap(int fd) if (RFIFOREST(fd) < 10) return 0; { - char_parse_frommap_remove_friend(fd); + chr->parse_frommap_remove_friend(fd); } break; @@ -4023,20 +3996,20 @@ int char_parse_frommap(int fd) if (RFIFOREST(fd) < 6) return 0; - char_parse_frommap_char_name_request(fd); + chr->parse_frommap_char_name_request(fd); break; case 0x2b0c: // Map server send information to change an email of an account -> login-server if (RFIFOREST(fd) < 86) return 0; - char_parse_frommap_change_email(fd); + chr->parse_frommap_change_email(fd); break; case 0x2b0e: // Request from map-server to change an account's or character's status (accounts will just be forwarded to login server) if (RFIFOREST(fd) < 44) return 0; { - char_parse_frommap_change_account(fd); + chr->parse_frommap_change_account(fd); } break; @@ -4044,7 +4017,7 @@ int char_parse_frommap(int fd) if (RFIFOREST(fd) < 11) return 0; { - char_parse_frommap_fame_list(fd); + chr->parse_frommap_fame_list(fd); } break; @@ -4053,49 +4026,49 @@ int char_parse_frommap(int fd) if( RFIFOREST(fd) < 10 ) return 0; - char_parse_frommap_divorce_char(fd); + chr->parse_frommap_divorce_char(fd); break; case 0x2b16: // Receive rates [Wizputer] if( RFIFOREST(fd) < 14 ) return 0; { - char_parse_frommap_ragsrvinfo(fd); + chr->parse_frommap_ragsrvinfo(fd); } break; case 0x2b17: // Character disconnected set online 0 [Wizputer] if (RFIFOREST(fd) < 6) return 0; - char_parse_frommap_set_char_offline(fd); + chr->parse_frommap_set_char_offline(fd); break; case 0x2b18: // Reset all chars to offline [Wizputer] - char_parse_frommap_set_all_offline(fd, id); + chr->parse_frommap_set_all_offline(fd, id); break; case 0x2b19: // Character set online [Wizputer] if (RFIFOREST(fd) < 10) return 0; - char_parse_frommap_set_char_online(fd, id); + chr->parse_frommap_set_char_online(fd, id); break; case 0x2b1a: // Build and send fame ranking lists [DracoRPG] if (RFIFOREST(fd) < 2) return 0; - char_parse_frommap_build_fame_list(fd); + chr->parse_frommap_build_fame_list(fd); break; case 0x2b1c: //Request to save status change data. [Skotlex] if (RFIFOREST(fd) < 4 || RFIFOREST(fd) < RFIFOW(fd,2)) return 0; { - char_parse_frommap_save_status_change_data(fd); + chr->parse_frommap_save_status_change_data(fd); } break; case 0x2b23: // map-server alive packet - char_parse_frommap_ping(fd); + chr->parse_frommap_ping(fd); break; case 0x2b26: // auth request from map-server @@ -4103,20 +4076,20 @@ int char_parse_frommap(int fd) return 0; { - char_parse_frommap_auth_request(fd, id); + chr->parse_frommap_auth_request(fd, id); } break; case 0x2736: // ip address update if (RFIFOREST(fd) < 6) return 0; - char_parse_frommap_update_ip(fd, id); + chr->parse_frommap_update_ip(fd, id); break; case 0x3008: if( RFIFOREST(fd) < RFIFOW(fd,4) ) return 0;/* packet wasn't fully received yet (still fragmented) */ else { - char_parse_frommap_request_stats_report(fd); + chr->parse_frommap_request_stats_report(fd); } break; @@ -4125,7 +4098,7 @@ int char_parse_frommap(int fd) if( RFIFOREST(fd) < 28 ) return 0; else { - char_parse_frommap_scdata_update(fd); + chr->parse_frommap_scdata_update(fd); } break; @@ -4134,7 +4107,7 @@ int char_parse_frommap(int fd) if( RFIFOREST(fd) < 12 ) return 0; else { - char_parse_frommap_scdata_delete(fd); + chr->parse_frommap_scdata_delete(fd); } break; @@ -4161,14 +4134,14 @@ void do_init_mapif(void) { int i; for( i = 0; i < ARRAYLENGTH(server); ++i ) - mapif_server_init(i); + mapif->server_init(i); } void do_final_mapif(void) { int i; for( i = 0; i < ARRAYLENGTH(server); ++i ) - mapif_server_destroy(i); + mapif->server_destroy(i); } // Searches for the mapserver that has a given map (and optionally ip/port, if not -1). @@ -4238,7 +4211,6 @@ void char_delete2_ack(int fd, int char_id, uint32 result, time_t delete_date) WFIFOSET(fd,14); } - void char_delete2_accept_actual_ack(int fd, int char_id, uint32 result) { WFIFOHEAD(fd,10); @@ -4262,13 +4234,12 @@ void char_delete2_accept_ack(int fd, int char_id, uint32 result) #if PACKETVER >= 20130000 /* not sure the exact date -- must refresh or client gets stuck */ if( result == 1 ) { struct char_session_data* sd = (struct char_session_data*)session[fd]->session_data; - char_mmo_char_send099d(fd, sd); + chr->mmo_char_send099d(fd, sd); } #endif - char_delete2_accept_actual_ack(fd, char_id, result); + chr->delete2_accept_actual_ack(fd, char_id, result); } - /// @param result /// 1 (0x718): none/success, (if char id not in deletion process): An unknown error has occurred. /// 2 (0x719): A database error occurred. @@ -4282,7 +4253,6 @@ void char_delete2_cancel_ack(int fd, int char_id, uint32 result) WFIFOSET(fd,10); } - static void char_delete2_req(int fd, struct char_session_data* sd) {// CH: <0827>.W .L int char_id, party_id, guild_id, i; @@ -4294,21 +4264,21 @@ static void char_delete2_req(int fd, struct char_session_data* sd) ARR_FIND( 0, MAX_CHARS, i, sd->found_char[i] == char_id ); if( i == MAX_CHARS ) {// character not found - char_delete2_ack(fd, char_id, 3, 0); + chr->delete2_ack(fd, char_id, 3, 0); return; } if( SQL_SUCCESS != SQL->Query(sql_handle, "SELECT `delete_date` FROM `%s` WHERE `char_id`='%d'", char_db, char_id) || SQL_SUCCESS != SQL->NextRow(sql_handle) ) { Sql_ShowDebug(sql_handle); - char_delete2_ack(fd, char_id, 3, 0); + chr->delete2_ack(fd, char_id, 3, 0); return; } SQL->GetData(sql_handle, 0, &data, NULL); delete_date = strtoul(data, NULL, 10); if( delete_date ) {// character already queued for deletion - char_delete2_ack(fd, char_id, 0, 0); + chr->delete2_ack(fd, char_id, 0, 0); return; } @@ -4322,7 +4292,7 @@ static void char_delete2_req(int fd, struct char_session_data* sd) ) { Sql_ShowDebug(sql_handle); - char_delete2_ack(fd, char_id, 3, 0); + chr->delete2_ack(fd, char_id, 3, 0); return; } SQL->GetData(sql_handle, 0, &data, NULL); party_id = atoi(data); @@ -4330,13 +4300,13 @@ static void char_delete2_req(int fd, struct char_session_data* sd) if( guild_id ) { - char_delete2_ack(fd, char_id, 4, 0); + chr->delete2_ack(fd, char_id, 4, 0); return; } if( party_id ) { - char_delete2_ack(fd, char_id, 5, 0); + chr->delete2_ack(fd, char_id, 5, 0); return; } } @@ -4347,14 +4317,13 @@ static void char_delete2_req(int fd, struct char_session_data* sd) if( SQL_SUCCESS != SQL->Query(sql_handle, "UPDATE `%s` SET `delete_date`='%lu' WHERE `char_id`='%d'", char_db, (unsigned long)delete_date, char_id) ) { Sql_ShowDebug(sql_handle); - char_delete2_ack(fd, char_id, 3, 0); + chr->delete2_ack(fd, char_id, 3, 0); return; } - char_delete2_ack(fd, char_id, 1, delete_date); + chr->delete2_ack(fd, char_id, 1, delete_date); } - static void char_delete2_accept(int fd, struct char_session_data* sd) {// CH: <0829>.W .L .6B char birthdate[8+1]; @@ -4381,14 +4350,14 @@ static void char_delete2_accept(int fd, struct char_session_data* sd) ARR_FIND( 0, MAX_CHARS, i, sd->found_char[i] == char_id ); if( i == MAX_CHARS ) {// character not found - char_delete2_accept_ack(fd, char_id, 3); + chr->delete2_accept_ack(fd, char_id, 3); return; } if( SQL_SUCCESS != SQL->Query(sql_handle, "SELECT `base_level`,`delete_date` FROM `%s` WHERE `char_id`='%d'", char_db, char_id) || SQL_SUCCESS != SQL->NextRow(sql_handle) ) {// data error Sql_ShowDebug(sql_handle); - char_delete2_accept_ack(fd, char_id, 3); + chr->delete2_accept_ack(fd, char_id, 3); return; } @@ -4397,36 +4366,35 @@ static void char_delete2_accept(int fd, struct char_session_data* sd) if( !delete_date || delete_date>time(NULL) ) {// not queued or delay not yet passed - char_delete2_accept_ack(fd, char_id, 4); + chr->delete2_accept_ack(fd, char_id, 4); return; } if( strcmp(sd->birthdate+2, birthdate) ) // +2 to cut off the century {// birth date is wrong - char_delete2_accept_ack(fd, char_id, 5); + chr->delete2_accept_ack(fd, char_id, 5); return; } if( ( char_del_level > 0 && base_level >= (unsigned int)char_del_level ) || ( char_del_level < 0 && base_level <= (unsigned int)(-char_del_level) ) ) {// character level config restriction - char_delete2_accept_ack(fd, char_id, 2); + chr->delete2_accept_ack(fd, char_id, 2); return; } // success - if( char_delete_char_sql(char_id) < 0 ) + if( chr->delete_char_sql(char_id) < 0 ) { - char_delete2_accept_ack(fd, char_id, 3); + chr->delete2_accept_ack(fd, char_id, 3); return; } // refresh character list cache sd->found_char[i] = -1; - char_delete2_accept_ack(fd, char_id, 1); + chr->delete2_accept_ack(fd, char_id, 1); } - static void char_delete2_cancel(int fd, struct char_session_data* sd) {// CH: <082b>.W .L int char_id, i; @@ -4436,21 +4404,21 @@ static void char_delete2_cancel(int fd, struct char_session_data* sd) ARR_FIND( 0, MAX_CHARS, i, sd->found_char[i] == char_id ); if( i == MAX_CHARS ) {// character not found - char_delete2_cancel_ack(fd, char_id, 2); + chr->delete2_cancel_ack(fd, char_id, 2); return; } // there is no need to check, whether or not the character was // queued for deletion, as the client prints an error message by - // itself, if it was not the case (@see char_delete2_cancel_ack) + // itself, if it was not the case (@see chr->delete2_cancel_ack) if( SQL_SUCCESS != SQL->Query(sql_handle, "UPDATE `%s` SET `delete_date`='0' WHERE `char_id`='%d'", char_db, char_id) ) { Sql_ShowDebug(sql_handle); - char_delete2_cancel_ack(fd, char_id, 2); + chr->delete2_cancel_ack(fd, char_id, 2); return; } - char_delete2_cancel_ack(fd, char_id, 1); + chr->delete2_cancel_ack(fd, char_id, 1); } void char_send_account_id(int fd, int account_id) @@ -4499,10 +4467,10 @@ void char_parse_char_connect(int fd, struct char_session_data* sd, uint32 ipl) sd->auth = false; // not authed yet // send back account_id - char_send_account_id(fd, account_id); + chr->send_account_id(fd, account_id); if( runflag != CHARSERVER_ST_RUNNING ) { - char_auth_error(fd, 0); + chr->auth_error(fd, 0); return; } @@ -4516,23 +4484,23 @@ void char_parse_char_connect(int fd, struct char_session_data* sd, uint32 ipl) {// authentication found (coming from map server) /* restrictions apply */ if( char_server_type == CST_MAINTENANCE && node->group_id < char_maintenance_min_group_id ) { - char_auth_error(fd, 0); + chr->auth_error(fd, 0); return; } /* the client will already deny this request, this check is to avoid someone bypassing. */ if( char_server_type == CST_PAYING && (time_t)node->expiration_time < time(NULL) ) { - char_auth_error(fd, 0); + chr->auth_error(fd, 0); return; } idb_remove(auth_db, account_id); - char_auth_ok(fd, sd); + chr->auth_ok(fd, sd); } else {// authentication not found (coming from login server) if (login_fd > 0) { // don't send request if no login-server - loginif_auth(fd, sd, ipl); + loginif->auth(fd, sd, ipl); } else { // if no login-server, we must refuse connection - char_auth_error(fd, 0); + chr->auth_error(fd, 0); } } } @@ -4561,22 +4529,22 @@ int char_search_default_maps_mapserver(struct mmo_charstatus *cd) { int i; int j; - if ((i = char_search_mapserver((j=mapindex->name2id(MAP_PRONTERA)),-1,-1)) >= 0) { + if ((i = chr->search_mapserver((j=mapindex->name2id(MAP_PRONTERA)),-1,-1)) >= 0) { cd->last_point.x = 273; cd->last_point.y = 354; - } else if ((i = char_search_mapserver((j=mapindex->name2id(MAP_GEFFEN)),-1,-1)) >= 0) { + } else if ((i = chr->search_mapserver((j=mapindex->name2id(MAP_GEFFEN)),-1,-1)) >= 0) { cd->last_point.x = 120; cd->last_point.y = 100; - } else if ((i = char_search_mapserver((j=mapindex->name2id(MAP_MORROC)),-1,-1)) >= 0) { + } else if ((i = chr->search_mapserver((j=mapindex->name2id(MAP_MORROC)),-1,-1)) >= 0) { cd->last_point.x = 160; cd->last_point.y = 94; - } else if ((i = char_search_mapserver((j=mapindex->name2id(MAP_ALBERTA)),-1,-1)) >= 0) { + } else if ((i = chr->search_mapserver((j=mapindex->name2id(MAP_ALBERTA)),-1,-1)) >= 0) { cd->last_point.x = 116; cd->last_point.y = 57; - } else if ((i = char_search_mapserver((j=mapindex->name2id(MAP_PAYON)),-1,-1)) >= 0) { + } else if ((i = chr->search_mapserver((j=mapindex->name2id(MAP_PAYON)),-1,-1)) >= 0) { cd->last_point.x = 87; cd->last_point.y = 117; - } else if ((i = char_search_mapserver((j=mapindex->name2id(MAP_IZLUDE)),-1,-1)) >= 0) { + } else if ((i = chr->search_mapserver((j=mapindex->name2id(MAP_IZLUDE)),-1,-1)) >= 0) { cd->last_point.x = 94; cd->last_point.y = 103; } @@ -4605,7 +4573,7 @@ void char_parse_char_select(int fd, struct char_session_data* sd, uint32 ipl) struct online_char_data* character; character = (struct online_char_data*)idb_get(online_char_db, sd->account_id); if( character && character->pincode_enable == -1){ - char_auth_error(fd, 0); + chr->auth_error(fd, 0); return; } } @@ -4615,7 +4583,7 @@ void char_parse_char_select(int fd, struct char_session_data* sd, uint32 ipl) /* not available, tell it to wait (client wont close; char select will respawn). * magic response found by Ind thanks to Yommy <3 */ if( server_id == ARRAYLENGTH(server) ) { - char_send_wait_char_server(fd); + chr->send_wait_char_server(fd); return; } @@ -4625,7 +4593,7 @@ void char_parse_char_select(int fd, struct char_session_data* sd, uint32 ipl) { //Not found?? May be forged packet. Sql_ShowDebug(sql_handle); SQL->FreeResult(sql_handle); - char_auth_error(fd, 0); + chr->auth_error(fd, 0); return; } @@ -4634,16 +4602,16 @@ void char_parse_char_select(int fd, struct char_session_data* sd, uint32 ipl) /* client doesn't let it get to this point if you're banned, so its a forged packet */ if( sd->found_char[slot] == char_id && sd->unban_time[slot] > time(NULL) ) { - char_auth_error(fd, 0); + chr->auth_error(fd, 0); return; } /* set char as online prior to loading its data so 3rd party applications will realize the sql data is not reliable */ - char_set_char_online(-2,char_id,sd->account_id); - if( !char_mmo_char_fromsql(char_id, &char_dat, true) ) { /* failed? set it back offline */ - char_set_char_offline(char_id, sd->account_id); + chr->set_char_online(-2,char_id,sd->account_id); + if( !chr->mmo_char_fromsql(char_id, &char_dat, true) ) { /* failed? set it back offline */ + chr->set_char_offline(char_id, sd->account_id); /* failed to load something. REJECT! */ - char_auth_error(fd, 0); + chr->auth_error(fd, 0); return;/* jump off this boat */ } @@ -4664,7 +4632,7 @@ void char_parse_char_select(int fd, struct char_session_data* sd, uint32 ipl) ShowInfo("Selected char: (Account %d: %d - %s)\n", sd->account_id, slot, char_dat.name); // searching map server - i = char_search_mapserver(cd->last_point.map, -1, -1); + i = chr->search_mapserver(cd->last_point.map, -1, -1); // if map is not found, we check major cities if (i < 0 || !cd->last_point.map) { @@ -4673,14 +4641,14 @@ void char_parse_char_select(int fd, struct char_session_data* sd, uint32 ipl) ARR_FIND( 0, ARRAYLENGTH(server), j, server[j].fd >= 0 && server[j].map ); if (j == ARRAYLENGTH(server)) { ShowInfo("Connection Closed. No map servers available.\n"); - char_authfail_fd(fd, 1); + chr->authfail_fd(fd, 1); return; } - i = char_search_default_maps_mapserver(cd); + i = chr->search_default_maps_mapserver(cd); if (i < 0) { ShowInfo("Connection Closed. No map server available that has a major city, and unable to find map-server for '%s'.\n", mapindex_id2name(cd->last_point.map)); - char_authfail_fd(fd, 1); + chr->authfail_fd(fd, 1); return; } } @@ -4690,17 +4658,17 @@ void char_parse_char_select(int fd, struct char_session_data* sd, uint32 ipl) //FIXME: is this case even possible? [ultramage] if ((map_fd = server[i].fd) < 1 || session[map_fd] == NULL) { - ShowError("char_parse_char: Attempting to write to invalid session %d! Map Server #%d disconnected.\n", map_fd, i); + ShowError("chr->parse_char: Attempting to write to invalid session %d! Map Server #%d disconnected.\n", map_fd, i); server[i].fd = -1; memset(&server[i], 0, sizeof(struct mmo_map_server)); //Send server closed. - char_authfail_fd(fd, 1); + chr->authfail_fd(fd, 1); return; } - uint32 subnet_map_ip = char_lan_subnetcheck(ipl); // Advanced subnet check [LuzZza] + uint32 subnet_map_ip = chr->lan_subnetcheck(ipl); // Advanced subnet check [LuzZza] //Send player to map - char_send_map_info(fd, i, subnet_map_ip, cd); + chr->send_map_info(fd, i, subnet_map_ip, cd); struct char_auth_node* node; // create temporary auth entry @@ -4732,7 +4700,7 @@ void char_creation_failed(int fd, int result) case -5: WFIFOB(fd,2) = 0x02; break; // 'Symbols in Character Names are forbidden' default: - ShowWarning("char_parse_char: Unknown result received from char_make_new_char_sql!\n"); + ShowWarning("chr->parse_char: Unknown result received from chr->make_new_char_sql!\n"); WFIFOB(fd,2) = 0xFF; break; } @@ -4744,7 +4712,7 @@ void char_creation_ok(int fd, struct mmo_charstatus *char_dat) // send to player WFIFOHEAD(fd,2+MAX_CHAR_BUF); WFIFOW(fd,0) = 0x6d; - int len = 2 + char_mmo_char_tobuf(WFIFOP(fd,2), char_dat); + int len = 2 + chr->mmo_char_tobuf(WFIFOP(fd,2), char_dat); WFIFOSET(fd,len); } @@ -4755,18 +4723,18 @@ void char_parse_char_create_new_char(int fd, struct char_session_data* sd) result = -2; else #if PACKETVER >= 20120307 - result = char_make_new_char_sql(sd, (char*)RFIFOP(fd,2),RFIFOB(fd,26),RFIFOW(fd,27),RFIFOW(fd,29)); + result = chr->make_new_char_sql(sd, (char*)RFIFOP(fd,2), 1, 1, 1, 1, 1, 1, RFIFOB(fd,26),RFIFOW(fd,27),RFIFOW(fd,29)); #else - result = char_make_new_char_sql(sd, (char*)RFIFOP(fd,2),RFIFOB(fd,26),RFIFOB(fd,27),RFIFOB(fd,28),RFIFOB(fd,29),RFIFOB(fd,30),RFIFOB(fd,31),RFIFOB(fd,32),RFIFOW(fd,33),RFIFOW(fd,35)); + result = chr->make_new_char_sql(sd, (char*)RFIFOP(fd,2),RFIFOB(fd,26),RFIFOB(fd,27),RFIFOB(fd,28),RFIFOB(fd,29),RFIFOB(fd,30),RFIFOB(fd,31),RFIFOB(fd,32),RFIFOW(fd,33),RFIFOW(fd,35)); #endif if (result < 0) { - char_creation_failed(fd, result); + chr->creation_failed(fd, result); } else { // retrieve data struct mmo_charstatus char_dat; - char_mmo_char_fromsql(result, &char_dat, false); //Only the short data is needed. - char_creation_ok(fd, &char_dat); + chr->mmo_char_fromsql(result, &char_dat, false); //Only the short data is needed. + chr->creation_ok(fd, &char_dat); // add new entry to the chars list sd->found_char[char_dat.slot] = result; // the char_id of the new char @@ -4804,7 +4772,7 @@ void char_parse_char_delete_char(int fd, struct char_session_data* sd, unsigned struct online_char_data* character; character = (struct online_char_data*)idb_get(online_char_db, sd->account_id); if( character && character->pincode_enable == -1 ){ - char_auth_error(fd, 0); + chr->auth_error(fd, 0); RFIFOSKIP(fd,( cmd == 0x68) ? 46 : 56); return; } @@ -4821,7 +4789,7 @@ void char_parse_char_delete_char(int fd, struct char_session_data* sd, unsigned 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 - char_delete_char_failed(fd, 0); + chr->delete_char_failed(fd, 0); return; } @@ -4829,7 +4797,7 @@ void char_parse_char_delete_char(int fd, struct char_session_data* sd, unsigned ARR_FIND( 0, MAX_CHARS, i, sd->found_char[i] == cid ); if( i == MAX_CHARS ) { // Such a character does not exist in the account - char_delete_char_failed(fd, 0); + chr->delete_char_failed(fd, 0); return; } @@ -4837,15 +4805,15 @@ void char_parse_char_delete_char(int fd, struct char_session_data* sd, unsigned sd->found_char[i] = -1; /* Delete character */ - if(char_delete_char_sql(cid)<0){ + if(chr->delete_char_sql(cid)<0){ //can't delete the char //either SQL error or can't delete by some CONFIG conditions //del fail - char_delete_char_failed(fd, 0); + chr->delete_char_failed(fd, 0); return; } /* Char successfully deleted.*/ - char_delete_char_ok(fd); + chr->delete_char_ok(fd); } void char_parse_char_ping(int fd) @@ -4875,14 +4843,14 @@ void char_parse_char_rename_char(int fd, struct char_session_data* sd) normalize_name(name,TRIM_CHARS); SQL->EscapeStringLen(sql_handle, esc_name, name, strnlen(name, NAME_LENGTH)); - if( !char_check_char_name(name,esc_name) ) { + if( !chr->check_char_name(name,esc_name) ) { i = 1; safestrncpy(sd->new_name, name, NAME_LENGTH); } else { i = 0; } - char_allow_rename(fd, i); + chr->allow_rename(fd, i); } void char_parse_char_rename_char2(int fd, struct char_session_data* sd) @@ -4901,7 +4869,7 @@ void char_parse_char_rename_char2(int fd, struct char_session_data* sd) normalize_name(name,TRIM_CHARS); SQL->EscapeStringLen(sql_handle, esc_name, name, strnlen(name, NAME_LENGTH)); - if( !char_check_char_name(name,esc_name) ) + if( !chr->check_char_name(name,esc_name) ) { i = 1; safestrncpy(sd->new_name, name, NAME_LENGTH); @@ -4909,7 +4877,7 @@ void char_parse_char_rename_char2(int fd, struct char_session_data* sd) else i = 0; - char_allow_rename(fd, i); + chr->allow_rename(fd, i); } void char_rename_char_ack(int fd, int flag) @@ -4929,9 +4897,9 @@ void char_parse_char_rename_char_confirm(int fd, struct char_session_data* sd) ARR_FIND( 0, MAX_CHARS, i, sd->found_char[i] == cid ); if( i == MAX_CHARS ) return; - i = char_rename_char_sql(sd, cid); + i = chr->rename_char_sql(sd, cid); - char_rename_char_ack(fd, i); + chr->rename_char_ack(fd, i); } void char_captcha_notsupported(int fd) @@ -4945,31 +4913,31 @@ void char_captcha_notsupported(int fd) void char_parse_char_request_captcha(int fd) { - char_captcha_notsupported(fd); + chr->captcha_notsupported(fd); RFIFOSKIP(fd,8); } void char_parse_char_check_captcha(int fd) { - char_captcha_notsupported(fd); + chr->captcha_notsupported(fd); RFIFOSKIP(fd,32); } void char_parse_char_delete2_req(int fd, struct char_session_data* sd) { - char_delete2_req(fd, sd); + chr->delete2_req(fd, sd); RFIFOSKIP(fd,6); } void char_parse_char_delete2_accept(int fd, struct char_session_data* sd) { - char_delete2_accept(fd, sd); + chr->delete2_accept(fd, sd); RFIFOSKIP(fd,12); } void char_parse_char_delete2_cancel(int fd, struct char_session_data* sd) { - char_delete2_cancel(fd, sd); + chr->delete2_cancel(fd, sd); RFIFOSKIP(fd,6); } @@ -4997,18 +4965,18 @@ void char_parse_char_login_map_server(int fd) strcmp(l_user, userid) != 0 || strcmp(l_pass, passwd) != 0 ) { - char_login_map_server_ack(fd, 3); + chr->login_map_server_ack(fd, 3); } else { - char_login_map_server_ack(fd, 0); + chr->login_map_server_ack(fd, 0); server[i].fd = fd; server[i].ip = ntohl(RFIFOL(fd,54)); server[i].port = ntohs(RFIFOW(fd,58)); server[i].users = 0; - session[fd]->func_parse = char_parse_frommap; + session[fd]->func_parse = chr->parse_frommap; session[fd]->flag.server = 1; realloc_fifo(fd, FIFOSIZE_SERVERLINK, FIFOSIZE_SERVERLINK); - char_mapif_init(fd); + chr->mapif_init(fd); } sockt->datasync(fd, true); @@ -5048,7 +5016,7 @@ void char_parse_char_pincode_first_pin(int fd, struct char_session_data* sd) void char_parse_char_request_chars(int fd, struct char_session_data* sd) { - char_mmo_char_send099d(fd, sd); + chr->mmo_char_send099d(fd, sd); RFIFOSKIP(fd,2); } @@ -5064,21 +5032,21 @@ void char_change_character_slot_ack(int fd, bool ret) void char_parse_char_move_character(int fd, struct char_session_data* sd) { - bool ret = char_char_slotchange(sd, fd, RFIFOW(fd, 2), RFIFOW(fd, 4)); - char_change_character_slot_ack(fd, ret); + bool ret = chr->char_slotchange(sd, fd, RFIFOW(fd, 2), RFIFOW(fd, 4)); + chr->change_character_slot_ack(fd, ret); /* for some stupid reason it requires the char data again (gravity -_-) */ if( ret ) #if PACKETVER >= 20130000 - char_mmo_char_send099d(fd, sd); + chr->mmo_char_send099d(fd, sd); #else - char_mmo_char_send_characters(fd, sd); + chr->mmo_char_send_characters(fd, sd); #endif RFIFOSKIP(fd, 8); } int char_parse_char_unknown_packet(int fd, uint32 ipl) { - ShowError("char_parse_char: Received unknown packet "CL_WHITE"0x%x"CL_RESET" from ip '"CL_WHITE"%s"CL_RESET"'! Disconnecting!\n", RFIFOW(fd,0), ip2str(ipl, NULL)); + ShowError("chr->parse_char: Received unknown packet "CL_WHITE"0x%x"CL_RESET" from ip '"CL_WHITE"%s"CL_RESET"'! Disconnecting!\n", RFIFOW(fd,0), ip2str(ipl, NULL)); set_eof(fd); return 1; } @@ -5103,7 +5071,7 @@ int char_parse_char(int fd) if( data != NULL && data->fd == fd) data->fd = -1; if( data == NULL || data->server == -1) //If it is not in any server, send it offline. [Skotlex] - char_set_char_offline(-1,sd->account_id); + chr->set_char_offline(-1,sd->account_id); } do_close(fd); return 0; @@ -5129,7 +5097,7 @@ int char_parse_char(int fd) if( RFIFOREST(fd) < 17 ) return 0; { - char_parse_char_connect(fd, sd, ipl); + chr->parse_char_connect(fd, sd, ipl); } break; @@ -5137,7 +5105,7 @@ int char_parse_char(int fd) case 0x66: FIFOSD_CHECK(3); { - char_parse_char_select(fd, sd, ipl); + chr->parse_char_select(fd, sd, ipl); } break; @@ -5155,7 +5123,7 @@ int char_parse_char(int fd) FIFOSD_CHECK(37); #endif - char_parse_char_create_new_char(fd, sd); + chr->parse_char_create_new_char(fd, sd); } break; @@ -5166,7 +5134,7 @@ int char_parse_char(int fd) if (cmd == 0x68) FIFOSD_CHECK(46); if (cmd == 0x1fb) FIFOSD_CHECK(56); { - char_parse_char_delete_char(fd, sd, cmd); + chr->parse_char_delete_char(fd, sd, cmd); } break; @@ -5175,14 +5143,14 @@ int char_parse_char(int fd) case 0x187: if (RFIFOREST(fd) < 6) return 0; - char_parse_char_ping(fd); + chr->parse_char_ping(fd); break; // char rename request // R 08fc .l .24B case 0x8fc: FIFOSD_CHECK(30); { - char_parse_char_rename_char(fd, sd); + chr->parse_char_rename_char(fd, sd); } break; @@ -5191,7 +5159,7 @@ int char_parse_char(int fd) case 0x28d: FIFOSD_CHECK(34); { - char_parse_char_rename_char2(fd, sd); + chr->parse_char_rename_char2(fd, sd); } break; //Confirm change name. @@ -5204,38 +5172,38 @@ int char_parse_char(int fd) // 4: Another user is using this character name, so please select another one. FIFOSD_CHECK(6); { - char_parse_char_rename_char_confirm(fd, sd); + chr->parse_char_rename_char_confirm(fd, sd); } break; // captcha code request (not implemented) // R 07e5 .w .l case 0x7e5: - char_parse_char_request_captcha(fd); + chr->parse_char_request_captcha(fd); break; // captcha code check (not implemented) // R 07e7 .w .l .b10 .b14 case 0x7e7: - char_parse_char_check_captcha(fd); + chr->parse_char_check_captcha(fd); break; // deletion timer request case 0x827: FIFOSD_CHECK(6); - char_parse_char_delete2_req(fd, sd); + chr->parse_char_delete2_req(fd, sd); break; // deletion accept request case 0x829: FIFOSD_CHECK(12); - char_parse_char_delete2_accept(fd, sd); + chr->parse_char_delete2_accept(fd, sd); break; // deletion cancel request case 0x82b: FIFOSD_CHECK(6); - char_parse_char_delete2_cancel(fd, sd); + chr->parse_char_delete2_cancel(fd, sd); break; // login as map-server @@ -5243,50 +5211,50 @@ int char_parse_char(int fd) if (RFIFOREST(fd) < 60) return 0; { - char_parse_char_login_map_server(fd); + chr->parse_char_login_map_server(fd); } return 0; // avoid processing of follow-up packets here // checks the entered pin case 0x8b8: FIFOSD_CHECK(10); - char_parse_char_pincode_check(fd, sd); + chr->parse_char_pincode_check(fd, sd); break; // request for PIN window case 0x8c5: FIFOSD_CHECK(6); - char_parse_char_pincode_window(fd, sd); + chr->parse_char_pincode_window(fd, sd); break; // pincode change request case 0x8be: FIFOSD_CHECK(14); - char_parse_char_pincode_change(fd, sd); + chr->parse_char_pincode_change(fd, sd); break; // activate PIN system and set first PIN case 0x8ba: FIFOSD_CHECK(10); - char_parse_char_pincode_first_pin(fd, sd); + chr->parse_char_pincode_first_pin(fd, sd); break; case 0x9a1: FIFOSD_CHECK(2); - char_parse_char_request_chars(fd, sd); + chr->parse_char_request_chars(fd, sd); break; /* 0x8d4 .W .W .W (2+2+2+2) */ case 0x8d4: FIFOSD_CHECK(8); { - char_parse_char_move_character(fd, sd); + chr->parse_char_move_character(fd, sd); } break; // unknown packet received default: - if (char_parse_char_unknown_packet(fd, ipl)) + if (chr->parse_char_unknown_packet(fd, ipl)) return 0; } } @@ -5361,11 +5329,11 @@ void mapif_send_users_count(int users) // send number of players to all map-servers WBUFW(buf,0) = 0x2b00; WBUFL(buf,2) = users; - mapif_sendall(buf,6); + mapif->sendall(buf,6); } int char_broadcast_user_count(int tid, int64 tick, int id, intptr_t data) { - int users = char_count_users(); + int users = chr->count_users(); // only send an update when needed static int prev_users = 0; @@ -5376,10 +5344,10 @@ int char_broadcast_user_count(int tid, int64 tick, int id, intptr_t data) { if( login_fd > 0 && session[login_fd] ) { // send number of user to login server - loginif_send_users_count(users); + loginif->send_users_count(users); } - mapif_send_users_count(users); + mapif->send_users_count(users); return 0; } @@ -5411,7 +5379,7 @@ int char_send_accounts_tologin(int tid, int64 tick, int id, intptr_t data) { WFIFOHEAD(login_fd,8+users*4); WFIFOW(login_fd,0) = 0x272d; - online_char_db->foreach(online_char_db, char_send_accounts_tologin_sub, &i, users); + online_char_db->foreach(online_char_db, chr->send_accounts_tologin_sub, &i, users); WFIFOW(login_fd,2) = 8+ i*4; WFIFOL(login_fd,4) = i; WFIFOSET(login_fd,WFIFOW(login_fd,2)); @@ -5419,7 +5387,7 @@ int char_send_accounts_tologin(int tid, int64 tick, int id, intptr_t data) { return 0; } -void loginif_connect_to_server() +void loginif_connect_to_server(void) { WFIFOHEAD(login_fd,86); WFIFOW(login_fd,0) = 0x2710; @@ -5446,11 +5414,11 @@ int char_check_connect_login_server(int tid, int64 tick, int id, intptr_t data) return 0; } - session[login_fd]->func_parse = char_parse_fromlogin; + session[login_fd]->func_parse = chr->parse_fromlogin; session[login_fd]->flag.server = 1; realloc_fifo(login_fd, FIFOSIZE_SERVERLINK, FIFOSIZE_SERVERLINK); - loginif_connect_to_server(); + loginif->connect_to_server(); return 1; } @@ -5464,7 +5432,7 @@ static int char_waiting_disconnect(int tid, int64 tick, int id, intptr_t data) { if ((character = (struct online_char_data*)idb_get(online_char_db, id)) != NULL && character->waiting_disconnect == tid) { //Mark it offline due to timeout. character->waiting_disconnect = INVALID_TIMER; - char_set_char_offline(character->char_id, character->account_id); + chr->set_char_offline(character->char_id, character->account_id); } return 0; } @@ -5478,7 +5446,7 @@ static int char_online_data_cleanup_sub(DBKey key, DBData *data, va_list ap) if (character->fd != -1) return 0; //Character still connected if (character->server == -2) //Unknown server.. set them offline - char_set_char_offline(character->char_id, character->account_id); + chr->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); @@ -5486,7 +5454,7 @@ static int char_online_data_cleanup_sub(DBKey key, DBData *data, va_list ap) } static int char_online_data_cleanup(int tid, int64 tick, int id, intptr_t data) { - online_char_db->foreach(online_char_db, char_online_data_cleanup_sub); + online_char_db->foreach(online_char_db, chr->online_data_cleanup_sub); return 0; } @@ -5637,11 +5605,12 @@ void char_sql_config_read(const char* cfgName) //support the import command, just like any other config else if(!strcmpi(w1,"import")) - char_sql_config_read(w2); + chr->sql_config_read(w2); } fclose(fp); ShowInfo("Done reading %s.\n", cfgName); } + void char_config_dispatch(char *w1, char *w2) { bool (*dispatch_to[]) (char *w1, char *w2) = { /* as many as it needs */ @@ -5653,6 +5622,7 @@ void char_config_dispatch(char *w1, char *w2) { break;/* we found who this belongs to, can stop */ } } + int char_config_read(const char* cfgName) { char line[1024], w1[1024], w2[1024]; @@ -5763,7 +5733,7 @@ int char_config_read(const char* cfgName) // Format is: id1,quantity1,stackable1,idN,quantityN,stackableN if( i%3 ) { - ShowWarning("char_config_read: There are not enough parameters in start_items, ignoring last item...\n"); + ShowWarning("chr->config_read: There are not enough parameters in start_items, ignoring last item...\n"); if( i%3 == 1 ) start_items[i-1] = 0; else @@ -5815,9 +5785,9 @@ int char_config_read(const char* cfgName) } else if (strcmpi(w1, "char_maintenance_min_group_id") == 0) { char_maintenance_min_group_id = atoi(w2); } else if (strcmpi(w1, "import") == 0) { - char_config_read(w2); + chr->config_read(w2); } else - char_config_dispatch(w1,w2); + chr->config_dispatch(w1,w2); } fclose(fp); @@ -5832,8 +5802,8 @@ int do_final(void) { HPM->event(HPET_FINAL); - char_set_all_offline(-1); - char_set_all_offline_sql(); + chr->set_all_offline(-1); + chr->set_all_offline_sql(); inter_final(); @@ -5881,7 +5851,6 @@ void set_server_type(void) { SERVER_TYPE = SERVER_TYPE_CHAR; } - /// Called when a terminate signal is received. void do_shutdown(void) { @@ -5892,8 +5861,8 @@ void do_shutdown(void) ShowStatus("Shutting down...\n"); // TODO proper shutdown procedure; wait for acks?, kick all characters, ... [FlavoJS] for( id = 0; id < ARRAYLENGTH(server); ++id ) - mapif_server_reset(id); - loginif_check_shutdown(); + mapif->server_reset(id); + loginif->check_shutdown(); flush_fifos(); runflag = CORE_ST_STOP; } @@ -5910,8 +5879,7 @@ int do_init(int argc, char **argv) { for(i = 0; i < MAX_MAP_SERVERS; i++ ) server[i].map = NULL; - mapindex_defaults(); - pincode_defaults(); + char_load_defaults(); HPM_char_do_init(); HPM->symbol_defaults_sub = char_hp_symbols; @@ -5940,9 +5908,9 @@ int do_init(int argc, char **argv) { 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); - char_sql_config_read(SQL_CONF_NAME); + chr->config_read((argc < 2) ? CHAR_CONF_NAME : argv[1]); + chr->lan_config_read((argc > 3) ? argv[3] : LAN_CONF_NAME); + chr->sql_config_read(SQL_CONF_NAME); if (strcmp(userid, "s1")==0 && strcmp(passwd, "p1")==0) { ShowWarning("Using the default user/password s1/p1 is NOT RECOMMENDED.\n"); @@ -5957,8 +5925,8 @@ int do_init(int argc, char **argv) { HPM->event(HPET_INIT); - char_mmo_char_sql_init(); - char_read_fame_list(); //Read fame lists. + chr->mmo_char_sql_init(); + chr->read_fame_list(); //Read fame lists. if ((sockt->naddr_ != 0) && (!login_ip || !char_ip)) { char ip_str[16]; @@ -5982,15 +5950,15 @@ int do_init(int argc, char **argv) { do_init_mapif(); // periodically update the overall user count on all mapservers + login server - timer->add_func_list(char_broadcast_user_count, "char_broadcast_user_count"); - timer->add_interval(timer->gettick() + 1000, char_broadcast_user_count, 0, 0, 5 * 1000); + timer->add_func_list(chr->broadcast_user_count, "chr->broadcast_user_count"); + timer->add_interval(timer->gettick() + 1000, chr->broadcast_user_count, 0, 0, 5 * 1000); // Timer to clear (online_char_db) - timer->add_func_list(char_waiting_disconnect, "char_waiting_disconnect"); + timer->add_func_list(chr->waiting_disconnect, "chr->waiting_disconnect"); // Online Data timers (checking if char still connected) - timer->add_func_list(char_online_data_cleanup, "char_online_data_cleanup"); - timer->add_interval(timer->gettick() + 1000, char_online_data_cleanup, 0, 0, 600 * 1000); + timer->add_func_list(chr->online_data_cleanup, "chr->online_data_cleanup"); + timer->add_interval(timer->gettick() + 1000, chr->online_data_cleanup, 0, 0, 600 * 1000); //Cleaning the tables for NULL entries @ startup [Sirius] //Chardb clean @@ -6005,7 +5973,7 @@ int do_init(int argc, char **argv) { if( SQL_ERROR == SQL->Query(sql_handle, "DELETE FROM `%s` WHERE `guild_id` = '0' AND `account_id` = '0' AND `char_id` = '0'", guild_member_db) ) Sql_ShowDebug(sql_handle); - set_defaultparse(char_parse_char); + set_defaultparse(chr->parse_char); if( (char_fd = make_listen_bind(bind_ip,char_port)) == -1 ) { ShowFatalError("Failed to bind to port '"CL_WHITE"%d"CL_RESET"'\n",char_port); @@ -6028,3 +5996,169 @@ int do_init(int argc, char **argv) { return 0; } + +void char_load_defaults(void) +{ + mapindex_defaults(); + pincode_defaults(); + char_defaults(); + loginif_defaults(); + mapif_defaults(); +} + +void char_defaults(void) +{ + chr = &char_s; + + chr->waiting_disconnect = char_waiting_disconnect; + chr->delete_char_sql = char_delete_char_sql; + chr->create_online_char_data = char_create_online_char_data; + chr->set_account_online = char_set_account_online; + chr->set_account_offline = char_set_account_offline; + chr->set_char_charselect = char_set_char_charselect; + chr->set_char_online = char_set_char_online; + chr->set_char_offline = char_set_char_offline; + chr->db_setoffline = char_db_setoffline; + chr->db_kickoffline = char_db_kickoffline; + chr->set_login_all_offline = char_set_login_all_offline; + chr->set_all_offline = char_set_all_offline; + chr->set_all_offline_sql = char_set_all_offline_sql; + chr->create_charstatus = char_create_charstatus; + chr->mmo_char_tosql = char_mmo_char_tosql; + chr->memitemdata_to_sql = char_memitemdata_to_sql; + chr->inventory_to_sql = char_inventory_to_sql; + chr->mmo_chars_fromsql = char_mmo_chars_fromsql; + chr->mmo_char_fromsql = char_mmo_char_fromsql; + chr->mmo_char_sql_init = char_mmo_char_sql_init; + chr->char_slotchange = char_char_slotchange; + chr->check_char_name = char_check_char_name; + chr->make_new_char_sql = char_make_new_char_sql; + chr->divorce_char_sql = char_divorce_char_sql; + chr->count_users = char_count_users; + chr->mmo_char_tobuf = char_mmo_char_tobuf; + chr->mmo_char_send099d = char_mmo_char_send099d; + chr->mmo_char_send_ban_list = char_mmo_char_send_ban_list; + chr->mmo_char_send_slots_info = char_mmo_char_send_slots_info; + chr->mmo_char_send_characters = char_mmo_char_send_characters; + chr->char_married = char_char_married; + chr->char_child = char_char_child; + chr->char_family = char_char_family; + chr->disconnect_player = char_disconnect_player; + chr->authfail_fd = char_authfail_fd; + chr->request_account_data = char_request_account_data; + chr->auth_ok = char_auth_ok; + chr->ping_login_server = char_ping_login_server; + chr->parse_fromlogin_connection_state = char_parse_fromlogin_connection_state; + chr->auth_error = char_auth_error; + chr->parse_fromlogin_auth_state = char_parse_fromlogin_auth_state; + chr->parse_fromlogin_account_data = char_parse_fromlogin_account_data; + chr->parse_fromlogin_login_pong = char_parse_fromlogin_login_pong; + chr->changesex = char_changesex; + chr->parse_fromlogin_changesex_reply = char_parse_fromlogin_changesex_reply; + chr->parse_fromlogin_account_reg2 = char_parse_fromlogin_account_reg2; + chr->parse_fromlogin_ban = char_parse_fromlogin_ban; + chr->parse_fromlogin_kick = char_parse_fromlogin_kick; + chr->parse_fromlogin_update_ip = char_parse_fromlogin_update_ip; + chr->parse_fromlogin_accinfo2_failed = char_parse_fromlogin_accinfo2_failed; + chr->parse_fromlogin_accinfo2_ok = char_parse_fromlogin_accinfo2_ok; + chr->parse_fromlogin = char_parse_fromlogin; + chr->request_accreg2 = char_request_accreg2; + chr->global_accreg_to_login_start = char_global_accreg_to_login_start; + chr->global_accreg_to_login_send = char_global_accreg_to_login_send; + chr->read_fame_list = char_read_fame_list; + chr->send_fame_list = char_send_fame_list; + chr->update_fame_list = char_update_fame_list; + chr->loadName = char_loadName; + chr->parse_frommap_datasync = char_parse_frommap_datasync; + chr->map_received_ok = char_map_received_ok; + chr->send_maps = char_send_maps; + chr->parse_frommap_map_names = char_parse_frommap_map_names; + chr->send_scdata = char_send_scdata; + chr->parse_frommap_request_scdata = char_parse_frommap_request_scdata; + chr->parse_frommap_set_users_count = char_parse_frommap_set_users_count; + chr->parse_frommap_set_users = char_parse_frommap_set_users; + chr->save_character_ack = char_save_character_ack; + chr->parse_frommap_save_character = char_parse_frommap_save_character; + chr->select_ack = char_select_ack; + chr->parse_frommap_char_select_req = char_parse_frommap_char_select_req; + chr->change_map_server_ack = char_change_map_server_ack; + chr->parse_frommap_change_map_server = char_parse_frommap_change_map_server; + chr->parse_frommap_remove_friend = char_parse_frommap_remove_friend; + chr->char_name_ack = char_char_name_ack; + chr->parse_frommap_char_name_request = char_parse_frommap_char_name_request; + chr->parse_frommap_change_email = char_parse_frommap_change_email; + chr->ban = char_ban; + chr->unban = char_unban; + chr->ask_name_ack = char_ask_name_ack; + chr->parse_frommap_change_account = char_parse_frommap_change_account; + chr->parse_frommap_fame_list = char_parse_frommap_fame_list; + chr->parse_frommap_divorce_char = char_parse_frommap_divorce_char; + chr->parse_frommap_ragsrvinfo = char_parse_frommap_ragsrvinfo; + chr->parse_frommap_set_char_offline = char_parse_frommap_set_char_offline; + chr->parse_frommap_set_all_offline = char_parse_frommap_set_all_offline; + chr->parse_frommap_set_char_online = char_parse_frommap_set_char_online; + chr->parse_frommap_build_fame_list = char_parse_frommap_build_fame_list; + chr->parse_frommap_save_status_change_data = char_parse_frommap_save_status_change_data; + chr->send_pong = char_send_pong; + chr->parse_frommap_ping = char_parse_frommap_ping; + chr->map_auth_ok = char_map_auth_ok; + chr->map_auth_failed = char_map_auth_failed; + chr->parse_frommap_auth_request = char_parse_frommap_auth_request; + chr->parse_frommap_request_stats_report = char_parse_frommap_request_stats_report; + chr->parse_frommap_scdata_update = char_parse_frommap_scdata_update; + chr->parse_frommap_scdata_delete = char_parse_frommap_scdata_delete; + chr->parse_frommap = char_parse_frommap; + chr->search_mapserver = char_search_mapserver; + chr->mapif_init = char_mapif_init; + chr->lan_subnetcheck = char_lan_subnetcheck; + chr->delete2_ack = char_delete2_ack; + chr->delete2_accept_actual_ack = char_delete2_accept_actual_ack; + chr->delete2_accept_ack = char_delete2_accept_ack; + chr->delete2_cancel_ack = char_delete2_cancel_ack; + chr->delete2_req = char_delete2_req; + chr->delete2_accept = char_delete2_accept; + chr->delete2_cancel = char_delete2_cancel; + chr->send_account_id = char_send_account_id; + chr->parse_char_connect = char_parse_char_connect; + chr->send_map_info = char_send_map_info; + chr->send_wait_char_server = char_send_wait_char_server; + chr->search_default_maps_mapserver = char_search_default_maps_mapserver; + chr->parse_char_select = char_parse_char_select; + chr->creation_failed = char_creation_failed; + chr->creation_ok = char_creation_ok; + chr->parse_char_create_new_char = char_parse_char_create_new_char; + chr->delete_char_failed = char_delete_char_failed; + chr->delete_char_ok = char_delete_char_ok; + chr->parse_char_delete_char = char_parse_char_delete_char; + chr->parse_char_ping = char_parse_char_ping; + chr->allow_rename = char_allow_rename; + chr->parse_char_rename_char = char_parse_char_rename_char; + chr->parse_char_rename_char2 = char_parse_char_rename_char2; + chr->rename_char_ack = char_rename_char_ack; + chr->parse_char_rename_char_confirm = char_parse_char_rename_char_confirm; + chr->captcha_notsupported = char_captcha_notsupported; + chr->parse_char_request_captcha = char_parse_char_request_captcha; + chr->parse_char_check_captcha = char_parse_char_check_captcha; + chr->parse_char_delete2_req = char_parse_char_delete2_req; + chr->parse_char_delete2_accept = char_parse_char_delete2_accept; + chr->parse_char_delete2_cancel = char_parse_char_delete2_cancel; + chr->login_map_server_ack = char_login_map_server_ack; + chr->parse_char_login_map_server = char_parse_char_login_map_server; + chr->parse_char_pincode_check = char_parse_char_pincode_check; + chr->parse_char_pincode_window = char_parse_char_pincode_window; + chr->parse_char_pincode_change = char_parse_char_pincode_change; + chr->parse_char_pincode_first_pin = char_parse_char_pincode_first_pin; + chr->parse_char_request_chars = char_parse_char_request_chars; + chr->change_character_slot_ack = char_change_character_slot_ack; + chr->parse_char_move_character = char_parse_char_move_character; + chr->parse_char = char_parse_char; + chr->broadcast_user_count = char_broadcast_user_count; + chr->send_accounts_tologin_sub = char_send_accounts_tologin_sub; + chr->send_accounts_tologin = char_send_accounts_tologin; + chr->online_data_cleanup_sub = char_online_data_cleanup_sub; + chr->online_data_cleanup = char_online_data_cleanup; + chr->lan_config_read = char_lan_config_read; + chr->sql_config_read = char_sql_config_read; + chr->config_dispatch = char_config_dispatch; + chr->config_read = char_config_read; +} diff --git a/src/char/char.h b/src/char/char.h index 8c3e726c6..b971abbea 100644 --- a/src/char/char.h +++ b/src/char/char.h @@ -55,20 +55,6 @@ enum { TABLE_GUILD_STORAGE, }; -int char_memitemdata_to_sql(const struct item items[], int max, int id, int tableswitch); - -int mapif_sendall(unsigned char *buf,unsigned int len); -int mapif_sendallwos(int fd,unsigned char *buf,unsigned int len); -int mapif_send(int fd,unsigned char *buf,unsigned int len); -void mapif_on_parse_accinfo(int account_id,int u_fd, int aid, int castergroup, int map_fd); - -void char_disconnect_player(int account_id); - -int char_char_married(int pl1,int pl2); -int char_char_child(int parent_id, int child_id); -int char_char_family(int pl1,int pl2,int pl3); - -int char_request_accreg2(int account_id, int char_id); int login_fd; extern int char_name_option; extern char char_name_letters[]; @@ -117,8 +103,182 @@ extern int db_use_sql_mob_skill_db; extern int guild_exp_rate; extern int log_inter; -void char_global_accreg_to_login_start (int account_id, int char_id); -void char_global_accreg_to_login_send (void); -void char_global_accreg_to_login_add (const char *key, unsigned int index, intptr_t val, bool is_string); +void char_load_defaults(); +void char_defaults(); + +struct char_auth_node { + int account_id; + int char_id; + uint32 login_id1; + uint32 login_id2; + uint32 ip; + int sex; + time_t expiration_time; // # of seconds 1/1/1970 (timestamp): Validity limit of the account (0 = unlimited) + int group_id; + unsigned changing_mapservers : 1; +}; + +struct char_interface { + int (*waiting_disconnect) (int tid, int64 tick, int id, intptr_t data); + int (*delete_char_sql) (int char_id); + DBData (*create_online_char_data) (DBKey key, va_list args); + void (*set_account_online) (int account_id); + void (*set_account_offline) (int account_id); + void (*set_char_charselect) (int account_id); + void (*set_char_online) (int map_id, int char_id, int account_id); + void (*set_char_offline) (int char_id, int account_id); + int (*db_setoffline) (DBKey key, DBData *data, va_list ap); + int (*db_kickoffline) (DBKey key, DBData *data, va_list ap); + void (*set_login_all_offline) (void); + void (*set_all_offline) (int id); + void (*set_all_offline_sql) (void); + DBData (*create_charstatus) (DBKey key, va_list args); + int (*mmo_char_tosql) (int char_id, struct mmo_charstatus* p); + int (*memitemdata_to_sql) (const struct item items[], int max, int id, int tableswitch); + int (*inventory_to_sql) (const struct item items[], int max, int id); + int (*mmo_chars_fromsql) (struct char_session_data* sd, uint8* buf); + int (*mmo_char_fromsql) (int char_id, struct mmo_charstatus* p, bool load_everything); + int (*mmo_char_sql_init) (void); + bool (*char_slotchange) (struct char_session_data *sd, int fd, unsigned short from, unsigned short to); + int (*rename_char_sql) (struct char_session_data *sd, int char_id); + int (*check_char_name) (char * name, char * esc_name); + int (*make_new_char_sql) (struct char_session_data* sd, char* name_, int str, int agi, int vit, int int_, int dex, int luk, int slot, int hair_color, int hair_style); + int (*divorce_char_sql) (int partner_id1, int partner_id2); + int (*count_users) (void); + int (*mmo_char_tobuf) (uint8* buffer, struct mmo_charstatus* p); + void (*mmo_char_send099d) (int fd, struct char_session_data *sd); + void (*mmo_char_send_ban_list) (int fd, struct char_session_data *sd); + void (*mmo_char_send_slots_info) (int fd, struct char_session_data* sd); + int (*mmo_char_send_characters) (int fd, struct char_session_data* sd); + int (*char_married) (int pl1, int pl2); + int (*char_child) (int parent_id, int child_id); + int (*char_family) (int cid1, int cid2, int cid3); + void (*disconnect_player) (int account_id); + void (*authfail_fd) (int fd, int type); + void (*request_account_data) (int account_id); + void (*auth_ok) (int fd, struct char_session_data *sd); + void (*ping_login_server) (int fd); + int (*parse_fromlogin_connection_state) (int fd); + void (*auth_error) (int fd, unsigned char flag); + void (*parse_fromlogin_auth_state) (int fd); + void (*parse_fromlogin_account_data) (int fd); + void (*parse_fromlogin_login_pong) (int fd); + void (*changesex) (int account_id, int sex); + int (*parse_fromlogin_changesex_reply) (int fd); + void (*parse_fromlogin_account_reg2) (int fd); + void (*parse_fromlogin_ban) (int fd); + void (*parse_fromlogin_kick) (int fd); + void (*update_ip) (int fd); + void (*parse_fromlogin_update_ip) (int fd); + void (*parse_fromlogin_accinfo2_failed) (int fd); + void (*parse_fromlogin_accinfo2_ok) (int fd); + int (*parse_fromlogin) (int fd); + int (*request_accreg2) (int account_id, int char_id); + void (*global_accreg_to_login_start) (int account_id, int char_id); + void (*global_accreg_to_login_send) (void); + void (*global_accreg_to_login_add) (const char *key, unsigned int index, intptr_t val, bool is_string); + void (*read_fame_list) (void); + int (*send_fame_list) (int fd); + void (*update_fame_list) (int type, int index, int fame); + int (*loadName) (int char_id, char* name); + void (*parse_frommap_datasync) (int fd); + void (*parse_frommap_skillid2idx) (int fd); + void (*map_received_ok) (int fd); + void (*send_maps) (int fd, int id, int j); + void (*parse_frommap_map_names) (int fd, int id); + void (*send_scdata) (int fd, int aid, int cid); + void (*parse_frommap_request_scdata) (int fd); + void (*parse_frommap_set_users_count) (int fd, int id); + void (*parse_frommap_set_users) (int fd, int id); + void (*save_character_ack) (int fd, int aid, int cid); + void (*parse_frommap_save_character) (int fd, int id); + void (*select_ack) (int fd, int account_id, uint8 flag); + void (*parse_frommap_char_select_req) (int fd); + void (*change_map_server_ack) (int fd, uint8 *data, bool ok); + void (*parse_frommap_change_map_server) (int fd); + void (*parse_frommap_remove_friend) (int fd); + void (*char_name_ack) (int fd, int char_id); + void (*parse_frommap_char_name_request) (int fd); + void (*parse_frommap_change_email) (int fd); + void (*ban) (int account_id, int char_id, time_t *unban_time, short year, short month, short day, short hour, short minute, short second); + void (*unban) (int char_id, int *result); + void (*ask_name_ack) (int fd, int acc, const char* name, int type, int result); + void (*parse_frommap_change_account) (int fd); + void (*parse_frommap_fame_list) (int fd); + void (*parse_frommap_divorce_char) (int fd); + void (*parse_frommap_ragsrvinfo) (int fd); + void (*parse_frommap_set_char_offline) (int fd); + void (*parse_frommap_set_all_offline) (int fd, int id); + void (*parse_frommap_set_char_online) (int fd, int id); + void (*parse_frommap_build_fame_list) (int fd); + void (*parse_frommap_save_status_change_data) (int fd); + void (*send_pong) (int fd); + void (*parse_frommap_ping) (int fd); + void (*map_auth_ok) (int fd, int account_id, struct char_auth_node* node, struct mmo_charstatus* cd); + void (*map_auth_failed) (int fd, int account_id, int char_id, int login_id1, char sex, uint32 ip); + void (*parse_frommap_auth_request) (int fd, int id); + void (*parse_frommap_update_ip) (int fd, int id); + void (*parse_frommap_request_stats_report) (int fd); + void (*parse_frommap_scdata_update) (int fd); + void (*parse_frommap_scdata_delete) (int fd); + int (*parse_frommap) (int fd); + int (*search_mapserver) (unsigned short map, uint32 ip, uint16 port); + int (*mapif_init) (int fd); + int (*lan_subnetcheck) (uint32 ip); + void (*delete2_ack) (int fd, int char_id, uint32 result, time_t delete_date); + void (*delete2_accept_actual_ack) (int fd, int char_id, uint32 result); + void (*delete2_accept_ack) (int fd, int char_id, uint32 result); + void (*delete2_cancel_ack) (int fd, int char_id, uint32 result); + void (*delete2_req) (int fd, struct char_session_data* sd); + void (*delete2_accept) (int fd, struct char_session_data* sd); + void (*delete2_cancel) (int fd, struct char_session_data* sd); + void (*send_account_id) (int fd, int account_id); + void (*parse_char_connect) (int fd, struct char_session_data* sd, uint32 ipl); + void (*send_map_info) (int fd, int i, uint32 subnet_map_ip, struct mmo_charstatus *cd); + void (*send_wait_char_server) (int fd); + int (*search_default_maps_mapserver) (struct mmo_charstatus *cd); + void (*parse_char_select) (int fd, struct char_session_data* sd, uint32 ipl); + void (*creation_failed) (int fd, int result); + void (*creation_ok) (int fd, struct mmo_charstatus *char_dat); + void (*parse_char_create_new_char) (int fd, struct char_session_data* sd); + void (*delete_char_failed) (int fd, int flag); + void (*delete_char_ok) (int fd); + void (*parse_char_delete_char) (int fd, struct char_session_data* sd, unsigned short cmd); + void (*parse_char_ping) (int fd); + void (*allow_rename) (int fd, int flag); + void (*parse_char_rename_char) (int fd, struct char_session_data* sd); + void (*parse_char_rename_char2) (int fd, struct char_session_data* sd); + void (*rename_char_ack) (int fd, int flag); + void (*parse_char_rename_char_confirm) (int fd, struct char_session_data* sd); + void (*captcha_notsupported) (int fd); + void (*parse_char_request_captcha) (int fd); + void (*parse_char_check_captcha) (int fd); + void (*parse_char_delete2_req) (int fd, struct char_session_data* sd); + void (*parse_char_delete2_accept) (int fd, struct char_session_data* sd); + void (*parse_char_delete2_cancel) (int fd, struct char_session_data* sd); + void (*login_map_server_ack) (int fd, uint8 flag); + void (*parse_char_login_map_server) (int fd); + void (*parse_char_pincode_check) (int fd, struct char_session_data* sd); + void (*parse_char_pincode_window) (int fd, struct char_session_data* sd); + void (*parse_char_pincode_change) (int fd, struct char_session_data* sd); + void (*parse_char_pincode_first_pin) (int fd, struct char_session_data* sd); + void (*parse_char_request_chars) (int fd, struct char_session_data* sd); + void (*change_character_slot_ack) (int fd, bool ret); + void (*parse_char_move_character) (int fd, struct char_session_data* sd); + int (*parse_char_unknown_packet) (int fd, uint32 ipl); + int (*parse_char) (int fd); + int (*broadcast_user_count) (int tid, int64 tick, int id, intptr_t data); + int (*send_accounts_tologin_sub) (DBKey key, DBData *data, va_list ap); + int (*send_accounts_tologin) (int tid, int64 tick, int id, intptr_t data); + int (*check_connect_login_server) (int tid, int64 tick, int id, intptr_t data); + int (*online_data_cleanup_sub) (DBKey key, DBData *data, va_list ap); + int (*online_data_cleanup) (int tid, int64 tick, int id, intptr_t data); + int (*lan_config_read) (const char *lancfgName); + void (*sql_config_read) (const char* cfgName); + void (*config_dispatch) (char *w1, char *w2); + int (*config_read) (const char* cfgName); +}; + +struct char_interface *chr; #endif /* COMMON_CHAR_H */ diff --git a/src/char/int_auction.c b/src/char/int_auction.c index 7a5a8b2fb..cab986101 100644 --- a/src/char/int_auction.c +++ b/src/char/int_auction.c @@ -13,6 +13,7 @@ #include "char.h" #include "int_mail.h" #include "inter.h" +#include "mapif.h" #include "../common/db.h" #include "../common/malloc.h" #include "../common/mmo.h" @@ -135,7 +136,7 @@ static void mapif_Auction_message(int char_id, unsigned char result) WBUFW(buf,0) = 0x3854; WBUFL(buf,2) = char_id; WBUFL(buf,6) = result; - mapif_sendall(buf,7); + mapif->sendall(buf,7); } static int inter_auction_end_timer(int tid, int64 tick, int id, intptr_t data) { diff --git a/src/char/int_guild.c b/src/char/int_guild.c index 755fee3bb..578666015 100644 --- a/src/char/int_guild.c +++ b/src/char/int_guild.c @@ -13,6 +13,7 @@ #include "char.h" #include "inter.h" +#include "mapif.h" #include "../common/cbasetypes.h" #include "../common/db.h" #include "../common/malloc.h" @@ -907,9 +908,9 @@ int mapif_guild_noinfo(int fd,int guild_id) WBUFL(buf,4)=guild_id; ShowWarning("int_guild: info not found %d\n",guild_id); if(fd<0) - mapif_sendall(buf,8); + mapif->sendall(buf,8); else - mapif_send(fd,buf,8); + mapif->send(fd,buf,8); return 0; } @@ -921,9 +922,9 @@ int mapif_guild_info(int fd,struct guild *g) WBUFW(buf,2)=4+sizeof(struct guild); memcpy(buf+4,g,sizeof(struct guild)); if(fd<0) - mapif_sendall(buf,WBUFW(buf,2)); + mapif->sendall(buf,WBUFW(buf,2)); else - mapif_send(fd,buf,WBUFW(buf,2)); + mapif->send(fd,buf,WBUFW(buf,2)); return 0; } @@ -951,7 +952,7 @@ int mapif_guild_withdraw(int guild_id,int account_id,int char_id,int flag, const WBUFB(buf,14)=flag; memcpy(WBUFP(buf,15),mes,40); memcpy(WBUFP(buf,55),name,NAME_LENGTH); - mapif_sendall(buf,55+NAME_LENGTH); + mapif->sendall(buf,55+NAME_LENGTH); ShowInfo("int_guild: guild withdraw (%d - %d: %s - %s)\n",guild_id,account_id,name,mes); return 0; } @@ -967,7 +968,7 @@ int mapif_guild_memberinfoshort(struct guild *g,int idx) WBUFB(buf,14)=(unsigned char)g->member[idx].online; WBUFW(buf,15)=g->member[idx].lv; WBUFW(buf,17)=g->member[idx].class_; - mapif_sendall(buf,19); + mapif->sendall(buf,19); return 0; } @@ -978,7 +979,7 @@ int mapif_guild_broken(int guild_id,int flag) WBUFW(buf,0)=0x3836; WBUFL(buf,2)=guild_id; WBUFB(buf,6)=flag; - mapif_sendall(buf,7); + mapif->sendall(buf,7); ShowInfo("int_guild: Guild broken (%d)\n",guild_id); return 0; } @@ -994,7 +995,7 @@ int mapif_guild_message(int guild_id,int account_id,char *mes,int len, int sfd) WBUFL(buf,4)=guild_id; WBUFL(buf,8)=account_id; memcpy(WBUFP(buf,12),mes,len); - mapif_sendallwos(sfd, buf,len+12); + mapif->sendallwos(sfd, buf,len+12); return 0; } @@ -1009,7 +1010,7 @@ int mapif_guild_basicinfochanged(int guild_id,int type,const void *data,int len) WBUFL(buf, 4)=guild_id; WBUFW(buf, 8)=type; memcpy(WBUFP(buf,10),data,len); - mapif_sendall(buf,len+10); + mapif->sendall(buf,len+10); return 0; } @@ -1026,7 +1027,7 @@ int mapif_guild_memberinfochanged(int guild_id,int account_id,int char_id, int t WBUFL(buf,12)=char_id; WBUFW(buf,16)=type; memcpy(WBUFP(buf,18),data,len); - mapif_sendall(buf,len+18); + mapif->sendall(buf,len+18); return 0; } @@ -1038,7 +1039,7 @@ int mapif_guild_skillupack(int guild_id,uint16 skill_id,int account_id) WBUFL(buf, 2)=guild_id; WBUFL(buf, 6)=skill_id; WBUFL(buf,10)=account_id; - mapif_sendall(buf,14); + mapif->sendall(buf,14); return 0; } @@ -1054,7 +1055,7 @@ int mapif_guild_alliance(int guild_id1,int guild_id2,int account_id1,int account WBUFB(buf,18)=flag; memcpy(WBUFP(buf,19),name1,NAME_LENGTH); memcpy(WBUFP(buf,19+NAME_LENGTH),name2,NAME_LENGTH); - mapif_sendall(buf,19+2*NAME_LENGTH); + mapif->sendall(buf,19+2*NAME_LENGTH); return 0; } @@ -1067,7 +1068,7 @@ int mapif_guild_position(struct guild *g,int idx) WBUFL(buf,4)=g->guild_id; WBUFL(buf,8)=idx; memcpy(WBUFP(buf,12),&g->position[idx],sizeof(struct guild_position)); - mapif_sendall(buf,WBUFW(buf,2)); + mapif->sendall(buf,WBUFW(buf,2)); return 0; } @@ -1079,7 +1080,7 @@ int mapif_guild_notice(struct guild *g) WBUFL(buf,2)=g->guild_id; memcpy(WBUFP(buf,6),g->mes1,MAX_GUILDMES1); memcpy(WBUFP(buf,66),g->mes2,MAX_GUILDMES2); - mapif_sendall(buf,186); + mapif->sendall(buf,186); return 0; } @@ -1092,7 +1093,7 @@ int mapif_guild_emblem(struct guild *g) WBUFL(buf,4)=g->guild_id; WBUFL(buf,8)=g->emblem_id; memcpy(WBUFP(buf,12),g->emblem_data,g->emblem_len); - mapif_sendall(buf,WBUFW(buf,2)); + mapif->sendall(buf,WBUFW(buf,2)); return 0; } @@ -1103,7 +1104,7 @@ int mapif_guild_master_changed(struct guild *g, int aid, int cid) WBUFL(buf,2)=g->guild_id; WBUFL(buf,6)=aid; WBUFL(buf,10)=cid; - mapif_sendall(buf,14); + mapif->sendall(buf,14); return 0; } diff --git a/src/char/int_mail.c b/src/char/int_mail.c index f3c039e29..f0cf4ce7c 100644 --- a/src/char/int_mail.c +++ b/src/char/int_mail.c @@ -12,6 +12,7 @@ #include "char.h" #include "inter.h" +#include "mapif.h" #include "../common/malloc.h" #include "../common/mmo.h" #include "../common/showmsg.h" @@ -342,7 +343,7 @@ void mapif_Mail_new(struct mail_message *msg) WBUFL(buf,6) = msg->id; memcpy(WBUFP(buf,10), msg->send_name, NAME_LENGTH); memcpy(WBUFP(buf,34), msg->title, MAIL_TITLE_LENGTH); - mapif_sendall(buf, 74); + mapif->sendall(buf, 74); } /*========================================== diff --git a/src/char/int_party.c b/src/char/int_party.c index bc2fbd964..8253df675 100644 --- a/src/char/int_party.c +++ b/src/char/int_party.c @@ -12,6 +12,7 @@ #include "char.h" #include "inter.h" +#include "mapif.h" #include "../common/cbasetypes.h" #include "../common/db.h" #include "../common/malloc.h" @@ -81,7 +82,7 @@ static void inter_party_calc_state(struct party_data *p) if(p->party.member[i].online) p->party.count++; } - if( p->size == 2 && ( char_char_child(p->party.member[0].char_id,p->party.member[1].char_id) || char_char_child(p->party.member[1].char_id,p->party.member[0].char_id) ) ) { + if( p->size == 2 && ( chr->char_child(p->party.member[0].char_id,p->party.member[1].char_id) || chr->char_child(p->party.member[1].char_id,p->party.member[0].char_id) ) ) { //Child should be able to share with either of their parents [RoM] if(p->party.member[0].class_&0x2000) //first slot is the child? p->family = p->party.member[0].char_id; @@ -89,7 +90,7 @@ static void inter_party_calc_state(struct party_data *p) p->family = p->party.member[1].char_id; } else if( p->size == 3 ) { //Check Family State. - p->family = char_char_family( + p->family = chr->char_family( p->party.member[0].char_id, p->party.member[1].char_id, p->party.member[2].char_id @@ -374,9 +375,9 @@ static void mapif_party_info(int fd, struct party* p, int char_id) memcpy(WBUFP(buf,8), p, sizeof(struct party)); if(fd<0) - mapif_sendall(buf,WBUFW(buf,2)); + mapif->sendall(buf,WBUFW(buf,2)); else - mapif_send(fd,buf,WBUFW(buf,2)); + mapif->send(fd,buf,WBUFW(buf,2)); } //Whether or not additional party members @@ -403,9 +404,9 @@ int mapif_party_optionchanged(int fd,struct party *p,int account_id,int flag) WBUFW(buf,12)=p->item; WBUFB(buf,14)=flag; if(flag==0) - mapif_sendall(buf,15); + mapif->sendall(buf,15); else - mapif_send(fd,buf,15); + mapif->send(fd,buf,15); return 0; } @@ -417,7 +418,7 @@ int mapif_party_withdraw(int party_id,int account_id, int char_id) { WBUFL(buf,2) = party_id; WBUFL(buf,6) = account_id; WBUFL(buf,10) = char_id; - mapif_sendall(buf, 14); + mapif->sendall(buf, 14); return 0; } @@ -433,7 +434,7 @@ int mapif_party_membermoved(struct party *p,int idx) WBUFW(buf,14) = p->member[idx].map; WBUFB(buf,16) = p->member[idx].online; WBUFW(buf,17) = p->member[idx].lv; - mapif_sendall(buf, 19); + mapif->sendall(buf, 19); return 0; } @@ -444,7 +445,7 @@ int mapif_party_broken(int party_id,int flag) WBUFW(buf,0)=0x3826; WBUFL(buf,2)=party_id; WBUFB(buf,6)=flag; - mapif_sendall(buf,7); + mapif->sendall(buf,7); //printf("int_party: broken %d\n",party_id); return 0; } @@ -458,7 +459,7 @@ int mapif_party_message(int party_id,int account_id,char *mes,int len, int sfd) WBUFL(buf,4)=party_id; WBUFL(buf,8)=account_id; memcpy(WBUFP(buf,12),mes,len); - mapif_sendallwos(sfd, buf,len+12); + mapif->sendallwos(sfd, buf,len+12); return 0; } diff --git a/src/char/int_storage.c b/src/char/int_storage.c index 07ce8436f..e3b09dea0 100644 --- a/src/char/int_storage.c +++ b/src/char/int_storage.c @@ -25,7 +25,7 @@ /// Save storage data to sql int inter_storage_tosql(int account_id, struct storage_data* p) { - char_memitemdata_to_sql(p->items, MAX_STORAGE, account_id, TABLE_STORAGE); + chr->memitemdata_to_sql(p->items, MAX_STORAGE, account_id, TABLE_STORAGE); return 0; } @@ -81,7 +81,7 @@ int inter_storage_fromsql(int account_id, struct storage_data* p) /// Save guild_storage data to sql int inter_storage_guild_storage_tosql(int guild_id, struct guild_storage* p) { - char_memitemdata_to_sql(p->items, MAX_GUILD_STORAGE, guild_id, TABLE_GUILD_STORAGE); + chr->memitemdata_to_sql(p->items, MAX_GUILD_STORAGE, guild_id, TABLE_GUILD_STORAGE); ShowInfo ("guild storage save to DB - guild: %d\n", guild_id); return 0; } @@ -379,9 +379,9 @@ int mapif_parse_ItemBoundRetrieve_sub(int fd) //Now let's update the guild storage with those deleted items /// TODO/FIXME: - /// This approach is basically the same as the one from char_memitemdata_to_sql, but + /// This approach is basically the same as the one from chr->memitemdata_to_sql, but /// the latter compares current database values and this is not needed in this case - /// maybe sometime separate char_memitemdata_to_sql into different methods in order to use + /// maybe sometime separate chr->memitemdata_to_sql into different methods in order to use /// call that function here as well [Panikon] StrBuf->Clear(&buf); StrBuf->Printf(&buf,"INSERT INTO `%s` (`guild_id`,`nameid`,`amount`,`equip`,`identify`,`refine`," @@ -419,7 +419,7 @@ int mapif_parse_ItemBoundRetrieve_sub(int fd) mapif_load_guild_storage(fd,aid,guild_id,0); // If character is logged in char, disconnect - char_disconnect_player(aid); + chr->disconnect_player(aid); #endif return 0; } diff --git a/src/char/inter.c b/src/char/inter.c index 83679aa21..cda4c8ed8 100644 --- a/src/char/inter.c +++ b/src/char/inter.c @@ -23,6 +23,7 @@ #include "int_pet.h" #include "int_quest.h" #include "int_storage.h" +#include "mapif.h" #include "../common/cbasetypes.h" #include "../common/db.h" #include "../common/malloc.h" @@ -630,7 +631,7 @@ void mapif_parse_accinfo(int fd) { /* it will only get here if we have a single match */ /* and we will send packet with account id to login server asking for account info */ if( account_id ) { - mapif_on_parse_accinfo(account_id, u_fd, aid, castergroup, fd); + mapif->on_parse_accinfo(account_id, u_fd, aid, castergroup, fd); } return; @@ -700,7 +701,7 @@ void inter_savereg(int account_id, int char_id, const char *key, unsigned int in /* to login server we go! */ if( key[0] == '#' && key[1] == '#' ) {/* global account reg */ if( session_isValid(login_fd) ) - char_global_accreg_to_login_add(key,index,val,is_string); + chr->global_accreg_to_login_add(key,index,val,is_string); else { ShowError("Login server unavailable, cant perform update on '%s' variable for AID:%d CID:%d\n",key,account_id,char_id); } @@ -1081,7 +1082,7 @@ int mapif_broadcast(unsigned char *mes, int len, unsigned int fontColor, short f WBUFW(buf,12) = fontAlign; WBUFW(buf,14) = fontY; memcpy(WBUFP(buf,16), mes, len - 16); - mapif_sendallwos(sfd, buf, len); + mapif->sendallwos(sfd, buf, len); if (buf) aFree(buf); @@ -1100,7 +1101,7 @@ int mapif_wis_message(struct WisData *wd) memcpy(WBUFP(buf, 8), wd->src, NAME_LENGTH); memcpy(WBUFP(buf,32), wd->dst, NAME_LENGTH); memcpy(WBUFP(buf,56), wd->msg, wd->len); - wd->count = mapif_sendall(buf,WBUFW(buf,2)); + wd->count = mapif->sendall(buf,WBUFW(buf,2)); return 0; } @@ -1111,7 +1112,7 @@ void mapif_wis_response(int fd, unsigned char *src, int flag) WBUFW(buf, 0)=0x3802; memcpy(WBUFP(buf, 2),src,24); WBUFB(buf,26)=flag; - mapif_send(fd,buf,27); + mapif->send(fd,buf,27); } // Wis sending result @@ -1125,7 +1126,7 @@ int mapif_wis_end(struct WisData *wd, int flag) //static void mapif_account_reg(int fd, unsigned char *src) //{ // WBUFW(src,0)=0x3804; //NOTE: writing to RFIFO -// mapif_sendallwos(fd, src, WBUFW(src,2)); +// mapif->sendallwos(fd, src, WBUFW(src,2)); //} // Send the requested account_reg @@ -1291,7 +1292,7 @@ int mapif_parse_WisToGM(int fd) memcpy(WBUFP(buf,0), RFIFOP(fd,0), RFIFOW(fd,2)); WBUFW(buf, 0) = 0x3803; - mapif_sendall(buf, RFIFOW(fd,2)); + mapif->sendall(buf, RFIFOW(fd,2)); return 0; } @@ -1308,7 +1309,7 @@ int mapif_parse_Registry(int fd) bool isLoginActive = session_isActive(login_fd); if( isLoginActive ) - char_global_accreg_to_login_start(account_id,char_id); + chr->global_accreg_to_login_start(account_id,char_id); for(i = 0; i < count; i++) { safestrncpy(key, (char*)RFIFOP(fd, cursor + 1), RFIFOB(fd, cursor)); @@ -1344,7 +1345,7 @@ int mapif_parse_Registry(int fd) } if( isLoginActive ) - char_global_accreg_to_login_send(); + chr->global_accreg_to_login_send(); } return 0; } @@ -1357,7 +1358,7 @@ int mapif_parse_RegistryRequest(int fd) //Load Account Registry if (RFIFOB(fd,11)) mapif_account_reg_reply(fd,RFIFOL(fd,2),RFIFOL(fd,6),2); //Ask Login Server for Account2 values. - if (RFIFOB(fd,10)) char_request_accreg2(RFIFOL(fd,2),RFIFOL(fd,6)); + if (RFIFOB(fd,10)) chr->request_accreg2(RFIFOL(fd,2),RFIFOL(fd,6)); return 1; } diff --git a/src/char/loginif.c b/src/char/loginif.c new file mode 100644 index 000000000..4026d1f7d --- /dev/null +++ b/src/char/loginif.c @@ -0,0 +1,45 @@ +// Copyright (c) Hercules Dev Team, licensed under GNU GPL. +// See the LICENSE file +// Portions Copyright (c) Athena Dev Teams + +#define HERCULES_CORE + +#include "loginif.h" + +#include + +#include "char.h" +#include "../common/cbasetypes.h" +#include "../common/mmo.h" +#include "../common/random.h" +#include "../common/showmsg.h" +#include "../common/socket.h" +#include "../common/strlib.h" + +void loginif_reset(void); +void loginif_check_shutdown(void); +void loginif_on_disconnect(void); +void loginif_on_ready(void); +void loginif_block_account(int account_id, int flag); +void loginif_ban_account(int account_id, short year, short month, short day, short hour, short minute, short second); +void loginif_unban_account(int account_id); +void loginif_changesex(int account_id); +void loginif_auth(int fd, struct char_session_data* sd, uint32 ipl); +void loginif_send_users_count(int users); +void loginif_connect_to_server(void); + +void loginif_defaults(void) { + loginif = &loginif_s; + + loginif->reset = loginif_reset; + loginif->check_shutdown = loginif_check_shutdown; + loginif->on_disconnect = loginif_on_disconnect; + loginif->on_ready = loginif_on_ready; + loginif->block_account = loginif_block_account; + loginif->ban_account = loginif_ban_account; + loginif->unban_account = loginif_unban_account; + loginif->changesex = loginif_changesex; + loginif->auth = loginif_auth; + loginif->send_users_count = loginif_send_users_count; + loginif->connect_to_server = loginif_connect_to_server; +} diff --git a/src/char/loginif.h b/src/char/loginif.h new file mode 100644 index 000000000..325e7d75f --- /dev/null +++ b/src/char/loginif.h @@ -0,0 +1,29 @@ +// Copyright (c) Hercules Dev Team, licensed under GNU GPL. +// See the LICENSE file +// Portions Copyright (c) Athena Dev Teams + +#ifndef CHAR_LOGINIF_H +#define CHAR_LOGINIF_H + +#include "char.h" + +/* loginif interface */ +struct loginif_interface { + void (*reset) (void); + void (*check_shutdown) (void); + void (*on_disconnect) (void); + void (*on_ready) (void); + void (*block_account) (int account_id, int flag); + void (*ban_account) (int account_id, short year, short month, short day, short hour, short minute, short second); + void (*unban_account) (int account_id); + void (*changesex) (int account_id); + void (*auth) (int fd, struct char_session_data* sd, uint32 ipl); + void (*send_users_count) (int users); + void (*connect_to_server) (void); +} loginif_s; + +struct loginif_interface *loginif; + +void loginif_defaults(void); + +#endif /* CHAR_LOGINIF_H */ diff --git a/src/char/mapif.c b/src/char/mapif.c new file mode 100644 index 000000000..7c807e21f --- /dev/null +++ b/src/char/mapif.c @@ -0,0 +1,45 @@ +// Copyright (c) Hercules Dev Team, licensed under GNU GPL. +// See the LICENSE file +// Portions Copyright (c) Athena Dev Teams + +#define HERCULES_CORE + +#include "mapif.h" + +#include + +#include "char.h" +#include "../common/cbasetypes.h" +#include "../common/mmo.h" +#include "../common/random.h" +#include "../common/showmsg.h" +#include "../common/socket.h" +#include "../common/strlib.h" + +void mapif_ban(int id, unsigned int flag, int status); +void mapif_server_init(int id); +void mapif_server_destroy(int id); +void mapif_server_reset(int id); +void mapif_on_disconnect(int id); +void mapif_on_parse_accinfo(int account_id, int u_fd, int u_aid, int u_group, int map_fd); +void mapif_char_ban(int char_id, time_t timestamp); +int mapif_sendall(unsigned char *buf, unsigned int len); +int mapif_sendallwos(int sfd, unsigned char *buf, unsigned int len); +int mapif_send(int fd, unsigned char *buf, unsigned int len); +void mapif_send_users_count(int users); + +void mapif_defaults(void) { + mapif = &mapif_s; + + mapif->ban = mapif_ban; + mapif->server_init = mapif_server_init; + mapif->server_destroy = mapif_server_destroy; + mapif->server_reset = mapif_server_reset; + mapif->on_disconnect = mapif_on_disconnect; + mapif->on_parse_accinfo = mapif_on_parse_accinfo; + mapif->char_ban = mapif_char_ban; + mapif->sendall = mapif_sendall; + mapif->sendallwos = mapif_sendallwos; + mapif->send = mapif_send; + mapif->send_users_count = mapif_send_users_count; +} diff --git a/src/char/mapif.h b/src/char/mapif.h new file mode 100644 index 000000000..089fb751b --- /dev/null +++ b/src/char/mapif.h @@ -0,0 +1,29 @@ +// Copyright (c) Hercules Dev Team, licensed under GNU GPL. +// See the LICENSE file +// Portions Copyright (c) Athena Dev Teams + +#ifndef CHAR_MAPIF_H +#define CHAR_MAPIF_H + +#include "char.h" + +/* mapif interface */ +struct mapif_interface { + void (*ban) (int id, unsigned int flag, int status); + void (*server_init) (int id); + void (*server_destroy) (int id); + void (*server_reset) (int id); + void (*on_disconnect) (int id); + void (*on_parse_accinfo) (int account_id, int u_fd, int u_aid, int u_group, int map_fd); + void (*char_ban) (int char_id, time_t timestamp); + int (*sendall) (unsigned char *buf, unsigned int len); + int (*sendallwos) (int sfd, unsigned char *buf, unsigned int len); + int (*send) (int fd, unsigned char *buf, unsigned int len); + void (*send_users_count) (int users); +} mapif_s; + +struct mapif_interface *mapif; + +void mapif_defaults(void); + +#endif /* CHAR_MAPIF_H */ -- cgit v1.2.3-60-g2f50