network.cpp

Go to the documentation of this file.

/*
 * This file is part of OpenTTD.
 * OpenTTD 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, version 2.
 * OpenTTD 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 OpenTTD. If not, see <https://www.gnu.org/licenses/old-licenses/gpl-2.0>.
 */

 
#include "../stdafx.h"
 
#include "../strings_func.h"
#include "../command_func.h"
#include "../timer/timer_game_tick.h"
#include "../timer/timer_game_economy.h"
#include "network_admin.h"
#include "network_client.h"
#include "network_query.h"
#include "network_server.h"
#include "network_content.h"
#include "network_udp.h"
#include "network_gamelist.h"
#include "network_base.h"
#include "network_coordinator.h"
#include "core/udp.h"
#include "core/host.h"
#include "network_gui.h"
#include "../console_func.h"
#include "../3rdparty/md5/md5.h"
#include "../core/random_func.hpp"
#include "../window_func.h"
#include "../company_func.h"
#include "../company_base.h"
#include "../landscape_type.h"
#include "../rev.h"
#include "../core/pool_func.hpp"
#include "../gfx_func.h"
#include "../error.h"
#include "../misc_cmd.h"
#include "../core/string_builder.hpp"
#ifdef DEBUG_DUMP_COMMANDS
# include "../fileio_func.h"
# include "../core/string_consumer.hpp"
#endif
#include <charconv>
 
#include "table/strings.h"
 
#include "../safeguards.h"
 
#ifdef DEBUG_DUMP_COMMANDS
bool _ddc_fastforward = true;
#endif /* DEBUG_DUMP_COMMANDS */

static_assert(NetworkClientInfoPool::MAX_SIZE == NetworkClientSocketPool::MAX_SIZE);

NetworkClientInfoPool _networkclientinfo_pool{"NetworkClientInfo"};
INSTANTIATE_POOL_METHODS(NetworkClientInfo)
 
bool _networking;         
bool _network_server;     
bool _network_available;  
bool _network_dedicated;  
bool _is_network_server;  
ClientID _network_own_client_id;      
ClientID _redirect_console_to_client; 
uint8_t _network_reconnect;             
StringList _network_bind_list;        
StringList _network_host_list;        
StringList _network_ban_list;         
uint32_t _frame_counter_server;         
uint32_t _frame_counter_max;            
uint32_t _frame_counter;                
uint32_t _last_sync_frame;              
NetworkAddressList _broadcast_list;   
uint32_t _sync_seed_1;                  
#ifdef NETWORK_SEND_DOUBLE_SEED
uint32_t _sync_seed_2;                  
#endif
uint32_t _sync_frame;                   
bool _network_first_time;             

uint8_t _network_clients_connected = 0;
 
extern std::string GenerateUid(std::string_view subject);

bool HasClients()
{
  return !NetworkClientSocket::Iterate().empty();
}

NetworkClientInfo::~NetworkClientInfo()
{
  /* Delete the chat window, if you were chatting with this client. */
  InvalidateWindowData(WC_SEND_NETWORK_MSG, NetworkChatDestinationType::Client, this->client_id);
}

/* static */ NetworkClientInfo *NetworkClientInfo::GetByClientID(ClientID client_id)
{
  for (NetworkClientInfo *ci : NetworkClientInfo::Iterate()) {
    if (ci->client_id == client_id) return ci;
  }
 
  return nullptr;
}

bool NetworkClientInfo::CanJoinCompany(CompanyID company_id) const
{
  Company *c = Company::GetIfValid(company_id);
  return c != nullptr && (c->allow_any || c->allow_list.Contains(this->public_key));
}

bool NetworkCanJoinCompany(CompanyID company_id)
{
  NetworkClientInfo *info = NetworkClientInfo::GetByClientID(_network_own_client_id);
  return info != nullptr && info->CanJoinCompany(company_id);
}

/* static */ ServerNetworkGameSocketHandler *ServerNetworkGameSocketHandler::GetByClientID(ClientID client_id)
{
  for (NetworkClientSocket *cs : NetworkClientSocket::Iterate()) {
    if (cs->client_id == client_id) return cs;
  }
 
  return nullptr;
}
 

static auto FindKey(auto *authorized_keys, std::string_view authorized_key)
{
  return std::ranges::find_if(*authorized_keys, [authorized_key](auto &value) { return StrEqualsIgnoreCase(value, authorized_key); });
}

bool NetworkAuthorizedKeys::Contains(std::string_view key) const
{
  return FindKey(this, key) != this->end();
}

bool NetworkAuthorizedKeys::Add(std::string_view key)
{
  if (key.empty()) return false;
 
  auto iter = FindKey(this, key);
  if (iter != this->end()) return false;
 
  this->emplace_back(key);
  return true;
}

bool NetworkAuthorizedKeys::Remove(std::string_view key)
{
  auto iter = FindKey(this, key);
  if (iter == this->end()) return false;
 
  this->erase(iter);
  return true;
}
 

uint8_t NetworkSpectatorCount()
{
  uint8_t count = 0;
 
  for (const NetworkClientInfo *ci : NetworkClientInfo::Iterate()) {
    if (ci->client_playas == COMPANY_SPECTATOR) count++;
  }
 
  /* Don't count a dedicated server as spectator */
  if (_network_dedicated) count--;
 
  return count;
}
 

