From c81126ad91bf5ef35d30c8c6378f6866a803233f Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Kjist=C3=B3f?= <mrtoth@strongds.hu>
Date: Fri, 18 Nov 2016 16:11:17 +0100
Subject: [PATCH] written an example server -- started experimenting with
 boost::asio

---
 CMakeLists.txt |  2 +-
 server.cpp     | 69 ++++++++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 70 insertions(+), 1 deletion(-)
 create mode 100644 server.cpp

diff --git a/CMakeLists.txt b/CMakeLists.txt
index 01eaa53..b02b16e 100644
--- a/CMakeLists.txt
+++ b/CMakeLists.txt
@@ -7,6 +7,6 @@ set(CMAKE_CXX_FLAGS "${CMAKE_CXX_FLAGS} -Wall -pedantic")
 find_package(Boost COMPONENTS serialization system REQUIRED)
 include_directories(${Boost_INCLUDE_DIR})
 
-set(SOURCE_FILES main.cpp)
+set(SOURCE_FILES server.cpp)
 add_executable(cpp11NHF2_chat ${SOURCE_FILES})
 target_link_libraries(cpp11NHF2_chat ${Boost_LIBRARIES})
\ No newline at end of file
diff --git a/server.cpp b/server.cpp
new file mode 100644
index 0000000..849a604
--- /dev/null
+++ b/server.cpp
@@ -0,0 +1,69 @@
+#include <iostream>
+#include <boost/asio/io_service.hpp>
+#include <boost/asio/ip/tcp.hpp>
+#include <boost/asio/buffer.hpp>
+#include <boost/asio/write.hpp>
+#include <boost/asio/read.hpp>
+#include <ctime>
+using namespace boost::asio;
+using namespace boost::asio::ip;
+
+
+
+io_service ioservice;
+tcp::endpoint tcpendpoint{tcp::v4(), 2222};
+tcp::acceptor tcpacceptor{ioservice, tcpendpoint};
+tcp::socket sock{ioservice};
+std::vector<char> alldata;
+std::array<char, 4096> data;
+
+
+void read_handler(const boost::system::error_code& ec, std::size_t transferred)
+{
+    if (!ec)
+    {
+        std::cout.write(data.data(), transferred);
+        for (int i = 0; i < transferred; ++i)
+            alldata.push_back(data[i]);
+        sock.async_read_some(buffer(data), read_handler);
+    }
+}
+
+void write_handler(const boost::system::error_code& ec, std::size_t transferred)
+{
+    if (!ec)
+    {
+        tcp::endpoint remoteendpoint = sock.remote_endpoint();
+        address ip =  remoteendpoint.address();
+
+        std::cout << transferred
+                  << " bytes transferred to "
+                  << ip.to_string() << ":" << remoteendpoint.port()
+                  << std::endl;
+
+        sock.async_read_some(buffer(data), read_handler);
+    }
+}
+
+void accept_handler(const boost::system::error_code& ec)
+{
+    if (!ec)
+    {
+        std::time_t now = std::time(nullptr);
+        std::string time(std::ctime(&now));
+        async_write(sock, buffer(time), write_handler);
+    }
+}
+
+
+int main()
+{
+    tcpacceptor.listen();
+    tcpacceptor.async_accept(sock, accept_handler);
+
+    // work, so the server does not stop listening
+    auto work = std::make_shared<io_service::work>(ioservice);
+    ioservice.run();
+
+    return EXIT_SUCCESS;
+}
\ No newline at end of file