#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 "../io/cxxstdio.hpp" #include "../io/extract.hpp" #include "../io/lock.hpp" #include "../io/read.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/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 "inter.hpp" #include "int_party.hpp" #include "int_storage.hpp" #include "../poison.hpp" namespace tmwa { static Array server; static Array server_session; static Array server_freezeflag; // Map-server anti-freeze system. Counter. 5 ok, 4...0 freezed static int anti_freeze_enable = 0; static std::chrono::seconds anti_freeze_interval = 6_s; constexpr std::chrono::milliseconds DEFAULT_AUTOSAVE_INTERVAL = 5_min; static Session *login_session, *char_session; static AccountName userid; static AccountPass passwd; static ServerName server_name; static CharName wisp_server_name = stringish("Server"_s); static IP4Address login_ip; static int login_port = 6900; static IP4Address char_ip; static int char_port = 6121; static AString char_txt; static CharName unknown_char_name = stringish("Unknown"_s); static AString char_log_filename = "log/char.log"_s; //Added for lan support static IP4Address lan_map_ip = IP4_LOCALHOST; static IP4Mask lan_subnet = IP4Mask(IP4_LOCALHOST, IP4_BROADCAST); static int char_name_option = 0; // Option to know which letters/symbols are authorised in the name of a character (0: all, 1: only those in char_name_letters, 2: all EXCEPT those in char_name_letters) by [Yor] static std::bitset<256> char_name_letters; // list of letters/symbols authorised (or not) in a character name. by [Yor] static constexpr GmLevel default_gm_level = GmLevel::from(0_u32); struct char_session_data : SessionData { AccountId account_id; int login_id1, login_id2; SEX sex; unsigned short packet_tmw_version; AccountEmail email; TimeT connect_until_time; }; void SessionDeleter::operator()(SessionData *sd) { really_delete1 static_cast(sd); } struct AuthFifoEntry { AccountId account_id; CharId char_id; int login_id1, login_id2; IP4Address ip; int delflag; SEX sex; unsigned short packet_tmw_version; TimeT connect_until_time; // # of seconds 1/1/1970 (timestamp): Validity limit of the account (0 = unlimited) }; static std::array auth_fifo; static auto auth_fifo_iter = auth_fifo.begin(); static int check_ip_flag = 1; // It's to check IP of a player between char-server and other servers (part of anti-hacking system) static CharId char_id_count = wrap(150000); static std::vector char_keys; static int max_connect_user = 0; static std::chrono::milliseconds autosave_time = DEFAULT_AUTOSAVE_INTERVAL; // Initial position (it's possible to set it in conf file) static Point start_point = { {"001-1.gat"_s}, 273, 354 }; static std::vector gm_accounts; // online players by [Yor] static AString online_txt_filename = "online.txt"_s; static AString online_html_filename = "online.html"_s; static int online_sorting_option = 0; // sorting option to display online players in online files static int online_refresh_html = 20; // refresh time (in sec) of the html file in the explorer static GmLevel online_gm_display_min_level = GmLevel::from(20_u32); // minimum GM level to display 'GM' when we want to display it static std::vector online_chars; // same size of char_keys, and id value of current server (or -1) static TimeT update_online; // to update online files when we receiving information from a server (not less than 8 seconds) static pid_t pid = 0; // For forked DB writes 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(); PRINTF("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_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 = start_point; } 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"_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); // memos were here (no longer supported) str_p += '\t'; 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); } static bool extract(XString str, Point *p) { return extract(str, record<','>(&p->map_, &p->x, &p->y)); } struct skill_loader { SkillID id; uint16_t level; SkillFlags flags; }; static bool 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; } //------------------------------------------------------------------------- // Function to set the character from the line (at read of characters file) //------------------------------------------------------------------------- static bool extract(XString str, CharPair *cp) { CharKey *k = &cp->key; CharData *p = cp->data.get(); uint32_t unused_guild_id, unused_pet_id; 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), &unused_memos, vrec<' '>(&inventory), &unused_cart, vrec<' '>(&skills), vrec<' '>(&vars)))) return false; // 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; } //--------------------------------- // Function to read characters file //--------------------------------- static int mmo_char_init(void) { char_keys.clear(); online_chars.clear(); io::ReadFile in(char_txt); if (!in.is_open()) { PRINTF("Characters file not found: %s.\n"_fmt, char_txt); CHAR_LOG("Characters file not found: %s.\n"_fmt, char_txt); CHAR_LOG("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("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); } PRINTF("mmo_char_init: %zu characters read in %s.\n"_fmt, char_keys.size(), char_txt); CHAR_LOG("mmo_char_init: %zu characters read in %s.\n"_fmt, char_keys.size(), char_txt); CHAR_LOG("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_txt); if (!fp.is_open()) { PRINTF("WARNING: Server can't not save characters.\n"_fmt); CHAR_LOG("WARNING: Server can't not 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) { // 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); 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); return nullptr; } // check lenght of character name if (name.to__actual().size() < 4) { CHAR_LOG("Make new char error (character name too small): (connection #%d, account: %d, name: '%s').\n"_fmt, s, sd->account_id, name); return nullptr; } // Check Authorised letters/symbols in the name of the character if (char_name_option == 1) { // only letters/symbols in char_name_letters are authorised for (uint8_t c : name.to__actual()) if (!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); return nullptr; } } else if (char_name_option == 2) { // letters/symbols in char_name_letters are forbidden for (uint8_t c : name.to__actual()) if (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); return nullptr; } } // else, all letters/symbols are authorised (except control char removed before) // 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 != 5 * 6 || // stats slot >= 9 || hair_style >= 20 || hair_color >= 12) { CHAR_LOG("Make new char error (invalid values): (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); return nullptr; } // check individual stat value for (int i = 0; i < 6; i++) { uint8_t statsi = reinterpret_cast(&stats)[i]; if (statsi < 1 || statsi > 9) { 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); 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); 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); 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); 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.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 = start_point; cd.save_point = 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(online_txt_filename); if (fp.is_open()) { io::WriteFile fp2(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, online_refresh_html); // update on client explorer every x seconds FPRINTF(fp2, " \n"_fmt); FPRINTF(fp2, " Online Players on %s\n"_fmt, server_name); FPRINTF(fp2, " \n"_fmt); FPRINTF(fp2, " \n"_fmt); FPRINTF(fp2, "

