Can u help me?
This is config.cpp:
#include "stdafx.h"
#include <sstream>
#ifndef __WIN32__
#include <ifaddrs.h>
#endif
#include "constants.h"
#include "utils.h"
#include "log.h"
#include "desc.h"
#include "desc_manager.h"
#include "item_manager.h"
#include "p2p.h"
#include "char.h"
#include "ip_ban.h"
#include "war_map.h"
#include "locale_service.h"
#include "config.h"
#include "dev_log.h"
#include "db.h"
#include "skill_power.h"
#include "check_server.h"
using std::string;
BYTE g_bChannel = 0;
WORD mother_port = 50080;
int passes_per_sec = 25;
WORD db_port = 0;
WORD p2p_port = 50900;
char db_addr[ADDRESS_MAX_LEN + 1];
int save_event_second_cycle = passes_per_sec * 120; // 3분
int ping_event_second_cycle = passes_per_sec * 60;
bool g_bNoMoreClient = false;
bool g_bNoRegen = false;
bool g_bNoPasspod = false;
// TRAFFIC_PROFILER
bool g_bTrafficProfileOn = false;
DWORD g_dwTrafficProfileFlushCycle = 3600;
// END_OF_TRAFFIC_PROFILER
int test_server = 0;
int speed_server = 0;
#ifdef __AUCTION__
int auction_server = 0;
#endif
bool distribution_test_server = false;
bool china_event_server = false;
bool guild_mark_server = true;
BYTE guild_mark_min_level = 3;
bool no_wander = false;
int g_iUserLimit = 32768;
char g_szPublicIP[16] = "0";
char g_szInternalIP[16] = "0";
bool g_bSkillDisable = false;
int g_iFullUserCount = 1200;
int g_iBusyUserCount = 650;
//Canada
//int g_iFullUserCount = 600;
//int g_iBusyUserCount = 350;
//Brazil
//int g_iFullUserCount = 650;
//int g_iBusyUserCount = 450;
bool g_bEmpireWhisper = true;
BYTE g_bAuthServer = false;
bool g_bCheckClientVersion = true;
string g_stClientVersion = "1215955205";
BYTE g_bBilling = false;
string g_stAuthMasterIP;
WORD g_wAuthMasterPort = 0;
static std::set<DWORD> s_set_dwFileCRC;
static std::set<DWORD> s_set_dwProcessCRC;
string g_stHostname = "";
string g_table_postfix = "";
string g_stQuestDir = "./quest";
//string g_stQuestObjectDir = "./quest/object";
string g_stDefaultQuestObjectDir = "./quest/object";
std::set<string> g_setQuestObjectDir;
std::vector<std::string> g_stAdminPageIP;
std::string g_stAdminPagePassword = "SHOWMETHEMONEY";
string g_stBlockDate = "30000705";
extern string g_stLocale;
char teen_addr[ADDRESS_MAX_LEN + 1] = {0};
WORD teen_port = 0;
int SPEEDHACK_LIMIT_COUNT = 50;
int SPEEDHACK_LIMIT_BONUS = 80;
int g_iSyncHackLimitCount = 10;
//시야 = VIEW_RANGE + VIEW_BONUS_RANGE
//VIEW_BONUSE_RANGE : 클라이언트와 시야 처리에서너무 딱 떨어질경우 문제가 발생할수있어 500CM의 여분을 항상준다.
int VIEW_RANGE = 5000;
int VIEW_BONUS_RANGE = 500;
int g_server_id = 0;
string g_strWebMallURL = "www.metin2.de";
unsigned int g_uiSpamBlockDuration = 60 * 15; // 기본 15분
unsigned int g_uiSpamBlockScore = 100; // 기본 100점
unsigned int g_uiSpamReloadCycle = 60 * 10; // 기본 10분
bool g_bCheckMultiHack = true;
int g_iSpamBlockMaxLevel = 10;
void LoadStateUserCount();
void LoadValidCRCList();
bool LoadClientVersion();
bool g_protectNormalPlayer = false; // 범법자가 "평화모드" 인 일반유저를 공격하지 못함
bool g_noticeBattleZone = false; // 중립지대에 입장하면 안내메세지를 알려줌
bool isHackShieldEnable = false;
int HackShield_FirstCheckWaitTime = passes_per_sec * 30;
int HackShield_CheckCycleTime = passes_per_sec * 180;
bool bXTrapEnabled = false;
int gPlayerMaxLevel = 99;
bool g_BlockCharCreation = false;
//OPENID
int openid_server = 0;
char openid_host[256];
char openid_uri[256];
bool is_string_true(const char * string)
{
bool result = 0;
if (isnhdigit(*string))
{
str_to_number(result, string);
return result > 0 ? true : false;
}
else if (LOWER(*string) == 't')
return true;
else
return false;
}
static std::set<int> s_set_map_allows;
bool map_allow_find(int index)
{
if (g_bAuthServer)
return false;
if (s_set_map_allows.find(index) == s_set_map_allows.end())
return false;
return true;
}
void map_allow_log()
{
std::set<int>::iterator i;
for (i = s_set_map_allows.begin(); i != s_set_map_allows.end(); ++i)
sys_log(0, "MAP_ALLOW: %d", *i);
}
void map_allow_add(int index)
{
if (map_allow_find(index) == true)
{
fprintf(stdout, "!!! FATAL ERROR !!! multiple MAP_ALLOW setting!!\n");
exit(1);
}
fprintf(stdout, "MAP ALLOW %d\n", index);
s_set_map_allows.insert(index);
}
void map_allow_copy(long * pl, int size)
{
int iCount = 0;
std::set<int>::iterator it = s_set_map_allows.begin();
while (it != s_set_map_allows.end())
{
int i = *(it++);
*(pl++) = i;
if (++iCount > size)
break;
}
}
static void FN_add_adminpageIP(char *line)
{
char *last;
const char *delim = " \t\r\n";
char *v = strtok_r(line, delim, &last);
while (v)
{
g_stAdminPageIP.push_back(v);
v = strtok_r(NULL, delim, &last);
}
}
static void FN_log_adminpage()
{
itertype(g_stAdminPageIP) iter = g_stAdminPageIP.begin();
while (iter != g_stAdminPageIP.end())
{
dev_log(LOG_DEB0, "ADMIN_PAGE_IP = %s", (*iter).c_str());
++iter;
}
dev_log(LOG_DEB0, "ADMIN_PAGE_PASSWORD = %s", g_stAdminPagePassword.c_str());
}
bool GetIPInfo()
{
#ifndef __WIN32__
struct ifaddrs* ifaddrp = NULL;
if (0 != getifaddrs(&ifaddrp))
return false;
for( struct ifaddrs* ifap=ifaddrp ; NULL != ifap ; ifap = ifap->ifa_next )
{
struct sockaddr_in * sai = (struct sockaddr_in *) ifap->ifa_addr;
if (!ifap->ifa_netmask || // ignore if no netmask
sai->sin_addr.s_addr == 0 || // ignore if address is 0.0.0.0
sai->sin_addr.s_addr == 16777343) // ignore if address is 127.0.0.1
continue;
#else
WSADATA wsa_data;
char host_name[100];
HOSTENT* host_ent;
int n = 0;
if (WSAStartup(0x0101, &wsa_data)) {
return false;
}
gethostname(host_name, sizeof(host_name));
host_ent = gethostbyname(host_name);
if (host_ent == NULL) {
return false;
}
for ( ; host_ent->h_addr_list[n] != NULL; ++n) {
struct sockaddr_in addr;
struct sockaddr_in* sai = &addr;
memcpy(&sai->sin_addr.s_addr, host_ent->h_addr_list[n], host_ent->h_length);
#endif
char * netip = inet_ntoa(sai->sin_addr);
if (!strncmp(netip, "192.168", 7)) // ignore if address is starting with 192
{
strlcpy(g_szInternalIP, netip, sizeof(g_szInternalIP));
#ifndef __WIN32__
fprintf(stderr, "INTERNAL_IP: %s interface %s\n", netip, ifap->ifa_name);
#else
fprintf(stderr, "INTERNAL_IP: %s\n", netip);
#endif
}
else if (!strncmp(netip, "10.", 3))
{
strlcpy(g_szInternalIP, netip, sizeof(g_szInternalIP));
#ifndef __WIN32__
fprintf(stderr, "INTERNAL_IP: %s interface %s\n", netip, ifap->ifa_name);
#else
fprintf(stderr, "INTERNAL_IP: %s\n", netip);
#endif
}
else if (g_szPublicIP[0] == '0')
{
strlcpy(g_szPublicIP, netip, sizeof(g_szPublicIP));
#ifndef __WIN32__
fprintf(stderr, "PUBLIC_IP: %s interface %s\n", netip, ifap->ifa_name);
#else
fprintf(stderr, "PUBLIC_IP: %s\n", netip);
#endif
}
}
#ifndef __WIN32__
freeifaddrs( ifaddrp );
#else
WSACleanup();
#endif
if (g_szPublicIP[0] != '0')
return true;
else
return false;
}
void config_init(const string& st_localeServiceName)
{
FILE *fp;
char buf[256];
char token_string[256];
char value_string[256];
// LOCALE_SERVICE
string st_configFileName;
st_configFileName.reserve(32);
st_configFileName = "CONFIG";
if (!st_localeServiceName.empty())
{
st_configFileName += ".";
st_configFileName += st_localeServiceName;
}
// END_OF_LOCALE_SERVICE
if (!(fp = fopen(st_configFileName.c_str(), "r")))
{
fprintf(stderr, "Can not open [%s]\n", st_configFileName.c_str());
exit(1);
}
if (!GetIPInfo())
{
fprintf(stderr, "Can not get public ip address\n");
exit(1);
}
char db_host[2][64], db_user[2][64], db_pwd[2][64], db_db[2][64];
// ... 아... db_port는 이미 있는데... 네이밍 어찌해야함...
int mysql_db_port[2];
for (int n = 0; n < 2; ++n)
{
*db_host[n] = '\0';
*db_user[n] = '\0';
*db_pwd[n]= '\0';
*db_db[n]= '\0';
mysql_db_port[n] = 0;
}
char log_host[64], log_user[64], log_pwd[64], log_db[64];
int log_port = 0;
*log_host = '\0';
*log_user = '\0';
*log_pwd = '\0';
*log_db = '\0';
// DB에서 로케일정보를 세팅하기위해서는 다른 세팅값보다 선행되어서
// DB정보만 읽어와 로케일 세팅을 한후 다른 세팅을 적용시켜야한다.
// 이유는 로케일관련된 초기화 루틴이 곳곳에 존재하기 때문.
bool isCommonSQL = false;
bool isPlayerSQL = false;
FILE* fpOnlyForDB;
if (!(fpOnlyForDB = fopen(st_configFileName.c_str(), "r")))
{
fprintf(stderr, "Can not open [%s]\n", st_configFileName.c_str());
exit(1);
}
while (fgets(buf, 256, fpOnlyForDB))
{
parse_token(buf, token_string, value_string);
TOKEN("BLOCK_LOGIN")
{
g_stBlockDate = value_string;
}
TOKEN("adminpage_ip")
{
FN_add_adminpageIP(value_string);
//g_stAdminPageIP[0] = value_string;
}
TOKEN("adminpage_ip1")
{
FN_add_adminpageIP(value_string);
//g_stAdminPageIP[0] = value_string;
}
TOKEN("adminpage_ip2")
{
FN_add_adminpageIP(value_string);
//g_stAdminPageIP[1] = value_string;
}
TOKEN("adminpage_ip3")
{
FN_add_adminpageIP(value_string);
//g_stAdminPageIP[2] = value_string;
}
TOKEN("adminpage_password")
{
g_stAdminPagePassword = value_string;
}
TOKEN("hostname")
{
g_stHostname = value_string;
fprintf(stdout, "HOSTNAME: %s\n", g_stHostname.c_str());
continue;
}
TOKEN("channel")
{
str_to_number(g_bChannel, value_string);
continue;
}
TOKEN("player_sql")
{
const char * line = two_arguments(value_string, db_host[0], sizeof(db_host[0]), db_user[0], sizeof(db_user[0]));
line = two_arguments(line, db_pwd[0], sizeof(db_pwd[0]), db_db[0], sizeof(db_db[0]));
if (NULL != line[0])
{
char buf[256];
one_argument(line, buf, sizeof(buf));
str_to_number(mysql_db_port[0], buf);
}
if (!*db_host[0] || !*db_user[0] || !*db_pwd[0] || !*db_db[0])
{
fprintf(stderr, "PLAYER_SQL syntax: logsql <host user password db>\n");
exit(1);
}
char buf[1024];
snprintf(buf, sizeof(buf), "PLAYER_SQL: %s %s %s %s %d", db_host[0], db_user[0], db_pwd[0], db_db[0], mysql_db_port[0]);
isPlayerSQL = true;
continue;
}
TOKEN("common_sql")
{
const char * line = two_arguments(value_string, db_host[1], sizeof(db_host[1]), db_user[1], sizeof(db_user[1]));
line = two_arguments(line, db_pwd[1], sizeof(db_pwd[1]), db_db[1], sizeof(db_db[1]));
if (NULL != line[0])
{
char buf[256];
one_argument(line, buf, sizeof(buf));
str_to_number(mysql_db_port[1], buf);
}
if (!*db_host[1] || !*db_user[1] || !*db_pwd[1] || !*db_db[1])
{
fprintf(stderr, "COMMON_SQL syntax: logsql <host user password db>\n");
exit(1);
}
char buf[1024];
snprintf(buf, sizeof(buf), "COMMON_SQL: %s %s %s %s %d", db_host[1], db_user[1], db_pwd[1], db_db[1], mysql_db_port[1]);
isCommonSQL = true;
continue;
}
TOKEN("log_sql")
{
const char * line = two_arguments(value_string, log_host, sizeof(log_host), log_user, sizeof(log_user));
line = two_arguments(line, log_pwd, sizeof(log_pwd), log_db, sizeof(log_db));
if (NULL != line[0])
{
char buf[256];
one_argument(line, buf, sizeof(buf));
str_to_number(log_port, buf);
}
if (!*log_host || !*log_user || !*log_pwd || !*log_db)
{
fprintf(stderr, "LOG_SQL syntax: logsql <host user password db>\n");
exit(1);
}
char buf[1024];
snprintf(buf, sizeof(buf), "LOG_SQL: %s %s %s %s %d", log_host, log_user, log_pwd, log_db, log_port);
continue;
}
//OPENID
TOKEN("WEB_AUTH")
{
const char * line = two_arguments(value_string, openid_host, sizeof(openid_host), openid_uri, sizeof(openid_uri));
if (!*openid_host || !*openid_uri)
{
fprintf(stderr, "WEB_AUTH syntax error (ex: WEB_AUTH <host(metin2.co.kr) uri(/kyw/gameauth.php)>\n");
exit(1);
}
char buf[1024];
openid_server = 1;
snprintf(buf, sizeof(buf), "WEB_AUTH: %s %s", openid_host, openid_uri);
continue;
}
}
//처리가 끝났으니 파일을 닫자.
fclose(fpOnlyForDB);
// CONFIG_SQL_INFO_ERROR
if (!isCommonSQL)
{
puts("LOAD_COMMON_SQL_INFO_FAILURE:");
puts("");
puts("CONFIG:");
puts("------------------------------------------------");
puts("COMMON_SQL: HOST USER PASSWORD DATABASE");
puts("");
exit(1);
}
if (!isPlayerSQL)
{
puts("LOAD_PLAYER_SQL_INFO_FAILURE:");
puts("");
puts("CONFIG:");
puts("------------------------------------------------");
puts("PLAYER_SQL: HOST USER PASSWORD DATABASE");
puts("");
exit(1);
}
// Common DB 가 Locale 정보를 가지고 있기 때문에 가장 먼저 접속해야 한다.
AccountDB::instance().Connect(db_host[1], mysql_db_port[1], db_user[1], db_pwd[1], db_db[1]);
if (false == AccountDB::instance().IsConnected())
{
fprintf(stderr, "cannot start server while no common sql connected\n");
exit(1);
}
fprintf(stdout, "CommonSQL connected\n");
// 로케일 정보를 가져오자
// <경고> 쿼리문에 절대 조건문(WHERE) 달지 마세요. (다른 지역에서 문제가 생길수 있습니다)
{
char szQuery[512];
snprintf(szQuery, sizeof(szQuery), "SELECT mKey, mValue FROM locale");
std::auto_ptr<SQLMsg> pMsg(AccountDB::instance().DirectQuery(szQuery));
if (pMsg->Get()->uiNumRows == 0)
{
fprintf(stderr, "COMMON_SQL: DirectQuery failed : %s\n", szQuery);
exit(1);
}
MYSQL_ROW row;
while (NULL != (row = mysql_fetch_row(pMsg->Get()->pSQLResult)))
{
// 로케일 세팅
if (strcasecmp(row[0], "LOCALE") == 0)
{
if (LocaleService_Init(row[1]) == false)
{
fprintf(stderr, "COMMON_SQL: invalid locale key %s\n", row[1]);
exit(1);
}
}
}
}
// 로케일 정보를 COMMON SQL에 세팅해준다.
// 참고로 g_stLocale 정보는 LocaleService_Init() 내부에서 세팅된다.
fprintf(stdout, "Setting DB to locale %s\n", g_stLocale.c_str());
AccountDB::instance().SetLocale(g_stLocale);
AccountDB::instance().ConnectAsync(db_host[1], mysql_db_port[1], db_user[1], db_pwd[1], db_db[1], g_stLocale.c_str());
// Player DB 접속
DBManager::instance().Connect(db_host[0], mysql_db_port[0], db_user[0], db_pwd[0], db_db[0]);
if (!DBManager::instance().IsConnected())
{
fprintf(stderr, "PlayerSQL.ConnectError\n");
exit(1);
}
fprintf(stdout, "PlayerSQL connected\n");
if (false == g_bAuthServer) // 인증 서버가 아닐 경우
{
// Log DB 접속
LogManager::instance().Connect(log_host, log_port, log_user, log_pwd, log_db);
if (!LogManager::instance().IsConnected())
{
fprintf(stderr, "LogSQL.ConnectError\n");
exit(1);
}
fprintf(stdout, "LogSQL connected\n");
LogManager::instance().BootLog(g_stHostname.c_str(), g_bChannel);
}
// SKILL_POWER_BY_LEVEL
// 스트링 비교의 문제로 인해서 AccountDB::instance().SetLocale(g_stLocale) 후부터 한다.
// 물론 국내는 별로 문제가 안된다(해외가 문제)
{
char szQuery[256];
snprintf(szQuery, sizeof(szQuery), "SELECT mValue FROM locale WHERE mKey='SKILL_POWER_BY_LEVEL'");
std::auto_ptr<SQLMsg> pMsg(AccountDB::instance().DirectQuery(szQuery));
if (pMsg->Get()->uiNumRows == 0)
{
fprintf(stderr, "[SKILL_PERCENT] Query failed: %s", szQuery);
exit(1);
}
MYSQL_ROW row;
row = mysql_fetch_row(pMsg->Get()->pSQLResult);
const char * p = row[0];
int cnt = 0;
char num[128];
int aiBaseSkillPowerByLevelTable[SKILL_MAX_LEVEL+1];
fprintf(stdout, "SKILL_POWER_BY_LEVEL %s\n", p);
while (*p != '\0' && cnt < (SKILL_MAX_LEVEL + 1))
{
p = one_argument(p, num, sizeof(num));
aiBaseSkillPowerByLevelTable[cnt++] = atoi(num);
//fprintf(stdout, "%d %d\n", cnt - 1, aiBaseSkillPowerByLevelTable[cnt - 1]);
if (*p == '\0')
{
if (cnt != (SKILL_MAX_LEVEL + 1))
{
fprintf(stderr, "[SKILL_PERCENT] locale table has not enough skill information! (count: %d query: %s)", cnt, szQuery);
exit(1);
}
fprintf(stdout, "SKILL_POWER_BY_LEVEL: Done! (count %d)\n", cnt);
break;
}
}
// 종족별 스킬 세팅
for (int job = 0; job < JOB_MAX_NUM * 2; ++job)
{
snprintf(szQuery, sizeof(szQuery), "SELECT mValue from locale where mKey='SKILL_POWER_BY_LEVEL_TYPE%d' ORDER BY CAST(mValue AS unsigned)", job);
std::auto_ptr<SQLMsg> pMsg(AccountDB::instance().DirectQuery(szQuery));
// 세팅이 안되어있으면 기본테이블을 사용한다.
if (pMsg->Get()->uiNumRows == 0)
{
CTableBySkill::instance().SetSkillPowerByLevelFromType(job, aiBaseSkillPowerByLevelTable);
continue;
}
row = mysql_fetch_row(pMsg->Get()->pSQLResult);
cnt = 0;
p = row[0];
int aiSkillTable[SKILL_MAX_LEVEL + 1];
fprintf(stdout, "SKILL_POWER_BY_JOB %d %s\n", job, p);
while (*p != '\0' && cnt < (SKILL_MAX_LEVEL + 1))
{
p = one_argument(p, num, sizeof(num));
aiSkillTable[cnt++] = atoi(num);
//fprintf(stdout, "%d %d\n", cnt - 1, aiBaseSkillPowerByLevelTable[cnt - 1]);
if (*p == '\0')
{
if (cnt != (SKILL_MAX_LEVEL + 1))
{
fprintf(stderr, "[SKILL_PERCENT] locale table has not enough skill information! (count: %d query: %s)", cnt, szQuery);
exit(1);
}
fprintf(stdout, "SKILL_POWER_BY_JOB: Done! (job: %d count: %d)\n", job, cnt);
break;
}
}
CTableBySkill::instance().SetSkillPowerByLevelFromType(job, aiSkillTable);
}
}
// END_SKILL_POWER_BY_LEVEL
// LOG_KEEP_DAYS_EXTEND
log_set_expiration_days(2);
// END_OF_LOG_KEEP_DAYS_EXTEND
while (fgets(buf, 256, fp))
{
parse_token(buf, token_string, value_string);
TOKEN("empire_whisper")
{
bool b_value = 0;
str_to_number(b_value, value_string);
g_bEmpireWhisper = !!b_value;
continue;
}
TOKEN("mark_server")
{
guild_mark_server = is_string_true(value_string);
continue;
}
TOKEN("mark_min_level")
{
str_to_number(guild_mark_min_level, value_string);
guild_mark_min_level = MINMAX(0, guild_mark_min_level, GUILD_MAX_LEVEL);
continue;
}
TOKEN("port")
{
str_to_number(mother_port, value_string);
continue;
}
TOKEN("log_keep_days")
{
int i = 0;
str_to_number(i, value_string);
log_set_expiration_days(MINMAX(1, i, 90));
continue;
}
TOKEN("passes_per_sec")
{
str_to_number(passes_per_sec, value_string);
continue;
}
TOKEN("p2p_port")
{
str_to_number(p2p_port, value_string);
continue;
}
TOKEN("db_port")
{
str_to_number(db_port, value_string);
continue;
}
TOKEN("db_addr")
{
strlcpy(db_addr, value_string, sizeof(db_addr));
for (int n =0; n < ADDRESS_MAX_LEN; ++n)
{
if (db_addr[n] == ' ')
db_addr[n] = '\0';
}
continue;
}
TOKEN("save_event_second_cycle")
{
int cycle = 0;
str_to_number(cycle, value_string);
save_event_second_cycle = cycle * passes_per_sec;
continue;
}
TOKEN("ping_event_second_cycle")
{
int cycle = 0;
str_to_number(cycle, value_string);
ping_event_second_cycle = cycle * passes_per_sec;
continue;
}
TOKEN("table_postfix")
{
g_table_postfix = value_string;
continue;
}
TOKEN("test_server")
{
printf("-----------------------------------------------\n");
printf("TEST_SERVER\n");
printf("-----------------------------------------------\n");
str_to_number(test_server, value_string);
continue;
}
TOKEN("speed_server")
{
printf("-----------------------------------------------\n");
printf("SPEED_SERVER\n");
printf("-----------------------------------------------\n");
str_to_number(speed_server, value_string);
continue;
}
#ifdef __AUCTION__
TOKEN("auction_server")
{
printf("-----------------------------------------------\n");
printf("AUCTION_SERVER\n");
printf("-----------------------------------------------\n");
str_to_number(auction_server, value_string);
continue;
}
#endif
TOKEN("distribution_test_server")
{
str_to_number(distribution_test_server, value_string);
continue;
}
TOKEN("china_event_server")
{
str_to_number(china_event_server, value_string);
continue;
}
TOKEN("shutdowned")
{
g_bNoMoreClient = true;
continue;
}
TOKEN("no_regen")
{
g_bNoRegen = true;
continue;
}
TOKEN("traffic_profile")
{
g_bTrafficProfileOn = true;
continue;
}
TOKEN("map_allow")
{
char * p = value_string;
string stNum;
for (; *p; p++)
{
if (isnhspace(*p))
{
if (stNum.length())
{
int index = 0;
str_to_number(index, stNum.c_str());
map_allow_add(index);
stNum.clear();
}
}
else
stNum += *p;
}
if (stNum.length())
{
int index = 0;
str_to_number(index, stNum.c_str());
map_allow_add(index);
}
continue;
}
TOKEN("no_wander")
{
no_wander = true;
continue;
}
TOKEN("user_limit")
{
str_to_number(g_iUserLimit, value_string);
continue;
}
TOKEN("skill_disable")
{
str_to_number(g_bSkillDisable, value_string);
continue;
}
TOKEN("auth_server")
{
char szIP[32];
char szPort[32];
two_arguments(value_string, szIP, sizeof(szIP), szPort, sizeof(szPort));
if (!*szIP || (!*szPort && strcasecmp(szIP, "master")))
{
fprintf(stderr, "AUTH_SERVER: syntax error: <ip|master> <port>\n");
exit(1);
}
g_bAuthServer = true;
LoadBanIP("BANIP");
if (!strcasecmp(szIP, "master"))
fprintf(stdout, "AUTH_SERVER: I am the master\n");
else
{
g_stAuthMasterIP = szIP;
str_to_number(g_wAuthMasterPort, szPort);
fprintf(stdout, "AUTH_SERVER: master %s %u\n", g_stAuthMasterIP.c_str(), g_wAuthMasterPort);
}
continue;
}
TOKEN("billing")
{
g_bBilling = true;
}
TOKEN("quest_dir")
{
sys_log(0, "QUEST_DIR SETTING : %s", value_string);
g_stQuestDir = value_string;
}
TOKEN("quest_object_dir")
{
//g_stQuestObjectDir = value_string;
std::istringstream is(value_string);
sys_log(0, "QUEST_OBJECT_DIR SETTING : %s", value_string);
string dir;
while (!is.eof())
{
is >> dir;
if (is.fail())
break;
g_setQuestObjectDir.insert(dir);
sys_log(0, "QUEST_OBJECT_DIR INSERT : %s", dir .c_str());
}
}
TOKEN("teen_addr")
{
strlcpy(teen_addr, value_string, sizeof(teen_addr));
for (int n =0; n < ADDRESS_MAX_LEN; ++n)
{
if (teen_addr[n] == ' ')
teen_addr[n] = '\0';
}
continue;
}
TOKEN("teen_port")
{
str_to_number(teen_port, value_string);
}
TOKEN("synchack_limit_count")
{
str_to_number(g_iSyncHackLimitCount, value_string);
}
TOKEN("speedhack_limit_count")
{
str_to_number(SPEEDHACK_LIMIT_COUNT, value_string);
}
TOKEN("speedhack_limit_bonus")
{
str_to_number(SPEEDHACK_LIMIT_BONUS, value_string);
}
TOKEN("server_id")
{
str_to_number(g_server_id, value_string);
}
TOKEN("mall_url")
{
g_strWebMallURL = value_string;
}
TOKEN("bind_ip")
{
strlcpy(g_szPublicIP, value_string, sizeof(g_szPublicIP));
}
TOKEN("view_range")
{
str_to_number(VIEW_RANGE, value_string);
}
TOKEN("spam_block_duration")
{
str_to_number(g_uiSpamBlockDuration, value_string);
}
TOKEN("spam_block_score")
{
str_to_number(g_uiSpamBlockScore, value_string);
g_uiSpamBlockScore = MAX(1, g_uiSpamBlockScore);
}
TOKEN("spam_block_reload_cycle")
{
str_to_number(g_uiSpamReloadCycle, value_string);
g_uiSpamReloadCycle = MAX(60, g_uiSpamReloadCycle); // 최소 1분
}
TOKEN("check_multihack")
{
str_to_number(g_bCheckMultiHack, value_string);
}
TOKEN("spam_block_max_level")
{
str_to_number(g_iSpamBlockMaxLevel, value_string);
}
TOKEN("protect_normal_player")
{
str_to_number(g_protectNormalPlayer, value_string);
}
TOKEN("notice_battle_zone")
{
str_to_number(g_noticeBattleZone, value_string);
}
TOKEN("hackshield_enable")
{
int flag = 0;
str_to_number(flag, value_string);
//if (1 == flag && LC_IsEurope() )
if (1 == flag)
{
isHackShieldEnable = true;
}
}
TOKEN("hackshield_first_check_time")
{
int secs = 30;
str_to_number(secs, value_string);
HackShield_FirstCheckWaitTime = passes_per_sec * secs;
}
TOKEN("hackshield_check_cycle_time")
{
int secs = 180;
str_to_number(secs, value_string);
HackShield_CheckCycleTime = passes_per_sec * secs;
}
TOKEN("xtrap_enable")
{
int flag = 0;
str_to_number(flag, value_string);
if (1 == flag )
{
bXTrapEnabled = true;
}
}
TOKEN("pk_protect_level")
{
str_to_number(PK_PROTECT_LEVEL, value_string);
fprintf(stderr, "PK_PROTECT_LEVEL: %d", PK_PROTECT_LEVEL);
}
TOKEN("max_level")
{
str_to_number(gPlayerMaxLevel, value_string);
gPlayerMaxLevel = MINMAX(1, gPlayerMaxLevel, PLAYER_MAX_LEVEL_CONST);
fprintf(stderr, "PLAYER_MAX_LEVEL: %d\n", gPlayerMaxLevel);
}
TOKEN("block_char_creation")
{
int tmp = 0;
str_to_number(tmp, value_string);
if (0 == tmp)
g_BlockCharCreation = false;
else
g_BlockCharCreation = true;
continue;
}
TOKEN("server_key")
{
CheckServer::AddServerKey(value_string);
continue;
}
}
if (g_setQuestObjectDir.empty())
g_setQuestObjectDir.insert(g_stDefaultQuestObjectDir);
if (0 == db_port)
{
fprintf(stderr, "DB_PORT not configured\n");
exit(1);
}
if (0 == g_bChannel)
{
fprintf(stderr, "CHANNEL not configured\n");
exit(1);
}
if (g_stHostname.empty())
{
fprintf(stderr, "HOSTNAME must be configured.\n");
exit(1);
}
// LOCALE_SERVICE
LocaleService_LoadLocaleStringFile();
LocaleService_TransferDefaultSetting();
LocaleService_LoadEmpireTextConvertTables();
// END_OF_LOCALE_SERVICE
fclose(fp);
if ((fp = fopen("CMD", "r")))
{
while (fgets(buf, 256, fp))
{
char cmd[32], levelname[32];
int level;
two_arguments(buf, cmd, sizeof(cmd), levelname, sizeof(levelname));
if (!*cmd || !*levelname)
{
fprintf(stderr, "CMD syntax error: <cmd> <DISABLE | LOW_WIZARD | WIZARD | HIGH_WIZARD | GOD>\n");
exit(1);
}
if (!strcasecmp(levelname, "LOW_WIZARD"))
level = GM_LOW_WIZARD;
else if (!strcasecmp(levelname, "WIZARD"))
level = GM_WIZARD;
else if (!strcasecmp(levelname, "HIGH_WIZARD"))
level = GM_HIGH_WIZARD;
else if (!strcasecmp(levelname, "GOD"))
level = GM_GOD;
else if (!strcasecmp(levelname, "IMPLEMENTOR"))
level = GM_IMPLEMENTOR;
else if (!strcasecmp(levelname, "DISABLE"))
level = GM_IMPLEMENTOR + 1;
else
{
fprintf(stderr, "CMD syntax error: <cmd> <DISABLE | LOW_WIZARD | WIZARD | HIGH_WIZARD | GOD>\n");
exit(1);
}
interpreter_set_privilege(cmd, level);
}
fclose(fp);
}
LoadValidCRCList();
LoadStateUserCount();
CWarMapManager::instance().LoadWarMapInfo(NULL);
FN_log_adminpage();
}
const char* get_table_postfix()
{
return g_table_postfix.c_str();
}
void LoadValidCRCList()
{
s_set_dwProcessCRC.clear();
s_set_dwFileCRC.clear();
FILE * fp;
char buf[256];
if ((fp = fopen("CRC", "r")))
{
while (fgets(buf, 256, fp))
{
if (!*buf)
continue;
DWORD dwValidClientProcessCRC;
DWORD dwValidClientFileCRC;
sscanf(buf, " %u %u ", &dwValidClientProcessCRC, &dwValidClientFileCRC);
s_set_dwProcessCRC.insert(dwValidClientProcessCRC);
s_set_dwFileCRC.insert(dwValidClientFileCRC);
fprintf(stderr, "CLIENT_CRC: %u %u\n", dwValidClientProcessCRC, dwValidClientFileCRC);
}
fclose(fp);
}
}
bool LoadClientVersion()
{
FILE * fp = fopen("VERSION", "r");
if (!fp)
return false;
char buf[256];
fgets(buf, 256, fp);
char * p = strchr(buf, '\n');
if (p) *p = '\0';
fprintf(stderr, "VERSION: \"%s\"\n", buf);
g_stClientVersion = buf;
fclose(fp);
return true;
}
void CheckClientVersion()
{
if (LC_IsEurope())
{
g_bCheckClientVersion = true;
}
else
{
g_bCheckClientVersion = false;
}
const DESC_MANAGER::DESC_SET & set = DESC_MANAGER::instance().GetClientSet();
DESC_MANAGER::DESC_SET::const_iterator it = set.begin();
while (it != set.end())
{
LPDESC d = *(it++);
if (!d->GetCharacter())
continue;
int version = atoi(g_stClientVersion.c_str());
int date = atoi(d->GetClientVersion() );
//if (0 != g_stClientVersion.compare(d->GetClientVersion()) )
if (version > date)
{
d->GetCharacter()->ChatPacket(CHAT_TYPE_NOTICE, LC_TEXT("클라이언트 버전이 틀려 로그아웃 됩니다. 정상적으로 패치 후 접속하세요."));
d->DelayedDisconnect(10);
}
}
}
void LoadStateUserCount()
{
FILE * fp = fopen("state_user_count", "r");
if (!fp)
return;
if (!LC_IsHongKong())
fscanf(fp, " %d %d ", &g_iFullUserCount, &g_iBusyUserCount);
fclose(fp);
}
bool IsValidProcessCRC(DWORD dwCRC)
{
return s_set_dwProcessCRC.find(dwCRC) != s_set_dwProcessCRC.end();
}
bool IsValidFileCRC(DWORD dwCRC)
{
return s_set_dwFileCRC.find(dwCRC) != s_set_dwFileCRC.end();
}
config.h:
#ifndef __INC_METIN_II_GAME_CONFIG_H__
#define __INC_METIN_II_GAME_CONFIG_H__
enum
{
ADDRESS_MAX_LEN = 15
};
void config_init(const std::string& st_localeServiceName); // default "" is CONFIG
extern char sql_addr[256];
extern WORD mother_port;
extern WORD p2p_port;
extern char db_addr[ADDRESS_MAX_LEN + 1];
extern WORD db_port;
extern char teen_addr[ADDRESS_MAX_LEN + 1];
extern WORD teen_port;
extern char passpod_addr[ADDRESS_MAX_LEN + 1];
extern WORD passpod_port;
extern int passes_per_sec;
extern int save_event_second_cycle;
extern int ping_event_second_cycle;
extern int test_server;
extern bool guild_mark_server;
extern BYTE guild_mark_min_level;
extern bool distribution_test_server;
extern bool china_event_server;
extern bool g_bNoMoreClient;
extern bool g_bNoRegen;
extern bool g_bTrafficProfileOn; ///< true 이면 TrafficProfiler 를 켠다.
extern BYTE g_bChannel;
extern bool map_allow_find(int index);
extern void map_allow_copy(long * pl, int size);
extern bool no_wander;
extern int g_iUserLimit;
extern time_t g_global_time;
const char * get_table_postfix();
extern std::string g_stHostname;
extern std::string g_stLocale;
extern std::string g_stLocaleFilename;
extern char g_szPublicIP[16];
extern char g_szInternalIP[16];
extern int (*is_twobyte) (const char * str);
extern int (*check_name) (const char * str);
extern bool g_bSkillDisable;
extern int g_iFullUserCount;
extern int g_iBusyUserCount;
extern void LoadStateUserCount();
extern bool g_bEmpireWhisper;
extern BYTE g_bAuthServer;
extern BYTE g_bBilling;
extern BYTE PK_PROTECT_LEVEL;
extern void LoadValidCRCList();
extern bool IsValidProcessCRC(DWORD dwCRC);
extern bool IsValidFileCRC(DWORD dwCRC);
extern std::string g_stAuthMasterIP;
extern WORD g_wAuthMasterPort;
extern std::string g_stClientVersion;
extern bool g_bCheckClientVersion;
extern void CheckClientVersion();
extern std::string g_stQuestDir;
//extern std::string g_stQuestObjectDir;
extern std::set<std::string> g_setQuestObjectDir;
extern std::vector<std::string> g_stAdminPageIP;
extern std::string g_stAdminPagePassword;
extern int SPEEDHACK_LIMIT_COUNT;
extern int SPEEDHACK_LIMIT_BONUS;
extern int g_iSyncHackLimitCount;
extern int g_server_id;
extern std::string g_strWebMallURL;
extern int VIEW_RANGE;
extern int VIEW_BONUS_RANGE;
extern bool g_bCheckMultiHack;
extern bool g_protectNormalPlayer; // 범법자가 "평화모드" 인 일반유저를 공격하지 못함
extern bool g_noticeBattleZone; // 중립지대에 입장하면 안내메세지를 알려줌
extern DWORD g_GoldDropTimeLimitValue;
extern bool isHackShieldEnable;
extern int HackShield_FirstCheckWaitTime;
extern int HackShield_CheckCycleTime;
extern bool bXTrapEnabled;
extern int gPlayerMaxLevel;
extern bool g_BlockCharCreation;
#endif /* __INC_METIN_II_GAME_CONFIG_H__ */
shutdown_manager.cpp:
#include "stdafx.h"
#include "../../libgame/include/grid.h"
#include "locale_service.h"
#include "config.h"
#include "desc.h"
#include "shutdown_manager.h"
// 싱글턴 생성자 호출하는데가 어딘지 몰라서 여기다 하나 만들어놓음
CShutdownManager t = CShutdownManager();
CShutdownManager::CShutdownManager() : m_pTime(NULL), m_lTime(0), m_bShutdownAlarm(false)
{
m_lstDesc.clear();
}
CShutdownManager::~CShutdownManager()
{
m_lstDesc.clear();
}
void CShutdownManager::AddDesc(LPDESC pDesc)
{
if(!CheckLocale() || pDesc == NULL || SearchDesc(pDesc) != -1) return;
UpdateTime();
const char* szSocialID = pDesc->GetAccountTable().social_id;
if(CheckShutdownAge(szSocialID))
{
m_lstDesc.push_back(pDesc);
}
}
void CShutdownManager::RemoveDesc(LPDESC pDesc)
{
if(!CheckLocale() || pDesc == NULL) return;
int nIndex = SearchDesc(pDesc);
if(nIndex < 0) return;
std::list<LPDESC>::iterator i = m_lstDesc.begin();
while(nIndex) { nIndex--; i++; }
m_lstDesc.erase(i);
}
void CShutdownManager::Update()
{
if(!CheckLocale()) return;
UpdateTime();
if(!m_bShutdownAlarm) // 10분전에 알림 출력.
{
if(m_pTime->tm_hour >= 23 && m_pTime->tm_min >= 50)
{
for(std::list<LPDESC>::iterator i = m_lstDesc.begin(); i != m_lstDesc.end(); i++) // 대상 모두 PHASE_CLOSE
{
if((*i) != NULL)
{
(*i)->ChatPacket(CHAT_TYPE_INFO, LC_TEXT("셧다운제 시행으로 10분 뒤 종료됩니다."));
}
}
m_bShutdownAlarm = true;
}
}
if(CheckShutdownTime()) // Check Shutdown Time
{
for(std::list<LPDESC>::iterator i = m_lstDesc.begin(); i != m_lstDesc.end(); i++) // 대상 모두 PHASE_CLOSE
{
if((*i) != NULL)
{
printf("ShutdownManager::Update() - Shutdown Account : %s\n", (*i)->GetAccountTable().login);
(*i)->SetPhase(PHASE_CLOSE);
}
}
m_bShutdownAlarm = false;
m_lstDesc.clear(); // 했으면 리스트를 비움.
}
}
int CShutdownManager::SearchDesc(LPDESC pDesc)
{
if(!CheckLocale()) return -1;
std::list<LPDESC>::iterator iter = m_lstDesc.begin();
for(int i = 0; i < m_lstDesc.size(); i++)
{
if(*(iter) == pDesc) return i;
iter++;
}
return -1; // 리스트에서 찾을 수 없는 경우
}
// 셧다운 대상 나이 체크
bool CShutdownManager::CheckShutdownAge(const char* szSocialID)
{
if(!CheckLocale() || !CheckCorrectSocialID(szSocialID)) return false;
UpdateTime();
int nAge = CharToInt(szSocialID[0]) * 10 + CharToInt(szSocialID[1]);
if(CharToInt(szSocialID[6]) < 3) // 주민번호 7번째 자리가 3~4인 경우는 2000년 이후 출생
{
nAge = m_pTime->tm_year - nAge;
}
else
{
nAge = m_pTime->tm_year - 100 - nAge;
}
if(nAge < gShutdownAge)
return true;
else
return false;
}
// 셧다운 시간 체크
bool CShutdownManager::CheckShutdownTime()
{
if(!CheckLocale()) return false;
UpdateTime();
if(m_pTime->tm_hour < 6)
return true;
else
return false;
}
// 주민번호 유효성 체크
bool CShutdownManager::CheckCorrectSocialID(const char* szSocialID)
{
if(!CheckLocale()) return true;
if(szSocialID == NULL || strlen(szSocialID) != 13) return false;
UpdateTime();
int nMonth = CharToInt(szSocialID[2]) * 10 + CharToInt(szSocialID[3]);
int nDay = CharToInt(szSocialID[4]) * 10 + CharToInt(szSocialID[5]);
int nGender = CharToInt(szSocialID[6]);
if(nMonth > 12 || nMonth == 0) return false;
if(nDay > 31 || nDay == 0) return false;
if(nGender == 0) return false;
int nSum =
CharToInt(szSocialID[0]) * 2
+ CharToInt(szSocialID[1]) * 3
+ CharToInt(szSocialID[2]) * 4
+ CharToInt(szSocialID[3]) * 5
+ CharToInt(szSocialID[4]) * 6
+ CharToInt(szSocialID[5]) * 7
+ CharToInt(szSocialID[6]) * 8
+ CharToInt(szSocialID[7]) * 9
+ CharToInt(szSocialID[8]) * 2
+ CharToInt(szSocialID[9]) * 3
+ CharToInt(szSocialID[10]) * 4
+ CharToInt(szSocialID[11]) * 5;
int nResult = 11 - (nSum % 11);
if(nResult > 9) nResult -= 10;
if(CharToInt(szSocialID[12]) != nResult) return false;
return true;
}
shutdown_manager.h:
#ifndef __INC_METIN_II_SHUTDOWNMANAGER_H__
#define __INC_METIN_II_SHUTDOWNMANAGER_H__
// CONFIG에서 SHUTDOWN_ENABLE FLAG를 0이 아닌 숫자로 지정할경우 활성화됨.
class CShutdownManager : public singleton<CShutdownManager>
{
public:
CShutdownManager();
virtual ~CShutdownManager();
void AddDesc(LPDESC pDesc);
void RemoveDesc(LPDESC pDesc);
int SearchDesc(LPDESC pDesc); // m_lstDesc에서 찾으면 대상의 index 리턴. 없으면 -1.
void Update();
private:
std::list<LPDESC> m_lstDesc; // AddDesc에서 선별.
struct tm* m_pTime; time_t m_lTime;
bool m_bShutdownAlarm;
void inline UpdateTime() { time(&m_lTime); m_pTime = localtime(&m_lTime); }
public:
bool CheckShutdownAge(const char* szSocialID);
bool CheckShutdownTime();
bool CheckCorrectSocialID(const char* szSocialID);
bool inline CheckLocale() { return (LC_IsYMIR() || LC_IsWE_Korea()) && gShutdownEnable; }
private:
int inline CharToInt(char c) { if(c >= '0' && c <= '9') return c - '0'; else return 0;} // char -> int
};
#endif