void NetworkTextMessage(NetworkAction action, TextColour colour, bool self_send, std::string_view name, std::string_view str, StringParameter &&data)
{
  std::string message;
  StringBuilder builder(message);
 
  /* All of these strings start with "***". These characters are interpreted as both left-to-right and
   * right-to-left characters depending on the context. As the next text might be an user's name, the
   * user name's characters will influence the direction of the "***" instead of the language setting
   * of the game. Manually set the direction of the "***" by inserting a text-direction marker. */
  builder.PutUtf8(_current_text_dir == TD_LTR ? CHAR_TD_LRM : CHAR_TD_RLM);
 
  switch (action) {
    case NetworkAction::ServerMessage:
      /* Ignore invalid messages */
      builder += GetString(STR_NETWORK_SERVER_MESSAGE, str);
      colour = CC_DEFAULT;
      break;
    case NetworkAction::CompanySpectator:
      colour = CC_DEFAULT;
      builder += GetString(STR_NETWORK_MESSAGE_CLIENT_COMPANY_SPECTATE, name);
      break;
    case NetworkAction::CompanyJoin:
      colour = CC_DEFAULT;
      builder += GetString(STR_NETWORK_MESSAGE_CLIENT_COMPANY_JOIN, name, str);
      break;
    case NetworkAction::CompanyNew:
      colour = CC_DEFAULT;
      builder += GetString(STR_NETWORK_MESSAGE_CLIENT_COMPANY_NEW, name, std::move(data));
      break;
    case NetworkAction::ClientJoin:
      /* Show the Client ID for the server but not for the client. */
      builder += _network_server ?
          GetString(STR_NETWORK_MESSAGE_CLIENT_JOINED_ID, name, std::move(data)) :
          GetString(STR_NETWORK_MESSAGE_CLIENT_JOINED, name);
      break;
    case NetworkAction::ClientLeave: builder += GetString(STR_NETWORK_MESSAGE_CLIENT_LEFT, name, std::move(data)); break;
    case NetworkAction::ClientNameChange:builder += GetString(STR_NETWORK_MESSAGE_NAME_CHANGE, name, str); break;
    case NetworkAction::GiveMoney: builder += GetString(STR_NETWORK_MESSAGE_GIVE_MONEY, name, std::move(data), str); break;
    case NetworkAction::ClientKicked: builder += GetString(STR_NETWORK_MESSAGE_KICKED, name, str); break;
    case NetworkAction::ChatTeam: builder += GetString(self_send ? STR_NETWORK_CHAT_TO_COMPANY : STR_NETWORK_CHAT_COMPANY, name, str); break;
    case NetworkAction::ChatClient: builder += GetString(self_send ? STR_NETWORK_CHAT_TO_CLIENT  : STR_NETWORK_CHAT_CLIENT, name, str);  break;
    case NetworkAction::ChatExternal: builder += GetString(STR_NETWORK_CHAT_EXTERNAL, std::move(data), name, str); break;
    default: builder += GetString(STR_NETWORK_CHAT_ALL, name, str); break;
  }
 
  Debug(desync, 1, "msg: {:08x}; {:02x}; {}", TimerGameEconomy::date, TimerGameEconomy::date_fract, message);
  IConsolePrint(colour, message);
  NetworkAddChatMessage(colour, _settings_client.gui.network_chat_timeout, message);
}

uint NetworkCalculateLag(const NetworkClientSocket *cs)
{
  int lag = cs->last_frame_server - cs->last_frame;
  /* This client has missed their ACK packet after 1 DAY_TICKS..
   *  so we increase their lag for every frame that passes!
   * The packet can be out by a max of _net_frame_freq */
  if (cs->last_frame_server + Ticks::DAY_TICKS + _settings_client.network.frame_freq < _frame_counter) {
    lag += _frame_counter - (cs->last_frame_server + Ticks::DAY_TICKS + _settings_client.network.frame_freq);
  }
  return lag;
}
 

void ShowNetworkError(StringID error_string)
{
  _switch_mode = SM_MENU;
  ShowErrorMessage(GetEncodedString(error_string), {}, WL_CRITICAL);
}

