#include "char.hpp" // char.cpp - Character server. // // Copyright © ????-2004 Athena Dev Teams // Copyright © 2004-2011 The Mana World Development Team // Copyright © 2011-2014 Ben Longbons // Copyright © 2013-2014 MadCamel // // This file is part of The Mana World (Athena server) // // This program is free software: you can redistribute it and/or modify // it under the terms of the GNU General Public License as published by // the Free Software Foundation, either version 3 of the License, or // (at your option) any later version. // // This program is distributed in the hope that it will be useful, // but WITHOUT ANY WARRANTY; without even the implied warranty of // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the // GNU General Public License for more details. // // You should have received a copy of the GNU General Public License // along with this program. If not, see . #include #include #include #include #include #include #include #include #include #include #include #include "../ints/cmp.hpp" #include "../ints/udl.hpp" #include "../strings/mstring.hpp" #include "../strings/astring.hpp" #include "../strings/zstring.hpp" #include "../strings/xstring.hpp" #include "../generic/array.hpp" #include "../generic/db.hpp" #include "../io/cxxstdio.hpp" #include "../io/extract.hpp" #include "../io/lock.hpp" #include "../io/read.hpp" #include "../io/span.hpp" #include "../io/tty.hpp" #include "../io/write.hpp" #include "../net/socket.hpp" #include "../net/timer.hpp" #include "../proto2/any-user.hpp" #include "../proto2/login-admin.hpp" #include "../proto2/login-char.hpp" #include "../proto2/login-user.hpp" #include "../proto2/char-map.hpp" #include "../proto2/char-user.hpp" #include "../mmo/config_parse.hpp" #include "../mmo/cxxstdio_enums.hpp" #include "../mmo/extract_enums.hpp" #include "../mmo/human_time_diff.hpp" #include "../mmo/version.hpp" #include "../high/core.hpp" #include "../high/extract_mmo.hpp" #include "../high/mmo.hpp" #include "../high/utils.hpp" #include "../wire/packets.hpp" #include "char_conf.hpp" #include "char_lan_conf.hpp" #include "globals.hpp" #include "inter.hpp" #include "inter_conf.hpp" #include "int_party.hpp" #include "int_storage.hpp" #include "../poison.hpp" namespace tmwa { namespace char_ { struct char_session_data : SessionData { bool auth; // whether the session is authed or not AccountId account_id; int login_id1, login_id2; SEX sex; ClientVersion client_version; AccountEmail email; int consumed_by; // amount of map servers for which we are authed }; } // namespace char_ void SessionDeleter::operator()(SessionData *sd) { really_delete1 static_cast(sd); } namespace char_ { auto iter_map_sessions() -> decltype(filter_iterator(std::declval *>())) { return filter_iterator(&server_session); } static void create_online_files(void); static void delete_tologin(Session *sess) { assert (sess == login_session); PRINTF("Char-server can't connect to login-server (connection #%d).\n"_fmt, sess); login_session = nullptr; } static void delete_char(Session *sess) { (void)sess; } static void delete_frommap(Session *sess) { auto it = std::find(server_session.begin(), server_session.end(), sess); assert (it != server_session.end()); int id = it - server_session.begin(); CHAR_LOG_AND_ECHO("Map-server %d (session #%d) has disconnected.\n"_fmt, id, sess); server[id] = mmo_map_server{}; server_session[id] = nullptr; for (Session *& oci : online_chars) if (oci == sess) oci = nullptr; create_online_files(); // update online players files (to remove all online players of this server) } //------------------------------ // Writing function of logs file //------------------------------ void char_log(XString line) { io::AppendFile logfp(char_conf.char_log_filename, true); if (!logfp.is_open()) return; log_with_timestamp(logfp, line); } //---------------------------------------------------------------------- // Determine if an account (id) is a GM account // and returns its level (or 0 if it isn't a GM account or if not found) //---------------------------------------------------------------------- static GmLevel isGM(AccountId account_id) { for (GM_Account& gma : gm_accounts) if (gma.account_id == account_id) return gma.level; return default_gm_level; } //---------------------------------------------- // Search an character id // (return character pointer or nullptr (if not found)) // If exact character name is not found, // the function checks without case sensitive // and returns index if only 1 character is found // and similar to the searched name. //---------------------------------------------- const CharPair *search_character(CharName character_name) { for (const CharPair& cd : char_keys) { { // Strict comparison (if found, we finish the function immediatly with correct value) if (cd.key.name == character_name) return &cd; } } // Exact character name is not found and 0 or more than 1 similar characters have been found ==> we say not found return nullptr; } const CharPair *search_character_id(CharId char_id) { for (const CharPair& cd : char_keys) { if (cd.key.char_id == char_id) return &cd; } return nullptr; } // TODO make these DIE already Session *server_for(const CharPair *mcs) { if (!mcs) return nullptr; return online_chars[mcs - &char_keys.front()]; } static Session *& server_for_m(const CharPair *mcs) { return online_chars[mcs - &char_keys.front()]; } //------------------------------------------------- // Function to create the character line (for save) //------------------------------------------------- static AString mmo_char_tostr(struct CharPair *cp) { CharKey *k = &cp->key; CharData *p = cp->data.get(); // on multi-map server, sometimes it's posssible that last_point become void. (reason???) We check that to not lost character at restart. if (!p->last_point.map_) { p->last_point = char_conf.start_point; } if (p->sex == SEX::UNSPECIFIED) { for (AuthFifoEntry& afi : auth_fifo) { if (afi.account_id == k->account_id) { p->sex = afi.sex; } } } MString str_p; str_p += STRPRINTF( "%d\t" "%d,%d\t" "%s\t" "%d,%d,%d\t" "%d,%d,%d\t" "%d,%d,%d,%d\t" "%d,%d,%d,%d,%d,%d\t" "%d,%d\t" "%d,%d,%d\t" "%d,%d,%d\t" "%d,%d,%d\t" "%d,%d,%d,%d,%d\t" "%s,%d,%d\t" "%s,%d,%d,%d\t" "%c\t"_fmt, k->char_id, k->account_id, k->char_num, k->name, p->species, p->base_level, p->job_level, p->base_exp, p->job_exp, p->zeny, p->hp, p->max_hp, p->sp, p->max_sp, p->attrs[ATTR::STR], p->attrs[ATTR::AGI], p->attrs[ATTR::VIT], p->attrs[ATTR::INT], p->attrs[ATTR::DEX], p->attrs[ATTR::LUK], p->status_point, p->skill_point, p->option, p->karma, p->manner, p->party_id, 0/*guild_id*/, 0/*pet_id*/, p->hair, p->hair_color, p->clothes_color, p->weapon, p->shield, p->head_top, p->head_mid, p->head_bottom, p->last_point.map_, p->last_point.x, p->last_point.y, p->save_point.map_, p->save_point.x, p->save_point.y, p->partner_id, sex_to_char(p->sex)); for (IOff0 i : IOff0::iter()) { if (p->inventory[i].nameid) { str_p += STRPRINTF("%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d,%d "_fmt, 0 /*id*/, p->inventory[i].nameid, p->inventory[i].amount, p->inventory[i].equip, 1 /*identify*/, 0 /*refine*/, 0 /*attribute*/, 0 /*card[0]*/, 0 /*card[1]*/, 0 /*card[2]*/, 0 /*card[3]*/, 0 /*broken*/); } } str_p += '\t'; // cart was here (no longer supported) str_p += '\t'; for (SkillID i : erange(SkillID(), MAX_SKILL)) { if (p->skill[i].lv) { str_p += STRPRINTF("%d,%d "_fmt, i, p->skill[i].lv | (static_cast(p->skill[i].flags) << 16)); } } str_p += '\t'; assert (p->global_reg_num < GLOBAL_REG_NUM); for (int i = 0; i < p->global_reg_num; i++) { if (p->global_reg[i].str) { str_p += STRPRINTF("%s,%d "_fmt, p->global_reg[i].str, p->global_reg[i].value); } } str_p += '\t'; return AString(str_p); } struct skill_loader { SkillID id; uint16_t level; SkillFlags flags; }; static bool impl_extract(XString str, struct skill_loader *s) { uint32_t flags_and_level; if (!extract(str, record<','>(&s->id, &flags_and_level))) return false; s->level = flags_and_level & 0xffff; s->flags = SkillFlags(flags_and_level >> 16); return true; } } // namespace char //------------------------------------------------------------------------- // Function to set the character from the line (at read of characters file) //------------------------------------------------------------------------- static bool impl_extract(XString str, CharPair *cp) { using namespace tmwa::char_; CharKey *k = &cp->key; CharData *p = cp->data.get(); uint32_t unused_guild_id, unused_pet_id; VString<1> sex; XString unused_memos; std::vector inventory; XString unused_cart; std::vector skills; std::vector vars; XString hair_style; if (!extract(str, record<'\t'>( &k->char_id, record<','>(&k->account_id, &k->char_num), &k->name, record<','>(&p->species, &p->base_level, &p->job_level), record<','>(&p->base_exp, &p->job_exp, &p->zeny), record<','>(&p->hp, &p->max_hp, &p->sp, &p->max_sp), record<','>(&p->attrs[ATTR::STR], &p->attrs[ATTR::AGI], &p->attrs[ATTR::VIT], &p->attrs[ATTR::INT], &p->attrs[ATTR::DEX], &p->attrs[ATTR::LUK]), record<','>(&p->status_point, &p->skill_point), record<','>(&p->option, &p->karma, &p->manner), record<','>(&p->party_id, &unused_guild_id, &unused_pet_id), record<','>(&hair_style, &p->hair_color, &p->clothes_color), record<','>(&p->weapon, &p->shield, &p->head_top, &p->head_mid, &p->head_bottom), &p->last_point, // somebody was silly and stuck partner id as a field // of this, instead of adding a new \t // or putting it elsewhere, like by pet/guild record<','>(&p->save_point.map_, &p->save_point.x, &p->save_point.y, &p->partner_id), &sex, vrec<' '>(&inventory), &unused_cart, vrec<' '>(&skills), vrec<' '>(&vars)))) return false; if (sex.size() != 1) p->sex = SEX::UNSPECIFIED; else p->sex = sex_from_char(sex.front()); // leftover corruption from Platinum if (hair_style == "-1"_s) { p->hair = 0; } else if (!extract(hair_style, &p->hair)) return false; if (WISP_SERVER_NAME == k->name) return false; // TODO replace *every* lookup with a map lookup static std::set seen_ids; static std::set seen_names; // we don't have to worry about deleted characters, // this is only called during startup auto _seen_id = seen_ids.insert(k->char_id); if (!_seen_id.second) return false; auto _seen_name = seen_names.insert(k->name); if (!_seen_name.second) { seen_ids.erase(_seen_id.first); return false; } // memos were here - no longer supported if (inventory.size() > MAX_INVENTORY) return false; std::copy(inventory.begin(), inventory.end(), p->inventory.begin()); // number of inventory items is not saved - it just detects nameid 0 // cart was here - no longer supported for (struct skill_loader& sk : skills) { if (sk.id >= MAX_SKILL) return false; p->skill[sk.id].lv = sk.level; p->skill[sk.id].flags = sk.flags; } if (vars.size() > GLOBAL_REG_NUM) return false; std::copy(vars.begin(), vars.end(), p->global_reg.begin()); p->global_reg_num = vars.size(); return true; } namespace char_ { //--------------------------------- // Function to read characters file //--------------------------------- static int mmo_char_init(void) { char_keys.clear(); online_chars.clear(); io::ReadFile in(char_conf.char_txt); if (!in.is_open()) { CHAR_LOG_AND_ECHO("Characters file not found: %s.\n"_fmt, char_conf.char_txt); CHAR_LOG_AND_ECHO("Id for the next created character: %d.\n"_fmt, char_id_count); return 0; } int line_count = 0; AString line; while (in.getline(line)) { line_count++; if (is_comment(line)) continue; { CharId i; if (extract(line, record<'\t'>(&i, "%newid%"_s))) { if (char_id_count < i) char_id_count = i; continue; } } CharPair cd; if (!extract(line, &cd)) { CHAR_LOG_AND_ECHO("Char skipped\n%s"_fmt, line); continue; } if (char_id_count < next(cd.key.char_id)) char_id_count = next(cd.key.char_id); char_keys.push_back(std::move(cd)); online_chars.push_back(nullptr); } CHAR_LOG_AND_ECHO("mmo_char_init: %zu characters read in %s.\n"_fmt, char_keys.size(), char_conf.char_txt); CHAR_LOG_AND_ECHO("Id for the next created character: %d.\n"_fmt, char_id_count); return 0; } //--------------------------------------------------------- // Function to save characters in files (speed up by [Yor]) //--------------------------------------------------------- static void mmo_char_sync(void) { io::WriteLock fp(char_conf.char_txt); if (!fp.is_open()) { CHAR_LOG_AND_ECHO("WARNING: Server can't save characters!\n"_fmt); return; } { // yes, we need a mutable reference to do the saves ... for (CharPair& cd : char_keys) { AString line = mmo_char_tostr(&cd); fp.put_line(line); } FPRINTF(fp, "%d\t%%newid%%\n"_fmt, char_id_count); } } //---------------------------------------------------- // Function to save (in a periodic way) datas in files //---------------------------------------------------- static void mmo_char_sync_timer(TimerData *, tick_t) { if (pid != 0) { int status; pid_t temp = waitpid(pid, &status, WNOHANG); // Need to check status too? if (temp == 0) { return; } } // This can take a lot of time. Fork a child to handle the work and return at once // If we're unable to fork just continue running the function normally if ((pid = fork()) > 0) { return; } // If we're a child, run as a lower priority process if (pid == 0) setpriority(PRIO_PROCESS, getpid(), 10); mmo_char_sync(); inter_save(); // If we're a child we should suicide now. if (pid == 0) _exit(0); } //----------------------------------- // Function to create a new character //----------------------------------- static CharPair *make_new_char(Session *s, CharName name, const Stats6& stats, uint8_t slot, uint16_t hair_color, uint16_t hair_style, short& error_code) { // ugh char_session_data *sd = static_cast(s->session_data.get()); // remove control characters from the name if (!name.to__actual().is_print()) { CHAR_LOG("Make new char error (control char received in the name): (connection #%d, account: %d).\n"_fmt, s, sd->account_id); error_code = 0x02; return nullptr; } // Eliminate whitespace if (name.to__actual() != name.to__actual().strip()) { CHAR_LOG("Make new char error (leading/trailing whitespace): (connection #%d, account: %d, name: '%s'.\n"_fmt, s, sd->account_id, name); error_code = 0x02; return nullptr; } // check lenght of character name if (name.to__actual().size() < char_conf.min_name_length) { CHAR_LOG("Make new char error (character name too small): (connection #%d, account: %d, name: '%s').\n"_fmt, s, sd->account_id, name); error_code = 0x02; return nullptr; } // Check Authorised letters/symbols in the name of the character { // only letters/symbols in char_name_letters are authorised for (uint8_t c : name.to__actual()) { if (!char_conf.char_name_letters[c]) { CHAR_LOG("Make new char error (invalid letter in the name): (connection #%d, account: %d), name: %s, invalid letter: %c.\n"_fmt, s, sd->account_id, name, c); error_code = 0x02; return nullptr; } } } // TODO this comment is obsolete // this is why it needs to be unsigned if (stats.str + stats.agi + stats.vit + stats.int_ + stats.dex + stats.luk != char_conf.total_stat_sum) { CHAR_LOG("Make new char error (invalid stats): (connection #%d, account: %d) slot %d, name: %s, stats: %d+%d+%d+%d+%d+%d=%d\n"_fmt, s, sd->account_id, slot, name, stats.str, stats.agi, stats.vit, stats.int_, stats.dex, stats.luk, stats.str + stats.agi + stats.vit + stats.int_ + stats.dex + stats.luk); error_code = 0x03; return nullptr; } if (slot >= char_conf.char_slots) { CHAR_LOG("Make new char error (invalid slot): (connection #%d, account: %d) slot %d, name: %s\n"_fmt, s, sd->account_id, slot, name); error_code = 0x05; return nullptr; } if (hair_style > char_conf.max_hair_style || hair_color > char_conf.max_hair_color) { CHAR_LOG("Make new char error (invalid hair): (connection #%d, account: %d) slot %d, name: %s, hair: %d, hair color: %d\n"_fmt, s, sd->account_id, slot, name, hair_style, hair_color); error_code = 0x04; return nullptr; } // check individual stat value for (int i = 0; i < 6; i++) { uint8_t statsi = reinterpret_cast(&stats)[i]; if (statsi < char_conf.min_stat_value || statsi > char_conf.max_stat_value) { CHAR_LOG("Make new char error (invalid stat value: not between 1 to 9): (connection #%d, account: %d) slot %d, name: %s, stats: %d+%d+%d+%d+%d+%d=%d, hair: %d, hair color: %d\n"_fmt, s, sd->account_id, slot, name, stats.str, stats.agi, stats.vit, stats.int_, stats.dex, stats.luk, stats.str + stats.agi + stats.vit + stats.int_ + stats.dex + stats.luk, hair_style, hair_color); error_code = 0x03; return nullptr; } } for (const CharPair& cd : char_keys) { if (cd.key.name == name) { CHAR_LOG("Make new char error (name already exists): (connection #%d, account: %d) slot %d, name: %s (actual name of other char: %s), stats: %d+%d+%d+%d+%d+%d=%d, hair: %d, hair color: %d.\n"_fmt, s, sd->account_id, slot, name, cd.key.name, stats.str, stats.agi, stats.vit, stats.int_, stats.dex, stats.luk, stats.str + stats.agi + stats.vit + stats.int_ + stats.dex + stats.luk, hair_style, hair_color); error_code = 0x01; return nullptr; } if (cd.key.account_id == sd->account_id && cd.key.char_num == slot) { CHAR_LOG("Make new char error (slot already used): (connection #%d, account: %d) slot %d, name: %s (actual name of other char: %s), stats: %d+%d+%d+%d+%d+%d=%d, hair: %d, hair color: %d.\n"_fmt, s, sd->account_id, slot, name, cd.key.name, stats.str, stats.agi, stats.vit, stats.int_, stats.dex, stats.luk, stats.str + stats.agi + stats.vit + stats.int_ + stats.dex + stats.luk, hair_style, hair_color); error_code = 0x05; return nullptr; } } if (WISP_SERVER_NAME == name) { CHAR_LOG("Make new char error (name used is wisp name for server): (connection #%d, account: %d) slot %d, name: %s (actual name whisper server: %s), stats: %d+%d+%d+%d+%d+%d=%d, hair: %d, hair color: %d.\n"_fmt, s, sd->account_id, slot, name, WISP_SERVER_NAME, stats.str, stats.agi, stats.vit, stats.int_, stats.dex, stats.luk, stats.str + stats.agi + stats.vit + stats.int_ + stats.dex + stats.luk, hair_style, hair_color); error_code = 0x01; return nullptr; } IP4Address ip = s->client_ip; CHAR_LOG("Creation of New Character: (connection #%d, account: %d) slot %d, character Name: %s, stats: %d+%d+%d+%d+%d+%d=%d, hair: %d, hair color: %d. [%s]\n"_fmt, s, sd->account_id, slot, name, stats.str, stats.agi, stats.vit, stats.int_, stats.dex, stats.luk, stats.str + stats.agi + stats.vit + stats.int_ + stats.dex + stats.luk, hair_style, hair_color, ip); CharPair cp; CharKey& ck = cp.key; CharData& cd = *cp.data; ck.char_id = char_id_count; char_id_count = next(char_id_count); ck.account_id = sd->account_id; ck.char_num = slot; ck.name = name; cd.species = Species(); cd.sex = SEX::NEUTRAL; cd.base_level = 1; cd.job_level = 1; cd.base_exp = 0; cd.job_exp = 0; cd.zeny = 0; cd.attrs[ATTR::STR] = stats.str; cd.attrs[ATTR::AGI] = stats.agi; cd.attrs[ATTR::VIT] = stats.vit; cd.attrs[ATTR::INT] = stats.int_; cd.attrs[ATTR::DEX] = stats.dex; cd.attrs[ATTR::LUK] = stats.luk; cd.max_hp = 40 * (100 + cd.attrs[ATTR::VIT]) / 100; cd.max_sp = 11 * (100 + cd.attrs[ATTR::INT]) / 100; cd.hp = cd.max_hp; cd.sp = cd.max_sp; cd.status_point = 0; cd.skill_point = 0; cd.option = static_cast(0x0000); // Opt0 is only declared cd.karma = 0; cd.manner = 0; cd.party_id = PartyId(); //cd.guild_id = 0; cd.hair = hair_style; cd.hair_color = hair_color; cd.clothes_color = 0; // removed initial armor/weapon - unused and problematic cd.weapon = ItemLook::NONE; cd.shield = ItemNameId(); cd.head_top = ItemNameId(); cd.head_mid = ItemNameId(); cd.head_bottom = ItemNameId(); cd.last_point = char_conf.start_point; cd.save_point = char_conf.start_point; char_keys.push_back(std::move(cp)); online_chars.push_back(nullptr); return &char_keys.back(); } //------------------------------------------------------------- // Function to create the online files (txt and html). by [Yor] //------------------------------------------------------------- static void create_online_files(void) { // write files io::WriteFile fp(char_conf.online_txt_filename); if (fp.is_open()) { io::WriteFile fp2(char_conf.online_html_filename); if (fp2.is_open()) { // get time timestamp_seconds_buffer timetemp; stamp_time(timetemp); // write heading FPRINTF(fp2, "\n"_fmt); FPRINTF(fp2, " \n"_fmt, char_conf.online_refresh_html); // update on client explorer every x seconds FPRINTF(fp2, " \n"_fmt); FPRINTF(fp2, " Online Players on %s\n"_fmt, char_conf.server_name); FPRINTF(fp2, " \n"_fmt); FPRINTF(fp2, " \n"_fmt); FPRINTF(fp2, "

