X-Git-Url: https://harrygodden.com/git/?a=blobdiff_plain;ds=sidebyside;f=gameserver.c;h=b90a4a8a34905c337709985477ebcab5913fbb2a;hb=a7d144c7905105909cc4434e0ab43008bbb8f89f;hp=3cbf87791fc0167a1c5d91c7a0f44c6fbb35040d;hpb=9a63a9dde9257c8f140af3a96816bcda232fe739;p=carveJwlIkooP6JGAAIwe30JlM.git diff --git a/gameserver.c b/gameserver.c index 3cbf877..b90a4a8 100644 --- a/gameserver.c +++ b/gameserver.c @@ -16,6 +16,7 @@ volatile sig_atomic_t sig_stop; #include "network_common.h" #include "gameserver_db.h" #include "vg/vg_m.h" +#include "vg/vg_msg.h" static void inthandler( int signum ) { sig_stop = 1; @@ -393,6 +394,175 @@ static void gameserver_rx_200_300( SteamNetworkingMessage_t *msg ){ gameserver_send_to_all( client_id, prop, msg->m_cbSize, k_nSteamNetworkingSend_Reliable ); } + else { + vg_warn( "Unknown inetmsg_id recieved from client. (%u)\n", + tmp->inetmsg_id ); + } +} + +static void gameserver_request_respond( enum request_status status, + netmsg_request *res, vg_msg *body, + SteamNetworkingMessage_t *msg ){ + int client_id = gameserver_client_index( msg->m_conn ); + u32 len = 0; + if( status == k_request_status_ok ){ + len = body->len; + + vg_success( "[%d#%d] Response: %d\n", client_id, (i32)res->id, status ); + vg_msg_print( body ); + } + else{ + vg_warn( "[%d#%d] Response: %d\n", client_id, (i32)res->id, status ); + } + + res->status = status; + + SteamAPI_ISteamNetworkingSockets_SendMessageToConnection( + hSteamNetworkingSockets, msg->m_conn, + res, sizeof(netmsg_request) + len, + k_nSteamNetworkingSend_Reliable, NULL ); + SteamAPI_SteamNetworkingMessage_t_Release( msg ); +} + +struct user_request_thread_data { + SteamNetworkingMessage_t *msg; +}; + +static void gameserver_process_user_request( db_request *db_req ){ + struct user_request_thread_data *inf = (void *)db_req->data; + SteamNetworkingMessage_t *msg = inf->msg; + + int client_id = gameserver_client_index( msg->m_conn ); + if( client_id == -1 ){ + SteamAPI_SteamNetworkingMessage_t_Release( msg ); + return; + } + + netmsg_request *req = (netmsg_request *)msg->m_pData; + vg_msg data = {0}; + data.buf = req->q; + data.len = msg->m_cbSize - sizeof(netmsg_request); + data.max = data.len; + + /* create response packet */ + netmsg_request *res = alloca( sizeof(netmsg_request) + 512 ); + res->inetmsg_id = k_inetmsg_response; + res->id = req->id; + vg_msg body = {0}; + body.buf = res->q; + body.max = 512; + + const char *endpoint = vg_msg_seekkvstr( &data, "endpoint", 0 ); + + if( !endpoint ){ + gameserver_request_respond( k_request_status_invalid_endpoint, + res, NULL, msg ); + return; + } + + if( !strcmp( endpoint, "scoreboard" ) ){ + const char *mod = vg_msg_seekkvstr( &data, "mod", 0 ); + const char *route = vg_msg_seekkvstr( &data, "route", 0 ); + u32 week = vg_msg_seekkvu32( &data, "week", 0 ); + + char table_name[ DB_TABLE_UID_MAX ]; + if( !db_get_highscore_table_name( mod, route, week, table_name ) ){ + gameserver_request_respond( k_request_status_out_of_memory, + res, NULL, msg ); + return; + } + + char buf[512]; + vg_str q; + vg_strnull( &q, buf, 512 ); + vg_strcat( &q, "SELECT * FROM \"" ); + vg_strcat( &q, table_name ); + vg_strcat( &q, "\" ORDER BY time DESC LIMIT 10;" ); + if( !vg_strgood(&q) ) { + gameserver_request_respond( k_request_status_out_of_memory, + res, NULL, msg ); + return; + } + + sqlite3_stmt *stmt = db_stmt( q.buffer ); + + if( !stmt ){ + gameserver_request_respond( k_request_status_database_error, + res, NULL, msg ); + return; + } + + vg_msg_frame( &body, "rows" ); + for( u32 i=0; i<10; i ++ ){ + int fc = sqlite3_step( stmt ); + + if( fc == SQLITE_ROW ){ + i32 time = sqlite3_column_int( stmt, 1 ); + i64 steamid_i64 = sqlite3_column_int64( stmt, 0 ); + u64 steamid = *((u64 *)&steamid_i64); + + vg_msg_frame( &body, "" ); + vg_msg_wkvu32( &body, "time", time ); + vg_msg_wkvu64( &body, "steamid", steamid ); + + char username[32]; + if( db_getuserinfo( steamid, username, sizeof(username), NULL ) ){ + vg_msg_wkvstr( &body, "username", username ); + } + + vg_msg_end_frame( &body ); + } + else if( fc == SQLITE_DONE ){ + break; + } + else { + log_sqlite3( fc ); + break; + } + } + + sqlite3_finalize( stmt ); + vg_msg_end_frame( &body ); + + if( body.error != k_vg_msg_error_OK ){ + gameserver_request_respond( k_request_status_out_of_memory, + res, NULL, msg ); + return; + } + + gameserver_request_respond( k_request_status_ok, res, &body, msg ); + } + else{ + gameserver_request_respond( k_request_status_invalid_endpoint, + res, NULL, msg ); + } +} + +static void gameserver_rx_300_400( SteamNetworkingMessage_t *msg ){ + netmsg_blank *tmp = msg->m_pData; + + int client_id = gameserver_client_index( msg->m_conn ); + if( client_id == -1 ){ + SteamAPI_SteamNetworkingMessage_t_Release( msg ); + return; + } + + if( tmp->inetmsg_id == k_inetmsg_request ){ + if( !packet_minsize( msg, sizeof(netmsg_request)+1 )) + return; + + db_request *call = db_alloc_request( + sizeof(struct user_request_thread_data) ); + struct user_request_thread_data *inf = (void *)call->data; + inf->msg = msg; + call->handler = gameserver_process_user_request; + db_send_request( call ); + } + else { + vg_warn( "Unknown inetmsg_id recieved from client. (%u)\n", + tmp->inetmsg_id ); + SteamAPI_SteamNetworkingMessage_t_Release( msg ); + } } static void poll_connections(void){ @@ -420,6 +590,10 @@ static void poll_connections(void){ if( (tmp->inetmsg_id >= 200) && (tmp->inetmsg_id < 300) ){ gameserver_rx_200_300( msg ); + SteamAPI_SteamNetworkingMessage_t_Release( msg ); + } + else if( (tmp->inetmsg_id >= 300) && (tmp->inetmsg_id < 400) ){ + gameserver_rx_300_400( msg ); } else{ if( tmp->inetmsg_id == k_inetmsg_auth ) @@ -428,9 +602,8 @@ static void poll_connections(void){ vg_warn( "Unknown inetmsg_id recieved from client. (%u)\n", tmp->inetmsg_id ); } + SteamAPI_SteamNetworkingMessage_t_Release( msg ); } - - SteamAPI_SteamNetworkingMessage_t_Release( msg ); } } } @@ -442,8 +615,8 @@ static u64 seconds_to_server_ticks( double s ){ static void test_runner( db_request *req ){ vg_warn( "RUNNER\n" ); char table[DB_TABLE_UID_MAX]; - if( db_get_highscore_table_name( "sr003-local-mp_mtzero", - "megapark-yellow", 302, table ) ){ + if( db_get_highscore_table_name( "sr002-local-mp_mtzero", + "Coastal Run", 0, table ) ){ if( db_writeusertime( table, 76561198072130043, 232, 1 ) ){ vg_success( "Written time\n" ); i32 v = db_readusertime( table, 76561198072130043 ); @@ -554,6 +727,7 @@ int main( int argc, char *argv[] ){ vg_info( "Shutting down\n..." ); SteamGameServer_Shutdown(); + db_kill(); db_free(); return 0;