StringID GetNetworkErrorMsg(NetworkErrorCode err)
{
  switch (err) {
    default:
    case NetworkErrorCode::General: return STR_NETWORK_ERROR_CLIENT_GENERAL;
    case NetworkErrorCode::Desync: return STR_NETWORK_ERROR_CLIENT_DESYNC;
    case NetworkErrorCode::SavegameFailed: return STR_NETWORK_ERROR_CLIENT_SAVEGAME;
    case NetworkErrorCode::ConnectionLost: return STR_NETWORK_ERROR_CLIENT_CONNECTION_LOST;
    case NetworkErrorCode::IllegalPacket: return STR_NETWORK_ERROR_CLIENT_PROTOCOL_ERROR;
    case NetworkErrorCode::NewGRFMismatch: return STR_NETWORK_ERROR_CLIENT_NEWGRF_MISMATCH;
    case NetworkErrorCode::NotAuthorized: return STR_NETWORK_ERROR_CLIENT_NOT_AUTHORIZED;
    case NetworkErrorCode::NotExpected: return STR_NETWORK_ERROR_CLIENT_NOT_EXPECTED;
    case NetworkErrorCode::WrongRevision: return STR_NETWORK_ERROR_CLIENT_WRONG_REVISION;
    case NetworkErrorCode::NameInUse: return STR_NETWORK_ERROR_CLIENT_NAME_IN_USE;
    case NetworkErrorCode::WrongPassword: return STR_NETWORK_ERROR_CLIENT_WRONG_PASSWORD;
    case NetworkErrorCode::CompanyMismatch: return STR_NETWORK_ERROR_CLIENT_COMPANY_MISMATCH;
    case NetworkErrorCode::Kicked: return STR_NETWORK_ERROR_CLIENT_KICKED;
    case NetworkErrorCode::Cheater: return STR_NETWORK_ERROR_CLIENT_CHEATER;
    case NetworkErrorCode::ServerFull: return STR_NETWORK_ERROR_CLIENT_SERVER_FULL;
    case NetworkErrorCode::TooManyCommands: return STR_NETWORK_ERROR_CLIENT_TOO_MANY_COMMANDS;
    case NetworkErrorCode::TimeoutPassword: return STR_NETWORK_ERROR_CLIENT_TIMEOUT_PASSWORD;
    case NetworkErrorCode::TimeoutComputer: return STR_NETWORK_ERROR_CLIENT_TIMEOUT_COMPUTER;
    case NetworkErrorCode::TimeoutMap: return STR_NETWORK_ERROR_CLIENT_TIMEOUT_MAP;
    case NetworkErrorCode::TimeoutJoin: return STR_NETWORK_ERROR_CLIENT_TIMEOUT_JOIN;
    case NetworkErrorCode::InvalidClientName: return STR_NETWORK_ERROR_CLIENT_INVALID_CLIENT_NAME;
    case NetworkErrorCode::NotOnAllowList: return STR_NETWORK_ERROR_CLIENT_NOT_ON_ALLOW_LIST;
    case NetworkErrorCode::NoAuthenticationMethodAvailable: return STR_NETWORK_ERROR_CLIENT_NO_AUTHENTICATION_METHOD_AVAILABLE;
  };
}

void NetworkHandlePauseChange(PauseModes prev_mode, PauseMode changed_mode)
{
  if (!_networking) return;
 
  switch (changed_mode) {
    case PauseMode::Normal:
    case PauseMode::Join:
    case PauseMode::GameScript:
    case PauseMode::ActiveClients:
    case PauseMode::LinkGraph: {
      bool changed = _pause_mode.None() != prev_mode.None();
      bool paused = _pause_mode.Any();
      if (!paused && !changed) return;
 
      std::string str;
      if (!changed) {
        std::array<StringParameter, 5> params{};
        auto it = params.begin();
        if (_pause_mode.Test(PauseMode::Normal))        *it++ = STR_NETWORK_SERVER_MESSAGE_GAME_REASON_MANUAL;
        if (_pause_mode.Test(PauseMode::Join))          *it++ = STR_NETWORK_SERVER_MESSAGE_GAME_REASON_CONNECTING_CLIENTS;
        if (_pause_mode.Test(PauseMode::GameScript))    *it++ = STR_NETWORK_SERVER_MESSAGE_GAME_REASON_GAME_SCRIPT;
        if (_pause_mode.Test(PauseMode::ActiveClients)) *it++ = STR_NETWORK_SERVER_MESSAGE_GAME_REASON_NOT_ENOUGH_PLAYERS;
        if (_pause_mode.Test(PauseMode::LinkGraph))     *it++ = STR_NETWORK_SERVER_MESSAGE_GAME_REASON_LINK_GRAPH;
        str = GetStringWithArgs(STR_NETWORK_SERVER_MESSAGE_GAME_STILL_PAUSED_1 + std::distance(params.begin(), it) - 1, {params.begin(), it});
      } else {
        StringID reason;
        switch (changed_mode) {
          case PauseMode::Normal:        reason = STR_NETWORK_SERVER_MESSAGE_GAME_REASON_MANUAL; break;
          case PauseMode::Join:          reason = STR_NETWORK_SERVER_MESSAGE_GAME_REASON_CONNECTING_CLIENTS; break;
          case PauseMode::GameScript:    reason = STR_NETWORK_SERVER_MESSAGE_GAME_REASON_GAME_SCRIPT; break;
          case PauseMode::ActiveClients: reason = STR_NETWORK_SERVER_MESSAGE_GAME_REASON_NOT_ENOUGH_PLAYERS; break;
          case PauseMode::LinkGraph:     reason = STR_NETWORK_SERVER_MESSAGE_GAME_REASON_LINK_GRAPH; break;
          default: NOT_REACHED();
        }
        str = GetString(paused ? STR_NETWORK_SERVER_MESSAGE_GAME_PAUSED : STR_NETWORK_SERVER_MESSAGE_GAME_UNPAUSED, reason);
      }
 
      NetworkTextMessage(NetworkAction::ServerMessage, CC_DEFAULT, false, "", str);
      break;
    }
 
    default:
      return;
  }
}
 

static void CheckPauseHelper(bool pause, PauseMode pm)
{
  if (pause == _pause_mode.Test(pm)) return;
 
  Command<Commands::Pause>::Post(pm, pause);
}

static uint NetworkCountActiveClients()
{
  uint count = 0;
 
  for (const NetworkClientSocket *cs : NetworkClientSocket::Iterate()) {
    if (cs->status != NetworkClientSocket::STATUS_ACTIVE) continue;
    if (!Company::IsValidID(cs->GetInfo()->client_playas)) continue;
    count++;
  }
 
  return count;
}

static void CheckMinActiveClients()
{
  if (_pause_mode.Test(PauseMode::Error) ||
      !_network_dedicated ||
      (_settings_client.network.min_active_clients == 0 && !_pause_mode.Test(PauseMode::ActiveClients))) {
    return;
  }
  CheckPauseHelper(NetworkCountActiveClients() < _settings_client.network.min_active_clients, PauseMode::ActiveClients);
}

