minetest
/
minetest
mirror of https://github.com/minetest/minetest.git
1
0
Fork 0
Code Issues Releases Wiki Activity

Finalize init packets and enable protocol v25 

This enables srp.
This commit is contained in:
est31 2015-05-16 01:19:43 +02:00
parent 19cbb6b37b
commit 8dbf683313
6 changed files with 38 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/client.cpp
View File

@ -1000,8 +1000,9 @@ void Client::sendInit(const std::string &playerName)
{ {
NetworkPacket pkt(TOSERVER_INIT, 1 + 2 + 2 + (1 + playerName.size())); NetworkPacket pkt(TOSERVER_INIT, 1 + 2 + 2 + (1 + playerName.size()));
// TODO (later) actually send supported compression modes // we don't support network compression yet
pkt << (u8) SER_FMT_VER_HIGHEST_READ << (u8) 42; u16 supp_comp_modes = NETPROTO_COMPRESSION_NONE;
pkt << (u8) SER_FMT_VER_HIGHEST_READ << (u16) supp_comp_modes;
pkt << (u16) CLIENT_PROTOCOL_VERSION_MIN << (u16) CLIENT_PROTOCOL_VERSION_MAX; pkt << (u16) CLIENT_PROTOCOL_VERSION_MIN << (u16) CLIENT_PROTOCOL_VERSION_MAX;
pkt << playerName; pkt << playerName;

4
src/clientiface.h
View File

@ -337,7 +337,7 @@ public:
void setPendingSerializationVersion(u8 version) void setPendingSerializationVersion(u8 version)
{ m_pending_serialization_version = version; } { m_pending_serialization_version = version; }
void setSupportedCompressionModes(u8 byteFlag) void setSupportedCompressionModes(u16 byteFlag)
{ m_supported_compressions = byteFlag; } { m_supported_compressions = byteFlag; }
void confirmSerializationVersion() void confirmSerializationVersion()
@ -416,7 +416,7 @@ private:
std::string m_full_version; std::string m_full_version;
u8 m_supported_compressions; u16 m_supported_compressions;
/* /*
time this client was created time this client was created

19
src/network/clientpackethandler.cpp
View File

@ -44,26 +44,31 @@ void Client::handleCommand_Hello(NetworkPacket* pkt)
if (pkt->getSize() < 1) if (pkt->getSize() < 1)
return; return;
u8 deployed; u8 serialization_ver;
u16 proto_ver;
u16 compression_mode;
u32 auth_mechs; u32 auth_mechs;
std::string username_legacy; // for case insensitivity std::string username_legacy; // for case insensitivity
*pkt >> deployed >> auth_mechs >> username_legacy; *pkt >> serialization_ver >> compression_mode >> proto_ver
>> auth_mechs >> username_legacy;
// Chose an auth method we support // Chose an auth method we support
AuthMechanism chosen_auth_mechanism = choseAuthMech(auth_mechs); AuthMechanism chosen_auth_mechanism = choseAuthMech(auth_mechs);
infostream << "Client: TOCLIENT_HELLO received with " infostream << "Client: TOCLIENT_HELLO received with "
"deployed=" << ((int)deployed & 0xff) << ", auth_mechs=" << "serialization_ver=" << serialization_ver
<< auth_mechs << ", chosen=" << chosen_auth_mechanism << std::endl; << ", auth_mechs=" << auth_mechs
<< ", compression_mode=" << compression_mode
<< ". Doing auth with mech " << chosen_auth_mechanism << std::endl;
if (!ser_ver_supported(deployed)) { if (!ser_ver_supported(serialization_ver)) {
infostream << "Client: TOCLIENT_HELLO: Server sent " infostream << "Client: TOCLIENT_HELLO: Server sent "
<< "unsupported ser_fmt_ver"<< std::endl; << "unsupported ser_fmt_ver"<< std::endl;
return; return;
} }
m_server_ser_ver = deployed; m_server_ser_ver = serialization_ver;
m_proto_ver = deployed; m_proto_ver = proto_ver;
//TODO verify that username_legacy matches sent username, only //TODO verify that username_legacy matches sent username, only
// differs in casing (make both uppercase and compare) // differs in casing (make both uppercase and compare)

18
src/network/networkprotocol.h
View File

@ -131,7 +131,7 @@ with this program; if not, write to the Free Software Foundation, Inc.,
Add TOCLIENT_AUTH_ACCEPT to accept connection from client Add TOCLIENT_AUTH_ACCEPT to accept connection from client
*/ */
#define LATEST_PROTOCOL_VERSION 24 #define LATEST_PROTOCOL_VERSION 25
// Server's supported network protocol range // Server's supported network protocol range
#define SERVER_PROTOCOL_VERSION_MIN 13 #define SERVER_PROTOCOL_VERSION_MIN 13
@ -158,7 +158,9 @@ enum ToClientCommand
/* /*
Sent after TOSERVER_INIT. Sent after TOSERVER_INIT.
u8 deployed version u8 deployed serialisation version
u16 deployed network compression mode
u16 deployed protocol version
u32 supported auth methods u32 supported auth methods
std::string username that should be used for legacy hash (for proper casing) std::string username that should be used for legacy hash (for proper casing)
*/ */
@ -632,11 +634,11 @@ enum ToServerCommand
/* /*
Sent first after connected. Sent first after connected.
[2] u8 SER_FMT_VER_HIGHEST_READ u8 serialisation version (=SER_FMT_VER_HIGHEST_READ)
[3] u8 compression_modes u16 supported network compression modes
[4] u16 minimum supported network protocol version u16 minimum supported network protocol version
[6] u16 maximum supported network protocol version u16 maximum supported network protocol version
[8] std::string player name std::string player name
*/ */
TOSERVER_INIT_LEGACY = 0x10, TOSERVER_INIT_LEGACY = 0x10,
@ -936,7 +938,7 @@ enum AccessDeniedCode {
}; };
enum NetProtoCompressionMode { enum NetProtoCompressionMode {
NETPROTO_COMPRESSION_ZLIB = 0, NETPROTO_COMPRESSION_NONE = 0,
}; };
const static std::string accessDeniedStrings[SERVER_ACCESSDENIED_MAX] = { const static std::string accessDeniedStrings[SERVER_ACCESSDENIED_MAX] = {

2
src/network/serveropcodes.cpp
View File

@ -115,7 +115,7 @@ const ClientCommandFactory clientCommandFactoryTable[TOCLIENT_NUM_MSG_TYPES] =
{ {
null_command_factory, // 0x00 null_command_factory, // 0x00
null_command_factory, // 0x01 null_command_factory, // 0x01
null_command_factory, // 0x02 { "TOCLIENT_HELLO", 0, true }, // 0x02
{ "TOCLIENT_AUTH_ACCEPT", 0, true }, // 0x03 { "TOCLIENT_AUTH_ACCEPT", 0, true }, // 0x03
{ "TOCLIENT_ACCEPT_SUDO_MODE", 0, true }, // 0x04 { "TOCLIENT_ACCEPT_SUDO_MODE", 0, true }, // 0x04
{ "TOCLIENT_DENY_SUDO_MODE", 0, true }, // 0x05 { "TOCLIENT_DENY_SUDO_MODE", 0, true }, // 0x05

18
src/network/serverpackethandler.cpp
View File

@ -91,22 +91,22 @@ void Server::handleCommand_Init(NetworkPacket* pkt)
// First byte after command is maximum supported // First byte after command is maximum supported
// serialization version // serialization version
u8 client_max; u8 client_max;
u8 compression_modes; u16 supp_compr_modes;
u16 min_net_proto_version = 0; u16 min_net_proto_version = 0;
u16 max_net_proto_version; u16 max_net_proto_version;
std::string playerName; std::string playerName;
*pkt >> client_max >> compression_modes >> min_net_proto_version *pkt >> client_max >> supp_compr_modes >> min_net_proto_version
>> max_net_proto_version >> playerName; >> max_net_proto_version >> playerName;
u8 our_max = SER_FMT_VER_HIGHEST_READ; u8 our_max = SER_FMT_VER_HIGHEST_READ;
// Use the highest version supported by both // Use the highest version supported by both
u8 deployed = std::min(client_max, our_max); u8 depl_serial_v = std::min(client_max, our_max);
// If it's lower than the lowest supported, give up. // If it's lower than the lowest supported, give up.
if (deployed < SER_FMT_VER_LOWEST) if (depl_serial_v < SER_FMT_VER_LOWEST)
deployed = SER_FMT_VER_INVALID; depl_serial_v = SER_FMT_VER_INVALID;
if (deployed == SER_FMT_VER_INVALID) { if (depl_serial_v == SER_FMT_VER_INVALID) {
actionstream << "Server: A mismatched client tried to connect from " actionstream << "Server: A mismatched client tried to connect from "
<< addr_s << std::endl; << addr_s << std::endl;
infostream<<"Server: Cannot negotiate serialization version with " infostream<<"Server: Cannot negotiate serialization version with "
@ -115,7 +115,7 @@ void Server::handleCommand_Init(NetworkPacket* pkt)
return; return;
} }
client->setPendingSerializationVersion(deployed); client->setPendingSerializationVersion(depl_serial_v);
/* /*
Read and check network protocol version Read and check network protocol version
@ -274,7 +274,9 @@ void Server::handleCommand_Init(NetworkPacket* pkt)
NetworkPacket resp_pkt(TOCLIENT_HELLO, 1 + 4 NetworkPacket resp_pkt(TOCLIENT_HELLO, 1 + 4
+ legacyPlayerNameCasing.size(), pkt->getPeerId()); + legacyPlayerNameCasing.size(), pkt->getPeerId());
resp_pkt << deployed << auth_mechs << legacyPlayerNameCasing; u16 depl_compress_mode = NETPROTO_COMPRESSION_NONE;
resp_pkt << depl_serial_v << depl_compress_mode << net_proto_version
<< auth_mechs << legacyPlayerNameCasing;
Send(&resp_pkt); Send(&resp_pkt);