Online Players on %s (%s):

\n"_fmt, char_conf.server_name, timetemp); FPRINTF(fp, "Online Players on %s (%s):\n"_fmt, char_conf.server_name, timetemp); FPRINTF(fp, "\n"_fmt); int players = 0; // This used to be conditional on having any players, // but this simplifies the logic. //if (players > 0) { int j = 0; // count the number of characters for the txt version and to set the separate line FPRINTF(fp2, " \n"_fmt); FPRINTF(fp2, " \n"_fmt); { FPRINTF(fp2, " \n"_fmt); { FPRINTF(fp, "Name "_fmt); // 30 j += 30; } } FPRINTF(fp2, " \n"_fmt); FPRINTF(fp, "\n"_fmt); for (int k = 0; k < j; k++) FPRINTF(fp, "-"_fmt); FPRINTF(fp, "\n"_fmt); // display each player. for (CharPair& cd : char_keys) { if (!server_for(&cd)) continue; players++; FPRINTF(fp2, " \n"_fmt); // displaying the character name { // without/with 'GM' display GmLevel gml = isGM(cd.key.account_id); { if ((gml.satisfies(char_conf.online_gm_display_min_level) && (gml.get_all_bits() == 60)) || gml.satisfies(GmLevel::from(99_u32))) FPRINTF(fp, "%-24s (GM) "_fmt, cd.key.name); else FPRINTF(fp, "%-24s "_fmt, cd.key.name); } // name of the character in the html (no < >, because that create problem in html code) FPRINTF(fp2, " \n"_fmt); } FPRINTF(fp, "\n"_fmt); FPRINTF(fp2, " \n"_fmt); } FPRINTF(fp2, "
Name
"_fmt); if ((gml.satisfies(char_conf.online_gm_display_min_level) && !(gml.get_all_bits() % 10)) || gml.satisfies(GmLevel::from(99_u32))) FPRINTF(fp2, ""_fmt); for (char c : cd.key.name.to__actual()) { switch (c) { case '&': FPRINTF(fp2, "&"_fmt); break; case '<': FPRINTF(fp2, "<"_fmt); break; case '>': FPRINTF(fp2, ">"_fmt); break; default: FPRINTF(fp2, "%c"_fmt, c); break; }; } if ((gml.satisfies(char_conf.online_gm_display_min_level) && !(gml.get_all_bits() % 10)) || gml.satisfies(GmLevel::from(99_u32))) { if (gml.get_all_bits() == 40) { FPRINTF(fp2, " (DEV)"_fmt); } if (gml.get_all_bits() == 50) { FPRINTF(fp2, " (EVTC)"_fmt); } if (gml.get_all_bits() == 60) { FPRINTF(fp2, " (GM)"_fmt); } if (gml.get_all_bits() == 80) { FPRINTF(fp2, " (DEV)"_fmt); } if (gml.get_all_bits() == 99) { FPRINTF(fp2, " (ADM)"_fmt); } else { FPRINTF(fp2, ""_fmt); } } FPRINTF(fp2, "
\n"_fmt); FPRINTF(fp, "\n"_fmt); } // Displaying number of online players if (players == 0) { FPRINTF(fp2, "