static bool NetworkHasJoiningClient()
{
  for (const NetworkClientSocket *cs : NetworkClientSocket::Iterate()) {
    if (cs->status >= NetworkClientSocket::STATUS_AUTHORIZED && cs->status < NetworkClientSocket::STATUS_ACTIVE) return true;
  }
 
  return false;
}

static void CheckPauseOnJoin()
{
  if (_pause_mode.Test(PauseMode::Error) ||
      (!_settings_client.network.pause_on_join && !_pause_mode.Test(PauseMode::Join))) {
    return;
  }
  CheckPauseHelper(NetworkHasJoiningClient(), PauseMode::Join);
}

std::string_view ParseCompanyFromConnectionString(std::string_view connection_string, CompanyID *company_id)
{
  std::string_view ip = connection_string;
  if (company_id == nullptr) return ip;
 
  size_t offset = ip.find_last_of('#');
  if (offset != std::string::npos) {
    std::string_view company_string = ip.substr(offset + 1);
    ip = ip.substr(0, offset);
 
    uint8_t company_value;
    auto [_, err] = std::from_chars(company_string.data(), company_string.data() + company_string.size(), company_value);
    if (err == std::errc()) {
      if (company_value != COMPANY_NEW_COMPANY && company_value != COMPANY_SPECTATOR) {
        if (company_value > MAX_COMPANIES || company_value == 0) {
          *company_id = COMPANY_SPECTATOR;
        } else {
          /* "#1" means the first company, which has index 0. */
          *company_id = (CompanyID)(company_value - 1);
        }
      } else {
        *company_id = (CompanyID)company_value;
      }
    }
  }
 
  return ip;
}

std::string_view ParseFullConnectionString(std::string_view connection_string, uint16_t &port, CompanyID *company_id)
{
  std::string_view ip = ParseCompanyFromConnectionString(connection_string, company_id);
 
  size_t port_offset = ip.find_last_of(':');
  size_t ipv6_close = ip.find_last_of(']');
  if (port_offset != std::string::npos && (ipv6_close == std::string::npos || ipv6_close < port_offset)) {
    std::string_view port_string = ip.substr(port_offset + 1);
    ip = ip.substr(0, port_offset);
    std::from_chars(port_string.data(), port_string.data() + port_string.size(), port);
  }
  return ip;
}

std::string NormalizeConnectionString(std::string_view connection_string, uint16_t default_port)
{
  uint16_t port = default_port;
  std::string_view ip = ParseFullConnectionString(connection_string, port);
  return fmt::format("{}:{}", ip, port);
}

NetworkAddress ParseConnectionString(std::string_view connection_string, uint16_t default_port)
{
  uint16_t port = default_port;
  std::string_view ip = ParseFullConnectionString(connection_string, port);
  return NetworkAddress(ip, port);
}

/* static */ void ServerNetworkGameSocketHandler::AcceptConnection(SOCKET s, const NetworkAddress &address)
{
  /* Register the login */
  _network_clients_connected++;
 
  ServerNetworkGameSocketHandler *cs = ServerNetworkGameSocketHandler::Create(s);
  cs->client_address = address; // Save the IP of the client
 
  InvalidateWindowData(WC_CLIENT_LIST, 0);
}

static void InitializeNetworkPools(bool close_admins = true)
{
  PoolTypes to_clean{PoolType::NetworkClient};
  if (close_admins) to_clean.Set(PoolType::NetworkAdmin);
  PoolBase::Clean(to_clean);
}

void NetworkClose(bool close_admins)
{
  if (_network_server) {
    if (close_admins) {
      for (ServerNetworkAdminSocketHandler *as : ServerNetworkAdminSocketHandler::Iterate()) {
        as->CloseConnection(true);
      }
    }
 
    for (NetworkClientSocket *cs : NetworkClientSocket::Iterate()) {
      cs->CloseConnection(NETWORK_RECV_STATUS_CLIENT_QUIT);
    }
    ServerNetworkGameSocketHandler::CloseListeners();
    ServerNetworkAdminSocketHandler::CloseListeners();
 
    _network_coordinator_client.CloseConnection();
  } else {
    if (MyClient::my_client != nullptr) {
      MyClient::SendQuit();
      MyClient::my_client->CloseConnection(NETWORK_RECV_STATUS_CLIENT_QUIT);
    }
 
    _network_coordinator_client.CloseAllConnections();
  }
  NetworkGameSocketHandler::ProcessDeferredDeletions();
 
  TCPConnecter::KillAll();
 
  _networking = false;
  _network_server = false;
 
  NetworkFreeLocalCommandQueue();
 
  InitializeNetworkPools(close_admins);
}

static void NetworkInitialize(bool close_admins = true)
{
  InitializeNetworkPools(close_admins);
 
  _sync_frame = 0;
  _network_first_time = true;
 
  _network_reconnect = 0;
}

class TCPQueryConnecter : public TCPServerConnecter {
private:
  std::string connection_string; 
 
public:
  TCPQueryConnecter(std::string_view connection_string) : TCPServerConnecter(connection_string, NETWORK_DEFAULT_PORT), connection_string(connection_string) {}
 
  void OnFailure() override
  {
    Debug(net, 9, "Query::OnFailure(): connection_string={}", this->connection_string);
 
    NetworkGame *item = NetworkGameListAddItem(connection_string);
    item->status = NGLS_OFFLINE;
    item->refreshing = false;
 
    UpdateNetworkGameWindow();
  }
 
