-
-static void network_connect_gc(void)
-{
- /* Connect to server if not connected */
- SteamNetworkingIPAddr remoteAddr;
-
-#ifdef SR_USE_LOCALHOST
- SteamAPI_SteamNetworkingIPAddr_SetIPv6LocalHost( &remoteAddr, 27402 );
-#else
- const char *server_lon1 = "46.101.34.155:27402";
- SteamAPI_SteamNetworkingIPAddr_ParseString( &remoteAddr, server_lon1 );
-#endif
-
- char buf[256];
- SteamAPI_SteamNetworkingIPAddr_ToString( &remoteAddr, buf, 256, 1 );
- vg_info( "connect to: %s\n", buf );
-
- cremote = SteamAPI_ISteamNetworkingSockets_ConnectByIPAddress(
- hSteamNetworkingSockets, &remoteAddr, 0, NULL );
-}
-
-static void on_inet_scoreboard( SteamNetworkingMessage_t *msg )
-{
- netmsg_scoreboard *sb = msg->m_pData;
-
- u32 base_size = sizeof(netmsg_scoreboard)-
- sizeof(struct netmsg_board)*vg_list_size(track_infos),
- expected = base_size+sizeof(struct netmsg_board)*sb->board_count;
-
- if( msg->m_cbSize != expected )
- {
- vg_error( "Server scoreboard was corrupted. Size: %u != %u\n",
- msg->m_cbSize, expected );
- }
- else
- {
- if( vg_list_size(track_infos) > sb->board_count )
- vg_warn( "Server is out of date, not enough boards recieved\n");
- else if( vg_list_size(track_infos) < sb->board_count )
- vg_warn( "Client out of date, server sent more boards than we have\n");
- else
- vg_success( "Recieved new scoreboards from server\n" );
-
- for( int i=0; i < vg_min(sb->board_count,vg_list_size(track_infos)); i++)
- {
- scoreboard_client_data.boards[i] = sb->boards[i];
- highscores_board_printf( stdout, sb->boards[i].data, 10 );
- }
- }
-
- /* We dont need to stay on the server currently */
- SteamAPI_ISteamNetworkingSockets_CloseConnection(
- hSteamNetworkingSockets, cremote, 0, NULL, 1 );
-}
-
-static void poll_connection(void)
-{
- SteamNetworkingMessage_t *messages[32];
- int len;
-
- while(1)
- {
- len = SteamAPI_ISteamNetworkingSockets_ReceiveMessagesOnConnection(
- hSteamNetworkingSockets, cremote, messages, vg_list_size(messages));
-
- if( len <= 0 )
- return;
-
- for( int i=0; i<len; i++ )
- {
- SteamNetworkingMessage_t *msg = messages[i];
-
- if( msg->m_cbSize < sizeof(netmsg_blank) )
- {
- vg_warn( "Discarding message (too small: %d)\n", msg->m_cbSize );
- continue;
- }
-
- netmsg_blank *tmp = msg->m_pData;
-
- if( tmp->inetmsg_id == k_inetmsg_scoreboard )
- on_inet_scoreboard( msg );
-
- SteamAPI_SteamNetworkingMessage_t_Release( msg );
- }
- }
-}
-
-/*
- * Subroutine to be connected to main game loop, runs all routines on timers
- */
-static void network_update(void)
-{
- if( steam_ready )
- {
- static double last_update = 0.0;
- poll_connection();
-
- if( vg_time > (last_update + 60.0) )
- {
- last_update = vg_time;
-
- if( steam_app_ticket_length )
- {
- network_connect_gc();
- }
- else
- {
- vg_log( "Not making remote connection; app ticket not gotten\n" );
- }
- }
-
- if( vg_time > (last_update + 10.0) &&
- (cremote_state == k_ESteamNetworkingConnectionState_Connected ))
- {
- vg_warn( "Connected to server but no return... disconnecting\n" );
- SteamAPI_ISteamNetworkingSockets_CloseConnection(
- hSteamNetworkingSockets, cremote, 0, NULL, 1 );
- }
- }
-}
-
-static void network_init(void)
-{
- if( steam_ready )
- {
- steam_register_callback( k_iSteamNetConnectionStatusChangedCallBack,
- on_server_connect_status );
- request_auth_ticket();
- }
-}
-
-static void network_end(void)
-{
- /* TODO: Fire off any buffered highscores that need to be setn */
- if( cremote_state == k_ESteamNetworkingConnectionState_Connected ||
- cremote_state == k_ESteamNetworkingConnectionState_Connecting )
- {
- SteamAPI_ISteamNetworkingSockets_CloseConnection(
- hSteamNetworkingSockets, cremote, 0, NULL, 1 );
- }
+static network_client = {
+ .auth_mode = eServerModeAuthentication,
+ .state = k_ESteamNetworkingConnectionState_None,
+ .server_adress = "46.101.34.155",
+ .last_intent_change = -99999.9
+};
+
+static int packet_minsize( SteamNetworkingMessage_t *msg, u32 size );
+static void network_send_item( enum netmsg_playeritem_type type );
+static void network_request_scoreboard( const char *mod_uid,
+ const char *route_uid,
+ u32 week, u64 userdata );
+static void network_publish_laptime( const char *mod_uid,
+ const char *route_uid, f64 lap_time );
+static void chat_send_message( const char *message );
+static void render_server_status_gui(void);
+static void network_status_string( vg_str *str, u32 *colour );
+static void network_send_region(void);
+
+static int network_connected(void){
+ if( network_client.remote_version != NETWORK_SKATERIFT_VERSION ) return 0;
+ return network_client.state == k_ESteamNetworkingConnectionState_Connected;