1 files changed, 0 insertions, 120 deletions
diff --git a/source/src/wanda/control_connection.cpp b/source/src/wanda/control_connection.cpp
deleted file mode 100644
index 40e29f3..0000000
--- a/source/src/wanda/control_connection.cpp
+++ /dev/null
@@ -1,120 +0,0 @@
-#include <wanda/control_connection.hpp>
-
-#include <limits>
-
-namespace wanda
-{
-  control_connection::pointer make_control_connection(control_connection::protocol::socket && socket)
-  {
-    return std::make_shared<control_connection>(control_connection::key{}, std::move(socket));
-  }
-
-  control_connection::control_connection(control_connection::key key, control_connection::protocol::socket socket)
-      : keyed{key}
-      , m_socket{std::move(socket)}
-  {
-  }
-
-  bool control_connection::add(listener * listener)
-  {
-    auto [_, inserted] = m_listeners.insert(listener);
-    return inserted;
-  }
-
-  bool control_connection::remove(listener * listener)
-  {
-    return m_listeners.erase(listener);
-  }
-
-  void control_connection::start()
-  {
-    if (m_state == state::unknown)
-    {
-      m_state = state::fresh;
-      perform_read();
-    }
-  }
-
-  void control_connection::send(message message)
-  {
-    m_output << message << '\n';
-    asio::async_write(m_socket, m_out, asio::transfer_exactly(message.size() + 1), [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 = std::error_code{}; m_socket.cancel(error))
-    {
-      for (auto & listener : m_listeners)
-      {
-        listener->on_error(shared_from_this(), error);
-      }
-    }
-
-    if (auto error = std::error_code{}; m_socket.close(error))
-    {
-      for (auto & listener : m_listeners)
-      {
-        listener->on_error(shared_from_this(), error);
-      }
-    }
-
-    for (auto & listener : m_listeners)
-    {
-      listener->on_close(shared_from_this());
-    }
-    m_listeners.clear();
-  }
-
-  void control_connection::update(state state)
-  {
-    m_state = state;
-  }
-
-  control_connection::state control_connection::current_state() const
-  {
-    return m_state;
-  }
-
-  void control_connection::perform_read()
-  {
-    asio::async_read_until(m_socket, m_in, '\n', [that = shared_from_this(), this](auto const & error, auto const length) {
-      if (error)
-      {
-        for (auto & listener : m_listeners)
-        {
-          listener->on_error(shared_from_this(), error);
-        }
-        close();
-      }
-      else
-      {
-        auto msg = message{};
-        m_input >> msg;
-        if (!m_input)
-        {
-          m_input.ignore(std::numeric_limits<std::streamsize>::max());
-          m_input.clear();
-        }
-        else
-        {
-          for (auto & listener : m_listeners)
-          {
-            listener->on_received(shared_from_this(), msg);
-          }
-        }
-        perform_read();
-      }
-    });
-  }
-
-}  // namespace wanda
-\ No newline at end of file