  void OnConnect(SOCKET s) override
  {
    Debug(net, 9, "Query::OnConnect(): connection_string={}", this->connection_string);
 
    QueryNetworkGameSocketHandler::QueryServer(s, this->connection_string);
  }
};

void NetworkQueryServer(std::string_view connection_string)
{
  if (!_network_available) return;
 
  Debug(net, 9, "NetworkQueryServer(): connection_string={}", connection_string);
 
  /* Mark the entry as refreshing, so the GUI can show the refresh is pending. */
  NetworkGame *item = NetworkGameListAddItem(connection_string);
  item->refreshing = true;
 
  TCPConnecter::Create<TCPQueryConnecter>(connection_string);
}

NetworkGame *NetworkAddServer(std::string_view connection_string, bool manually, bool never_expire)
{
  if (connection_string.empty()) return nullptr;
 
  /* Ensure the item already exists in the list */
  NetworkGame *item = NetworkGameListAddItem(connection_string);
  if (item->info.server_name.empty()) {
    ClearGRFConfigList(item->info.grfconfig);
    item->info.server_name = connection_string;
 
    UpdateNetworkGameWindow();
 
    NetworkQueryServer(connection_string);
  }
 
  if (manually) item->manually = true;
  if (never_expire) item->version = INT32_MAX;
 
  return item;
}

void GetBindAddresses(NetworkAddressList *addresses, uint16_t port)
{
  for (const auto &iter : _network_bind_list) {
    addresses->emplace_back(iter, port);
  }
 
  /* No address, so bind to everything. */
  if (addresses->empty()) {
    addresses->emplace_back("", port);
  }
}

void NetworkRebuildHostList()
{
  _network_host_list.clear();
 
  for (const auto &item : _network_game_list) {
    if (item->manually) _network_host_list.emplace_back(item->connection_string);
  }
}

class TCPClientConnecter : public TCPServerConnecter {
private:
  std::string connection_string; 
 
public:
  TCPClientConnecter(std::string_view connection_string) : TCPServerConnecter(connection_string, NETWORK_DEFAULT_PORT), connection_string(connection_string) {}
 
  void OnFailure() override
  {
    Debug(net, 9, "Client::OnFailure(): connection_string={}", this->connection_string);
 
    ShowNetworkError(STR_NETWORK_ERROR_NOCONNECTION);
  }
 
  void OnConnect(SOCKET s) override
  {
    Debug(net, 9, "Client::OnConnect(): connection_string={}", this->connection_string);
 
    _networking = true;
    _network_own_client_id = ClientID{};
    new ClientNetworkGameSocketHandler(s, this->connection_string);
    IConsoleCmdExec("exec scripts/on_client.scr 0");
    NetworkClient_Connected();
  }
};

bool NetworkClientConnectGame(std::string_view connection_string, CompanyID default_company, const std::string &join_server_password)
{
  Debug(net, 9, "NetworkClientConnectGame(): connection_string={}", connection_string);
 
  CompanyID join_as = default_company;
  std::string resolved_connection_string = ServerAddress::Parse(connection_string, NETWORK_DEFAULT_PORT, &join_as).connection_string;
 
  if (!_network_available) return false;
  if (!NetworkValidateOurClientName()) return false;
 
  _network_join.connection_string = std::move(resolved_connection_string);
  _network_join.company = join_as;
  _network_join.server_password = join_server_password;
 
  if (_game_mode == GM_MENU) {
    /* From the menu we can immediately continue with the actual join. */
    NetworkClientJoinGame();
  } else {
    /* When already playing a game, first go back to the main menu. This
     * disconnects the user from the current game, meaning we can safely
     * load in the new. After all, there is little point in continuing to
     * play on a server if we are connecting to another one.
     */
    _switch_mode = SM_JOIN_GAME;
  }
  return true;
}

void NetworkClientJoinGame()
{
  NetworkDisconnect();
  NetworkInitialize();
 
  _settings_client.network.last_joined = _network_join.connection_string;
  Debug(net, 9, "status = Connecting");
  _network_join_status = NetworkJoinStatus::Connecting;
  ShowJoinStatusWindow();
 
  TCPConnecter::Create<TCPClientConnecter>(_network_join.connection_string);
}

static void NetworkInitGameInfo()
{
  FillStaticNetworkServerGameInfo();
  /* The server is a client too */
  _network_game_info.clients_on = _network_dedicated ? 0 : 1;
}

static void NetworkInitServerClientInfo()
{
  /* There should be always space for the server. */
  assert(NetworkClientInfo::CanAllocateItem());
  NetworkClientInfo *ci = NetworkClientInfo::Create(CLIENT_ID_SERVER);
  ci->client_playas = COMPANY_SPECTATOR;
 
  ci->client_name = _settings_client.network.client_name;
 
  NetworkAuthenticationClientHandler::EnsureValidSecretKeyAndUpdatePublicKey(_settings_client.network.client_secret_key, _settings_client.network.client_public_key);
  ci->public_key = _settings_client.network.client_public_key;
}

bool NetworkValidateServerName(std::string &server_name)
{
  StrTrimInPlace(server_name);
  if (!server_name.empty()) return true;
 
  ShowErrorMessage(GetEncodedString(STR_NETWORK_ERROR_BAD_SERVER_NAME), {}, WL_ERROR);
  return false;
}

