Adding SocketInput

Author: Sebi

CMakeLists.txt

@@ -66,6 +66,8 @@ ADD_Executable(DasherUI
 	${PROJECT_SOURCE_DIR}/src/MainWindow.h
 	${PROJECT_SOURCE_DIR}/src/DasherUIScreen.cpp
 	${PROJECT_SOURCE_DIR}/src/DasherUIScreen.h
+	${PROJECT_SOURCE_DIR}/src/SocketInput.cpp
+	${PROJECT_SOURCE_DIR}/src/SocketInput.h
 	${PROJECT_SOURCE_DIR}/src/main.cpp
 )
 target_include_directories(DasherUI PUBLIC ${CMAKE_CURRENT_LIST_DIR}/Thirdparty/)

src/DasherController.cpp

@@ -88,7 +88,12 @@ void DasherController::CreateModules()
 	CDashIntfScreenMsgs::CreateModules();
 
 	RegisterModule(ScreenModule.get());
-	SetDefaultInputDevice(ScreenModule.get());
+
+	SocketInputModule = std::make_shared<SocketInput>(static_cast<CSettingsUser*>(this), this, m_pFramerate);
+	RegisterModule(static_cast<Dasher::CInputFilter*>(SocketInputModule.get()));
+	SocketInputModule->startListen();
+
+	SetDefaultInputDevice(SocketInputModule.get());
 }
 
 void DasherController::CopyToClipboard(const std::string& text)

src/DasherController.h

@@ -4,6 +4,7 @@
 #include "DasherUIScreen.h"
 #include "imgui.h"
 #include "imgui_internal.h"
+#include "SocketInput.h"
 
 
 class DasherController : public Dasher::CDashIntfScreenMsgs
@@ -43,4 +44,5 @@ class DasherController : public Dasher::CDashIntfScreenMsgs
 
 	//Modules
 	std::shared_ptr<DasherUIScreen> ScreenModule;
+	std::shared_ptr<SocketInput> SocketInputModule;
 };

src/SocketInput.cpp

@@ -0,0 +1,103 @@
+#include "SocketInput.h"
+
+#include <I18n.h>
+#include <thread>
+
+#include "DasherInterfaceBase.h"
+#include "DasherModel.h"
+
+SocketInput::SocketInput(CSettingsUser* Creator, Dasher::CDashIntfSettings* Controller, Dasher::CFrameRate* pFramerate): CScreenCoordInput(0, _("Socket Input")),
+                                                                                                                         CDefaultFilter(Creator, Controller, pFramerate, 2, "Socket Mode")
+{
+    xLabel = Controller->GetStringParameter(Dasher::Parameter::SP_SOCKET_INPUT_X_LABEL);
+    yLabel = Controller->GetStringParameter(Dasher::Parameter::SP_SOCKET_INPUT_Y_LABEL);
+}
+
+SocketInput::~SocketInput()
+{
+	stopListen();
+}
+
+bool SocketInput::GetScreenCoords(Dasher::screenint& iX, Dasher::screenint& iY, Dasher::CDasherView* pView)
+{
+	const Dasher::CDasherView::ScreenRegion screenRegion = pView->VisibleRegion();
+
+	const double vectorLength = std::min(Dasher::CDasherModel::ORIGIN_Y - screenRegion.minY, screenRegion.maxY - Dasher::CDasherModel::ORIGIN_Y);
+	const double normalization = sqrt(lastRelativeX * lastRelativeX + lastRelativeY * lastRelativeY);
+
+	pView->Dasher2Screen(
+		Dasher::CDasherModel::ORIGIN_X - static_cast<Dasher::myint>(lastRelativeX * (normalization > 1.0 ? vectorLength / normalization : vectorLength)),
+		Dasher::CDasherModel::ORIGIN_Y - static_cast<Dasher::myint>(lastRelativeY * (normalization > 1.0 ? vectorLength / normalization : vectorLength)),
+		iX, iY);
+
+	return true;
+}
+
+void SocketInput::startListen()
+{
+	session_acceptor = std::make_unique<asio::ip::tcp::acceptor>(io_service, asio::ip::tcp::endpoint(asio::ip::tcp::v4(), static_cast<short>(Controller->GetLongParameter(Dasher::LP_SOCKET_PORT))));
+
+	receiveThread = std::thread([this](){
+
+		asio::error_code ec;
+		keepListenServerAlive = true;
+		while(keepListenServerAlive)
+		{
+            open_socket = std::make_unique<asio::ip::tcp::socket>(session_acceptor->accept(ec));
+
+			if(ec) continue; //error while accepting occured
+
+		    keepReadThreadAlive = true;
+			size_t bytes_read = 0;
+		    while(keepReadThreadAlive)
+		    {
+			    if((bytes_read = read_until(*open_socket, stream_buffer, '\n', ec)))
+			    {
+                    std::string_view data{
+                        static_cast<const char*>(stream_buffer.data().data()), 
+                    stream_buffer.size()
+                    };
+
+					try	{
+                        std::string_view cmd = data.substr(0, data.find(' '));
+			            const double num = std::stod(data.data() + cmd.size()); //skip first two characters <cmd><whitespace>
+
+						if(cmd == xLabel)
+						{
+						    lastRelativeX = num;
+							relativeMode = true;
+						}else if(cmd == yLabel)
+						{
+						    lastRelativeY = num;
+							relativeMode = true;
+						}else if(cmd == startStopLabel)
+						{
+							if(num >= 0.5)
+							{
+						       run(0);
+							}else
+							{
+						       stop();
+							}
+						}
+					} catch (std::exception& e)
+					{
+                        std::cout << "Wrong format for socket input" << std::endl;
+					}
+
+					stream_buffer.consume(bytes_read);
+			    } else if(ec) break;
+		    }
+			open_socket->close();
+		}
+	});
+}
+
+void SocketInput::stopListen()
+{
+	keepListenServerAlive = false;
+	keepReadThreadAlive = false;
+	session_acceptor->close();
+	open_socket->close();
+	receiveThread.join();
+}

src/SocketInput.h

@@ -0,0 +1,45 @@
+#pragma once
+
+#include "DasherInput.h"
+#include "asio.hpp"
+#include "DashIntfSettings.h"
+#include "PressFilter.h"
+
+class SocketInput : public Dasher::CScreenCoordInput, public Dasher::CDefaultFilter
+{
+public:
+    SocketInput(CSettingsUser* Creator, Dasher::CDashIntfSettings* Controller, Dasher::CFrameRate* pFramerate);
+    virtual ~SocketInput();
+
+	bool GetScreenCoords(Dasher::screenint& iX, Dasher::screenint& iY, Dasher::CDasherView* pView) override;
+
+    void startListen();
+    void stopListen();
+
+    bool GetSettings(SModuleSettings** sets, int* iCount) override;
+private:
+    bool relativeMode;
+	double lastRelativeX = 0.5;
+	double lastRelativeY = 0.5;
+    Dasher::screenint lastX = 0;
+    Dasher::screenint lastY = 0;
+
+    //Dasher Stuff
+    Dasher::CDashIntfSettings* Controller;
+
+    //Commands
+    std::string xLabel;
+    std::string yLabel;
+    std::string startStopLabel = "s";
+
+    // ASIO Stuff
+    asio::io_service io_service;
+    std::unique_ptr<asio::ip::tcp::acceptor> session_acceptor;
+    std::unique_ptr<asio::ip::tcp::socket> open_socket;
+    asio::streambuf stream_buffer;
+
+    // Async Thread
+    std::thread receiveThread;
+    bool keepReadThreadAlive = true;
+    bool keepListenServerAlive = true;
+};