1 files changed, 24 insertions, 44 deletions

diff --git a/src/engine/user/input.cpp b/src/engine/user/input.cpp
index 7e9fe22..ac6d660 100644
--- a/src/engine/user/input.cpp
+++ b/src/engine/user/input.cpp
@@ -3,66 +3,46 @@
 #include <iostream>
 #include <unistd.h>
 
-void InputHandler::listen() const noexcept
-{
-	char character = 0;
+#include <iostream>
 
-	while (!std::cin.read(&character, 1).fail())
+void UserInputObserver::listen() noexcept
+{
+	while (true)
 	{
-		notify_subscribers(character, nullptr);
-	}
-}
+		char character = 0;
 
-void InputHandler::subscribe(
-	const Event &event,
-	const std::shared_ptr<ISubscriber<Context>> &subscriber) noexcept
-{
-	auto event_index = _event_as_index(event);
+		if (std::cin.read(&character, 1).fail())
+		{
+			continue;
+		}
 
-	_subscribers.at(event_index).push_back(subscriber);
-}
+		_currently_pressed_mutex.lock();
 
-void InputHandler::notify_subscribers(const Event &event, const Context &context)
-	const noexcept
-{
-	auto event_index = _event_as_index(event);
+		if (character != _currently_pressed)
+		{
+			_currently_pressed = character;
+		}
 
-	for (const auto &subscriber : _subscribers.at(event_index))
-	{
-		subscriber->update(context);
+		_currently_pressed_mutex.unlock();
 	}
 }
 
-void InputHandler::enter_raw_mode() noexcept
+bool UserInputObserver::is_key_pressed(Key key) noexcept
 {
-	if (_original_termios == nullptr)
-	{
-		_original_termios = std::make_shared<termios>();
-	}
+	_currently_pressed_mutex.lock();
 
-	tcgetattr(STDIN_FILENO, _original_termios.get());
+	const auto is_key_pressed = key == _currently_pressed;
 
-	auto raw_termios = termios(*_original_termios);
+	_currently_pressed_mutex.unlock();
 
-	raw_termios.c_lflag &= static_cast<uint32_t>(~(ECHO | ICANON | ISIG));
-
-	tcsetattr(STDIN_FILENO, TCSAFLUSH, &raw_termios);
+	return is_key_pressed;
 }
 
-void InputHandler::leave_raw_mode() noexcept
+void UserInputObserver::clear_currently_pressed() noexcept
 {
-	if (_original_termios == nullptr)
-	{
-		return;
-	}
-
-	tcsetattr(STDIN_FILENO, TCSAFLUSH, _original_termios.get());
+	_currently_pressed_mutex.lock();
 
-	_original_termios = nullptr;
-}
+	_currently_pressed = 0;
 
-auto InputHandler::_event_as_index(const Event &event) noexcept
-	-> InputHandler::SubscribersSizeType
-{
-	return static_cast<SubscribersSizeType>(static_cast<uint8_t>(event));
+	_currently_pressed_mutex.unlock();
 }