static void CheckClientAndServerName()
{
  static const std::string fallback_client_name = "Unnamed Client";
  StrTrimInPlace(_settings_client.network.client_name);
  if (_settings_client.network.client_name.empty() || _settings_client.network.client_name == fallback_client_name) {
    Debug(net, 1, "No \"client_name\" has been set, using \"{}\" instead. Please set this now using the \"name <new name>\" command", fallback_client_name);
    _settings_client.network.client_name = fallback_client_name;
  }
 
  static const std::string fallback_server_name = "Unnamed Server";
  StrTrimInPlace(_settings_client.network.server_name);
  if (_settings_client.network.server_name.empty() || _settings_client.network.server_name == fallback_server_name) {
    Debug(net, 1, "No \"server_name\" has been set, using \"{}\" instead. Please set this now using the \"server_name <new name>\" command", fallback_server_name);
    _settings_client.network.server_name = fallback_server_name;
  }
}

bool NetworkServerStart()
{
  if (!_network_available) return false;
 
  /* Call the pre-scripts */
  IConsoleCmdExec("exec scripts/pre_server.scr 0");
  if (_network_dedicated) IConsoleCmdExec("exec scripts/pre_dedicated.scr 0");
 
  /* Check for the client and server names to be set, but only after the scripts had a chance to set them.*/
  if (_network_dedicated) CheckClientAndServerName();
 
  NetworkDisconnect(false);
  NetworkInitialize(false);
  NetworkUDPInitialize();
  Debug(net, 5, "Starting listeners for clients");
  if (!ServerNetworkGameSocketHandler::Listen(_settings_client.network.server_port)) return false;
 
  /* Only listen for admins when the authentication is configured. */
  if (_settings_client.network.AdminAuthenticationConfigured()) {
    Debug(net, 5, "Starting listeners for admins");
    if (!ServerNetworkAdminSocketHandler::Listen(_settings_client.network.server_admin_port)) return false;
  }
 
  /* Try to start UDP-server */
  Debug(net, 5, "Starting listeners for incoming server queries");
  NetworkUDPServerListen();
 
  _network_server = true;
  _networking = true;
  _frame_counter = 0;
  _frame_counter_server = 0;
  _frame_counter_max = 0;
  _last_sync_frame = 0;
  _network_own_client_id = CLIENT_ID_SERVER;
 
  _network_clients_connected = 0;
 
  NetworkInitGameInfo();
  NetworkInitServerClientInfo();
 
  if (_settings_client.network.server_game_type != ServerGameType::Local) {
    _network_coordinator_client.Register();
  }
 
  /* execute server initialization script */
  IConsoleCmdExec("exec scripts/on_server.scr 0");
  /* if the server is dedicated ... add some other script */
  if (_network_dedicated) IConsoleCmdExec("exec scripts/on_dedicated.scr 0");
 
  return true;
}

void NetworkOnGameStart()
{
  if (!_network_server) return;
 
  /* Update the static game info to set the values from the new game. */
  NetworkServerUpdateGameInfo();
 
  ChangeNetworkRestartTime(true);
 
  if (!_network_dedicated) {
    Company *c = Company::GetIfValid(GetFirstPlayableCompanyID());
    NetworkClientInfo *ci = NetworkClientInfo::GetByClientID(CLIENT_ID_SERVER);
    if (c != nullptr && ci != nullptr) {
      ci->client_playas = c->index;
 
      /*
       * If the company has not been named yet, the company was just started.
       * Otherwise it would have gotten a name already, so announce it as a new company.
       */
      if (c->name_1 == STR_SV_UNNAMED && c->name.empty()) NetworkServerNewCompany(c, ci);
    }
 
    ShowClientList();
  } else {
    /* welcome possibly still connected admins - this can only happen on a dedicated server. */
    ServerNetworkAdminSocketHandler::WelcomeAll();
  }
}

void NetworkReboot()
{
  if (_network_server) {
    for (NetworkClientSocket *cs : NetworkClientSocket::Iterate()) {
      cs->SendNewGame();
      cs->SendPackets();
    }
 
    for (ServerNetworkAdminSocketHandler *as : ServerNetworkAdminSocketHandler::IterateActive()) {
      as->SendNewGame();
      as->SendPackets();
    }
  }
 
  /* For non-dedicated servers we have to kick the admins as we are not
   * certain that we will end up in a new network game. */
  NetworkClose(!_network_dedicated);
}

void NetworkDisconnect(bool close_admins)
{
  if (_network_server) {
    for (NetworkClientSocket *cs : NetworkClientSocket::Iterate()) {
      cs->SendShutdown();
      cs->SendPackets();
    }
 
    if (close_admins) {
      for (ServerNetworkAdminSocketHandler *as : ServerNetworkAdminSocketHandler::IterateActive()) {
        as->SendShutdown();
        as->SendPackets();
      }
    }
  }
 
  CloseWindowById(WC_NETWORK_STATUS_WINDOW, WN_NETWORK_STATUS_WINDOW_JOIN);
 
  NetworkClose(close_admins);
 
  /* Reinitialize the UDP stack, i.e. close all existing connections. */
  NetworkUDPInitialize();
}

void NetworkUpdateServerGameType()
{
  if (!_networking) return;
 
  switch (_settings_client.network.server_game_type) {
    case ServerGameType::Local:
      _network_coordinator_client.CloseConnection();
      break;
 
    case ServerGameType::InviteOnly:
    case ServerGameType::Public:
      _network_coordinator_client.Register();
      break;
 
    default:
      NOT_REACHED();
  }
}

