tron@2186: /* $Id$ */
tron@2186: 
rubidium@9111: /** @file network_client.cpp Client part of the network protocol. */
rubidium@9111: 
Darkvater@4826: #ifdef ENABLE_NETWORK
Darkvater@4826: 
rubidium@5469: #include "../stdafx.h"
rubidium@5469: #include "../debug.h"
rubidium@7266: #include "../openttd.h"
rubidium@9428: #include "network_internal.h"
rubidium@5469: #include "core/tcp.h"
truelight@543: #include "network_client.h"
truelight@543: #include "network_gamelist.h"
tron@4512: #include "network_gui.h"
rubidium@5469: #include "../saveload.h"
rubidium@8116: #include "../command_func.h"
rubidium@9336: #include "../console_func.h"
rubidium@5469: #include "../variables.h"
rubidium@5469: #include "../ai/ai.h"
rubidium@8130: #include "../core/alloc_func.hpp"
rubidium@10039: #include "../fileio_func.h"
rubidium@7999: #include "../md5.h"
rubidium@8114: #include "../strings_func.h"
rubidium@8131: #include "../window_func.h"
rubidium@8214: #include "../string_func.h"
rubidium@10208: #include "../company_func.h"
rubidium@10208: #include "../company_base.h"
rubidium@10208: #include "../company_gui.h"
smatz@9085: #include "../rev.h"
truelight@543: 
rubidium@8264: #include "table/strings.h"
rubidium@8264: 
truelight@543: // This file handles all the client-commands
truelight@543: 
truelight@543: 
truelight@543: // So we don't make too much typos ;)
truelight@543: #define MY_CLIENT DEREF_CLIENT(0)
truelight@543: 
truelight@543: static uint32 last_ack_frame;
truelight@543: 
rubidium@7999: /** One bit of 'entropy' used to generate a salt for the company passwords. */
rubidium@7999: static uint32 _password_game_seed;
rubidium@7999: /** The other bit of 'entropy' used to generate a salt for the company passwords. */
rubidium@7999: static char _password_server_unique_id[NETWORK_UNIQUE_ID_LENGTH];
rubidium@7999: 
rubidium@7999: /** Make sure the unique ID length is the same as a md5 hash. */
rubidium@7999: assert_compile(NETWORK_UNIQUE_ID_LENGTH == 16 * 2 + 1);
rubidium@7999: 
rubidium@7999: /**
rubidium@7999:  * Generates a hashed password for the company name.
rubidium@7999:  * @param password the password to 'encrypt'.
rubidium@7999:  * @return the hashed password.
rubidium@7999:  */
rubidium@7999: static const char *GenerateCompanyPasswordHash(const char *password)
rubidium@7999: {
rubidium@7999: 	if (StrEmpty(password)) return password;
rubidium@7999: 
rubidium@7999: 	char salted_password[NETWORK_UNIQUE_ID_LENGTH];
rubidium@7999: 
rubidium@7999: 	memset(salted_password, 0, sizeof(salted_password));
rubidium@7999: 	snprintf(salted_password, sizeof(salted_password), "%s", password);
rubidium@7999: 	/* Add the game seed and the server's unique ID as the salt. */
rubidium@8252: 	for (uint i = 0; i < NETWORK_UNIQUE_ID_LENGTH - 1; i++) salted_password[i] ^= _password_server_unique_id[i] ^ (_password_game_seed >> i);
rubidium@7999: 
skidd13@8133: 	Md5 checksum;
skidd13@8133: 	uint8 digest[16];
rubidium@7999: 	static char hashed_password[NETWORK_UNIQUE_ID_LENGTH];
rubidium@7999: 
rubidium@7999: 	/* Generate the MD5 hash */
rubidium@8252: 	checksum.Append((const uint8*)salted_password, sizeof(salted_password) - 1);
skidd13@8133: 	checksum.Finish(digest);
rubidium@7999: 
rubidium@7999: 	for (int di = 0; di < 16; di++) sprintf(hashed_password + di * 2, "%02x", digest[di]);
rubidium@8252: 	hashed_password[lengthof(hashed_password) - 1] = '\0';
rubidium@7999: 
rubidium@7999: 	return hashed_password;
rubidium@7999: }
rubidium@7999: 
rubidium@7999: /**
rubidium@10207:  * Hash the current company password; used when the server 'company' sets his/her password.
rubidium@7999:  */
rubidium@7999: void HashCurrentCompanyPassword()
rubidium@7999: {
rubidium@10207: 	if (StrEmpty(_network_company_info[_local_company].password)) return;
rubidium@7999: 
rubidium@9413: 	_password_game_seed = _settings_game.game_creation.generation_seed;
rubidium@9420: 	ttd_strlcpy(_password_server_unique_id, _settings_client.network.network_id, sizeof(_password_server_unique_id));
rubidium@7999: 
rubidium@10207: 	const char *new_pw = GenerateCompanyPasswordHash(_network_company_info[_local_company].password);
rubidium@10207: 	ttd_strlcpy(_network_company_info[_local_company].password, new_pw, sizeof(_network_company_info[_local_company].password));
rubidium@7999: }
rubidium@7999: 
rubidium@7999: 
truelight@543: // **********
truelight@543: // Sending functions
truelight@543: //   DEF_CLIENT_SEND_COMMAND has no parameters
truelight@543: // **********
truelight@543: 
truelight@543: DEF_CLIENT_SEND_COMMAND(PACKET_CLIENT_COMPANY_INFO)
truelight@543: {
truelight@543: 	//
truelight@543: 	// Packet: CLIENT_COMPANY_INFO
truelight@543: 	// Function: Request company-info (in detail)
truelight@543: 	// Data:
truelight@543: 	//    <none>
truelight@543: 	//
truelight@543: 	Packet *p;
truelight@543: 	_network_join_status = NETWORK_JOIN_STATUS_GETTING_COMPANY_INFO;
truelight@543: 	InvalidateWindow(WC_NETWORK_STATUS_WINDOW, 0);
truelight@543: 
truelight@543: 	p = NetworkSend_Init(PACKET_CLIENT_COMPANY_INFO);
rubidium@5902: 	MY_CLIENT->Send_Packet(p);
truelight@543: }
truelight@543: 
truelight@543: DEF_CLIENT_SEND_COMMAND(PACKET_CLIENT_JOIN)
truelight@543: {
truelight@543: 	//
truelight@543: 	// Packet: CLIENT_JOIN
truelight@543: 	// Function: Try to join the server
truelight@543: 	// Data:
truelight@543: 	//    String: OpenTTD Revision (norev000 if no revision)
rubidium@10207: 	//    String: Client Name (max NETWORK_NAME_LENGTH)
rubidium@10207: 	//    uint8:  Play as Company id (1..MAX_COMPANIES)
truelight@543: 	//    uint8:  Language ID
rubidium@10207: 	//    String: Unique id to find the client back in server-listing
truelight@543: 	//
truelight@543: 
truelight@543: 	Packet *p;
truelight@543: 	_network_join_status = NETWORK_JOIN_STATUS_AUTHORIZING;
truelight@543: 	InvalidateWindow(WC_NETWORK_STATUS_WINDOW, 0);
truelight@543: 
truelight@543: 	p = NetworkSend_Init(PACKET_CLIENT_JOIN);
rubidium@5900: 	p->Send_string(_openttd_revision);
rubidium@10207: 	p->Send_string(_settings_client.network.client_name); // Client name
rubidium@5900: 	p->Send_uint8 (_network_playas);      // PlayAs
rubidium@5900: 	p->Send_uint8 (NETLANG_ANY);          // Language
rubidium@9420: 	p->Send_string(_settings_client.network.network_id);
rubidium@5902: 	MY_CLIENT->Send_Packet(p);
truelight@543: }
truelight@543: 
rubidium@5872: DEF_CLIENT_SEND_COMMAND(PACKET_CLIENT_NEWGRFS_CHECKED)
rubidium@5872: {
rubidium@5872: 	//
rubidium@5872: 	// Packet: CLIENT_NEWGRFS_CHECKED
rubidium@5872: 	// Function: Tell the server that we have the required GRFs
rubidium@5872: 	// Data:
rubidium@5872: 	//
rubidium@5872: 
rubidium@5872: 	Packet *p = NetworkSend_Init(PACKET_CLIENT_NEWGRFS_CHECKED);
rubidium@5902: 	MY_CLIENT->Send_Packet(p);
rubidium@5872: }
rubidium@5872: 
truelight@543: DEF_CLIENT_SEND_COMMAND_PARAM(PACKET_CLIENT_PASSWORD)(NetworkPasswordType type, const char *password)
truelight@543: {
truelight@543: 	//
truelight@543: 	// Packet: CLIENT_PASSWORD
truelight@543: 	// Function: Send a password to the server to authorize
truelight@543: 	// Data:
truelight@543: 	//    uint8:  NetworkPasswordType
truelight@543: 	//    String: Password
truelight@543: 	//
truelight@543: 	Packet *p = NetworkSend_Init(PACKET_CLIENT_PASSWORD);
rubidium@5900: 	p->Send_uint8 (type);
rubidium@7999: 	p->Send_string(type == NETWORK_GAME_PASSWORD ? password : GenerateCompanyPasswordHash(password));
rubidium@5902: 	MY_CLIENT->Send_Packet(p);
truelight@543: }
truelight@543: 
truelight@543: DEF_CLIENT_SEND_COMMAND(PACKET_CLIENT_GETMAP)
truelight@543: {
truelight@543: 	//
truelight@543: 	// Packet: CLIENT_GETMAP
truelight@543: 	// Function: Request the map from the server
truelight@543: 	// Data:
truelight@543: 	//    <none>
truelight@543: 	//
truelight@543: 
truelight@543: 	Packet *p = NetworkSend_Init(PACKET_CLIENT_GETMAP);
rubidium@5902: 	MY_CLIENT->Send_Packet(p);
truelight@543: }
truelight@543: 
truelight@543: DEF_CLIENT_SEND_COMMAND(PACKET_CLIENT_MAP_OK)
truelight@543: {
truelight@543: 	//
truelight@543: 	// Packet: CLIENT_MAP_OK
truelight@543: 	// Function: Tell the server that we are done receiving/loading the map
truelight@543: 	// Data:
truelight@543: 	//    <none>
truelight@543: 	//
truelight@543: 
truelight@543: 	Packet *p = NetworkSend_Init(PACKET_CLIENT_MAP_OK);
rubidium@5902: 	MY_CLIENT->Send_Packet(p);
truelight@543: }
truelight@543: 
truelight@543: DEF_CLIENT_SEND_COMMAND(PACKET_CLIENT_ACK)
truelight@543: {
truelight@543: 	//
truelight@543: 	// Packet: CLIENT_ACK
truelight@543: 	// Function: Tell the server we are done with this frame
truelight@543: 	// Data:
truelight@543: 	//    uint32: current FrameCounter of the client
truelight@543: 	//
truelight@543: 
truelight@543: 	Packet *p = NetworkSend_Init(PACKET_CLIENT_ACK);
truelight@543: 
rubidium@5900: 	p->Send_uint32(_frame_counter);
rubidium@5902: 	MY_CLIENT->Send_Packet(p);
truelight@543: }
truelight@543: 
truelight@543: // Send a command packet to the server
truelight@543: DEF_CLIENT_SEND_COMMAND_PARAM(PACKET_CLIENT_COMMAND)(CommandPacket *cp)
truelight@543: {
truelight@543: 	//
truelight@543: 	// Packet: CLIENT_COMMAND
truelight@543: 	// Function: Send a DoCommand to the Server
truelight@543: 	// Data:
rubidium@10207: 	//    uint8:  CompanyID (0..MAX_COMPANIES-1)
truelight@543: 	//    uint32: CommandID (see command.h)
truelight@543: 	//    uint32: P1 (free variables used in DoCommand)
truelight@543: 	//    uint32: P2
truelight@543: 	//    uint32: Tile
tron@1820: 	//    string: text
truelight@543: 	//    uint8:  CallBackID (see callback_table.c)
truelight@543: 	//
truelight@543: 
truelight@543: 	Packet *p = NetworkSend_Init(PACKET_CLIENT_COMMAND);
truelight@543: 
rubidium@10207: 	p->Send_uint8 (cp->company);
rubidium@5900: 	p->Send_uint32(cp->cmd);
rubidium@5900: 	p->Send_uint32(cp->p1);
rubidium@5900: 	p->Send_uint32(cp->p2);
rubidium@5900: 	p->Send_uint32((uint32)cp->tile);
rubidium@5900: 	p->Send_string(cp->text);
rubidium@5900: 	p->Send_uint8 (cp->callback);
truelight@543: 
rubidium@5902: 	MY_CLIENT->Send_Packet(p);
truelight@543: }
truelight@543: 
truelight@543: // Send a chat-packet over the network
Darkvater@4906: DEF_CLIENT_SEND_COMMAND_PARAM(PACKET_CLIENT_CHAT)(NetworkAction action, DestType type, int dest, const char *msg)
truelight@543: {
truelight@543: 	//
truelight@543: 	// Packet: CLIENT_CHAT
truelight@543: 	// Function: Send a chat-packet to the serve
truelight@543: 	// Data:
truelight@543: 	//    uint8:  ActionID (see network_data.h, NetworkAction)
truelight@543: 	//    uint8:  Destination Type (see network_data.h, DestType);
rubidium@10207: 	//    uint16: Destination Company/Client
rubidium@9896: 	//    String: Message (max NETWORK_CHAT_LENGTH)
truelight@543: 	//
truelight@543: 
truelight@543: 	Packet *p = NetworkSend_Init(PACKET_CLIENT_CHAT);
truelight@543: 
rubidium@5900: 	p->Send_uint8 (action);
rubidium@5900: 	p->Send_uint8 (type);
rubidium@6531: 	p->Send_uint16(dest);
rubidium@5900: 	p->Send_string(msg);
rubidium@5902: 	MY_CLIENT->Send_Packet(p);
truelight@543: }
truelight@543: 
truelight@543: // Send an error-packet over the network
truelight@543: DEF_CLIENT_SEND_COMMAND_PARAM(PACKET_CLIENT_ERROR)(NetworkErrorCode errorno)
truelight@543: {
truelight@543: 	//
truelight@543: 	// Packet: CLIENT_ERROR
truelight@543: 	// Function: The client made an error and is quiting the game
truelight@543: 	// Data:
truelight@543: 	//    uint8:  ErrorID (see network_data.h, NetworkErrorCode)
truelight@543: 	//
truelight@543: 	Packet *p = NetworkSend_Init(PACKET_CLIENT_ERROR);
truelight@543: 
rubidium@5900: 	p->Send_uint8(errorno);
rubidium@5902: 	MY_CLIENT->Send_Packet(p);
truelight@543: }
truelight@543: 
truelight@543: DEF_CLIENT_SEND_COMMAND_PARAM(PACKET_CLIENT_SET_PASSWORD)(const char *password)
truelight@543: {
truelight@543: 	//
truelight@543: 	// Packet: PACKET_CLIENT_SET_PASSWORD
truelight@543: 	// Function: Set the password for the clients current company
truelight@543: 	// Data:
truelight@543: 	//    String: Password
truelight@543: 	//
truelight@543: 	Packet *p = NetworkSend_Init(PACKET_CLIENT_SET_PASSWORD);
truelight@543: 
rubidium@7999: 	p->Send_string(GenerateCompanyPasswordHash(password));
rubidium@5902: 	MY_CLIENT->Send_Packet(p);
truelight@543: }
truelight@543: 
truelight@543: DEF_CLIENT_SEND_COMMAND_PARAM(PACKET_CLIENT_SET_NAME)(const char *name)
truelight@543: {
truelight@543: 	//
truelight@543: 	// Packet: PACKET_CLIENT_SET_NAME
rubidium@10207: 	// Function: Gives the client a new name
truelight@543: 	// Data:
truelight@543: 	//    String: Name
truelight@543: 	//
truelight@543: 	Packet *p = NetworkSend_Init(PACKET_CLIENT_SET_NAME);
truelight@543: 
rubidium@5900: 	p->Send_string(name);
rubidium@5902: 	MY_CLIENT->Send_Packet(p);
truelight@543: }
truelight@543: 
truelight@543: // Send an quit-packet over the network
truelight@543: DEF_CLIENT_SEND_COMMAND_PARAM(PACKET_CLIENT_QUIT)(const char *leavemsg)
truelight@543: {
truelight@543: 	//
truelight@543: 	// Packet: CLIENT_QUIT
truelight@543: 	// Function: The client is quiting the game
truelight@543: 	// Data:
truelight@543: 	//    String: leave-message
truelight@543: 	//
truelight@543: 	Packet *p = NetworkSend_Init(PACKET_CLIENT_QUIT);
truelight@543: 
rubidium@5900: 	p->Send_string(leavemsg);
rubidium@5902: 	MY_CLIENT->Send_Packet(p);
truelight@543: }
truelight@543: 
truelight@1026: DEF_CLIENT_SEND_COMMAND_PARAM(PACKET_CLIENT_RCON)(const char *pass, const char *command)
truelight@1026: {
truelight@1026: 	Packet *p = NetworkSend_Init(PACKET_CLIENT_RCON);
rubidium@5900: 	p->Send_string(pass);
rubidium@5900: 	p->Send_string(command);
rubidium@5902: 	MY_CLIENT->Send_Packet(p);
truelight@1026: }
truelight@1026: 
truelight@543: 
truelight@543: // **********
truelight@543: // Receiving functions
truelight@543: //   DEF_CLIENT_RECEIVE_COMMAND has parameter: Packet *p
truelight@543: // **********
truelight@543: 
rubidium@6929: extern bool SafeSaveOrLoad(const char *filename, int mode, int newgm, Subdirectory subdir);
rubidium@8973: extern StringID _switch_mode_errorstr;
truelight@543: 
truelight@543: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_FULL)
truelight@543: {
truelight@543: 	// We try to join a server which is full
truelight@543: 	_switch_mode_errorstr = STR_NETWORK_ERR_SERVER_FULL;
truelight@543: 	DeleteWindowById(WC_NETWORK_STATUS_WINDOW, 0);
truelight@543: 
truelight@543: 	return NETWORK_RECV_STATUS_SERVER_FULL;
truelight@543: }
truelight@543: 
truelight@841: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_BANNED)
truelight@841: {
truelight@841: 	// We try to join a server where we are banned
truelight@841: 	_switch_mode_errorstr = STR_NETWORK_ERR_SERVER_BANNED;
truelight@841: 	DeleteWindowById(WC_NETWORK_STATUS_WINDOW, 0);
truelight@841: 
truelight@841: 	return NETWORK_RECV_STATUS_SERVER_BANNED;
truelight@841: }
truelight@841: 
truelight@543: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_COMPANY_INFO)
truelight@543: {
truelight@543: 	byte company_info_version;
truelight@543: 	int i;
truelight@543: 
rubidium@5900: 	company_info_version = p->Recv_uint8();
truelight@543: 
Darkvater@4880: 	if (!MY_CLIENT->has_quit && company_info_version == NETWORK_COMPANY_INFO_VERSION) {
truelight@543: 		byte total;
rubidium@10207: 		CompanyID current;
truelight@543: 
rubidium@5900: 		total = p->Recv_uint8();
truelight@543: 
truelight@543: 		// There is no data at all..
Darkvater@4880: 		if (total == 0) return NETWORK_RECV_STATUS_CLOSE_QUERY;
truelight@543: 
rubidium@5900: 		current = (Owner)p->Recv_uint8();
rubidium@10207: 		if (current >= MAX_COMPANIES) return NETWORK_RECV_STATUS_CLOSE_QUERY;
truelight@543: 
rubidium@10207: 		p->Recv_string(_network_company_info[current].company_name, sizeof(_network_company_info[current].company_name));
rubidium@10207: 		_network_company_info[current].inaugurated_year = p->Recv_uint32();
rubidium@10207: 		_network_company_info[current].company_value    = p->Recv_uint64();
rubidium@10207: 		_network_company_info[current].money            = p->Recv_uint64();
rubidium@10207: 		_network_company_info[current].income           = p->Recv_uint64();
rubidium@10207: 		_network_company_info[current].performance      = p->Recv_uint16();
rubidium@10207: 		_network_company_info[current].use_password     = p->Recv_bool();
truelight@543: 		for (i = 0; i < NETWORK_VEHICLE_TYPES; i++)
rubidium@10207: 			_network_company_info[current].num_vehicle[i] = p->Recv_uint16();
truelight@543: 		for (i = 0; i < NETWORK_STATION_TYPES; i++)
rubidium@10207: 			_network_company_info[current].num_station[i] = p->Recv_uint16();
truelight@543: 
rubidium@10207: 		p->Recv_string(_network_company_info[current].clients, sizeof(_network_company_info[current].clients));
truelight@543: 
truelight@543: 		InvalidateWindow(WC_NETWORK_WINDOW, 0);
truelight@543: 
truelight@734: 		return NETWORK_RECV_STATUS_OKAY;
truelight@543: 	}
truelight@543: 
truelight@543: 	return NETWORK_RECV_STATUS_CLOSE_QUERY;
truelight@543: }
truelight@543: 
truelight@543: // This packet contains info about the client (playas and name)
truelight@543: //  as client we save this in NetworkClientInfo, linked via 'index'
truelight@543: //  which is always an unique number on a server.
truelight@543: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_CLIENT_INFO)
truelight@543: {
truelight@543: 	NetworkClientInfo *ci;
rubidium@5900: 	uint16 index = p->Recv_uint16();
rubidium@10207: 	CompanyID playas = (CompanyID)p->Recv_uint8();
truelight@662: 	char name[NETWORK_NAME_LENGTH];
truelight@662: 
rubidium@5900: 	p->Recv_string(name, sizeof(name));
truelight@903: 
Darkvater@4880: 	if (MY_CLIENT->has_quit) return NETWORK_RECV_STATUS_CONN_LOST;
truelight@662: 
truelight@662: 	/* Do we receive a change of data? Most likely we changed playas */
Darkvater@4880: 	if (index == _network_own_client_index) _network_playas = playas;
truelight@2684: 
truelight@543: 	ci = NetworkFindClientInfoFromIndex(index);
truelight@543: 	if (ci != NULL) {
truelight@543: 		if (playas == ci->client_playas && strcmp(name, ci->client_name) != 0) {
truelight@543: 			// Client name changed, display the change
rubidium@9337: 			NetworkTextMessage(NETWORK_ACTION_NAME_CHANGE, CC_DEFAULT, false, ci->client_name, "%s", name);
truelight@543: 		} else if (playas != ci->client_playas) {
rubidium@10207: 			// The client changed from client-player..
truelight@543: 			// Do not display that for now
truelight@543: 		}
truelight@543: 
truelight@543: 		ci->client_playas = playas;
truelight@543: 		ttd_strlcpy(ci->client_name, name, sizeof(ci->client_name));
truelight@662: 
truelight@722: 		InvalidateWindow(WC_CLIENT_LIST, 0);
truelight@722: 
truelight@543: 		return NETWORK_RECV_STATUS_OKAY;
truelight@543: 	}
truelight@543: 
truelight@543: 	// We don't have this index yet, find an empty index, and put the data there
truelight@543: 	ci = NetworkFindClientInfoFromIndex(NETWORK_EMPTY_INDEX);
truelight@543: 	if (ci != NULL) {
truelight@543: 		ci->client_index = index;
truelight@662: 		ci->client_playas = playas;
truelight@662: 
truelight@662: 		ttd_strlcpy(ci->client_name, name, sizeof(ci->client_name));
truelight@662: 
truelight@722: 		InvalidateWindow(WC_CLIENT_LIST, 0);
truelight@722: 
truelight@543: 		return NETWORK_RECV_STATUS_OKAY;
truelight@543: 	}
truelight@543: 
truelight@543: 	// Here the program should never ever come.....
truelight@543: 	return NETWORK_RECV_STATUS_MALFORMED_PACKET;
truelight@543: }
truelight@543: 
truelight@543: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_ERROR)
truelight@543: {
rubidium@5900: 	NetworkErrorCode error = (NetworkErrorCode)p->Recv_uint8();
truelight@543: 
Darkvater@2879: 	switch (error) {
Darkvater@2879: 		/* We made an error in the protocol, and our connection is closed.... */
Darkvater@2879: 		case NETWORK_ERROR_NOT_AUTHORIZED:
Darkvater@2879: 		case NETWORK_ERROR_NOT_EXPECTED:
rubidium@10207: 		case NETWORK_ERROR_COMPANY_MISMATCH:
Darkvater@2879: 			_switch_mode_errorstr = STR_NETWORK_ERR_SERVER_ERROR;
Darkvater@2879: 			break;
Darkvater@2879: 		case NETWORK_ERROR_FULL:
Darkvater@2879: 			_switch_mode_errorstr = STR_NETWORK_ERR_SERVER_FULL;
Darkvater@2879: 			break;
Darkvater@2879: 		case NETWORK_ERROR_WRONG_REVISION:
Darkvater@2879: 			_switch_mode_errorstr = STR_NETWORK_ERR_WRONG_REVISION;
Darkvater@2879: 			break;
Darkvater@2879: 		case NETWORK_ERROR_WRONG_PASSWORD:
Darkvater@2879: 			_switch_mode_errorstr = STR_NETWORK_ERR_WRONG_PASSWORD;
Darkvater@2879: 			break;
Darkvater@2879: 		case NETWORK_ERROR_KICKED:
Darkvater@2879: 			_switch_mode_errorstr = STR_NETWORK_ERR_KICKED;
Darkvater@2879: 			break;
Darkvater@2879: 		case NETWORK_ERROR_CHEATER:
Darkvater@2879: 			_switch_mode_errorstr = STR_NETWORK_ERR_CHEATER;
Darkvater@2879: 			break;
Darkvater@2879: 		default:
Darkvater@2879: 			_switch_mode_errorstr = STR_NETWORK_ERR_LOSTCONNECTION;
truelight@543: 	}
truelight@543: 
truelight@543: 	DeleteWindowById(WC_NETWORK_STATUS_WINDOW, 0);
truelight@543: 
truelight@543: 	return NETWORK_RECV_STATUS_SERVER_ERROR;
truelight@543: }
truelight@543: 
rubidium@5872: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_CHECK_NEWGRFS)
rubidium@5872: {
rubidium@5900: 	uint grf_count = p->Recv_uint8();
rubidium@5872: 	NetworkRecvStatus ret = NETWORK_RECV_STATUS_OKAY;
rubidium@5872: 
rubidium@5872: 	/* Check all GRFs */
rubidium@5872: 	for (; grf_count > 0; grf_count--) {
rubidium@5872: 		GRFConfig c;
rubidium@5872: 		MY_CLIENT->Recv_GRFIdentifier(p, &c);
rubidium@5872: 
rubidium@5872: 		/* Check whether we know this GRF */
rubidium@5872: 		const GRFConfig *f = FindGRFConfig(c.grfid, c.md5sum);
rubidium@5872: 		if (f == NULL) {
rubidium@5872: 			/* We do not know this GRF, bail out of initialization */
rubidium@5872: 			char buf[sizeof(c.md5sum) * 2 + 1];
rubidium@5872: 			md5sumToString(buf, lastof(buf), c.md5sum);
rubidium@5872: 			DEBUG(grf, 0, "NewGRF %08X not found; checksum %s", BSWAP32(c.grfid), buf);
rubidium@5872: 			ret = NETWORK_RECV_STATUS_NEWGRF_MISMATCH;
rubidium@5872: 		}
rubidium@5872: 	}
rubidium@5872: 
rubidium@5872: 	if (ret == NETWORK_RECV_STATUS_OKAY) {
rubidium@5872: 		/* Start receiving the map */
rubidium@5872: 		SEND_COMMAND(PACKET_CLIENT_NEWGRFS_CHECKED)();
rubidium@5872: 	} else {
rubidium@5872: 		/* NewGRF mismatch, bail out */
rubidium@5872: 		_switch_mode_errorstr = STR_NETWORK_ERR_NEWGRF_MISMATCH;
rubidium@5872: 	}
rubidium@5872: 	return ret;
rubidium@5872: }
rubidium@5872: 
truelight@543: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_NEED_PASSWORD)
truelight@543: {
rubidium@5900: 	NetworkPasswordType type = (NetworkPasswordType)p->Recv_uint8();
truelight@543: 
tron@4512: 	switch (type) {
rubidium@7999: 		case NETWORK_COMPANY_PASSWORD:
rubidium@7999: 			/* Initialize the password hash salting variables. */
rubidium@7999: 			_password_game_seed = p->Recv_uint32();
rubidium@7999: 			p->Recv_string(_password_server_unique_id, sizeof(_password_server_unique_id));
rubidium@7999: 			if (MY_CLIENT->has_quit) return NETWORK_RECV_STATUS_MALFORMED_PACKET;
rubidium@7999: 
tron@4512: 		case NETWORK_GAME_PASSWORD:
tron@4512: 			ShowNetworkNeedPassword(type);
tron@4512: 			return NETWORK_RECV_STATUS_OKAY;
tron@4512: 
tron@4512: 		default: return NETWORK_RECV_STATUS_MALFORMED_PACKET;
truelight@543: 	}
truelight@543: }
truelight@543: 
truelight@543: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_WELCOME)
truelight@543: {
rubidium@5900: 	_network_own_client_index = p->Recv_uint16();
truelight@543: 
rubidium@7999: 	/* Initialize the password hash salting variables, even if they were previously. */
rubidium@7999: 	_password_game_seed = p->Recv_uint32();
rubidium@7999: 	p->Recv_string(_password_server_unique_id, sizeof(_password_server_unique_id));
rubidium@7999: 
truelight@543: 	// Start receiving the map
truelight@543: 	SEND_COMMAND(PACKET_CLIENT_GETMAP)();
truelight@543: 	return NETWORK_RECV_STATUS_OKAY;
truelight@543: }
truelight@543: 
truelight@543: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_WAIT)
truelight@543: {
truelight@543: 	_network_join_status = NETWORK_JOIN_STATUS_WAITING;
rubidium@5900: 	_network_join_waiting = p->Recv_uint8();
truelight@543: 	InvalidateWindow(WC_NETWORK_STATUS_WINDOW, 0);
truelight@543: 
truelight@543: 	// We are put on hold for receiving the map.. we need GUI for this ;)
Darkvater@5380: 	DEBUG(net, 1, "The server is currently busy sending the map to someone else, please wait..." );
Darkvater@5380: 	DEBUG(net, 1, "There are %d clients in front of you", _network_join_waiting);
truelight@543: 
truelight@543: 	return NETWORK_RECV_STATUS_OKAY;
truelight@543: }
truelight@543: 
truelight@543: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_MAP)
truelight@543: {
truelight@543: 	static FILE *file_pointer;
truelight@543: 
truelight@543: 	byte maptype;
truelight@543: 
rubidium@5900: 	maptype = p->Recv_uint8();
truelight@903: 
Darkvater@4880: 	if (MY_CLIENT->has_quit) return NETWORK_RECV_STATUS_CONN_LOST;
truelight@543: 
truelight@543: 	// First packet, init some stuff
truelight@543: 	if (maptype == MAP_PACKET_START) {
rubidium@6929: 		file_pointer = FioFOpenFile("network_client.tmp", "wb", AUTOSAVE_DIR);;
truelight@543: 		if (file_pointer == NULL) {
truelight@543: 			_switch_mode_errorstr = STR_NETWORK_ERR_SAVEGAMEERROR;
truelight@543: 			return NETWORK_RECV_STATUS_SAVEGAME;
truelight@543: 		}
truelight@543: 
rubidium@5900: 		_frame_counter = _frame_counter_server = _frame_counter_max = p->Recv_uint32();
truelight@543: 
truelight@543: 		_network_join_kbytes = 0;
rubidium@5900: 		_network_join_kbytes_total = p->Recv_uint32() / 1024;
rubidium@5703: 
rubidium@5703: 		/* If the network connection has been closed due to loss of connection
rubidium@5703: 		 * or when _network_join_kbytes_total is 0, the join status window will
rubidium@5703: 		 * do a division by zero. When the connection is lost, we just return
rubidium@5703: 		 * that. If kbytes_total is 0, the packet must be malformed as a
rubidium@5703: 		 * savegame less than 1 kilobyte is practically impossible. */
rubidium@5703: 		if (MY_CLIENT->has_quit) return NETWORK_RECV_STATUS_CONN_LOST;
rubidium@5703: 		if (_network_join_kbytes_total == 0) return NETWORK_RECV_STATUS_MALFORMED_PACKET;
rubidium@5703: 
rubidium@5703: 		_network_join_status = NETWORK_JOIN_STATUS_DOWNLOADING;
rubidium@6492: 		InvalidateWindow(WC_NETWORK_STATUS_WINDOW, 0);
truelight@543: 
truelight@543: 		// The first packet does not contain any more data
truelight@543: 		return NETWORK_RECV_STATUS_OKAY;
truelight@543: 	}
truelight@543: 
truelight@543: 	if (maptype == MAP_PACKET_NORMAL) {
truelight@543: 		// We are still receiving data, put it to the file
rubidium@9103: 		if (fwrite(p->buffer + p->pos, 1, p->size - p->pos, file_pointer) != (size_t)(p->size - p->pos)) {
rubidium@9100: 			_switch_mode_errorstr = STR_NETWORK_ERR_SAVEGAMEERROR;
rubidium@9100: 			return NETWORK_RECV_STATUS_SAVEGAME;
rubidium@9100: 		}
truelight@543: 
truelight@543: 		_network_join_kbytes = ftell(file_pointer) / 1024;
truelight@543: 		InvalidateWindow(WC_NETWORK_STATUS_WINDOW, 0);
truelight@543: 	}
truelight@543: 
truelight@543: 	// Check if this was the last packet
truelight@543: 	if (maptype == MAP_PACKET_END) {
truelight@543: 		fclose(file_pointer);
truelight@543: 
truelight@543: 		_network_join_status = NETWORK_JOIN_STATUS_PROCESSING;
truelight@543: 		InvalidateWindow(WC_NETWORK_STATUS_WINDOW, 0);
truelight@543: 
Darkvater@5413: 		/* The map is done downloading, load it */
rubidium@6929: 		if (!SafeSaveOrLoad("network_client.tmp", SL_LOAD, GM_NORMAL, AUTOSAVE_DIR)) {
truelight@543: 			DeleteWindowById(WC_NETWORK_STATUS_WINDOW, 0);
truelight@543: 			_switch_mode_errorstr = STR_NETWORK_ERR_SAVEGAMEERROR;
truelight@543: 			return NETWORK_RECV_STATUS_SAVEGAME;
truelight@543: 		}
Darkvater@5432: 		/* If the savegame has successfully loaded, ALL windows have been removed,
Darkvater@5432: 		 * only toolbar/statusbar and gamefield are visible */
Darkvater@1500: 
truelight@543: 		// Say we received the map and loaded it correctly!
truelight@543: 		SEND_COMMAND(PACKET_CLIENT_MAP_OK)();
truelight@543: 
rubidium@10207: 		/* New company/spectator (invalid company) or company we want to join is not active
rubidium@10207: 		 * Switch local company to spectator and await the server's judgement */
rubidium@10207: 		if (_network_playas == COMPANY_NEW_COMPANY || !IsValidCompanyID(_network_playas)) {
rubidium@10207: 			SetLocalCompany(COMPANY_SPECTATOR);
Darkvater@4880: 
rubidium@10207: 			if (_network_playas != COMPANY_SPECTATOR) {
rubidium@10207: 				/* We have arrived and ready to start playing; send a command to make a new company;
Darkvater@1797: 				 * the server will give us a client-id and let us in */
Darkvater@5432: 				_network_join_status = NETWORK_JOIN_STATUS_REGISTERING;
Darkvater@5432: 				ShowJoinStatusWindow();
rubidium@10207: 				NetworkSend_Command(0, 0, 0, CMD_COMPANY_CTRL, NULL);
truelight@543: 			}
truelight@543: 		} else {
truelight@543: 			// take control over an existing company
rubidium@10207: 			SetLocalCompany(_network_playas);
truelight@543: 		}
truelight@543: 	}
truelight@543: 
truelight@543: 	return NETWORK_RECV_STATUS_OKAY;
truelight@543: }
truelight@543: 
truelight@543: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_FRAME)
truelight@543: {
rubidium@5900: 	_frame_counter_server = p->Recv_uint32();
rubidium@5900: 	_frame_counter_max = p->Recv_uint32();
truelight@543: #ifdef ENABLE_NETWORK_SYNC_EVERY_FRAME
truelight@543: 	// Test if the server supports this option
truelight@543: 	//  and if we are at the frame the server is
truelight@543: 	if (p->pos < p->size) {
truelight@543: 		_sync_frame = _frame_counter_server;
rubidium@5900: 		_sync_seed_1 = p->Recv_uint32();
truelight@543: #ifdef NETWORK_SEND_DOUBLE_SEED
rubidium@5900: 		_sync_seed_2 = p->Recv_uint32();
truelight@543: #endif
truelight@543: 	}
truelight@543: #endif
Darkvater@5380: 	DEBUG(net, 5, "Received FRAME %d", _frame_counter_server);
truelight@543: 
truelight@543: 	// Let the server know that we received this frame correctly
truelight@543: 	//  We do this only once per day, to save some bandwidth ;)
truelight@543: 	if (!_network_first_time && last_ack_frame < _frame_counter) {
truelight@543: 		last_ack_frame = _frame_counter + DAY_TICKS;
Darkvater@5380: 		DEBUG(net, 4, "Sent ACK at %d", _frame_counter);
truelight@543: 		SEND_COMMAND(PACKET_CLIENT_ACK)();
truelight@543: 	}
truelight@543: 
truelight@543: 	return NETWORK_RECV_STATUS_OKAY;
truelight@543: }
truelight@543: 
truelight@543: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_SYNC)
truelight@543: {
rubidium@5900: 	_sync_frame = p->Recv_uint32();
rubidium@5900: 	_sync_seed_1 = p->Recv_uint32();
truelight@543: #ifdef NETWORK_SEND_DOUBLE_SEED
rubidium@5900: 	_sync_seed_2 = p->Recv_uint32();
truelight@543: #endif
truelight@543: 
truelight@543: 	return NETWORK_RECV_STATUS_OKAY;
truelight@543: }
truelight@543: 
truelight@543: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_COMMAND)
truelight@543: {
KUDr@5609: 	CommandPacket *cp = MallocT<CommandPacket>(1);
rubidium@10207: 	cp->company  = (CompanyID)p->Recv_uint8();
rubidium@5900: 	cp->cmd      = p->Recv_uint32();
rubidium@5900: 	cp->p1       = p->Recv_uint32();
rubidium@5900: 	cp->p2       = p->Recv_uint32();
rubidium@5900: 	cp->tile     = p->Recv_uint32();
rubidium@5900: 	p->Recv_string(cp->text, sizeof(cp->text));
rubidium@5900: 	cp->callback = p->Recv_uint8();
rubidium@5900: 	cp->frame    = p->Recv_uint32();
rubidium@7222: 	cp->my_cmd   = p->Recv_bool();
rubidium@5900: 	cp->next     = NULL;
truelight@543: 
truelight@543: 	// The server did send us this command..
truelight@543: 	//  queue it in our own queue, so we can handle it in the upcoming frame!
truelight@543: 
truelight@543: 	if (_local_command_queue == NULL) {
truelight@543: 		_local_command_queue = cp;
truelight@543: 	} else {
truelight@543: 		// Find last packet
truelight@543: 		CommandPacket *c = _local_command_queue;
truelight@543: 		while (c->next != NULL) c = c->next;
truelight@543: 		c->next = cp;
truelight@543: 	}
truelight@543: 
truelight@543: 	return NETWORK_RECV_STATUS_OKAY;
truelight@543: }
truelight@543: 
truelight@543: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_CHAT)
truelight@543: {
rubidium@9896: 	char name[NETWORK_NAME_LENGTH], msg[NETWORK_CHAT_LENGTH];
Darkvater@4880: 	const NetworkClientInfo *ci = NULL, *ci_to;
truelight@543: 
rubidium@5900: 	NetworkAction action = (NetworkAction)p->Recv_uint8();
rubidium@5900: 	uint16 index = p->Recv_uint16();
rubidium@5918: 	bool self_send = p->Recv_bool();
rubidium@9896: 	p->Recv_string(msg, NETWORK_CHAT_LENGTH);
truelight@543: 
truelight@543: 	ci_to = NetworkFindClientInfoFromIndex(index);
truelight@543: 	if (ci_to == NULL) return NETWORK_RECV_STATUS_OKAY;
truelight@543: 
Darkvater@4946: 	/* Did we initiate the action locally? */
truelight@722: 	if (self_send) {
truelight@722: 		switch (action) {
truelight@722: 			case NETWORK_ACTION_CHAT_CLIENT:
Darkvater@4946: 				/* For speaking to client we need the client-name */
truelight@722: 				snprintf(name, sizeof(name), "%s", ci_to->client_name);
truelight@722: 				ci = NetworkFindClientInfoFromIndex(_network_own_client_index);
truelight@722: 				break;
Darkvater@4945: 
rubidium@10207: 			/* For speaking to company or giving money, we need the company-name */
truelight@722: 			case NETWORK_ACTION_GIVE_MONEY:
rubidium@10207: 				if (!IsValidCompanyID(ci_to->client_playas)) return NETWORK_RECV_STATUS_OKAY;
Darkvater@4945: 				/* fallthrough */
Darkvater@4945: 			case NETWORK_ACTION_CHAT_COMPANY: {
rubidium@10207: 				StringID str = IsValidCompanyID(ci_to->client_playas) ? STR_COMPANY_NAME : STR_NETWORK_SPECTATORS;
peter1138@7060: 				SetDParam(0, ci_to->client_playas);
Darkvater@4878: 
Darkvater@4945: 				GetString(name, str, lastof(name));
truelight@722: 				ci = NetworkFindClientInfoFromIndex(_network_own_client_index);
Darkvater@4945: 			} break;
Darkvater@4946: 
Darkvater@4946: 			default: NOT_REACHED(); break;
truelight@722: 		}
truelight@543: 	} else {
truelight@722: 		/* Display message from somebody else */
truelight@602: 		snprintf(name, sizeof(name), "%s", ci_to->client_name);
truelight@543: 		ci = ci_to;
truelight@543: 	}
truelight@543: 
truelight@543: 	if (ci != NULL)
rubidium@10207: 		NetworkTextMessage(action, (ConsoleColour)GetDrawStringCompanyColor(ci->client_playas), self_send, name, "%s", msg);
truelight@543: 	return NETWORK_RECV_STATUS_OKAY;
truelight@543: }
truelight@543: 
truelight@543: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_ERROR_QUIT)
truelight@543: {
truelight@722: 	char str[100];
truelight@543: 	uint16 index;
truelight@543: 	NetworkClientInfo *ci;
truelight@543: 
rubidium@5900: 	index = p->Recv_uint16();
rubidium@5900: 	GetNetworkErrorMsg(str, (NetworkErrorCode)p->Recv_uint8(), lastof(str));
truelight@543: 
truelight@543: 	ci = NetworkFindClientInfoFromIndex(index);
truelight@543: 	if (ci != NULL) {
rubidium@9337: 		NetworkTextMessage(NETWORK_ACTION_LEAVE, CC_DEFAULT, false, ci->client_name, "%s", str);
truelight@543: 
truelight@543: 		// The client is gone, give the NetworkClientInfo free
truelight@543: 		ci->client_index = NETWORK_EMPTY_INDEX;
truelight@543: 	}
truelight@543: 
truelight@543: 	InvalidateWindow(WC_CLIENT_LIST, 0);
truelight@543: 
truelight@543: 	return NETWORK_RECV_STATUS_OKAY;
truelight@543: }
truelight@543: 
truelight@543: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_QUIT)
truelight@543: {
truelight@722: 	char str[100];
truelight@543: 	uint16 index;
truelight@543: 	NetworkClientInfo *ci;
truelight@543: 
rubidium@5900: 	index = p->Recv_uint16();
rubidium@5900: 	p->Recv_string(str, lengthof(str));
truelight@543: 
truelight@543: 	ci = NetworkFindClientInfoFromIndex(index);
truelight@543: 	if (ci != NULL) {
rubidium@9337: 		NetworkTextMessage(NETWORK_ACTION_LEAVE, CC_DEFAULT, false, ci->client_name, "%s", str);
truelight@543: 
truelight@543: 		// The client is gone, give the NetworkClientInfo free
truelight@543: 		ci->client_index = NETWORK_EMPTY_INDEX;
truelight@543: 	} else {
Darkvater@5380: 		DEBUG(net, 0, "Unknown client (%d) is leaving the game", index);
truelight@543: 	}
truelight@543: 
truelight@543: 	InvalidateWindow(WC_CLIENT_LIST, 0);
truelight@543: 
truelight@543: 	// If we come here it means we could not locate the client.. strange :s
truelight@543: 	return NETWORK_RECV_STATUS_OKAY;
truelight@543: }
truelight@543: 
truelight@543: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_JOIN)
truelight@543: {
truelight@543: 	uint16 index;
truelight@543: 	NetworkClientInfo *ci;
truelight@543: 
rubidium@5900: 	index = p->Recv_uint16();
truelight@543: 
truelight@543: 	ci = NetworkFindClientInfoFromIndex(index);
truelight@722: 	if (ci != NULL)
rubidium@9337: 		NetworkTextMessage(NETWORK_ACTION_JOIN, CC_DEFAULT, false, ci->client_name, "");
truelight@543: 
truelight@543: 	InvalidateWindow(WC_CLIENT_LIST, 0);
truelight@543: 
truelight@543: 	return NETWORK_RECV_STATUS_OKAY;
truelight@543: }
truelight@543: 
truelight@543: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_SHUTDOWN)
truelight@543: {
truelight@543: 	_switch_mode_errorstr = STR_NETWORK_SERVER_SHUTDOWN;
truelight@543: 
truelight@543: 	return NETWORK_RECV_STATUS_SERVER_ERROR;
truelight@543: }
truelight@543: 
truelight@543: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_NEWGAME)
truelight@543: {
truelight@543: 	// To trottle the reconnects a bit, every clients waits
rubidium@10207: 	//  his _local_company value before reconnecting
rubidium@10207: 	// COMPANY_SPECTATOR is currently 255, so to avoid long wait periods
truelight@543: 	//  set the max to 10.
rubidium@10207: 	_network_reconnect = min(_local_company + 1, 10);
truelight@543: 	_switch_mode_errorstr = STR_NETWORK_SERVER_REBOOT;
truelight@543: 
truelight@543: 	return NETWORK_RECV_STATUS_SERVER_ERROR;
truelight@543: }
truelight@543: 
truelight@1026: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_RCON)
truelight@1026: {
truelight@1026: 	char rcon_out[NETWORK_RCONCOMMAND_LENGTH];
truelight@1026: 
rubidium@9337: 	ConsoleColour color_code = (ConsoleColour)p->Recv_uint16();
rubidium@5900: 	p->Recv_string(rcon_out, sizeof(rcon_out));
truelight@1026: 
truelight@1026: 	IConsolePrint(color_code, rcon_out);
truelight@1026: 
truelight@1026: 	return NETWORK_RECV_STATUS_OKAY;
truelight@1026: }
truelight@543: 
truelight@543: 
truelight@543: 
truelight@543: // The layout for the receive-functions by the client
truelight@543: typedef NetworkRecvStatus NetworkClientPacket(Packet *p);
truelight@543: 
truelight@543: // This array matches PacketType. At an incoming
truelight@543: //  packet it is matches against this array
truelight@543: //  and that way the right function to handle that
truelight@543: //  packet is found.
truelight@543: static NetworkClientPacket* const _network_client_packet[] = {
truelight@543: 	RECEIVE_COMMAND(PACKET_SERVER_FULL),
truelight@841: 	RECEIVE_COMMAND(PACKET_SERVER_BANNED),
truelight@543: 	NULL, /*PACKET_CLIENT_JOIN,*/
truelight@543: 	RECEIVE_COMMAND(PACKET_SERVER_ERROR),
truelight@543: 	NULL, /*PACKET_CLIENT_COMPANY_INFO,*/
truelight@543: 	RECEIVE_COMMAND(PACKET_SERVER_COMPANY_INFO),
truelight@543: 	RECEIVE_COMMAND(PACKET_SERVER_CLIENT_INFO),
truelight@543: 	RECEIVE_COMMAND(PACKET_SERVER_NEED_PASSWORD),
truelight@543: 	NULL, /*PACKET_CLIENT_PASSWORD,*/
truelight@543: 	RECEIVE_COMMAND(PACKET_SERVER_WELCOME),
truelight@543: 	NULL, /*PACKET_CLIENT_GETMAP,*/
truelight@543: 	RECEIVE_COMMAND(PACKET_SERVER_WAIT),
truelight@543: 	RECEIVE_COMMAND(PACKET_SERVER_MAP),
truelight@543: 	NULL, /*PACKET_CLIENT_MAP_OK,*/
truelight@543: 	RECEIVE_COMMAND(PACKET_SERVER_JOIN),
truelight@543: 	RECEIVE_COMMAND(PACKET_SERVER_FRAME),
truelight@543: 	RECEIVE_COMMAND(PACKET_SERVER_SYNC),
truelight@543: 	NULL, /*PACKET_CLIENT_ACK,*/
truelight@543: 	NULL, /*PACKET_CLIENT_COMMAND,*/
truelight@543: 	RECEIVE_COMMAND(PACKET_SERVER_COMMAND),
truelight@543: 	NULL, /*PACKET_CLIENT_CHAT,*/
truelight@543: 	RECEIVE_COMMAND(PACKET_SERVER_CHAT),
truelight@543: 	NULL, /*PACKET_CLIENT_SET_PASSWORD,*/
truelight@543: 	NULL, /*PACKET_CLIENT_SET_NAME,*/
truelight@543: 	NULL, /*PACKET_CLIENT_QUIT,*/
truelight@543: 	NULL, /*PACKET_CLIENT_ERROR,*/
truelight@543: 	RECEIVE_COMMAND(PACKET_SERVER_QUIT),
truelight@543: 	RECEIVE_COMMAND(PACKET_SERVER_ERROR_QUIT),
truelight@543: 	RECEIVE_COMMAND(PACKET_SERVER_SHUTDOWN),
truelight@543: 	RECEIVE_COMMAND(PACKET_SERVER_NEWGAME),
truelight@1026: 	RECEIVE_COMMAND(PACKET_SERVER_RCON),
truelight@1026: 	NULL, /*PACKET_CLIENT_RCON,*/
rubidium@5872: 	RECEIVE_COMMAND(PACKET_SERVER_CHECK_NEWGRFS),
rubidium@5872: 	NULL, /*PACKET_CLIENT_NEWGRFS_CHECKED,*/
truelight@543: };
truelight@543: 
truelight@543: // If this fails, check the array above with network_data.h
truelight@543: assert_compile(lengthof(_network_client_packet) == PACKET_END);
truelight@543: 
truelight@543: // Is called after a client is connected to the server
rubidium@6247: void NetworkClient_Connected()
truelight@543: {
truelight@543: 	// Set the frame-counter to 0 so nothing happens till we are ready
truelight@543: 	_frame_counter = 0;
truelight@543: 	_frame_counter_server = 0;
truelight@543: 	last_ack_frame = 0;
truelight@543: 	// Request the game-info
truelight@543: 	SEND_COMMAND(PACKET_CLIENT_JOIN)();
truelight@543: }
truelight@543: 
truelight@543: // Reads the packets from the socket-stream, if available
rubidium@5624: NetworkRecvStatus NetworkClient_ReadPackets(NetworkTCPSocketHandler *cs)
truelight@543: {
truelight@543: 	Packet *p;
truelight@543: 	NetworkRecvStatus res = NETWORK_RECV_STATUS_OKAY;
truelight@543: 
rubidium@5902: 	while (res == NETWORK_RECV_STATUS_OKAY && (p = cs->Recv_Packet(&res)) != NULL) {
rubidium@5900: 		byte type = p->Recv_uint8();
Darkvater@4880: 		if (type < PACKET_END && _network_client_packet[type] != NULL && !MY_CLIENT->has_quit) {
truelight@543: 			res = _network_client_packet[type](p);
tron@2026: 		} else {
truelight@543: 			res = NETWORK_RECV_STATUS_MALFORMED_PACKET;
Darkvater@5380: 			DEBUG(net, 0, "[client] received invalid packet type %d", type);
truelight@543: 		}
truelight@543: 
rubidium@5898: 		delete p;
truelight@543: 	}
truelight@543: 
truelight@543: 	return res;
truelight@543: }
truelight@543: 
rubidium@9428: void NetworkClientSendRcon(const char *password, const char *command)
rubidium@9428: {
rubidium@9428: 	SEND_COMMAND(PACKET_CLIENT_RCON)(password, command);
rubidium@9428: }
rubidium@9428: 
rubidium@10207: void NetworkUpdateClientName()
rubidium@9428: {
rubidium@9428: 	NetworkClientInfo *ci = NetworkFindClientInfoFromIndex(_network_own_client_index);
rubidium@9428: 
rubidium@9428: 	if (ci == NULL) return;
rubidium@9428: 
rubidium@9428: 	/* Don't change the name if it is the same as the old name */
rubidium@10207: 	if (strcmp(ci->client_name, _settings_client.network.client_name) != 0) {
rubidium@9428: 		if (!_network_server) {
rubidium@10207: 			SEND_COMMAND(PACKET_CLIENT_SET_NAME)(_settings_client.network.client_name);
rubidium@9428: 		} else {
rubidium@10207: 			if (NetworkFindName(_settings_client.network.client_name)) {
rubidium@10207: 				NetworkTextMessage(NETWORK_ACTION_NAME_CHANGE, CC_DEFAULT, false, ci->client_name, "%s", _settings_client.network.client_name);
rubidium@10207: 				ttd_strlcpy(ci->client_name, _settings_client.network.client_name, sizeof(ci->client_name));
rubidium@9428: 				NetworkUpdateClientInfo(NETWORK_SERVER_INDEX);
rubidium@9428: 			}
rubidium@9428: 		}
rubidium@9428: 	}
rubidium@9428: }
rubidium@9428: 
rubidium@9428: void NetworkClientSendChat(NetworkAction action, DestType type, int dest, const char *msg)
rubidium@9428: {
rubidium@9428: 	SEND_COMMAND(PACKET_CLIENT_CHAT)(action, type, dest, msg);
rubidium@9428: }
rubidium@9428: 
rubidium@9428: void NetworkClientSetPassword()
rubidium@9428: {
rubidium@10207: 	SEND_COMMAND(PACKET_CLIENT_SET_PASSWORD)(_network_company_info[_local_company].password);
rubidium@9428: }
rubidium@9428: 
truelight@543: #endif /* ENABLE_NETWORK */