No user is online.

\n"_fmt); FPRINTF(fp, "No user is online.\n"_fmt); } else if (players == 1) { // no display if only 1 player } else { FPRINTF(fp2, "

%d users are online.

\n"_fmt, players); FPRINTF(fp, "%d users are online.\n"_fmt, players); } FPRINTF(fp2, " \n"_fmt); FPRINTF(fp2, "\n"_fmt); } } return; } //--------------------------------------------------------------------- // This function return the number of online players in all map-servers //--------------------------------------------------------------------- static int count_users(void) { int i, users; users = 0; for (i = 0; i < MAX_MAP_SERVERS; i++) if (server_session[i]) users += server[i].users; return users; } //---------------------------------------- // [Fate] Find inventory item based on equipment mask, return view. ID must match view ID (!). //---------------------------------------- static ItemNameId find_equip_view(const CharPair *cp, EPOS equipmask) { CharData *p = cp->data.get(); for (IOff0 i : IOff0::iter()) { if (p->inventory[i].nameid && p->inventory[i].amount && bool(p->inventory[i].equip & equipmask)) { return p->inventory[i].nameid; } } return ItemNameId(); } //---------------------------------------- // Function to send characters to a player //---------------------------------------- static int mmo_char_send006b(Session *s, struct char_session_data *sd) { int found_num = 0; std::array found_char; for (const CharPair& cd : char_keys) { if (cd.key.account_id == sd->account_id) { found_char[found_num] = &cd; found_num++; if (found_num == 9) break; } } Packet_Head<0x006b> head_6b; std::vector> repeat_6b; head_6b.unused = {}; for (int i = 0; i < found_num; i++) { const CharPair *cp = found_char[i]; const CharKey *k = &cp->key; const CharData *p = cp->data.get(); Packet_Repeat<0x006b> info; CharSelect& sel = info.char_select; sel.char_id = k->char_id; sel.base_exp = p->base_exp; sel.zeny = p->zeny; sel.job_exp = p->job_exp; sel.job_level = p->job_level; sel.shoes = find_equip_view(cp, EPOS::SHOES); sel.gloves = find_equip_view(cp, EPOS::GLOVES); sel.cape = find_equip_view(cp, EPOS::CAPE); sel.misc1 = find_equip_view(cp, EPOS::MISC1); sel.option = p->option; sel.karma = p->karma; sel.manner = p->manner; sel.status_point = p->status_point; sel.hp = std::min(p->hp, 0x7fff); sel.max_hp = std::min(p->max_hp, 0x7fff); sel.sp = std::min(p->sp, 0x7fff); sel.max_sp = std::min(p->max_sp, 0x7fff); sel.speed = static_cast(DEFAULT_WALK_SPEED.count()); // p->speed; sel.species = p->species; sel.hair_style = p->hair; sel.weapon = 0; // p->weapon; // dont send weapon since TMW does not support it sel.base_level = p->base_level; sel.skill_point = p->skill_point; sel.head_bottom = p->head_bottom; sel.shield = p->shield; sel.head_top = p->head_top; sel.head_mid = p->head_mid; sel.hair_color = p->hair_color; sel.misc2 = find_equip_view(cp, EPOS::MISC2); // = p->clothes_color; sel.char_name = k->name; sel.stats.str = saturate(p->attrs[ATTR::STR]); sel.stats.agi = saturate(p->attrs[ATTR::AGI]); sel.stats.vit = saturate(p->attrs[ATTR::VIT]); sel.stats.int_ = saturate(p->attrs[ATTR::INT]); sel.stats.dex = saturate(p->attrs[ATTR::DEX]); sel.stats.luk = saturate(p->attrs[ATTR::LUK]); sel.char_num = k->char_num; if (p->sex == SEX::UNSPECIFIED) sel.sex = sd->sex; else sel.sex = p->sex; repeat_6b.push_back(info); } send_vpacket<0x006b, 24, 106>(s, head_6b, repeat_6b); return 0; } static int set_account_reg2(AccountId acc, Slice reg) { size_t num = reg.size(); assert (num < ACCOUNT_REG2_NUM); int c = 0; for (CharPair& cd : char_keys) { if (cd.key.account_id == acc) { for (int i = 0; i < num; ++i) cd.data->account_reg2[i] = reg[i]; cd.data->account_reg2_num = num; for (int i = num; i < ACCOUNT_REG2_NUM; ++i) cd.data->account_reg2[i] = GlobalReg{}; c++; } } return c; } // Divorce a character from it's partner and let the map server know static int char_divorce(CharPair *cp) { if (cp == nullptr) return 0; CharKey *ck = &cp->key; CharData *cs = cp->data.get(); if (!cs->partner_id) { Packet_Fixed<0x2b12> fixed_12; fixed_12.char_id = ck->char_id; // partner id 0 means failure fixed_12.partner_id = cs->partner_id; for (Session *ss : iter_map_sessions()) { send_fpacket<0x2b12, 10>(ss, fixed_12); } return 0; } Packet_Fixed<0x2b12> fixed_12; fixed_12.char_id = ck->char_id; for (CharPair& cd : char_keys) { if (cd.key.char_id == cs->partner_id && cd.data->partner_id == ck->char_id) { fixed_12.partner_id = cs->partner_id; for (Session *ss : iter_map_sessions()) { send_fpacket<0x2b12, 10>(ss, fixed_12); } cs->partner_id = CharId(); cd.data->partner_id = CharId(); return 0; } // The other char doesn't have us as their partner, so just clear our partner // Don't worry about this, as the map server should verify itself that the other doesn't have us as a partner, and so won't mess with their marriage else if (cd.key.char_id == cs->partner_id) { fixed_12.partner_id = cs->partner_id; for (Session *ss : iter_map_sessions()) { send_fpacket<0x2b12, 10>(ss, fixed_12); } cs->partner_id = CharId(); return 0; } } // Our partner wasn't found, so just clear our marriage fixed_12.partner_id = cs->partner_id; cs->partner_id = CharId(); for (Session *ss : iter_map_sessions()) { send_fpacket<0x2b12, 10>(ss, fixed_12); } return 0; } //---------------------------------------------------------------------- // Force disconnection of an online player (with account value) by [Yor] //---------------------------------------------------------------------- static void disconnect_player(AccountId accound_id) { // disconnect player if online on char-server for (io::FD i : iter_fds()) { Session *s = get_session(i); if (!s) continue; struct char_session_data *sd = static_cast(s->session_data.get()); if (sd) { if (sd->account_id == accound_id) { s->set_eof(); return; } } } } // キャラ削除に伴うデータ削除 static int char_delete(CharPair *cp) { CharKey *ck = &cp->key; CharData *cs = cp->data.get(); // パーティー脱退 if (cs->party_id) inter_party_leave(cs->party_id, ck->account_id); // 離婚 if (cs->partner_id) char_divorce(cp); // Force the character (and all on the same account) to leave all map servers { Packet_Fixed<0x2afe> fixed_fe; fixed_fe.account_id = ck->account_id; for (Session *ss : iter_map_sessions()) { send_fpacket<0x2afe, 6>(ss, fixed_fe); } } return 0; } static void parse_tologin(Session *ls) { assert (ls == login_session); char_session_data *sd = static_cast(ls->session_data.get()); RecvResult rv = RecvResult::Complete; uint16_t packet_id; while (rv == RecvResult::Complete && packet_peek_id(ls, &packet_id)) { switch (packet_id) { case 0x2711: { Packet_Fixed<0x2711> fixed; rv = recv_fpacket<0x2711, 3>(ls, fixed); if (rv != RecvResult::Complete) break; if (fixed.code) { PRINTF("Can not connect to login-server.\n"_fmt); PRINTF("The server communication passwords (default s1/p1) is probably invalid.\n"_fmt); PRINTF("Also, please make sure your accounts file (default: accounts.txt) has those values present.\n"_fmt); PRINTF("If you changed the communication passwords, change them back at map_athena.conf and char_athena.conf\n"_fmt); exit(1); } else { CHAR_LOG_AND_ECHO("Connected to login-server (connection #%d).\n"_fmt, ls); // if no map-server already connected, display a message... int i; for (i = 0; i < MAX_MAP_SERVERS; i++) { if (server_session[i] && server[i].maps[0]) // if map-server online and at least 1 map break; } if (i == MAX_MAP_SERVERS) PRINTF("Awaiting maps from map-server.\n"_fmt); } break; } case 0x2713: { Packet_Fixed<0x2713> fixed; rv = recv_fpacket<0x2713, 55>(ls, fixed); if (rv != RecvResult::Complete) break; for (io::FD i : iter_fds()) { AccountId acc = fixed.account_id; Session *s2 = get_session(i); if (!s2) continue; sd = static_cast(s2->session_data.get()); if (sd && sd->account_id == acc) { if (fixed.invalid != 0) { Packet_Fixed<0x006c> fixed_6c; fixed_6c.code = fixed.invalid; send_fpacket<0x006c, 3>(s2, fixed_6c); CHAR_LOG_AND_ECHO("Account %d authentication REJECTED (login-server reply) (REJECTED IP: %s)\n"_fmt, acc, s2->client_ip); } else if (char_conf.max_connect_user == 0 || count_users() < char_conf.max_connect_user) { sd->email = stringish(fixed.email); if (!e_mail_check(sd->email)) sd->email = DEFAULT_EMAIL; sd->client_version = fixed.client_protocol_version; CHAR_LOG_AND_ECHO("Account %d [%s] authentication accepted (login-server reply)\n"_fmt, acc, s2->client_ip); // mark session as 'authed' (cleared as ok by reply from login server) sd->auth = true; // send characters to player mmo_char_send006b(s2, sd); } else { // refuse connection: too much online players Packet_Fixed<0x006c> fixed_6c; fixed_6c.code = 0; send_fpacket<0x006c, 3>(s2, fixed_6c); CHAR_LOG_AND_ECHO("Account %d [%s] authentication acceptable (login-server reply), but server is too full!\n"_fmt, acc, s2->client_ip); } break; } } break; } case 0x2715: { Packet_Fixed<0x2715> fixed; rv = recv_fpacket<0x2715, 22>(ls, fixed); if (rv != RecvResult::Complete) break; // re-use any previous fifo entry instead of flooding the queue AuthFifoEntry *found = nullptr; for (AuthFifoEntry& afi : auth_fifo) if (afi.account_id == fixed.account_id) found = &afi; // found: update entry // not found: add new entry if (found == nullptr) { if (auth_fifo_iter == auth_fifo.end()) auth_fifo_iter = auth_fifo.begin(); found = auth_fifo_iter; auth_fifo_iter++; } found->account_id = fixed.account_id; found->char_id = CharId(); found->login_id1 = fixed.login_id1; found->login_id2 = fixed.login_id2; found->delflag = 2; found->ip = fixed.ip; found->client_version = fixed.client_protocol_version; if (login_session) { // tell login server we accepted the auth details Packet_Fixed<0x2742> fixed_2742; fixed_2742.account_id = fixed.account_id; fixed_2742.login_id1 = fixed.login_id1; fixed_2742.login_id2 = fixed.login_id2; fixed_2742.ip = fixed.ip; fixed_2742.client_protocol_version = fixed.client_protocol_version; send_fpacket<0x2742, 22>(login_session, fixed_2742); CHAR_LOG_AND_ECHO("Received auth details for account %d [%s], replying to login server\n"_fmt, fixed.account_id, fixed.ip); } break; } // Receiving of an e-mail/time limit from the login-server (answer of a request because a player comes back from map-server to char-server) by [Yor] case 0x2717: { Packet_Fixed<0x2717> fixed; rv = recv_fpacket<0x2717, 50>(ls, fixed); if (rv != RecvResult::Complete) break; for (io::FD i : iter_fds()) { AccountId acc = fixed.account_id; Session *s2 = get_session(i); if (!s2) continue; sd = static_cast(s2->session_data.get()); if (sd) { if (sd->account_id == acc) { sd->email = fixed.email; if (!e_mail_check(sd->email)) sd->email = DEFAULT_EMAIL; break; } } } break; } case 0x2723: // changesex reply (modified by [Yor]) { Packet_Fixed<0x2723> fixed; rv = recv_fpacket<0x2723, 7>(ls, fixed); if (rv != RecvResult::Complete) break; { AccountId acc = fixed.account_id; SEX sex = fixed.sex; if (acc) { disconnect_player(acc); } Packet_Fixed<0x2b0d> fixed_0d; fixed_0d.account_id = acc; fixed_0d.sex = sex; for (Session *ss : iter_map_sessions()) { send_fpacket<0x2b0d, 7>(ss, fixed_0d); } } break; } case 0x2726: // Request to send a broadcast message (no answer) { Packet_Head<0x2726> head; AString repeat; rv = recv_vpacket<0x2726, 8, 1>(ls, head, repeat); if (rv != RecvResult::Complete) break; if (!repeat) CHAR_LOG("Receiving a message for broadcast, but message is void.\n"_fmt); else { int i; // at least 1 map-server for (i = 0; i < MAX_MAP_SERVERS; i++) if (server_session[i]) break; if (i == MAX_MAP_SERVERS) CHAR_LOG("'ladmin': Receiving a message for broadcast, but no map-server is online.\n"_fmt); else { AString message = repeat.to_print().lstrip(); // if message is only composed of spaces if (!message) CHAR_LOG("Receiving a message for broadcast, but message is only a lot of spaces.\n"_fmt); // else send message to all map-servers else { CHAR_LOG("'ladmin': Receiving a message for broadcast (message (in yellow): %s)\n"_fmt, message); // send broadcast to all map-servers for (Session *ss : iter_map_sessions()) { send_packet_repeatonly<0x3800, 4, 1>(ss, message); } } } } break; } // account_reg2変更通知 case 0x2729: { Packet_Head<0x2729> head; std::vector> repeat; rv = recv_vpacket<0x2729, 8, 36>(ls, head, repeat); if (rv != RecvResult::Complete) break; { Array reg; int j = 0; AccountId acc = head.account_id; for (const auto& info : repeat) { reg[j].str = info.name; reg[j].value = info.value; ++j; if (j == ACCOUNT_REG2_NUM) break; } set_account_reg2(acc, Slice(reg.begin(), j)); Packet_Head<0x2b11> head_11; head_11.account_id = head.account_id; std::vector> repeat_11(repeat.size()); for (size_t k = 0; k < repeat.size(); ++k) { repeat_11[k].name = repeat[k].name; repeat_11[k].value = repeat[k].value; } for (Session *ss : iter_map_sessions()) { send_vpacket<0x2b11, 8, 36>(ss, head_11, repeat_11); } } break; } // Account deletion notification (from login-server) case 0x2730: { Packet_Fixed<0x2730> fixed; rv = recv_fpacket<0x2730, 6>(ls, fixed); if (rv != RecvResult::Complete) break; AccountId aid = fixed.account_id; // Deletion of all characters of the account //#warning "This comment is a lie, but it's still true." // needs to use index because they may move during resize for (int idx = 0; idx < char_keys.size(); idx++) { CharPair& cp = char_keys[idx]; CharKey& ck = cp.key; if (ck.account_id == aid) { char_delete(&cp); if (&cp != &char_keys.back()) { std::swap(cp, char_keys.back()); // if moved character owns to deleted account, check again it's character // YES this is the newly swapped one // we could avoid this by working backwards if (ck.account_id == aid) { idx--; // Correct moved character reference in the character's owner by [Yor] } } char_keys.pop_back(); } } // Deletion of the storage inter_storage_delete(aid); // send to all map-servers to disconnect the player { Packet_Fixed<0x2b13> fixed_13; fixed_13.account_id = aid; for (Session *ss : iter_map_sessions()) { send_fpacket<0x2b13, 6>(ss, fixed_13); } } // disconnect player if online on char-server disconnect_player(aid); break; } // State change of account/ban notification (from login-server) by [Yor] case 0x2731: { Packet_Fixed<0x2731> fixed; rv = recv_fpacket<0x2731, 11>(ls, fixed); if (rv != RecvResult::Complete) break; AccountId aid = fixed.account_id; // send to all map-servers to disconnect the player { Packet_Fixed<0x2b14> fixed_14; fixed_14.account_id = aid; fixed_14.ban_not_status = fixed.ban_not_status; // 0: change of statut, 1: ban fixed_14.status_or_ban_until = fixed.status_or_ban_until; // status or final date of a banishment for (Session *ss : iter_map_sessions()) { send_fpacket<0x2b14, 11>(ss, fixed_14); } } // disconnect player if online on char-server disconnect_player(aid); break; } // Receiving GM acounts info from login-server (by [Yor]) case 0x2732: { std::vector> repeat; rv = recv_packet_repeatonly<0x2732, 4, 5>(ls, repeat); if (rv != RecvResult::Complete) break; { gm_accounts.resize(repeat.size()); for (size_t k = 0; k < repeat.size(); ++k) { gm_accounts[k].account_id = repeat[k].account_id; gm_accounts[k].level = repeat[k].gm_level; } CHAR_LOG_AND_ECHO("From login-server: receiving %zu GM accounts.\n"_fmt, gm_accounts.size()); create_online_files(); // update online players files (perhaps some online players change of GM level) // send new gm acccounts level to map-servers std::vector> repeat_15(repeat.size()); for (size_t k = 0; k < repeat.size(); ++k) { repeat_15[k].account_id = repeat[k].account_id; repeat_15[k].gm_level = repeat[k].gm_level; } for (Session *ss : iter_map_sessions()) { send_packet_repeatonly<0x2b15, 4, 5>(ss, repeat_15); } } break; } case 0x2741: // change password reply { Packet_Fixed<0x2741> fixed; rv = recv_fpacket<0x2741, 7>(ls, fixed); if (rv != RecvResult::Complete) break; { AccountId acc = fixed.account_id; int status = fixed.status; for (io::FD i : iter_fds()) { Session *s2 = get_session(i); if (!s2) continue; sd = static_cast(s2->session_data.get()); if (sd) { if (sd->account_id == acc) { Packet_Fixed<0x0062> fixed_62; fixed_62.status = status; send_fpacket<0x0062, 3>(s2, fixed_62); break; } } } } break; } default: { ls->set_eof(); return; } } } if (rv == RecvResult::Error) ls->set_eof(); } //-------------------------------- // Map-server anti-freeze system //-------------------------------- static void map_anti_freeze_system(TimerData *, tick_t) { int i; for (i = 0; i < MAX_MAP_SERVERS; i++) { if (server_session[i]) { // if map-server is online if (server_freezeflag[i]-- < 1) { // Map-server anti-freeze system. Counter. 5 ok, 4...0 freezed CHAR_LOG_AND_ECHO("Map-server anti-freeze system: char-server #%d is freezed -> disconnection.\n"_fmt, i); server_session[i]->set_eof(); } } } } static int search_mapserver(XString map) { for (int i = 0; i < MAX_MAP_SERVERS; i++) { if (server_session[i]) { for (int j = 0; server[i].maps[j]; j++) { if (server[i].maps[j] == map) return i; } } } return -1; } //----------------------------------------------------- // Test to know if an IP come from LAN or WAN. by [Yor] //----------------------------------------------------- static int lan_ip_check(IP4Address addr) { bool lancheck = char_lan_conf.lan_subnet.covers(addr); PRINTF("LAN test (result): %s.\n"_fmt, (lancheck) ? SGR_BOLD SGR_CYAN "LAN source" SGR_RESET ""_s : SGR_BOLD SGR_GREEN "WAN source" SGR_RESET ""_s); return lancheck; } static void parse_frommap(Session *ms) { int id; for (id = 0; id < MAX_MAP_SERVERS; id++) if (server_session[id] == ms) break; if (id == MAX_MAP_SERVERS) { ms->set_eof(); return; } RecvResult rv = RecvResult::Complete; uint16_t packet_id; while (rv == RecvResult::Complete && packet_peek_id(ms, &packet_id)) { switch (packet_id) { // Receiving map names list from the map-server case 0x2afa: { std::vector> repeat; rv = recv_packet_repeatonly<0x2afa, 4, 16>(ms, repeat); if (rv != RecvResult::Complete) break; for (MapName &foo : server[id].maps) foo = MapName(); for (size_t j = 0; j < repeat.size(); ++j) { server[id].maps[j] = repeat[j].map_name; } const size_t j = repeat.size(); { CHAR_LOG_AND_ECHO("Map-Server %d connected: %zu maps, from IP %s port %d. Map-server %d loading complete.\n"_fmt, id, j, server[id].ip, server[id].port, id); } Packet_Fixed<0x2afb> fixed_fb; fixed_fb.unknown = 0; send_fpacket<0x2afb, 27>(ms, fixed_fb); { if (j == 0) { CHAR_LOG_AND_ECHO("WARNING: Map-Server %d has NO maps.\n"_fmt, id); // Transmitting maps information to the other map-servers } else { Packet_Head<0x2b04> head_04; head_04.ip = server[id].ip; head_04.port = server[id].port; std::vector> repeat_04(j); for (int i = 0; i < j; ++i) { repeat_04[i].map_name = server[id].maps[i]; } for (Session *ss : iter_map_sessions()) { if (ss == ms) continue; send_vpacket<0x2b04, 10, 16>(ss, head_04, repeat_04); } } // Transmitting the maps of the other map-servers to the new map-server for (int x = 0; x < MAX_MAP_SERVERS; x++) { if (server_session[x] && x != id) { Packet_Head<0x2b04> head_04; head_04.ip = server[x].ip; head_04.port = server[x].port; std::vector> repeat_04; for (int i = 0; i < MAX_MAP_PER_SERVER; i++) { if (server[x].maps[i]) { Packet_Repeat<0x2b04> info; info.map_name = server[x].maps[i]; repeat_04.push_back(info); } } if (repeat.size()) { send_vpacket<0x2b04, 10, 16>(ms, head_04, repeat_04); } } } } break; } // 認証要求 case 0x2afc: { Packet_Fixed<0x2afc> fixed; rv = recv_fpacket<0x2afc, 22>(ms, fixed); if (rv != RecvResult::Complete) break; AccountId account_id = fixed.account_id; CharId char_id = fixed.char_id; int login_id1 = fixed.login_id1; int login_id2 = fixed.login_id2; IP4Address ip = fixed.ip; for (AuthFifoEntry& afi : auth_fifo) { if (afi.account_id == account_id && afi.char_id == char_id && afi.login_id1 == login_id1 && // here, it's the only area where it's possible that we doesn't know login_id2 (map-server asks just after 0x72 packet, that doesn't given the value) (afi.login_id2 == login_id2 || login_id2 == 0) && // relate to the versions higher than 18 afi.ip == ip && afi.delflag == 3) { CharPair *cp = nullptr; for (CharPair& cdi : char_keys) { if (cdi.key.char_id == afi.char_id) { cp = &cdi; break; } } assert (cp && "uh-oh - deleted while in queue?"_s); CharKey *ck = &cp->key; CharData *cd = cp->data.get(); afi.delflag = 1; Packet_Payload<0x2afd> payload_fd; // not file descriptor payload_fd.account_id = account_id; payload_fd.login_id2 = afi.login_id2; payload_fd.client_protocol_version = afi.client_version; FPRINTF(stderr, "From queue index %zd: recalling packet version %d\n"_fmt, (&afi - &auth_fifo.front()), afi.client_version); CHAR_LOG_AND_ECHO("Authenticated account %d [%s] for map server %d.\n"_fmt, account_id, ip, id); payload_fd.char_key = *ck; payload_fd.char_data = *cd; send_ppacket<0x2afd>(ms, payload_fd); goto x2afc_out; } } { Packet_Fixed<0x2afe> fixed_fe; fixed_fe.account_id = account_id; send_fpacket<0x2afe, 6>(ms, fixed_fe); CHAR_LOG_AND_ECHO("REJECTED authentication of account %d (REJECTED IP: %s) for map server %d.\n"_fmt, account_id, ip, id); } x2afc_out: break; } // MAPサーバー上のユーザー数受信 case 0x2aff: { Packet_Head<0x2aff> head; std::vector> repeat; rv = recv_vpacket<0x2aff, 6, 4>(ms, head, repeat); if (rv != RecvResult::Complete) break; server[id].users = head.users; assert (head.users == repeat.size()); if (char_conf.anti_freeze_enable) server_freezeflag[id] = 5; // Map anti-freeze system. Counter. 5 ok, 4...0 freezed // remove all previously online players of the server for (Session *& oci : online_chars) { // there was a bug here if (oci == ms) oci = nullptr; } // add online players in the list by [Yor] for (int i = 0; i < server[id].users; i++) { CharId char_id = repeat[i].char_id; for (const CharPair& cd : char_keys) { if (cd.key.char_id == char_id) { server_for_m(&cd) = ms; break; } } } if (update_online < TimeT::now()) { // Time is done update_online = static_cast(TimeT::now()) + 8; create_online_files(); // only every 8 sec. (normally, 1 server send users every 5 sec.) Don't update every time, because that takes time, but only every 2 connection. // it set to 8 sec because is more than 5 (sec) and if we have more than 1 map-server, informations can be received in shifted. } break; } // キャラデータ保存 case 0x2b01: { Packet_Payload<0x2b01> payload; rv = recv_ppacket<0x2b01>(ms, payload); if (rv != RecvResult::Complete) break; AccountId aid = payload.account_id; CharId cid = payload.char_id; for (CharPair& cd : char_keys) { if (cd.key.account_id == aid && cd.key.char_id == cid) { cd.key = payload.char_key; *cd.data = payload.char_data; break; } } break; } // キャラセレ要求 case 0x2b02: { Packet_Fixed<0x2b02> fixed; rv = recv_fpacket<0x2b02, 22>(ms, fixed); if (rv != RecvResult::Complete) break; AccountId account_id = fixed.account_id; if (auth_fifo_iter == auth_fifo.end()) auth_fifo_iter = auth_fifo.begin(); auth_fifo_iter->account_id = account_id; auth_fifo_iter->char_id = CharId(); auth_fifo_iter->login_id1 = fixed.login_id1; auth_fifo_iter->login_id2 = fixed.login_id2; auth_fifo_iter->delflag = 2; auth_fifo_iter->ip = fixed.ip; auth_fifo_iter->client_version = fixed.client_protocol_version; auth_fifo_iter++; Packet_Fixed<0x2b03> fixed_03; fixed_03.account_id = account_id; fixed_03.unknown = 0; send_fpacket<0x2b03, 7>(ms, fixed_03); break; } // マップサーバー間移動要求 case 0x2b05: { Packet_Fixed<0x2b05> fixed; rv = recv_fpacket<0x2b05, 49>(ms, fixed); if (rv != RecvResult::Complete) break; if (auth_fifo_iter == auth_fifo.end()) auth_fifo_iter = auth_fifo.begin(); Packet_Fixed<0x2b06> fixed_06; fixed_06.account_id = fixed.account_id; //fixed_06.error = fixed.login_id1; //fixed_06.unknown = fixed.login_id2; fixed_06.char_id = fixed.char_id; fixed_06.map_name = fixed.map_name; fixed_06.x = fixed.x; fixed_06.y = fixed.y; fixed_06.map_ip = fixed.map_ip; fixed_06.map_port = fixed.map_port; auth_fifo_iter->account_id = fixed.account_id; auth_fifo_iter->login_id1 = fixed.login_id1; auth_fifo_iter->login_id2 = fixed.login_id2; auth_fifo_iter->char_id = fixed.char_id; auth_fifo_iter->delflag = 0; auth_fifo_iter->sex = fixed.sex; auth_fifo_iter->ip = fixed.client_ip; // default, if not found in the loop fixed_06.error = 1; for (const CharPair& cd : char_keys) { AccountId aid = fixed.account_id; CharId cid = fixed.char_id; if (cd.key.account_id == aid && cd.key.char_id == cid) { auth_fifo_iter++; fixed_06.error = 0; break; } } send_fpacket<0x2b06, 44>(ms, fixed_06); break; } // Map server send information to change an email of an account -> login-server case 0x2b0c: { Packet_Fixed<0x2b0c> fixed; rv = recv_fpacket<0x2b0c, 86>(ms, fixed); if (rv != RecvResult::Complete) break; if (login_session) { // don't send request if no login-server Packet_Fixed<0x2722> fixed_22; fixed_22.account_id = fixed.account_id; fixed_22.old_email = fixed.old_email; fixed_22.new_email = fixed.new_email; send_fpacket<0x2722, 86>(login_session, fixed_22); } break; } // Map server ask char-server about a character name to do some operations (all operations are transmitted to login-server) case 0x2b0e: { Packet_Fixed<0x2b0e> fixed; rv = recv_fpacket<0x2b0e, 44>(ms, fixed); if (rv != RecvResult::Complete) break; { AccountId acc = fixed.account_id; CharName character_name = fixed.char_name; int operation = fixed.operation; // prepare answer Packet_Fixed<0x2b0f> fixed_0f; fixed_0f.account_id = acc; fixed_0f.operation = operation; // search character const CharPair *cd = search_character(character_name); // TODO invert the below logic to shrink this code // Current logic: // 1. if no character, return error 1 // 2. else if gm level too low, return error 2 // 3. else if login server offline, return error 3 // 4. else return error 0 and maybe do other stuff if (cd) { const CharKey *ck = &cd->key; fixed_0f.char_name = ck->name; fixed_0f.error = 0; switch (operation) { case 1: // block { if (!acc || isGM(acc).overwhelms(isGM(ck->account_id))) { if (login_session) { // don't send request if no login-server Packet_Fixed<0x2724> fixed_24; fixed_24.account_id = ck->account_id; fixed_24.status = 5; send_fpacket<0x2724, 10>(login_session, fixed_24); } else fixed_0f.error = 3; } else fixed_0f.error = 2; break; } case 2: // ban { if (!acc || isGM(acc).overwhelms(isGM(ck->account_id))) { if (login_session) { // don't send request if no login-server Packet_Fixed<0x2725> fixed_25; fixed_25.account_id = ck->account_id; HumanTimeDiff ban_change = fixed.ban_add; fixed_25.ban_add = ban_change; send_fpacket<0x2725, 18>(login_session, fixed_25); } else fixed_0f.error = 3; } else fixed_0f.error = 2; break; } case 3: // unblock { if (!acc || isGM(acc).overwhelms(isGM(ck->account_id))) { if (login_session) { // don't send request if no login-server Packet_Fixed<0x2724> fixed_24; fixed_24.account_id = ck->account_id; fixed_24.status = 0; send_fpacket<0x2724, 10>(login_session, fixed_24); } else fixed_0f.error = 3; } else fixed_0f.error = 2; break; } case 4: // unban { if (!acc || isGM(acc).overwhelms(isGM(ck->account_id))) { if (login_session) { // don't send request if no login-server Packet_Fixed<0x272a> fixed_2a; fixed_2a.account_id = ck->account_id; send_fpacket<0x272a, 6>(login_session, fixed_2a); } else fixed_0f.error = 3; } else fixed_0f.error = 2; break; } } } else { // character name not found fixed_0f.char_name = character_name; fixed_0f.error = 1; } // send answer if a player ask, not if the server ask if (acc) { send_fpacket<0x2b0f, 34>(ms, fixed_0f); } break; } } // account_reg保存要求 case 0x2b10: { Packet_Head<0x2b10> head; std::vector> repeat; rv = recv_vpacket<0x2b10, 8, 36>(ms, head, repeat); if (rv != RecvResult::Complete) break; { Array reg; AccountId acc = head.account_id; auto jlim = std::min(repeat.size(), ACCOUNT_REG2_NUM); for (size_t j = 0; j < jlim; ++j) { reg[j].str = repeat[j].name; reg[j].value = repeat[j].value; } set_account_reg2(acc, Slice(reg.begin(), jlim)); // loginサーバーへ送る if (login_session) { // don't send request if no login-server Packet_Head<0x2728> head_28; std::vector> repeat_28(repeat.size()); for (size_t j = 0; j < repeat.size(); ++j) { repeat_28[j].name = repeat[j].name; repeat_28[j].value = repeat[j].value; } send_vpacket<0x2728, 8, 36>(login_session, head_28, repeat_28); } break; } } // Map server is requesting a divorce case 0x2b16: { Packet_Fixed<0x2b16> fixed; rv = recv_fpacket<0x2b16, 6>(ms, fixed); if (rv != RecvResult::Complete) break; { CharId cid = fixed.char_id; for (CharPair& cd : char_keys) { if (cd.key.char_id == cid) { char_divorce(&cd); break; } } break; } } case 0x3830: { Packet_Fixed<0x3830> fixed; rv = recv_fpacket<0x3830, 22>(ms, fixed); if (rv != RecvResult::Complete) break; for (io::FD i : iter_fds()) { Session *s2 = get_session(i); if (!s2) continue; struct char_session_data *sd = static_cast(s2->session_data.get()); if (sd && sd->account_id == fixed.account_id && sd->login_id1 == fixed.login_id1 && sd->login_id2 == fixed.login_id2 /*&& sd->ip == fixed.ip &&*/) { sd->consumed_by++; // one char server consumed this CHAR_LOG_AND_ECHO("Map server %i accepted pre-auth details for account %d [%s].\n"_fmt, id, fixed.account_id, fixed.ip); int server_count = 0; // FIXME: this is silly, we should have a active_map_servers global var for (Session *ss : iter_map_sessions()) if (ss) server_count++; if (sd->consumed_by == server_count) { CHAR_LOG_AND_ECHO("All map servers accepted pre-auth details for account %d [%s], sending authorization to client...\n"_fmt, fixed.account_id, fixed.ip); CharPair *cp = nullptr; for (CharPair& cdi : char_keys) { if (cdi.key.account_id == sd->account_id && cdi.key.char_id == fixed.char_id) { cp = &cdi; break; } } if (!cp) return; CharKey *ck = &cp->key; CharData *cd = cp->data.get(); int mi = search_mapserver(cd->last_point.map_); // now that preauth is done we prepare for actual auth if (auth_fifo_iter == auth_fifo.end()) auth_fifo_iter = auth_fifo.begin(); auth_fifo_iter->account_id = sd->account_id; auth_fifo_iter->char_id = ck->char_id; auth_fifo_iter->login_id1 = sd->login_id1; auth_fifo_iter->login_id2 = sd->login_id2; auth_fifo_iter->delflag = 3; auth_fifo_iter->sex = sd->sex; auth_fifo_iter->ip = s2->client_ip; auth_fifo_iter->client_version = sd->client_version; auth_fifo_iter++; Packet_Fixed<0x0071> fixed_71; fixed_71.char_id = ck->char_id; fixed_71.map_name = cd->last_point.map_; if (lan_ip_check(s2->client_ip)) fixed_71.ip = char_lan_conf.lan_map_ip; else fixed_71.ip = server[mi].ip; fixed_71.port = server[mi].port; send_fpacket<0x0071, 28>(s2, fixed_71); } break; } } break; } default: // inter server処理に渡す { RecvResult r = inter_parse_frommap(ms, packet_id); if (r == RecvResult::Complete) break; if (r == RecvResult::Incomplete) return; // inter server処理でもない場合は切断 PRINTF("char: unknown packet 0x%04x (%zu bytes to read in buffer)! (from map).\n"_fmt, packet_id, packet_avail(ms)); ms->set_eof(); return; } } } if (rv == RecvResult::Error) ms->set_eof(); } static void handle_x0066(Session *s, struct char_session_data *sd, uint8_t rfifob_2, IP4Address ip) { { CharPair *cp = nullptr; for (CharPair& cdi : char_keys) { if (cdi.key.account_id == sd->account_id && cdi.key.char_num == rfifob_2) { cp = &cdi; break; } } if (cp) { CharKey *ck = &cp->key; CharData *cd = cp->data.get(); CHAR_LOG_AND_ECHO("Character Selected, Account ID: %d, Character Slot: %d, Character Name: %s [%s]\n"_fmt, sd->account_id, rfifob_2, ck->name, ip); // searching map server int i = search_mapserver(cd->last_point.map_); // if map is not found, we check major cities if (i < 0) { int j; // get first online server (with a map) i = 0; for (j = 0; j < MAX_MAP_SERVERS; j++) if (server_session[j] && server[j].maps[0]) { // change save point to one of map found on the server (the first) i = j; cd->last_point.map_ = server[j].maps[0]; PRINTF("Map-server #%d found with a map: '%s'.\n"_fmt, j, server[j].maps[0]); // coordonates are unknown break; } // if no map-server is connected, we send: server closed if (j == MAX_MAP_SERVERS) { Packet_Fixed<0x0081> fixed_81; fixed_81.error_code = 1; send_fpacket<0x0081, 3>(s, fixed_81); return; } } // send auth details to map server, wait for a reply Packet_Fixed<0x3829> fixed_3829; fixed_3829.account_id = ck->account_id; fixed_3829.char_id = ck->char_id; fixed_3829.login_id1 = sd->login_id1; fixed_3829.login_id2 = sd->login_id2; fixed_3829.ip = ip; sd->consumed_by = 0; for (Session *ss : iter_map_sessions()) send_fpacket<0x3829, 22>(ss, fixed_3829); } } } static void parse_char(Session *s) { IP4Address ip = s->client_ip; assert (s != login_session); if (!login_session) { s->set_eof(); return; } char_session_data *sd = static_cast(s->session_data.get()); RecvResult rv = RecvResult::Complete; uint16_t packet_id; while (rv == RecvResult::Complete && packet_peek_id(s, &packet_id)) { switch (packet_id) { case 0x61: // change password request { Packet_Fixed<0x0061> fixed; rv = recv_fpacket<0x0061, 50>(s, fixed); if (rv != RecvResult::Complete) break; if (!sd || !sd->auth) { if (sd) CHAR_LOG_AND_ECHO("Unauthenticated attempt to change password of account %d (REJECTED IP: %s)!\n"_fmt, sd->account_id, s->client_ip); s->set_eof(); return; } { Packet_Fixed<0x2740> fixed_40; fixed_40.account_id = sd->account_id; AccountPass old_pass = fixed.old_pass; fixed_40.old_pass = old_pass; AccountPass new_pass = fixed.new_pass; fixed_40.new_pass = new_pass; send_fpacket<0x2740, 54>(login_session, fixed_40); } break; } // User connection request (not authed yet) case 0x65: // 接続要求 { Packet_Fixed<0x0065> fixed; rv = recv_fpacket<0x0065, 17>(s, fixed); if (rv != RecvResult::Complete) break; { AccountId account_id = fixed.account_id; GmLevel GM_value = isGM(account_id); if (GM_value) CHAR_LOG_AND_ECHO("Account logging on - Account ID: %d (GM level %d).\n"_fmt, account_id, GM_value); else CHAR_LOG_AND_ECHO("Account logging on - Account ID: %d.\n"_fmt, account_id); if (sd == nullptr) { s->session_data = make_unique(); sd = static_cast(s->session_data.get()); sd->email = stringish("no mail"_s); // put here a mail without '@' to refuse deletion if we don't receive the e-mail } sd->account_id = account_id; sd->login_id1 = fixed.login_id1; sd->login_id2 = fixed.login_id2; sd->sex = fixed.sex; sd->auth = false; // not authed yet sd->consumed_by = 0; // formerly: send back account_id Packet_Payload<0x8000> special; special.magic_packet_length = 4; send_ppacket<0x8000>(s, special); // search authentification for (AuthFifoEntry& afi : auth_fifo) { if (afi.account_id == sd->account_id && afi.login_id1 == sd->login_id1 && afi.login_id2 == sd->login_id2 && afi.ip == s->client_ip && afi.delflag == 2) { afi.delflag = 1; if (char_conf.max_connect_user == 0 || count_users() < char_conf.max_connect_user) { { // there is always a login server // request to login-server to obtain e-mail/time limit Packet_Fixed<0x2716> fixed_16; fixed_16.account_id = sd->account_id; send_fpacket<0x2716, 6>(login_session, fixed_16); } sd->client_version = afi.client_version; CHAR_LOG_AND_ECHO("Account %d [%s] authentication accepted (precached)\n"_fmt, account_id, ip); // User is now authed (credentials found in preloaded auth_fifo) sd->auth = true; // send characters to player mmo_char_send006b(s, sd); } else { // refuse connection (over populated) Packet_Fixed<0x006c> fixed_6c; fixed_6c.code = 0; send_fpacket<0x006c, 3>(s, fixed_6c); CHAR_LOG_AND_ECHO("Account %d [%s] authentication acceptable (precached), but server is too full!\n"_fmt, account_id, ip); } goto x65_out; } } // authentification not found { { if (sd) CHAR_LOG_AND_ECHO("Unauthenticated attempt to request chars from account %d (REJECTED IP: %s)!\n"_fmt, sd->account_id, ip); s->set_eof(); } } } x65_out: break; } // Character selection case 0x66: // キャラ選択 { Packet_Fixed<0x0066> fixed; rv = recv_fpacket<0x0066, 3>(s, fixed); if (rv != RecvResult::Complete) break; if (!sd || !sd->auth) { if (sd) CHAR_LOG_AND_ECHO("Unauthenticated attempt to select character from account %d (REJECTED IP: %s)!\n"_fmt, sd->account_id, ip); s->set_eof(); return; } handle_x0066(s, sd, fixed.code, ip); break; } // Character creation case 0x67: // 作成 { Packet_Fixed<0x0067> fixed; rv = recv_fpacket<0x0067, 37>(s, fixed); if (rv != RecvResult::Complete) break; if (!sd || !sd->auth) { if (sd) CHAR_LOG_AND_ECHO("Unauthenticated attempt to create character on account %d (REJECTED IP: %s)!\n"_fmt, sd->account_id, ip); s->set_eof(); return; } CharName name = fixed.char_name; Stats6 stats = fixed.stats; uint8_t slot = fixed.slot; uint16_t hair_color = fixed.hair_color; uint16_t hair_style = fixed.hair_style; short error_code = 0; const CharPair *cp = make_new_char(s, name, stats, slot, hair_color, hair_style, error_code); if (!cp) { Packet_Fixed<0x006e> fixed_6e; fixed_6e.code = error_code; send_fpacket<0x006e, 3>(s, fixed_6e); break; } const CharKey *ck = &cp->key; const CharData *cd = cp->data.get(); Packet_Fixed<0x006d> fixed_6d; fixed_6d.char_select.char_id = ck->char_id; fixed_6d.char_select.base_exp = cd->base_exp; fixed_6d.char_select.zeny = cd->zeny; fixed_6d.char_select.job_exp = cd->job_exp; fixed_6d.char_select.job_level = cd->job_level; fixed_6d.char_select.shoes = ItemNameId(); fixed_6d.char_select.gloves = ItemNameId(); fixed_6d.char_select.cape = ItemNameId(); fixed_6d.char_select.misc1 = ItemNameId(); fixed_6d.char_select.option = Opt0(); fixed_6d.char_select.unused = 0; // this was buggy until the protocol became generated // but the client ignores it anyway fixed_6d.char_select.karma = cd->karma; fixed_6d.char_select.manner = cd->manner; fixed_6d.char_select.status_point = 0x30; fixed_6d.char_select.hp = saturate(cd->hp); fixed_6d.char_select.max_hp = saturate(cd->max_hp); fixed_6d.char_select.sp = saturate(cd->sp); fixed_6d.char_select.max_sp = saturate(cd->max_sp); fixed_6d.char_select.speed = static_cast(DEFAULT_WALK_SPEED.count()); // cd->speed; fixed_6d.char_select.species = cd->species; fixed_6d.char_select.hair_style = cd->hair; fixed_6d.char_select.weapon = 0; fixed_6d.char_select.base_level = cd->base_level; fixed_6d.char_select.skill_point = cd->skill_point; fixed_6d.char_select.head_bottom = ItemNameId(); fixed_6d.char_select.shield = cd->shield; fixed_6d.char_select.head_top = cd->head_top; fixed_6d.char_select.head_mid = cd->head_mid; fixed_6d.char_select.hair_color = cd->hair_color; fixed_6d.char_select.misc2 = ItemNameId(); fixed_6d.char_select.char_name = ck->name; fixed_6d.char_select.stats.str = saturate(cd->attrs[ATTR::STR]); fixed_6d.char_select.stats.agi = saturate(cd->attrs[ATTR::AGI]); fixed_6d.char_select.stats.vit = saturate(cd->attrs[ATTR::VIT]); fixed_6d.char_select.stats.int_ = saturate(cd->attrs[ATTR::INT]); fixed_6d.char_select.stats.dex = saturate(cd->attrs[ATTR::DEX]); fixed_6d.char_select.stats.luk = saturate(cd->attrs[ATTR::LUK]); fixed_6d.char_select.char_num = ck->char_num; fixed_6d.char_select.sex = cd->sex; send_fpacket<0x006d, 108>(s, fixed_6d); break; } case 0x68: // delete char //Yor's Fix { Packet_Fixed<0x0068> fixed; rv = recv_fpacket<0x0068, 46>(s, fixed); if (rv != RecvResult::Complete) break; if (!sd || !sd->auth) { if (sd) CHAR_LOG_AND_ECHO("Unauthenticated attempt to delete character on account %d (REJECTED IP: %s)!\n"_fmt, sd->account_id, ip); s->set_eof(); return; } { { CharId cid = fixed.char_id; CharPair *cs = nullptr; for (CharPair& cd : char_keys) { if (cd.key.char_id == cid) { if (cd.key.account_id == sd->account_id) cs = &cd; break; } } if (cs) { char_delete(cs); // deletion process if (cs != &char_keys.back()) { std::swap(*cs, char_keys.back()); } char_keys.pop_back(); Packet_Fixed<0x006f> fixed_6f; send_fpacket<0x006f, 2>(s, fixed_6f); goto x68_out; } } { Packet_Fixed<0x0070> fixed_70; fixed_70.code = 0; send_fpacket<0x0070, 3>(s, fixed_70); } } x68_out: break; } // Map server connecting (not authed yet) case 0x2af8: // マップサーバーログイン { Packet_Fixed<0x2af8> fixed; rv = recv_fpacket<0x2af8, 60>(s, fixed); if (rv != RecvResult::Complete) break; int i; Packet_Fixed<0x2af9> fixed_f9; for (i = 0; i < MAX_MAP_SERVERS; i++) { if (!server_session[i]) break; } AccountName userid_ = fixed.account_name; AccountPass passwd_ = fixed.account_pass; if (i == MAX_MAP_SERVERS || userid_ != char_conf.userid || passwd_ != char_conf.passwd) { if (i != MAX_MAP_SERVERS) { CHAR_LOG_AND_ECHO("Attempt to connect as map-server without correct authentication (REJECTED IP: %s)!\n"_fmt, ip); } fixed_f9.code = 3; send_fpacket<0x2af9, 3>(s, fixed_f9); } else { fixed_f9.code = 0; s->set_parsers(SessionParsers{.func_parse= parse_frommap, .func_delete= delete_frommap}); server_session[i] = s; if (char_conf.anti_freeze_enable) server_freezeflag[i] = 5; // Map anti-freeze system. Counter. 5 ok, 4...0 freezed // ignore fixed.unknown server[i].ip = fixed.ip; server[i].port = fixed.port; server[i].users = 0; for (MapName& mapi : server[i].maps) mapi = MapName(); send_fpacket<0x2af9, 3>(s, fixed_f9); realloc_fifo(s, FIFOSIZE_SERVERLINK, FIFOSIZE_SERVERLINK); // send gm acccounts level to map-servers std::vector> repeat_15(gm_accounts.size()); auto it = repeat_15.begin(); for (const GM_Account& gma : gm_accounts) { it->account_id = gma.account_id; it->gm_level = gma.level; ++it; } send_packet_repeatonly<0x2b15, 4, 5>(s, repeat_15); // justification: we switched the session parsers parse_frommap(s); return; } break; } // Request char server version case 0x7530: // Athena情報所得 { Packet_Fixed<0x7530> fixed; rv = recv_fpacket<0x7530, 2>(s, fixed); if (rv != RecvResult::Complete) break; Packet_Fixed<0x7531> fixed_31; fixed_31.version = CURRENT_CHAR_SERVER_VERSION; send_fpacket<0x7531, 10>(s, fixed_31); break; } // Explicit disconnection request case 0x7532: // 接続の切断(defaultと処理は一緒だが明示的にするため) { Packet_Fixed<0x7532> fixed; rv = recv_fpacket<0x7532, 2>(s, fixed); if (rv != RecvResult::Complete) break; s->set_eof(); return; } default: s->set_eof(); return; } } if (rv == RecvResult::Error) s->set_eof(); } static void send_users_tologin(TimerData *, tick_t) { int users = count_users(); if (login_session) { // send number of user to login server Packet_Fixed<0x2714> fixed_14; fixed_14.users = users; send_fpacket<0x2714, 6>(login_session, fixed_14); } // send number of players to all map-servers Packet_Fixed<0x2b00> fixed_00; fixed_00.users = users; for (Session *ss : iter_map_sessions()) { send_fpacket<0x2b00, 6>(ss, fixed_00); } } static void check_connect_login_server(TimerData *, tick_t) { if (!login_session) { PRINTF("Attempt to connect to login-server...\n"_fmt); login_session = make_connection(char_conf.login_ip, char_conf.login_port, SessionParsers{.func_parse= parse_tologin, .func_delete= delete_tologin}); if (!login_session) return; realloc_fifo(login_session, FIFOSIZE_SERVERLINK, FIFOSIZE_SERVERLINK); Packet_Fixed<0x2710> fixed_10; fixed_10.account_name = char_conf.userid; fixed_10.account_pass = char_conf.passwd; fixed_10.unknown = 0; fixed_10.ip = char_conf.char_ip; fixed_10.port = char_conf.char_port; fixed_10.server_name = char_conf.server_name; fixed_10.unknown2 = 0; fixed_10.maintenance = 0; fixed_10.is_new = 0; send_fpacket<0x2710, 86>(login_session, fixed_10); } } static bool lan_check() { // sub-network check of the map-server { PRINTF("LAN test of LAN IP of the map-server: "_fmt); if (!lan_ip_check(char_lan_conf.lan_map_ip)) { PRINTF(SGR_BOLD SGR_RED "***ERROR: LAN IP of the map-server doesn't belong to the specified Sub-network." SGR_RESET "\n"_fmt); return false; } } return true; } static bool char_config(io::Spanned key, io::Spanned value) { return parse_char_conf(char_conf, key, value); } static bool char_lan_config(io::Spanned key, io::Spanned value) { return parse_char_lan_conf(char_lan_conf, key, value); } static bool inter_config(io::Spanned key, io::Spanned value) { return parse_inter_conf(inter_conf, key, value); } static bool char_confs(io::Spanned key, io::Spanned value) { if (key.data == "char_conf"_s) { return load_config_file(value.data, char_config); } if (key.data == "char_lan_conf"_s) { return load_config_file(value.data, char_lan_config); } if (key.data == "inter_conf"_s) { return load_config_file(value.data, inter_config); } key.span.error("Unknown meta-key for char server"_s); return false; } } // namespace char_ void term_func(void) { using namespace tmwa::char_; // write online players files with no player std::fill(online_chars.begin(), online_chars.end(), nullptr); create_online_files(); online_chars.clear(); mmo_char_sync(); inter_save(); gm_accounts.clear(); char_keys.clear(); delete_session(login_session); delete_session(char_session); CHAR_LOG_AND_ECHO("----End of char-server (normal end with closing of all files).\n"_fmt); } static void party_corruption_fix() { using namespace tmwa::char_; for (auto& pair : party_db) { PartyPair pp{pair.first, borrow(pair.second)}; for (int i = 0; i < MAX_PARTY; i++) { if (!pp.party_most->member[i].account_id) break; for (const CharPair& cp : char_keys) { if (cp.key.account_id == pp.party_most->member[i].account_id && cp.key.name == pp.party_most->member[i].name && cp.data->party_id != pp.party_id) { CHAR_LOG_AND_ECHO("Fixing corrupt party on character %s...\n"_fmt, cp.key.name); cp.data->party_id = pp.party_id; } } } } } int do_init(Slice argv) { using namespace tmwa::char_; ZString argv0 = argv.pop_front(); bool loaded_config_yet = false; while (argv) { ZString argvi = argv.pop_front(); if (argvi.startswith('-')) { if (argvi == "--help"_s) { PRINTF("Usage: %s [--help] [--version] [files...]\n"_fmt, argv0); exit(0); } else if (argvi == "--version"_s) { PRINTF("%s\n"_fmt, CURRENT_VERSION_STRING); exit(0); } else { FPRINTF(stderr, "Unknown argument: %s\n"_fmt, argvi); runflag = false; } } else { loaded_config_yet = true; runflag &= load_config_file(argvi, char_::char_confs); } } if (!loaded_config_yet) runflag &= load_config_file("conf/tmwa-char.conf"_s, char_::char_confs); // a newline in the log... CHAR_LOG(""_fmt); CHAR_LOG("do_init: char-server starting...\n"_fmt); runflag &= lan_check(); mmo_char_init(); inter_init2(); party_corruption_fix(); update_online = TimeT::now(); create_online_files(); // update online players files at start of the server char_session = make_listen_port(char_conf.char_port, SessionParsers{parse_char, delete_char}); Timer(gettick() + 1_s, check_connect_login_server, 10_s ).detach(); Timer(gettick() + 1_s, send_users_tologin, 5_s ).detach(); Timer(gettick() + char_conf.autosave_time, mmo_char_sync_timer, char_conf.autosave_time ).detach(); if (char_conf.anti_freeze_enable > 0) { Timer(gettick() + 1_s, map_anti_freeze_system, char_conf.anti_freeze_interval ).detach(); } CHAR_LOG("The char-server is ready (Server is listening on the port %d).\n"_fmt, char_conf.char_port); PRINTF("The char-server is " SGR_BOLD SGR_GREEN "ready" SGR_RESET " (Server is listening on the port %d).\n\n"_fmt, char_conf.char_port); return 0; } // namespace char_ ends before term_func and do_init } // namespace tmwa