static bool NetworkReceive()
{
  bool result;
  if (_network_server) {
    ServerNetworkAdminSocketHandler::Receive();
    result = ServerNetworkGameSocketHandler::Receive();
  } else {
    result = ClientNetworkGameSocketHandler::Receive();
  }
  NetworkGameSocketHandler::ProcessDeferredDeletions();
  return result;
}

static void NetworkSend()
{
  if (_network_server) {
    ServerNetworkAdminSocketHandler::Send();
    ServerNetworkGameSocketHandler::Send();
  } else {
    ClientNetworkGameSocketHandler::Send();
  }
  NetworkGameSocketHandler::ProcessDeferredDeletions();
}

void NetworkBackgroundLoop()
{
  _network_content_client.SendReceive();
  _network_coordinator_client.SendReceive();
  TCPConnecter::CheckCallbacks();
  NetworkHTTPSocketHandler::HTTPReceive();
  QueryNetworkGameSocketHandler::SendReceive();
  NetworkGameSocketHandler::ProcessDeferredDeletions();
 
  NetworkBackgroundUDPLoop();
}

void NetworkGameLoop()
{
  if (!_networking) return;
 
  if (!NetworkReceive()) return;
 
  if (_network_server) {
    /* Log the sync state to check for in-syncedness of replays. */
    if (TimerGameEconomy::date_fract == 0) {
      /* We don't want to log multiple times if paused. */
      static TimerGameEconomy::Date last_log;
      if (last_log != TimerGameEconomy::date) {
        Debug(desync, 1, "sync: {:08x}; {:02x}; {:08x}; {:08x}", TimerGameEconomy::date, TimerGameEconomy::date_fract, _random.state[0], _random.state[1]);
        last_log = TimerGameEconomy::date;
      }
    }
 
#ifdef DEBUG_DUMP_COMMANDS
    /* Loading of the debug commands from -ddesync>=1 */
    static auto f = FioFOpenFile("commands.log", "rb", Subdirectory::Save);
    static TimerGameEconomy::Date next_date(0);
    static uint32_t next_date_fract;
    static CommandPacket *cp = nullptr;
    static bool check_sync_state = false;
    static uint32_t sync_state[2];
    if (!f.has_value() && next_date == 0) {
      Debug(desync, 0, "Cannot open commands.log");
      next_date = TimerGameEconomy::Date(1);
    }
 
    while (f.has_value() && !feof(*f)) {
      if (TimerGameEconomy::date == next_date && TimerGameEconomy::date_fract == next_date_fract) {
        if (cp != nullptr) {
          NetworkSendCommand(cp->cmd, cp->err_msg, nullptr, cp->company, cp->data);
          Debug(desync, 0, "Injecting: {:08x}; {:02x}; {:02x}; {:08x}; {} ({})", TimerGameEconomy::date, TimerGameEconomy::date_fract, _current_company.base(), cp->cmd, FormatArrayAsHex(cp->data), GetCommandName(cp->cmd));
          delete cp;
          cp = nullptr;
        }
        if (check_sync_state) {
          if (sync_state[0] == _random.state[0] && sync_state[1] == _random.state[1]) {
            Debug(desync, 0, "Sync check: {:08x}; {:02x}; match", TimerGameEconomy::date, TimerGameEconomy::date_fract);
          } else {
            Debug(desync, 0, "Sync check: {:08x}; {:02x}; mismatch expected {{{:08x}, {:08x}}}, got {{{:08x}, {:08x}}}",
                  TimerGameEconomy::date, TimerGameEconomy::date_fract, sync_state[0], sync_state[1], _random.state[0], _random.state[1]);
            NOT_REACHED();
          }
          check_sync_state = false;
        }
      }
 
      /* Skip all entries in the command-log till we caught up with the current game again. */
      if (TimerGameEconomy::date > next_date || (TimerGameEconomy::date == next_date && TimerGameEconomy::date_fract > next_date_fract)) {
        Debug(desync, 0, "Skipping to next command at {:08x}:{:02x}", next_date, next_date_fract);
        if (cp != nullptr) {
          delete cp;
          cp = nullptr;
        }
        check_sync_state = false;
      }
 
      if (cp != nullptr || check_sync_state) break;
 
      char buff[4096];
      if (fgets(buff, lengthof(buff), *f) == nullptr) break;
 
      StringConsumer consumer{std::string_view{buff}};
      /* Ignore the "[date time] " part of the message */
      if (consumer.ReadCharIf('[')) {
        consumer.SkipUntilChar(']', StringConsumer::SKIP_ONE_SEPARATOR);
        consumer.SkipCharIf(' ');
      }
 
      if (consumer.ReadIf("cmd: ")
#ifdef DEBUG_FAILED_DUMP_COMMANDS
        || consumer.ReadIf("cmdf: ")
#endif
        ) {
        cp = new CommandPacket();
        next_date = TimerGameEconomy::Date(consumer.ReadIntegerBase<uint32_t>(16));
        bool valid = consumer.ReadIf("; ");
        next_date_fract = consumer.ReadIntegerBase<uint32_t>(16);
        valid &= consumer.ReadIf("; ");
        cp->company = static_cast<CompanyID>(consumer.ReadIntegerBase<uint16_t>(16));
        valid &= consumer.ReadIf("; ");
        cp->cmd = static_cast<Commands>(consumer.ReadIntegerBase<uint32_t>(16));
        valid &= consumer.ReadIf("; ");
        cp->err_msg = consumer.ReadIntegerBase<uint32_t>(16);
        valid &= consumer.ReadIf("; ");
        auto args = consumer.ReadUntilChar(' ', StringConsumer::SKIP_ONE_SEPARATOR);
        assert(valid);
 
        /* Parse command data. */
        cp->data.clear();
        for (size_t i = 0; i + 1 < args.size(); i += 2) {
          uint8_t e = 0;
          std::from_chars(args.data() + i, args.data() + i + 2, e, 16);
          cp->data.push_back(e);
        }
      } else if (consumer.ReadIf("join: ")) {
        /* Manually insert a pause when joining; this way the client can join at the exact right time. */
        next_date = TimerGameEconomy::Date(consumer.ReadIntegerBase<uint32_t>(16));
        bool valid = consumer.ReadIf("; ");
        next_date_fract = consumer.ReadIntegerBase<uint32_t>(16);
        assert(valid);
        Debug(desync, 0, "Injecting pause for join at {:08x}:{:02x}; please join when paused", next_date, next_date_fract);
        cp = new CommandPacket();
        cp->company = COMPANY_SPECTATOR;
        cp->cmd = Commands::Pause;
        cp->data = EndianBufferWriter<>::FromValue(CommandTraits<Commands::Pause>::Args{ PauseMode::Normal, true });
        _ddc_fastforward = false;
      } else if (consumer.ReadIf("sync: ")) {
        next_date = TimerGameEconomy::Date(consumer.ReadIntegerBase<uint32_t>(16));
        bool valid = consumer.ReadIf("; ");
        next_date_fract = consumer.ReadIntegerBase<uint32_t>(16);
        valid &= consumer.ReadIf("; ");
        sync_state[0] = consumer.ReadIntegerBase<uint32_t>(16);
        valid &= consumer.ReadIf("; ");
        sync_state[1] = consumer.ReadIntegerBase<uint32_t>(16);
        assert(valid);
        check_sync_state = true;
      } else if (consumer.ReadIf("msg: ") || consumer.ReadIf("client: ") ||
            consumer.ReadIf("load: ") || consumer.ReadIf("save: ") ||
            consumer.ReadIf("warning: ")) {
        /* A message that is not very important to the log playback, but part of the log. */
#ifndef DEBUG_FAILED_DUMP_COMMANDS
      } else if (consumer.ReadIf("cmdf: ")) {
        Debug(desync, 0, "Skipping replay of failed command: {}", consumer.Read(StringConsumer::npos));
#endif
      } else {
        /* Can't parse a line; what's wrong here? */
        Debug(desync, 0, "Trying to parse: {}", consumer.Read(StringConsumer::npos));
        NOT_REACHED();
      }
    }
    if (f.has_value() && feof(*f)) {
      Debug(desync, 0, "End of commands.log");
      f.reset();
    }
#endif /* DEBUG_DUMP_COMMANDS */
    if (_frame_counter >= _frame_counter_max) {
      /* Only check for active clients just before we're going to send out
       * the commands so we don't send multiple pause/unpause commands when
       * the frame_freq is more than 1 tick. Same with distributing commands. */
      CheckPauseOnJoin();
      CheckMinActiveClients();
      NetworkDistributeCommands();
    }
 
    bool send_frame = false;
 
    /* We first increase the _frame_counter */
    _frame_counter++;
    /* Update max-frame-counter */
    if (_frame_counter > _frame_counter_max) {
      _frame_counter_max = _frame_counter + _settings_client.network.frame_freq;
      send_frame = true;
    }
 
    NetworkExecuteLocalCommandQueue();
 
    /* Then we make the frame */
    StateGameLoop();
 
    _sync_seed_1 = _random.state[0];
#ifdef NETWORK_SEND_DOUBLE_SEED
    _sync_seed_2 = _random.state[1];
#endif
 
    NetworkServer_Tick(send_frame);
  } else {
    /* Client */
 
    /* Make sure we are at the frame were the server is (quick-frames) */
    if (_frame_counter_server > _frame_counter) {
      /* Run a number of frames; when things go bad, get out. */
      while (_frame_counter_server > _frame_counter) {
        if (!ClientNetworkGameSocketHandler::GameLoop()) return;
      }
    } else {
      /* Else, keep on going till _frame_counter_max */
      if (_frame_counter_max > _frame_counter) {
        /* Run one frame; if things went bad, get out. */
        if (!ClientNetworkGameSocketHandler::GameLoop()) return;
      }
    }
  }
 
  NetworkSend();
}

void NetworkStartUp()
{
  Debug(net, 3, "Starting network");
 
  /* Network is available */
  _network_available = NetworkCoreInitialize();
  _network_dedicated = false;
 
  _network_game_info = {};
 
  NetworkInitialize();
  NetworkUDPInitialize();
  Debug(net, 3, "Network online, multiplayer available");
  NetworkFindBroadcastIPs(&_broadcast_list);
  NetworkHTTPInitialize();
}

void NetworkShutDown()
{
  NetworkDisconnect();
  NetworkHTTPUninitialize();
  NetworkUDPClose();
 
  Debug(net, 3, "Shutting down network");
 
  _network_available = false;
 
  NetworkCoreShutdown();
}
 
#ifdef __EMSCRIPTEN__
extern "C" {
 
void CDECL em_openttd_add_server(const char *connection_string)
{
  NetworkAddServer(connection_string, false, true);
}
 
}
#endif