diff options
| author | alpine <[email protected]> | 2020-06-13 22:27:52 +0200 |
|---|---|---|
| committer | alpine <[email protected]> | 2020-06-13 22:27:52 +0200 |
| commit | bad7b4f2d19f95b278fdcb3056be01cae9af1dbb (patch) | |
| tree | 5bef91f910a2c03d74df9693a077ee33b2fe7886 /client/src/main.cpp | |
| parent | Initial commit (diff) | |
| download | loader-bad7b4f2d19f95b278fdcb3056be01cae9af1dbb.tar.xz loader-bad7b4f2d19f95b278fdcb3056be01cae9af1dbb.zip | |
Client.
Message encryption.
Packet handler.
Disconnect event handler.
Diffstat (limited to 'client/src/main.cpp')
| -rw-r--r-- | client/src/main.cpp | 17 |
1 files changed, 13 insertions, 4 deletions
diff --git a/client/src/main.cpp b/client/src/main.cpp index 1dc9db2..13da109 100644 --- a/client/src/main.cpp +++ b/client/src/main.cpp @@ -3,23 +3,32 @@ #include "client/client.h" int main(int argc, char *argv[]) { + io::init(); + tcp::client client; + if (client.start("127.0.0.1", 6666)) { io::logger->info("connected."); client.set_state(tcp::client_state::active); } - client.on_recv().add([&](std::string msg) { - io::logger->info(msg); + client.receive_event.add([&](tcp::packet_t &packet) { + if(!packet) + return; + + io::logger->info(packet.message); + io::logger->info(packet.uid.data()); }); - std::thread t{tcp::client::read, std::ref(client)}; + std::thread t{tcp::client::monitor, std::ref(client)}; while (client.is_active()) { std::string p; getline(std::cin, p); - bool ret = client.send_message(p); + tcp::packet_t packet(p, tcp::packet_type::write, "1234567890"); + + bool ret = client.write(packet.message.data(), packet.message.size()); if (!ret) { break; } |