mysql/main.cpp

#include <iostream>
#include <cstdint>
#include <bitset>
#include <boost/endian/conversion.hpp>
#include <boost/asio/io_context.hpp>
#include <boost/asio/executor_work_guard.hpp>
#include <boost/asio/post.hpp>
#include <boost/asio/ip/tcp.hpp>
#include <boost/asio/read.hpp>
#include <boost/asio/write.hpp>
#include <cassert>
#include "basic_types.hpp"
#include "deserialization.hpp"
#include "auth.hpp"

using namespace std;
using namespace boost::asio;
using namespace mysql;

constexpr auto HOSTNAME = "localhost"sv;
constexpr auto PORT = "3306"sv;

int main()
{
	// Basic
	io_context ctx;
	auto guard = make_work_guard(ctx);
	boost::system::error_code errc;

	// DNS resolution
	ip::tcp::resolver resolver {ctx};
	auto results = resolver.resolve(ip::tcp::v4(), HOSTNAME, PORT);
	if (results.size() != 1)
	{
		cout << "Found endpoints: " << results.size() << ", exiting" << endl;
		exit(1);
	}
	auto endpoint = results.begin()->endpoint();
	cout << "Connecting to: " << endpoint << endl;

	// TCP connection
	ip::tcp::socket sock {ctx};
	sock.connect(endpoint);
	unsigned char char_buffer [1024];
	mutable_buffer buffer {char_buffer, sizeof(char_buffer)};

	// Connection phase

	// Read packet header
	boost::asio::read(sock, mutable_buffer{char_buffer, 4});
	mysql::int3 packet_size;
	deserialize(char_buffer, char_buffer+4, packet_size); // TODO: redundant size check
	uint8_t sequence_number = char_buffer[3];

	// Read the rest of the packet
	std::unique_ptr<unsigned char[]> packet_buffer { new unsigned char[packet_size.value] };
	boost::asio::read(sock, mutable_buffer{packet_buffer.get(), packet_size.value});
	// TODO: handling the case where the packet is bigger than X bytes

	uint8_t msg_type = packet_buffer[0];
	if (msg_type == 10) // handshake
	{
		mysql::Handshake handshake;
		auto last = mysql::deserialize(packet_buffer.get() + 1, packet_buffer.get() + packet_size.value, handshake);
		if (last != packet_buffer.get() + packet_size.value)
		{
			std::cerr << "Additional bytes at the end of packet" << endl;
		}
		std::cout <<
				"server_version=" << handshake.server_version.value << ",\n" <<
				"connection_id="  << handshake.connection_id  << ",\n" <<
				"auth_plugin_data=" << handshake.auth_plugin_data << ",\n" <<
				"capability_falgs=" << std::bitset<32>{handshake.capability_falgs} << ",\n" <<
				"character_set=" << handshake.character_set << ",\n" <<
				"status_flags=" << std::bitset<16>{handshake.status_flags} << ",\n" <<
				"auth_plugin_name=" << handshake.auth_plugin_name.value << endl;
		mysql::HandshakeResponse handshake_response;
		assert(handshake.auth_plugin_data.size() == mysql_native_password::challenge_length);
		mysql_native_password::response_buffer auth_response;
		mysql_native_password::compute_auth_string("root", handshake.auth_plugin_data.data(), auth_response);
		handshake_response.client_flag =
				CLIENT_CONNECT_WITH_DB |
				CLIENT_PROTOCOL_41 |
				CLIENT_PLUGIN_AUTH |
				CLIENT_PLUGIN_AUTH_LENENC_CLIENT_DATA |
				CLIENT_DEPRECATE_EOF;
		handshake_response.max_packet_size = 0xffff;
		handshake_response.character_set = 33; // utf8
		handshake_response.username.value = "root";
		handshake_response.auth_response.value = string_view {(const char*)auth_response, sizeof(auth_response)};
		handshake_response.database.value = "mysql";
		handshake_response.client_plugin_name.value = "mysql_native_password";

		// Serialize and send
		DynamicBuffer response_buffer { ++sequence_number };
		serialize(response_buffer, handshake_response);
		response_buffer.set_size();
		boost::asio::write(sock, boost::asio::buffer(response_buffer.data(), response_buffer.size()));
	}
	else
	{
		cout << "Message type is: " << hex << msg_type << endl;
	}

	//   Either ERR
	//   Or Handshake



	//post(ctx, [&guard] { cout << "Hello word\n"; guard.reset(); });
	//ctx.run();
}