summaryrefslogtreecommitdiff
path: root/src/login/login_sql.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/login/login_sql.c')
-rw-r--r--src/login/login_sql.c532
1 files changed, 26 insertions, 506 deletions
diff --git a/src/login/login_sql.c b/src/login/login_sql.c
index c72a2d08c..04d5deb39 100644
--- a/src/login/login_sql.c
+++ b/src/login/login_sql.c
@@ -20,33 +20,11 @@
#include <string.h>
#include <sys/stat.h> // for stat/lstat/fstat
-struct Login_Config login_config;
-
-int login_fd; // login server socket
-#define MAX_SERVERS 30
-struct mmo_char_server server[MAX_SERVERS]; // char server data
-
-#define sex_num2str(num) ( (num == 0 ) ? 'F' : (num == 1 ) ? 'M' : 'S' )
-#define sex_str2num(str) ( (str == 'F' ) ? 0 : (str == 'M' ) ? 1 : 2 )
-
-// Advanced subnet check [LuzZza]
-struct s_subnet {
- uint32 mask;
- uint32 char_ip;
- uint32 map_ip;
-} subnet[16];
-
-int subnet_count = 0;
// GM account management
struct gm_account* gm_account_db = NULL;
unsigned int GM_num = 0; // number of gm accounts
-//Account registration flood protection [Kevin]
-int allowed_regs = 1;
-int time_allowed = 10; //in seconds
-unsigned int new_reg_tick = 0;
-
// data handling (SQL)
Sql* sql_handle;
@@ -71,106 +49,31 @@ char login_db_user_pass[256] = "user_pass";
char login_db_level[256] = "level";
-//-----------------------------------------------------
-// Auth database
-//-----------------------------------------------------
+// temporary external imports
+#define MAX_SERVERS 30
#define AUTH_TIMEOUT 30000
+#define sex_num2str(num) ( (num == 0 ) ? 'F' : (num == 1 ) ? 'M' : 'S' )
+#define sex_str2num(str) ( (str == 'F' ) ? 0 : (str == 'M' ) ? 1 : 2 )
-struct auth_node {
- int account_id;
- uint32 login_id1;
- uint32 login_id2;
- uint32 ip;
- char sex;
-};
+struct online_login_data;
+extern DBMap* auth_db;
+extern DBMap* online_db;
+struct Login_Config login_config;
+extern struct Login_Config login_config;
+extern struct mmo_char_server server[MAX_SERVERS];
+extern int login_fd;
+extern int allowed_regs;
+extern int time_allowed;
+
+int charif_sendallwos(int sfd, uint8* buf, size_t len);
+bool check_password(struct login_session_data* sd, int passwdenc, const char* passwd, const char* refpass);
+int online_db_setoffline(DBKey key, void* data, va_list ap);
+struct online_login_data* add_online_user(int char_server, int account_id);
+void remove_online_user(int account_id);
+void* create_online_user(DBKey key, va_list args);
+int waiting_disconnect_timer(int tid, unsigned int tick, int id, int data);
+int lan_subnetcheck(uint32 ip);
-static DBMap* auth_db; // int account_id -> struct auth_node*
-
-//-----------------------------------------------------
-// Online User Database [Wizputer]
-//-----------------------------------------------------
-
-struct online_login_data {
- int account_id;
- int waiting_disconnect;
- int char_server;
-};
-
-static DBMap* online_db; // int account_id -> struct online_login_data*
-static int waiting_disconnect_timer(int tid, unsigned int tick, int id, int data);
-
-static void* create_online_user(DBKey key, va_list args)
-{
- struct online_login_data* p;
- CREATE(p, struct online_login_data, 1);
- p->account_id = key.i;
- p->char_server = -1;
- p->waiting_disconnect = -1;
- return p;
-}
-
-struct online_login_data* add_online_user(int char_server, int account_id)
-{
- struct online_login_data* p;
- if( !login_config.online_check )
- return NULL;
- p = (struct online_login_data*)idb_ensure(online_db, account_id, create_online_user);
- p->char_server = char_server;
- if( p->waiting_disconnect != -1 )
- {
- delete_timer(p->waiting_disconnect, waiting_disconnect_timer);
- p->waiting_disconnect = -1;
- }
- return p;
-}
-
-void remove_online_user(int account_id)
-{
- struct online_login_data* p;
- if( !login_config.online_check )
- return;
- p = (struct online_login_data*)idb_get(online_db, account_id);
- if( p == NULL )
- return;
- if( p->waiting_disconnect != -1 )
- delete_timer(p->waiting_disconnect, waiting_disconnect_timer);
-
- idb_remove(online_db, account_id);
-}
-
-static int waiting_disconnect_timer(int tid, unsigned int tick, int id, int data)
-{
- struct online_login_data* p = (struct online_login_data*)idb_get(online_db, id);
- if( p != NULL && p->waiting_disconnect == tid && p->account_id == id )
- {
- p->waiting_disconnect = -1;
- remove_online_user(id);
- idb_remove(auth_db, id);
- }
- return 0;
-}
-
-//--------------------------------------------------------------------
-// Packet send to all char-servers, except one (wos: without our self)
-//--------------------------------------------------------------------
-int charif_sendallwos(int sfd, uint8* buf, size_t len)
-{
- int i, c;
-
- for( i = 0, c = 0; i < MAX_SERVERS; ++i )
- {
- int fd = server[i].fd;
- if( session_isValid(fd) && fd != sfd )
- {
- WFIFOHEAD(fd,len);
- memcpy(WFIFOP(fd,0), buf, len);
- WFIFOSET(fd,len);
- ++c;
- }
- }
-
- return c;
-}
//-----------------------------------------------------
// Read GM accounts
@@ -278,7 +181,7 @@ int sql_ping_init(void)
//-----------------------------------------------------
// Read Account database - mysql db
//-----------------------------------------------------
-int mmo_auth_sqldb_init(void)
+int mmo_auth_init(void)
{
ShowStatus("Login server init....\n");
@@ -337,49 +240,6 @@ void mmo_db_close(void)
do_close(login_fd);
}
-//-----------------------------------------------------
-// periodic ip address synchronization
-//-----------------------------------------------------
-static int sync_ip_addresses(int tid, unsigned int tick, int id, int data)
-{
- uint8 buf[2];
- ShowInfo("IP Sync in progress...\n");
- WBUFW(buf,0) = 0x2735;
- charif_sendallwos(-1, buf, 2);
- return 0;
-}
-
-//-----------------------------------------------------
-// encrypted/unencrypted password check
-//-----------------------------------------------------
-bool check_encrypted(const char* str1, const char* str2, const char* passwd)
-{
- char md5str[64], md5bin[32];
-
- snprintf(md5str, sizeof(md5str), "%s%s", str1, str2);
- md5str[sizeof(md5str)-1] = '\0';
- MD5_String2binary(md5str, md5bin);
-
- return (0==memcmp(passwd, md5bin, 16));
-}
-
-bool check_password(struct login_session_data* ld, int passwdenc, const char* passwd, const char* refpass)
-{
- if(passwdenc == 0)
- {
- return (0==strcmp(passwd, refpass));
- }
- else if (ld)
- {
- // password mode set to 1 -> (md5key, refpass) enable with <passwordencrypt></passwordencrypt>
- // password mode set to 2 -> (refpass, md5key) enable with <passwordencrypt2></passwordencrypt2>
-
- return ((passwdenc&0x01) && check_encrypted(ld->md5key, refpass, passwd)) ||
- ((passwdenc&0x02) && check_encrypted(refpass, ld->md5key, passwd));
- }
- return false;
-}
-
//-----------------------------------------------------
// Make new account
@@ -387,6 +247,7 @@ bool check_password(struct login_session_data* ld, int passwdenc, const char* pa
int mmo_auth_new(struct mmo_account* account)
{
static int num_regs = 0; // registration counter
+ static unsigned int new_reg_tick = 0;
unsigned int tick = gettick();
char md5buf[32+1];
@@ -395,6 +256,8 @@ int mmo_auth_new(struct mmo_account* account)
int result = 0;
//Account Registration Flood Protection by [Kevin]
+ if( new_reg_tick == 0 )
+ new_reg_tick = gettick();
if( DIFF_TICK(tick, new_reg_tick) < 0 && num_regs >= allowed_regs )
{
ShowNotice("Account registration denied (registration limit exceeded)\n");
@@ -590,24 +453,6 @@ int mmo_auth(struct login_session_data* sd)
return -1; // account OK
}
-static int online_db_setoffline(DBKey key, void* data, va_list ap)
-{
- struct online_login_data* p = (struct online_login_data*)data;
- int server = va_arg(ap, int);
- if( server == -1 )
- {
- p->char_server = -1;
- if( p->waiting_disconnect != -1 )
- {
- delete_timer(p->waiting_disconnect, waiting_disconnect_timer);
- p->waiting_disconnect = -1;
- }
- }
- else if( p->char_server == server )
- p->char_server = -2; //Char server disconnected.
- return 0;
-}
-
//--------------------------------
// Packet parsing for char-servers
//--------------------------------
@@ -1137,16 +982,6 @@ int parse_fromchar(int fd)
return 0;
}
-//--------------------------------------------
-// Test to know if an IP come from LAN or WAN.
-//--------------------------------------------
-int lan_subnetcheck(uint32 ip)
-{
- int i;
- ARR_FIND( 0, subnet_count, i, (subnet[i].char_ip & subnet[i].mask) == (ip & subnet[i].mask) );
- return ( i < subnet_count ) ? subnet[i].char_ip : 0;
-}
-
int login_ip_ban_check(uint32 ip)
{
uint8* p = (uint8*)&ip;
@@ -1603,103 +1438,6 @@ int parse_login(int fd)
return 0;
}
-//-----------------------
-// Console Command Parser [Wizputer]
-//-----------------------
-int parse_console(char* buf)
-{
- char command[256];
-
- memset(command, 0, sizeof(command));
-
- sscanf(buf, "%[^\n]", command);
-
- ShowInfo("Console command :%s", command);
-
- if( strcmpi("shutdown", command) == 0 ||
- strcmpi("exit", command) == 0 ||
- strcmpi("quit", command) == 0 ||
- strcmpi("end", command) == 0 )
- runflag = 0;
- else
- if( strcmpi("alive", command) == 0 ||
- strcmpi("status", command) == 0 )
- ShowInfo(CL_CYAN"Console: "CL_BOLD"I'm Alive."CL_RESET"\n");
- else
- if( strcmpi("help", command) == 0 ) {
- ShowInfo(CL_BOLD"Help of commands:"CL_RESET"\n");
- ShowInfo(" To shutdown the server:\n");
- ShowInfo(" 'shutdown|exit|quit|end'\n");
- ShowInfo(" To know if server is alive:\n");
- ShowInfo(" 'alive|status'\n");
- }
-
- return 0;
-}
-
-static int online_data_cleanup_sub(DBKey key, void *data, va_list ap)
-{
- struct online_login_data *character= (struct online_login_data*)data;
- if (character->char_server == -2) //Unknown server.. set them offline
- remove_online_user(character->account_id);
- return 0;
-}
-
-static int online_data_cleanup(int tid, unsigned int tick, int id, int data)
-{
- online_db->foreach(online_db, online_data_cleanup_sub);
- return 0;
-}
-
-//----------------------------------
-// Reading Lan Support configuration
-//----------------------------------
-int login_lan_config_read(const char *lancfgName)
-{
- FILE *fp;
- int line_num = 0;
- char line[1024], w1[64], w2[64], w3[64], w4[64];
-
- if((fp = fopen(lancfgName, "r")) == NULL) {
- ShowWarning("LAN Support configuration file is not found: %s\n", lancfgName);
- return 1;
- }
-
- ShowInfo("Reading the configuration file %s...\n", lancfgName);
-
- while(fgets(line, sizeof(line), fp))
- {
- line_num++;
- if ((line[0] == '/' && line[1] == '/') || line[0] == '\n' || line[1] == '\n')
- continue;
-
- if(sscanf(line,"%[^:]: %[^:]:%[^:]:%[^\r\n]", w1, w2, w3, w4) != 4)
- {
- ShowWarning("Error syntax of configuration file %s in line %d.\n", lancfgName, line_num);
- continue;
- }
-
- if( strcmpi(w1, "subnet") == 0 )
- {
- subnet[subnet_count].mask = str2ip(w2);
- subnet[subnet_count].char_ip = str2ip(w3);
- subnet[subnet_count].map_ip = str2ip(w4);
-
- if( (subnet[subnet_count].char_ip & subnet[subnet_count].mask) != (subnet[subnet_count].map_ip & subnet[subnet_count].mask) )
- {
- ShowError("%s: Configuration Error: The char server (%s) and map server (%s) belong to different subnetworks!\n", lancfgName, w3, w4);
- continue;
- }
-
- subnet_count++;
- }
- }
-
- ShowStatus("Read information about %d subnetworks.\n", subnet_count);
-
- fclose(fp);
- return 0;
-}
//-----------------------------------------------------
// clear expired ip bans
@@ -1712,96 +1450,6 @@ int ip_ban_flush(int tid, unsigned int tick, int id, int data)
return 0;
}
-//-----------------------------------
-// Reading main configuration file
-//-----------------------------------
-int login_config_read(const char* cfgName)
-{
- char line[1024], w1[1024], w2[1024];
- FILE* fp = fopen(cfgName, "r");
- if (fp == NULL) {
- ShowError("Configuration file (%s) not found.\n", cfgName);
- return 1;
- }
- ShowInfo("Reading configuration file %s...\n", cfgName);
- while(fgets(line, sizeof(line), fp))
- {
- if (line[0] == '/' && line[1] == '/')
- continue;
-
- if (sscanf(line, "%[^:]: %[^\r\n]", w1, w2) < 2)
- continue;
-
- if(!strcmpi(w1,"timestamp_format"))
- strncpy(timestamp_format, w2, 20);
- else if(!strcmpi(w1,"stdout_with_ansisequence"))
- stdout_with_ansisequence = config_switch(w2);
- else if(!strcmpi(w1,"console_silent")) {
- ShowInfo("Console Silent Setting: %d\n", atoi(w2));
- msg_silent = atoi(w2);
- }
- else if( !strcmpi(w1, "bind_ip") ) {
- char ip_str[16];
- login_config.login_ip = host2ip(w2);
- if( login_config.login_ip )
- ShowStatus("Login server binding IP address : %s -> %s\n", w2, ip2str(login_config.login_ip, ip_str));
- }
- else if( !strcmpi(w1, "login_port") ) {
- login_config.login_port = (uint16)atoi(w2);
- ShowStatus("set login_port : %s\n",w2);
- }
- else if(!strcmpi(w1, "log_login"))
- login_config.log_login = (bool)config_switch(w2);
-
- else if(!strcmpi(w1, "ipban"))
- login_config.ipban = (bool)config_switch(w2);
- else if(!strcmpi(w1, "dynamic_pass_failure_ban"))
- login_config.dynamic_pass_failure_ban = (bool)config_switch(w2);
- else if(!strcmpi(w1, "dynamic_pass_failure_ban_interval"))
- login_config.dynamic_pass_failure_ban_interval = atoi(w2);
- else if(!strcmpi(w1, "dynamic_pass_failure_ban_limit"))
- login_config.dynamic_pass_failure_ban_limit = atoi(w2);
- else if(!strcmpi(w1, "dynamic_pass_failure_ban_duration"))
- login_config.dynamic_pass_failure_ban_duration = atoi(w2);
-
- else if(!strcmpi(w1, "new_account"))
- login_config.new_account_flag = (bool)config_switch(w2);
- else if(!strcmpi(w1, "start_limited_time"))
- login_config.start_limited_time = atoi(w2);
- else if(!strcmpi(w1, "check_client_version"))
- login_config.check_client_version = (bool)config_switch(w2);
- else if(!strcmpi(w1, "client_version_to_connect"))
- login_config.client_version_to_connect = atoi(w2);
- else if(!strcmpi(w1, "use_MD5_passwords"))
- login_config.use_md5_passwds = (bool)config_switch(w2);
- else if(!strcmpi(w1, "min_level_to_connect"))
- login_config.min_level_to_connect = atoi(w2);
- else if(!strcmpi(w1, "date_format"))
- safestrncpy(login_config.date_format, w2, sizeof(login_config.date_format));
- else if(!strcmpi(w1, "console"))
- login_config.console = (bool)config_switch(w2);
- else if(!strcmpi(w1, "case_sensitive"))
- login_config.case_sensitive = (bool)config_switch(w2);
- else if(!strcmpi(w1, "allowed_regs")) //account flood protection system
- allowed_regs = atoi(w2);
- else if(!strcmpi(w1, "time_allowed"))
- time_allowed = atoi(w2);
- else if(!strcmpi(w1, "online_check"))
- login_config.online_check = (bool)config_switch(w2);
- else if(!strcmpi(w1, "use_dnsbl"))
- login_config.use_dnsbl = (bool)config_switch(w2);
- else if(!strcmpi(w1, "dnsbl_servers"))
- safestrncpy(login_config.dnsbl_servs, w2, sizeof(login_config.dnsbl_servs));
- else if(!strcmpi(w1, "ip_sync_interval"))
- login_config.ip_sync_interval = (unsigned int)1000*60*atoi(w2); //w2 comes in minutes.
- else if(!strcmpi(w1, "import"))
- login_config_read(w2);
- }
- fclose(fp);
- ShowInfo("Finished reading %s.\n", cfgName);
- return 0;
-}
-
void sql_config_read(const char* cfgName)
{
char line[1024], w1[1024], w2[1024];
@@ -1852,131 +1500,3 @@ void sql_config_read(const char* cfgName)
fclose(fp);
ShowInfo("Done reading %s.\n", cfgName);
}
-
-void login_set_defaults()
-{
- login_config.login_ip = INADDR_ANY;
- login_config.login_port = 6900;
- login_config.ip_sync_interval = 0;
- login_config.log_login = true;
- safestrncpy(login_config.date_format, "%Y-%m-%d %H:%M:%S", sizeof(login_config.date_format));
- login_config.console = false;
- login_config.new_account_flag = true;
- login_config.case_sensitive = true;
- login_config.use_md5_passwds = false;
- login_config.login_gm_read = true;
- login_config.min_level_to_connect = 0;
- login_config.online_check = true;
- login_config.check_client_version = false;
- login_config.client_version_to_connect = 20;
-
- login_config.ipban = true;
- login_config.dynamic_pass_failure_ban = true;
- login_config.dynamic_pass_failure_ban_interval = 5;
- login_config.dynamic_pass_failure_ban_limit = 7;
- login_config.dynamic_pass_failure_ban_duration = 5;
- login_config.use_dnsbl = false;
- safestrncpy(login_config.dnsbl_servs, "", sizeof(login_config.dnsbl_servs));
-}
-
-//--------------------------------------
-// Function called at exit of the server
-//--------------------------------------
-void do_final(void)
-{
- int i, fd;
- ShowStatus("Terminating...\n");
-
- mmo_db_close();
- online_db->destroy(online_db, NULL);
- auth_db->destroy(auth_db, NULL);
-
- if(gm_account_db) aFree(gm_account_db);
-
- for (i = 0; i < MAX_SERVERS; i++) {
- if ((fd = server[i].fd) >= 0) {
- memset(&server[i], 0, sizeof(struct mmo_char_server));
- server[i].fd = -1;
- do_close(fd);
- }
- }
- do_close(login_fd);
-
- ShowStatus("Finished.\n");
-}
-
-//------------------------------
-// Function called when the server
-// has received a crash signal.
-//------------------------------
-void do_abort(void)
-{
-}
-
-void set_server_type(void)
-{
- SERVER_TYPE = ATHENA_SERVER_LOGIN;
-}
-
-//------------------------------
-// Login server initialization
-//------------------------------
-int do_init(int argc, char** argv)
-{
- int i;
-
- login_set_defaults();
-
- // read login-server configuration
- login_config_read((argc > 1) ? argv[1] : LOGIN_CONF_NAME);
- sql_config_read(INTER_CONF_NAME);
- login_lan_config_read((argc > 2) ? argv[2] : LAN_CONF_NAME);
-
- srand((unsigned int)time(NULL));
-
- for( i = 0; i < MAX_SERVERS; i++ )
- server[i].fd = -1;
-
- // Online user database init
- online_db = idb_alloc(DB_OPT_RELEASE_DATA);
- add_timer_func_list(waiting_disconnect_timer, "waiting_disconnect_timer");
-
- // Auth init
- auth_db = idb_alloc(DB_OPT_RELEASE_DATA);
- mmo_auth_sqldb_init();
-
- // Read account information.
- if(login_config.login_gm_read)
- read_gm_account();
-
- // set default parser as parse_login function
- set_defaultparse(parse_login);
-
- // ban deleter timer
- add_timer_func_list(ip_ban_flush, "ip_ban_flush");
- add_timer_interval(gettick()+10, ip_ban_flush, 0, 0, 60*1000);
-
- // every 10 minutes cleanup online account db.
- add_timer_func_list(online_data_cleanup, "online_data_cleanup");
- add_timer_interval(gettick() + 600*1000, online_data_cleanup, 0, 0, 600*1000);
-
- // add timer to detect ip address change and perform update
- if (login_config.ip_sync_interval) {
- add_timer_func_list(sync_ip_addresses, "sync_ip_addresses");
- add_timer_interval(gettick() + login_config.ip_sync_interval, sync_ip_addresses, 0, 0, login_config.ip_sync_interval);
- }
-
- if( login_config.console )
- {
- //##TODO invoke a CONSOLE_START plugin event
- }
-
- new_reg_tick = gettick();
-
- // server port open & binding
- login_fd = make_listen_bind(login_config.login_ip, login_config.login_port);
-
- ShowStatus("The login-server is "CL_GREEN"ready"CL_RESET" (Server is listening on the port %u).\n\n", login_config.login_port);
-
- return 0;
-}