From c307f09ca63f5dd609be0b3f1c077cd3bc1a9266 Mon Sep 17 00:00:00 2001
From: Felix Morgner <felix.morgner@gmail.com>
Date: Thu, 29 Nov 2018 23:42:11 +0100
Subject: core: implement message sending

---
 src/control_connection.cpp | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

(limited to 'src/control_connection.cpp')

diff --git a/src/control_connection.cpp b/src/control_connection.cpp
index 88a136e..094a058 100644
--- a/src/control_connection.cpp
+++ b/src/control_connection.cpp
@@ -34,6 +34,21 @@ void control_connection::start()
     }
 }
 
+void control_connection::send(std::string message)
+{
+    m_output << message;
+    boost::asio::async_write(m_socket, m_out, boost::asio::transfer_exactly(message.size()), [that = shared_from_this(), this](auto const &error, auto const length) {
+        if (error)
+        {
+            // TODO: Handle error
+        }
+        else
+        {
+            m_out.consume(length);
+        }
+    });
+}
+
 void control_connection::close()
 {
     if (auto error = boost::system::error_code{}; m_socket.cancel(error))
-- 
cgit v1.2.3