tron@2186: /* $Id$ */ tron@2186: truelight@543: #include "stdafx.h" tron@1299: #include "debug.h" tron@1317: #include "string.h" tron@1309: #include "strings.h" truelight@543: #include "network_data.h" truelight@543: truelight@543: #ifdef ENABLE_NETWORK truelight@543: truelight@543: #include "table/strings.h" tron@2163: #include "functions.h" truelight@543: #include "network_client.h" truelight@543: #include "network_gamelist.h" tron@2162: #include "saveload.h" truelight@543: #include "command.h" truelight@543: #include "gfx.h" truelight@543: #include "window.h" truelight@543: #include "settings.h" truelight@1026: #include "console.h" tron@2159: #include "variables.h" truelight@2684: #include "ai/ai.h" truelight@543: truelight@543: truelight@543: // This file handles all the client-commands truelight@543: truelight@543: truelight@716: extern const char _openttd_revision[]; truelight@716: 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: tron@2817: static void NetworkRecvPatchSettings(NetworkClientState* cs, Packet* p); truelight@543: 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: // 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); truelight@543: NetworkSend_Packet(p, MY_CLIENT); 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) truelight@543: // String: Player Name (max NETWORK_NAME_LENGTH) truelight@543: // uint8: Play as Player id (1..MAX_PLAYERS) truelight@543: // uint8: Language ID truelight@602: // String: Unique id to find the player 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); truelight@543: NetworkSend_string(p, _openttd_revision); truelight@543: NetworkSend_string(p, _network_player_name); // Player name truelight@662: NetworkSend_uint8(p, _network_playas); // PlayAs truelight@543: NetworkSend_uint8(p, NETLANG_ANY); // Language truelight@602: NetworkSend_string(p, _network_unique_id); truelight@543: NetworkSend_Packet(p, MY_CLIENT); truelight@543: } truelight@543: 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); truelight@543: NetworkSend_uint8(p, type); truelight@543: NetworkSend_string(p, password); truelight@543: NetworkSend_Packet(p, MY_CLIENT); 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: // truelight@543: // truelight@543: truelight@543: Packet *p = NetworkSend_Init(PACKET_CLIENT_GETMAP); truelight@543: NetworkSend_Packet(p, MY_CLIENT); 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: // truelight@543: // truelight@543: truelight@543: Packet *p = NetworkSend_Init(PACKET_CLIENT_MAP_OK); truelight@543: NetworkSend_Packet(p, MY_CLIENT); 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: truelight@543: NetworkSend_uint32(p, _frame_counter); truelight@543: NetworkSend_Packet(p, MY_CLIENT); 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: truelight@543: // uint8: PlayerID (0..MAX_PLAYERS-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: truelight@543: NetworkSend_uint8(p, cp->player); truelight@543: NetworkSend_uint32(p, cp->cmd); truelight@543: NetworkSend_uint32(p, cp->p1); truelight@543: NetworkSend_uint32(p, cp->p2); truelight@543: NetworkSend_uint32(p, (uint32)cp->tile); tron@1820: NetworkSend_string(p, cp->text); truelight@543: NetworkSend_uint8(p, cp->callback); truelight@543: truelight@543: NetworkSend_Packet(p, MY_CLIENT); truelight@543: } truelight@543: truelight@543: // Send a chat-packet over the network truelight@543: DEF_CLIENT_SEND_COMMAND_PARAM(PACKET_CLIENT_CHAT)(NetworkAction action, DestType desttype, 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); truelight@543: // uint8: Destination Player (1..MAX_PLAYERS) truelight@543: // String: Message (max MAX_TEXT_MSG_LEN) truelight@543: // truelight@543: truelight@543: Packet *p = NetworkSend_Init(PACKET_CLIENT_CHAT); truelight@543: truelight@543: NetworkSend_uint8(p, action); truelight@543: NetworkSend_uint8(p, desttype); truelight@543: NetworkSend_uint8(p, dest); truelight@543: NetworkSend_string(p, msg); truelight@543: NetworkSend_Packet(p, MY_CLIENT); 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: truelight@543: NetworkSend_uint8(p, errorno); truelight@543: NetworkSend_Packet(p, MY_CLIENT); 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: truelight@543: NetworkSend_string(p, password); truelight@543: NetworkSend_Packet(p, MY_CLIENT); 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 truelight@543: // Function: Gives the player a new name truelight@543: // Data: truelight@543: // String: Name truelight@543: // truelight@543: Packet *p = NetworkSend_Init(PACKET_CLIENT_SET_NAME); truelight@543: truelight@543: NetworkSend_string(p, name); truelight@543: NetworkSend_Packet(p, MY_CLIENT); 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: truelight@543: NetworkSend_string(p, leavemsg); truelight@543: NetworkSend_Packet(p, MY_CLIENT); 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); truelight@1026: NetworkSend_string(p, pass); truelight@1026: NetworkSend_string(p, command); truelight@1026: NetworkSend_Packet(p, MY_CLIENT); 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: truelight@543: extern bool SafeSaveOrLoad(const char *filename, int mode, int newgm); 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: truelight@903: company_info_version = NetworkRecv_uint8(MY_CLIENT, p); truelight@543: truelight@1013: if (!MY_CLIENT->quited && company_info_version == NETWORK_COMPANY_INFO_VERSION) { truelight@543: byte total; truelight@543: byte current; truelight@543: truelight@903: total = NetworkRecv_uint8(MY_CLIENT, p); truelight@543: truelight@543: // There is no data at all.. truelight@543: if (total == 0) truelight@543: return NETWORK_RECV_STATUS_CLOSE_QUERY; truelight@543: truelight@903: current = NetworkRecv_uint8(MY_CLIENT, p); truelight@543: if (current >= MAX_PLAYERS) truelight@543: return NETWORK_RECV_STATUS_CLOSE_QUERY; truelight@543: truelight@903: NetworkRecv_string(MY_CLIENT, p, _network_player_info[current].company_name, sizeof(_network_player_info[current].company_name)); truelight@903: _network_player_info[current].inaugurated_year = NetworkRecv_uint8(MY_CLIENT, p); truelight@903: _network_player_info[current].company_value = NetworkRecv_uint64(MY_CLIENT, p); truelight@903: _network_player_info[current].money = NetworkRecv_uint64(MY_CLIENT, p); truelight@903: _network_player_info[current].income = NetworkRecv_uint64(MY_CLIENT, p); truelight@903: _network_player_info[current].performance = NetworkRecv_uint16(MY_CLIENT, p); truelight@1011: _network_player_info[current].use_password = NetworkRecv_uint8(MY_CLIENT, p); truelight@543: for (i = 0; i < NETWORK_VEHICLE_TYPES; i++) truelight@903: _network_player_info[current].num_vehicle[i] = NetworkRecv_uint16(MY_CLIENT, p); truelight@543: for (i = 0; i < NETWORK_STATION_TYPES; i++) truelight@903: _network_player_info[current].num_station[i] = NetworkRecv_uint16(MY_CLIENT, p); truelight@543: truelight@903: NetworkRecv_string(MY_CLIENT, p, _network_player_info[current].players, sizeof(_network_player_info[current].players)); 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; truelight@903: uint16 index = NetworkRecv_uint16(MY_CLIENT, p); truelight@903: byte playas = NetworkRecv_uint8(MY_CLIENT, p); truelight@662: char name[NETWORK_NAME_LENGTH]; truelight@662: char unique_id[NETWORK_NAME_LENGTH]; truelight@662: truelight@903: NetworkRecv_string(MY_CLIENT, p, name, sizeof(name)); truelight@903: NetworkRecv_string(MY_CLIENT, p, unique_id, sizeof(unique_id)); truelight@903: truelight@903: if (MY_CLIENT->quited) truelight@903: return NETWORK_RECV_STATUS_CONN_LOST; truelight@662: truelight@662: /* Do we receive a change of data? Most likely we changed playas */ truelight@2684: if (index == _network_own_client_index) { truelight@662: _network_playas = playas; truelight@543: truelight@2702: /* Are we a ai-network-client? Are we not joining as a SPECTATOR (playas == 0, means SPECTATOR) */ truelight@2702: if (_ai.network_client && playas != 0) { truelight@2684: if (_ai.network_playas == OWNER_SPECTATOR) truelight@2684: AI_StartNewAI(playas - 1); truelight@2684: truelight@2684: _ai.network_playas = playas - 1; truelight@2684: } truelight@2684: } 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 tron@2373: NetworkTextMessage(NETWORK_ACTION_NAME_CHANGE, 1, false, ci->client_name, "%s", name); truelight@543: } else if (playas != ci->client_playas) { truelight@543: // The player 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: ttd_strlcpy(ci->unique_id, unique_id, sizeof(ci->unique_id)); 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: { truelight@903: NetworkErrorCode error = NetworkRecv_uint8(MY_CLIENT, p); 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: Darkvater@2879: case NETWORK_ERROR_PLAYER_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: truelight@543: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_NEED_PASSWORD) truelight@543: { truelight@543: NetworkPasswordType type; truelight@903: type = NetworkRecv_uint8(MY_CLIENT, p); truelight@543: truelight@543: if (type == NETWORK_GAME_PASSWORD) { truelight@543: ShowNetworkNeedGamePassword(); truelight@543: return NETWORK_RECV_STATUS_OKAY; truelight@543: } else if (type == NETWORK_COMPANY_PASSWORD) { truelight@543: ShowNetworkNeedCompanyPassword(); truelight@543: return NETWORK_RECV_STATUS_OKAY; truelight@543: } truelight@543: truelight@543: return NETWORK_RECV_STATUS_MALFORMED_PACKET; truelight@543: } truelight@543: truelight@543: DEF_CLIENT_RECEIVE_COMMAND(PACKET_SERVER_WELCOME) truelight@543: { truelight@903: _network_own_client_index = NetworkRecv_uint16(MY_CLIENT, p); truelight@543: 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; truelight@903: _network_join_waiting = NetworkRecv_uint8(MY_CLIENT, p); 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 ;) truelight@543: DEBUG(net, 1)("[NET] The server is currently busy sending the map to someone else.. please hold..." ); truelight@543: DEBUG(net, 1)("[NET] 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 char filename[256]; truelight@543: static FILE *file_pointer; truelight@543: truelight@543: byte maptype; truelight@543: truelight@903: maptype = NetworkRecv_uint8(MY_CLIENT, p); truelight@903: truelight@903: if (MY_CLIENT->quited) truelight@903: return NETWORK_RECV_STATUS_CONN_LOST; truelight@543: truelight@543: // First packet, init some stuff truelight@543: if (maptype == MAP_PACKET_START) { truelight@543: // The name for the temp-map truelight@543: sprintf(filename, "%s%snetwork_client.tmp", _path.autosave_dir, PATHSEP); truelight@543: truelight@543: file_pointer = fopen(filename, "wb"); 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: truelight@903: _frame_counter = _frame_counter_server = _frame_counter_max = NetworkRecv_uint32(MY_CLIENT, p); truelight@543: truelight@543: _network_join_status = NETWORK_JOIN_STATUS_DOWNLOADING; truelight@543: _network_join_kbytes = 0; truelight@903: _network_join_kbytes_total = NetworkRecv_uint32(MY_CLIENT, p) / 1024; truelight@543: 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 truelight@543: fwrite(p->buffer + p->pos, 1, p->size - p->pos, file_pointer); 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: if (maptype == MAP_PACKET_PATCH) { truelight@903: NetworkRecvPatchSettings(MY_CLIENT, p); 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: truelight@543: // The map is done downloading, load it truelight@543: // Load the map truelight@543: if (!SafeSaveOrLoad(filename, SL_LOAD, GM_NORMAL)) { 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@1500: Darkvater@1500: _opt_ptr = &_opt; // during a network game you are always in-game truelight@543: truelight@543: // Say we received the map and loaded it correctly! truelight@543: SEND_COMMAND(PACKET_CLIENT_MAP_OK)(); truelight@543: truelight@543: if (_network_playas == 0 || _network_playas > MAX_PLAYERS || celestar@1962: !GetPlayer(_network_playas - 1)->is_active) { truelight@543: truelight@543: if (_network_playas == OWNER_SPECTATOR) { truelight@543: // The client wants to be a spectator.. truelight@543: _local_player = OWNER_SPECTATOR; truelight@670: DeleteWindowById(WC_NETWORK_STATUS_WINDOW, 0); truelight@543: } else { Darkvater@1797: /* We have arrived and ready to start playing; send a command to make a new player; Darkvater@1797: * the server will give us a client-id and let us in */ truelight@543: _local_player = 0; truelight@543: NetworkSend_Command(0, 0, 0, CMD_PLAYER_CTRL, NULL); truelight@543: _local_player = OWNER_SPECTATOR; truelight@543: } truelight@543: } else { truelight@543: // take control over an existing company truelight@543: _local_player = _network_playas - 1; bjarni@2293: _patches.autorenew = GetPlayer(_local_player)->engine_renew; bjarni@2293: _patches.autorenew_months = GetPlayer(_local_player)->engine_renew_months; bjarni@2293: _patches.autorenew_money = GetPlayer(_local_player)->engine_renew_money; truelight@684: DeleteWindowById(WC_NETWORK_STATUS_WINDOW, 0); truelight@543: } truelight@2684: truelight@2684: /* Check if we are an ai-network-client, and if so, disable GUI */ truelight@2684: if (_ai.network_client) { truelight@2684: _ai.network_playas = _local_player; truelight@2684: _local_player = OWNER_SPECTATOR; truelight@2684: truelight@2684: if (_ai.network_playas != OWNER_SPECTATOR) { truelight@2684: /* If we didn't join the game as a spectator, activate the AI */ truelight@2684: AI_StartNewAI(_ai.network_playas); truelight@2684: } truelight@2684: } 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: { truelight@903: _frame_counter_server = NetworkRecv_uint32(MY_CLIENT, p); truelight@903: _frame_counter_max = NetworkRecv_uint32(MY_CLIENT, p); 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; truelight@903: _sync_seed_1 = NetworkRecv_uint32(MY_CLIENT, p); truelight@543: #ifdef NETWORK_SEND_DOUBLE_SEED truelight@903: _sync_seed_2 = NetworkRecv_uint32(MY_CLIENT, p); truelight@543: #endif truelight@543: } truelight@543: #endif truelight@543: DEBUG(net, 7)("[NET] 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; truelight@543: DEBUG(net,6)("[NET] 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: { truelight@903: _sync_frame = NetworkRecv_uint32(MY_CLIENT, p); truelight@903: _sync_seed_1 = NetworkRecv_uint32(MY_CLIENT, p); truelight@543: #ifdef NETWORK_SEND_DOUBLE_SEED truelight@903: _sync_seed_2 = NetworkRecv_uint32(MY_CLIENT, p); 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: { truelight@543: CommandPacket *cp = malloc(sizeof(CommandPacket)); truelight@903: cp->player = NetworkRecv_uint8(MY_CLIENT, p); truelight@903: cp->cmd = NetworkRecv_uint32(MY_CLIENT, p); truelight@903: cp->p1 = NetworkRecv_uint32(MY_CLIENT, p); truelight@903: cp->p2 = NetworkRecv_uint32(MY_CLIENT, p); truelight@903: cp->tile = NetworkRecv_uint32(MY_CLIENT, p); tron@1820: NetworkRecv_string(MY_CLIENT, p, cp->text, sizeof(cp->text)); truelight@903: cp->callback = NetworkRecv_uint8(MY_CLIENT, p); truelight@903: cp->frame = NetworkRecv_uint32(MY_CLIENT, p); truelight@543: 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: { truelight@903: NetworkAction action = NetworkRecv_uint8(MY_CLIENT, p); truelight@543: char msg[MAX_TEXT_MSG_LEN]; darkvater@774: NetworkClientInfo *ci = NULL, *ci_to; truelight@543: uint16 index; truelight@543: char name[NETWORK_NAME_LENGTH]; truelight@722: bool self_send; truelight@543: truelight@903: index = NetworkRecv_uint16(MY_CLIENT, p); truelight@903: self_send = NetworkRecv_uint8(MY_CLIENT, p); truelight@903: NetworkRecv_string(MY_CLIENT, p, msg, MAX_TEXT_MSG_LEN); truelight@543: truelight@543: ci_to = NetworkFindClientInfoFromIndex(index); truelight@543: if (ci_to == NULL) return NETWORK_RECV_STATUS_OKAY; truelight@543: truelight@722: /* Do we display the action locally? */ truelight@722: if (self_send) { truelight@722: switch (action) { truelight@722: case NETWORK_ACTION_CHAT_CLIENT: truelight@722: /* For speak 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; truelight@722: case NETWORK_ACTION_CHAT_PLAYER: truelight@722: case NETWORK_ACTION_GIVE_MONEY: truelight@722: /* For speak to player or give money, we need the player-name */ truelight@779: if (ci_to->client_playas > MAX_PLAYERS) truelight@779: return NETWORK_RECV_STATUS_OKAY; // This should never happen celestar@1962: GetString(name, GetPlayer(ci_to->client_playas-1)->name_1); truelight@722: ci = NetworkFindClientInfoFromIndex(_network_own_client_index); truelight@722: break; truelight@722: default: truelight@722: /* This should never happen */ truelight@722: NOT_REACHED(); truelight@722: 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) truelight@722: NetworkTextMessage(action, GetDrawStringPlayerColor(ci->client_playas-1), 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@543: int errorno; truelight@722: char str[100]; truelight@543: uint16 index; truelight@543: NetworkClientInfo *ci; truelight@543: truelight@903: index = NetworkRecv_uint16(MY_CLIENT, p); truelight@903: errorno = NetworkRecv_uint8(MY_CLIENT, p); truelight@543: truelight@722: GetString(str, STR_NETWORK_ERR_CLIENT_GENERAL + errorno); truelight@543: truelight@543: ci = NetworkFindClientInfoFromIndex(index); truelight@543: if (ci != NULL) { tron@2373: NetworkTextMessage(NETWORK_ACTION_LEAVE, 1, 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: truelight@903: index = NetworkRecv_uint16(MY_CLIENT, p); tron@2373: NetworkRecv_string(MY_CLIENT, p, str, lengthof(str)); truelight@543: truelight@543: ci = NetworkFindClientInfoFromIndex(index); truelight@543: if (ci != NULL) { tron@2373: NetworkTextMessage(NETWORK_ACTION_LEAVE, 1, 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 { truelight@543: DEBUG(net, 0)("[NET] Error - 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: truelight@903: index = NetworkRecv_uint16(MY_CLIENT, p); truelight@543: truelight@543: ci = NetworkFindClientInfoFromIndex(index); truelight@722: if (ci != NULL) truelight@722: NetworkTextMessage(NETWORK_ACTION_JOIN, 1, 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 truelight@543: // his _local_player value before reconnecting truelight@543: // OWNER_SPECTATOR is currently 255, so to avoid long wait periods truelight@543: // set the max to 10. truelight@543: _network_reconnect = min(_local_player + 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: uint16 color_code; truelight@1026: truelight@1026: color_code = NetworkRecv_uint16(MY_CLIENT, p); truelight@1026: NetworkRecv_string(MY_CLIENT, p, 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,*/ 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: extern const SettingDesc patch_settings[]; truelight@543: truelight@543: // This is a TEMPORARY solution to get the patch-settings truelight@543: // to the client. When the patch-settings are saved in the savegame truelight@543: // this should be removed!! tron@2817: static void NetworkRecvPatchSettings(NetworkClientState* cs, Packet* p) truelight@543: { truelight@543: const SettingDesc *item; truelight@543: truelight@543: item = patch_settings; truelight@543: truelight@543: while (item->name != NULL) { truelight@543: switch (item->flags) { truelight@543: case SDT_BOOL: truelight@543: case SDT_INT8: truelight@543: case SDT_UINT8: truelight@903: *(uint8 *)(item->ptr) = NetworkRecv_uint8(cs, p); truelight@543: break; truelight@543: case SDT_INT16: truelight@543: case SDT_UINT16: truelight@903: *(uint16 *)(item->ptr) = NetworkRecv_uint16(cs, p); truelight@543: break; truelight@543: case SDT_INT32: truelight@543: case SDT_UINT32: truelight@903: *(uint32 *)(item->ptr) = NetworkRecv_uint32(cs, p); truelight@543: break; truelight@543: } truelight@543: item++; truelight@543: } truelight@543: } truelight@543: truelight@543: // Is called after a client is connected to the server truelight@543: void NetworkClient_Connected(void) 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 truelight@716: NetworkRecvStatus NetworkClient_ReadPackets(NetworkClientState *cs) truelight@543: { truelight@543: Packet *p; truelight@543: NetworkRecvStatus res = NETWORK_RECV_STATUS_OKAY; truelight@543: truelight@543: while (res == NETWORK_RECV_STATUS_OKAY && (p = NetworkRecv_Packet(cs, &res)) != NULL) { truelight@903: byte type = NetworkRecv_uint8(MY_CLIENT, p); truelight@903: if (type < PACKET_END && _network_client_packet[type] != NULL && !MY_CLIENT->quited) { truelight@543: res = _network_client_packet[type](p); tron@2026: } else { truelight@543: res = NETWORK_RECV_STATUS_MALFORMED_PACKET; truelight@543: DEBUG(net, 0)("[NET][client] Received invalid packet type %d", type); truelight@543: } truelight@543: truelight@543: free(p); truelight@543: } truelight@543: truelight@543: return res; truelight@543: } truelight@543: truelight@543: #endif /* ENABLE_NETWORK */