tcpinterface.cpp

#include "tcpinterface.h"
#include <QDebug>

RemoteControlSocket::RemoteControlSocket(uint16_t port) : server() {
	server.listen(QHostAddress::Any, port);
	connect(&server, &QTcpServer::newConnection, this, &RemoteControlSocket::addClient);
}

void RemoteControlSocket::addClient() {
	auto *client = server.nextPendingConnection();
	clients.push_back(client);
	connect(client, &QTcpSocket::readyRead, this, [this, client]() {
		while(client->canReadLine())
			this->handleLine(client->readLine().trimmed(), client);
	});
}

void RemoteControlSocket::handleLine(QString s, QTcpSocket *sock) {
	qInfo() << s;
	if (s == "start")
		emit start();
	else if (s == "stop")
		emit stop();
	else if (s == "update")
		emit refresh_streams();
	else if (s.contains("filename")) {
		emit filename(s);
	}
	else if (s.contains("select all"))
		emit select_all();
	else if (s.contains("select none"))
		emit select_none();
	else if (s.contains("select")) {
		QString search_str = s.mid(7).trimmed(); // Assuming "select" is 7 characters long
		if (!search_str.isEmpty()) {
			emit select_stream(search_str);
		}
	}
	else if (s.contains("regexselect")) {
		QString regexPattern = s.mid(12).trimmed(); // Assuming "regexselect" is 12 characters long
		if (!regexPattern.isEmpty()) {
			emit select_stream_regex(regexPattern);
		}
	}
	sock->write("OK");
	// TODO: select /deselect streams
	// TODO: send acknowledgement
	// TODO: get current state
	//
	// else this->sender()->sender("Whoops");
}