Online Players on %s (%s):

\n"_fmt, server_name, timetemp); FPRINTF(fp, "Online Players on %s (%s):\n"_fmt, 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(online_gm_display_min_level)) 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(online_gm_display_min_level)) 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(online_gm_display_min_level)) FPRINTF(fp2, " (GM)"_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; sel.unused = 0; 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 { PRINTF("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, 51>(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 = 0x42; send_fpacket<0x006c, 3>(s2, fixed_6c); } else if (max_connect_user == 0 || count_users() < max_connect_user) { sd->email = stringish(fixed.email); if (!e_mail_check(sd->email)) sd->email = DEFAULT_EMAIL; sd->connect_until_time = fixed.connect_until; // 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); } break; } } 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; sd->connect_until_time = fixed.connect_until; break; } } } break; } case 0x2721: // gm reply { Packet_Fixed<0x2721> fixed; rv = recv_fpacket<0x2721, 10>(ls, fixed); if (rv != RecvResult::Complete) break; { AccountId acc = fixed.account_id; GmLevel gml = fixed.gm_level; Packet_Fixed<0x2b0b> fixed_2b; fixed_2b.account_id = acc; fixed_2b.gm_level = gml; for (Session *ss : iter_map_sessions()) { send_fpacket<0x2b0b, 10>(ss, fixed_2b); } } 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) { for (CharPair& cp : char_keys) { CharKey& ck = cp.key; CharData& cd = *cp.data; if (ck.account_id == acc) { cd.sex = sex; // auth_fifo[i].sex = sex; // to avoid any problem with equipment and invalid sex, equipment is unequiped. for (IOff0 j : IOff0::iter()) { if (cd.inventory[j].nameid && bool(cd.inventory[j].equip)) cd.inventory[j].equip = EPOS::ZERO; } cd.weapon = ItemLook::NONE; cd.shield = ItemNameId(); cd.head_top = ItemNameId(); cd.head_mid = ItemNameId(); cd.head_bottom = ItemNameId(); } } // disconnect player if online on char-server 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; } case 0x7924: { // [Fate] Itemfrob package: forwarded from login-server Packet_Fixed<0x7924> fixed; rv = recv_fpacket<0x7924, 10>(ls, fixed); if (rv != RecvResult::Complete) break; ItemNameId source_id = fixed.source_item_id; ItemNameId dest_id = fixed.dest_item_id; Packet_Fixed<0x2afa> fixed_fa; fixed_fa.source_item_id = source_id; fixed_fa.dest_item_id = dest_id; // forward package to map servers for (Session *ss : iter_map_sessions()) { send_fpacket<0x2afa, 10>(ss, fixed_fa); } for (CharPair& cp : char_keys) { CharKey *k = &cp.key; CharData& cd = *cp.data.get(); CharData *c = &cd; Borrowed s = account2storage(k->account_id); int changes = 0; #define FIX(v) if (v == source_id) {v = dest_id; ++changes; } for (IOff0 j : IOff0::iter()) { FIX(c->inventory[j].nameid); } // used to FIX cart, but it's no longer supported // FIX(c->weapon); FIX(c->shield); FIX(c->head_top); FIX(c->head_mid); FIX(c->head_bottom); { for (SOff0 j : SOff0::iter()) { FIX(s->storage_[j].nameid); } } #undef FIX if (changes) CHAR_LOG("itemfrob(%d -> %d): `%s'(%d, account %d): changed %d times\n"_fmt, source_id, dest_id, k->name, k->char_id, k->account_id, changes); } mmo_char_sync(); inter_storage_save(); 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; } PRINTF("From login-server: receiving of %zu GM accounts information.\n"_fmt, gm_accounts.size()); CHAR_LOG("From login-server: receiving of %zu GM accounts information.\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 PRINTF("Map-server anti-freeze system: char-server #%d is freezed -> disconnection.\n"_fmt, i); CHAR_LOG("Map-server anti-freeze system: char-server #%d is freezed -> disconnection.\n"_fmt, i); server_session[i]->set_eof(); } } } } 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) { // request from map-server to reload GM accounts. Transmission to login-server (by Yor) case 0x2af7: { Packet_Fixed<0x2af7> fixed; rv = recv_fpacket<0x2af7, 2>(ms, fixed); if (rv != RecvResult::Complete) break; if (login_session) { // don't send request if no login-server Packet_Fixed<0x2709> fixed_09; send_fpacket<0x2709, 2>(login_session, fixed_09); } break; } // 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(); { PRINTF("Map-Server %d connected: %zu maps, from IP %s port %d.\n"_fmt, id, j, server[id].ip, server[id].port); PRINTF("Map-server %d loading complete.\n"_fmt, id); CHAR_LOG("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; fixed_fb.whisper_name = wisp_server_name; send_fpacket<0x2afb, 27>(ms, fixed_fb); { if (j == 0) { PRINTF("WARNING: Map-Server %d have NO map.\n"_fmt, id); CHAR_LOG("WARNING: Map-Server %d have NO map.\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 (!check_ip_flag || afi.ip == ip) && !afi.delflag) { 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.connect_until = afi.connect_until_time; cd->sex = afi.sex; payload_fd.packet_tmw_version = afi.packet_tmw_version; FPRINTF(stderr, "From queue index %zd: recalling packet version %d\n"_fmt, (&afi - &auth_fifo.front()), afi.packet_tmw_version); 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); PRINTF("auth_fifo search error! account %d not authentified.\n"_fmt, account_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 (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, 18>(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->connect_until_time = TimeT(); // unlimited/unknown time by default (not display in map-server) auth_fifo_iter->ip = fixed.ip; 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->connect_until_time = TimeT(); // unlimited/unknown time by default (not display in map-server) 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; } // it is a request to become GM case 0x2b0a: { Packet_Head<0x2b0a> head; AString repeat; rv = recv_vpacket<0x2b0a, 8, 1>(ms, head, repeat); if (rv != RecvResult::Complete) break; AccountId account_id = head.account_id; if (login_session) { // don't send request if no login-server Packet_Head<0x2720> head_20; head_20.account_id = account_id; AString& repeat_20 = repeat; send_vpacket<0x2720, 8, 1>(login_session, head_20, repeat_20); } else { Packet_Fixed<0x2b0b> fixed_0b; fixed_0b.account_id = account_id; fixed_0b.gm_level = GmLevel(); send_fpacket<0x2b0b, 10>(ms, fixed_0b); } 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; } case 5: // changesex { if (!acc || isGM(acc).overwhelms(isGM(ck->account_id))) { if (login_session) { // don't send request if no login-server Packet_Fixed<0x2727> fixed_27; fixed_27.account_id = ck->account_id; send_fpacket<0x2727, 6>(login_session, fixed_27); } 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; } } 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 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 = 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 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("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; } } Packet_Fixed<0x0071> fixed_71; fixed_71.char_id = ck->char_id; fixed_71.map_name = cd->last_point.map_; PRINTF("Character selection '%s' (account: %d, slot: %d) [%s]\n"_fmt, ck->name, sd->account_id, ck->char_num, ip); PRINTF("--Send IP of map-server. "_fmt); if (lan_ip_check(ip)) fixed_71.ip = lan_map_ip; else fixed_71.ip = server[i].ip; fixed_71.port = server[i].port; send_fpacket<0x0071, 28>(s, fixed_71); 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 = 0; auth_fifo_iter->sex = sd->sex; auth_fifo_iter->connect_until_time = sd->connect_until_time; auth_fifo_iter->ip = s->client_ip; auth_fifo_iter->packet_tmw_version = sd->packet_tmw_version; auth_fifo_iter++; } } } 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; { 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; } 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) PRINTF("Account Logged On; Account ID: %d (GM level %d).\n"_fmt, account_id, GM_value); else PRINTF("Account Logged 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->connect_until_time = TimeT(); // unknow or illimited (not displaying on map-server) } sd->account_id = account_id; sd->login_id1 = fixed.login_id1; sd->login_id2 = fixed.login_id2; sd->packet_tmw_version = fixed.packet_tmw_version; sd->sex = fixed.sex; // 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 && (!check_ip_flag || afi.ip == s->client_ip) && afi.delflag == 2) { afi.delflag = 1; if (max_connect_user == 0 || count_users() < 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); } // Record client version afi.packet_tmw_version = sd->packet_tmw_version; // 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); } goto x65_out; } } // authentification not found { { // there is always a login-server Packet_Fixed<0x2712> fixed_12; fixed_12.account_id = sd->account_id; fixed_12.login_id1 = sd->login_id1; fixed_12.login_id2 = sd->login_id2; // relate to the versions higher than 18 fixed_12.sex = sd->sex; fixed_12.ip = s->client_ip; send_fpacket<0x2712, 19>(login_session, fixed_12); } } } x65_out: break; } case 0x66: // キャラ選択 { Packet_Fixed<0x0066> fixed; rv = recv_fpacket<0x0066, 3>(s, fixed); if (rv != RecvResult::Complete) break; if (!sd) { s->set_eof(); return; } handle_x0066(s, sd, fixed.code, ip); break; } case 0x67: // 作成 { Packet_Fixed<0x0067> fixed; rv = recv_fpacket<0x0067, 37>(s, fixed); if (rv != RecvResult::Complete) break; if (!sd) { 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; const CharPair *cp = make_new_char(s, name, stats, slot, hair_color, hair_style); if (!cp) { Packet_Fixed<0x006e> fixed_6e; fixed_6e.code = 0x00; 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.unused2 = 0; 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) { s->set_eof(); return; } AccountEmail email = fixed.email; if (!e_mail_check(email)) email = DEFAULT_EMAIL; { { 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; } 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_ != userid || passwd_ != passwd) { 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 (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; } 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; } 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(login_ip, 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 = userid; fixed_10.account_pass = passwd; fixed_10.unknown = 0; fixed_10.ip = char_ip; fixed_10.port = char_port; fixed_10.server_name = server_name; fixed_10.unknown2 = 0; fixed_10.maintenance = 0; fixed_10.is_new = 0; send_fpacket<0x2710, 86>(login_session, fixed_10); } } //------------------------------------------- // Reading Lan Support configuration by [Yor] //------------------------------------------- static bool char_lan_config(XString w1, ZString w2) { struct hostent *h = nullptr; { if (w1 == "lan_map_ip"_s) { // Read map-server Lan IP Address h = gethostbyname(w2.c_str()); if (h != nullptr) { lan_map_ip = IP4Address({ static_cast(h->h_addr[0]), static_cast(h->h_addr[1]), static_cast(h->h_addr[2]), static_cast(h->h_addr[3]), }); } else { PRINTF("Bad IP value: %s\n"_fmt, w2); return false; } PRINTF("LAN IP of map-server: %s.\n"_fmt, lan_map_ip); } else if (w1 == "subnet"_s /*backward compatibility*/ || w1 == "lan_subnet"_s) { if (!extract(w2, &lan_subnet)) { PRINTF("Bad IP mask: %s\n"_fmt, w2); return false; } PRINTF("Sub-network of the map-server: %s.\n"_fmt, lan_subnet); } else { return false; } } return true; } 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(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(XString w1, ZString w2) { struct hostent *h = nullptr; { if (w1 == "userid"_s) userid = stringish(w2); else if (w1 == "passwd"_s) passwd = stringish(w2); else if (w1 == "server_name"_s) { server_name = stringish(w2); PRINTF("%s server has been intialized\n"_fmt, w2); } else if (w1 == "wisp_server_name"_s) { if (w2.size() >= 4) wisp_server_name = stringish(w2); } else if (w1 == "login_ip"_s) { h = gethostbyname(w2.c_str()); if (h != nullptr) { login_ip = IP4Address({ static_cast(h->h_addr[0]), static_cast(h->h_addr[1]), static_cast(h->h_addr[2]), static_cast(h->h_addr[3]), }); PRINTF("Login server IP address : %s -> %s\n"_fmt, w2, login_ip); } else { PRINTF("Bad IP value: %s\n"_fmt, w2); return false; } } else if (w1 == "login_port"_s) { login_port = atoi(w2.c_str()); } else if (w1 == "char_ip"_s) { h = gethostbyname(w2.c_str()); if (h != nullptr) { char_ip = IP4Address({ static_cast(h->h_addr[0]), static_cast(h->h_addr[1]), static_cast(h->h_addr[2]), static_cast(h->h_addr[3]), }); PRINTF("Character server IP address : %s -> %s\n"_fmt, w2, char_ip); } else { PRINTF("Bad IP value: %s\n"_fmt, w2); return false; } } else if (w1 == "char_port"_s) { char_port = atoi(w2.c_str()); } else if (w1 == "char_txt"_s) { char_txt = w2; } else if (w1 == "max_connect_user"_s) { max_connect_user = atoi(w2.c_str()); if (max_connect_user < 0) max_connect_user = 0; // unlimited online players } else if (w1 == "check_ip_flag"_s) { check_ip_flag = config_switch(w2); } else if (w1 == "autosave_time"_s) { autosave_time = std::chrono::seconds(atoi(w2.c_str())); if (autosave_time <= std::chrono::seconds::zero()) autosave_time = DEFAULT_AUTOSAVE_INTERVAL; } else if (w1 == "start_point"_s) { extract(w2, &start_point); } else if (w1 == "unknown_char_name"_s) { unknown_char_name = stringish(w2); } else if (w1 == "char_log_filename"_s) { char_log_filename = w2; } else if (w1 == "char_name_option"_s) { char_name_option = atoi(w2.c_str()); } else if (w1 == "char_name_letters"_s) { if (!w2) char_name_letters.reset(); else for (uint8_t c : w2) char_name_letters[c] = true; } else if (w1 == "online_txt_filename"_s) { online_txt_filename = w2; } else if (w1 == "online_html_filename"_s) { online_html_filename = w2; } else if (w1 == "online_sorting_option"_s) { online_sorting_option = atoi(w2.c_str()); } else if (w1 == "online_gm_display_min_level"_s) { // minimum GM level to display 'GM' when we want to display it return extract(w2, &online_gm_display_min_level); } else if (w1 == "online_refresh_html"_s) { online_refresh_html = atoi(w2.c_str()); if (online_refresh_html < 1) online_refresh_html = 1; } else if (w1 == "anti_freeze_enable"_s) { anti_freeze_enable = config_switch(w2); } else if (w1 == "anti_freeze_interval"_s) { anti_freeze_interval = std::max( std::chrono::seconds(atoi(w2.c_str())), 5_s); } else { return false; } } return true; } void term_func(void) { // 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("----End of char-server (normal end with closing of all files).\n"_fmt); } static bool char_confs(XString key, ZString value) { unsigned sum = 0; sum += char_config(key, value); sum += char_lan_config(key, value); sum += inter_config(key, value); if (sum >= 2) abort(); return sum; } int do_init(Slice argv) { 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_confs); } } if (!loaded_config_yet) runflag &= load_config_file("conf/tmwa-char.conf"_s, char_confs); // a newline in the log... CHAR_LOG(""_fmt); CHAR_LOG("The char-server starting...\n"_fmt); runflag &= lan_check(); mmo_char_init(); inter_init2(); update_online = TimeT::now(); create_online_files(); // update online players files at start of the server char_session = make_listen_port(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() + autosave_time, mmo_char_sync_timer, autosave_time ).detach(); if (anti_freeze_enable > 0) { Timer(gettick() + 1_s, map_anti_freeze_system, anti_freeze_interval ).detach(); } CHAR_LOG("The char-server is ready (Server is listening on the port %d).\n"_fmt, 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_port); return 0; } } // namespace tmwa