CLOUD: Add LocalWebserver

Available as LocalServer singleton. It's being started and stopped by
StorageWizardDialog. It doesn't handle clients yet, though.

2 files changed, 209 insertions, 0 deletions

diff --git a/backends/networking/sdl_net/localwebserver.cpp b/backends/networking/sdl_net/localwebserver.cpp
new file mode 100644
index 0000000000..681485701b
--- /dev/null
+++ b/backends/networking/sdl_net/localwebserver.cpp
@@ -0,0 +1,144 @@
+/* ScummVM - Graphic Adventure Engine
+*
+* ScummVM is the legal property of its developers, whose names
+* are too numerous to list here. Please refer to the COPYRIGHT
+* file distributed with this source distribution.
+*
+* This program is free software; you can redistribute it and/or
+* modify it under the terms of the GNU General Public License
+* as published by the Free Software Foundation; either version 2
+* of the License, or (at your option) any later version.
+*
+* This program is distributed in the hope that it will be useful,
+* but WITHOUT ANY WARRANTY; without even the implied warranty of
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+* GNU General Public License for more details.
+*
+* You should have received a copy of the GNU General Public License
+* along with this program; if not, write to the Free Software
+* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
+*
+*/
+
+#define FORBIDDEN_SYMBOL_ALLOW_ALL
+
+#include "backends/networking/sdl_net/localwebserver.h"
+#include "common/str.h"
+#include "common/system.h"
+#include "common/timer.h"
+#include "common/textconsole.h"
+#include <SDL/SDL_net.h>
+
+namespace Common {
+
+DECLARE_SINGLETON(Networking::LocalWebserver);
+
+}
+
+namespace Networking {
+
+LocalWebserver::LocalWebserver(): _set(nullptr), _serverSocket(nullptr), _timerStarted(false), _clients(0) {
+	for (uint32 i = 0; i < MAX_CONNECTIONS; ++i)
+		_clientSocket[i] = nullptr;
+}
+
+LocalWebserver::~LocalWebserver() {
+	stop();
+}
+
+void localWebserverTimer(void *ignored) {
+	LocalServer.handle();
+}
+
+void LocalWebserver::startTimer(int interval) {
+	Common::TimerManager *manager = g_system->getTimerManager();
+	if (manager->installTimerProc(localWebserverTimer, interval, 0, "Networking::LocalWebserver's Timer")) {
+		_timerStarted = true;
+	} else {
+		warning("Failed to install Networking::LocalWebserver's timer");
+	}
+}
+
+void LocalWebserver::stopTimer() {	
+	Common::TimerManager *manager = g_system->getTimerManager();
+	manager->removeTimerProc(localWebserverTimer);
+	_timerStarted = false;
+}
+
+void LocalWebserver::start() {
+	if (_timerStarted) return;
+	startTimer();
+
+	// Create a listening TCP socket
+	IPaddress ip;	
+	if (SDLNet_ResolveHost(&ip, NULL, SERVER_PORT) == -1) {
+		error("SDLNet_ResolveHost: %s\n", SDLNet_GetError());
+	}
+	_serverSocket = SDLNet_TCP_Open(&ip);
+	if (!_serverSocket) {
+		error("SDLNet_TCP_Open: %s\n", SDLNet_GetError());		
+	}
+
+	// Create a socket set
+	_set = SDLNet_AllocSocketSet(MAX_CONNECTIONS + 1); //one more for our server socket
+	if (!_set) {
+		error("SDLNet_AllocSocketSet: %s\n", SDLNet_GetError());		
+	}
+	
+	int numused = SDLNet_TCP_AddSocket(_set, _serverSocket);
+	if (numused == -1) {
+		error("SDLNet_AddSocket: %s\n", SDLNet_GetError());
+	}
+}
+
+void LocalWebserver::stop() {
+	if (_timerStarted) stopTimer();
+
+	if (_set) {
+		SDLNet_FreeSocketSet(_set);
+		_set = nullptr;
+	}
+
+	if (_serverSocket) {
+		SDLNet_TCP_Close(_serverSocket);
+		_serverSocket = nullptr;
+	}
+
+	for (uint32 i = 0; i < MAX_CONNECTIONS; ++i)
+		if (_clientSocket[i]) {			
+			SDLNet_TCP_Close(_clientSocket[i]);
+			_clientSocket[i] = nullptr;
+		}
+
+	_clients = 0;
+}
+
+void LocalWebserver::handle() {
+	int numready = SDLNet_CheckSockets(_set, 0);
+	if (numready == -1) {
+		error("SDLNet_CheckSockets: %s\n", SDLNet_GetError());
+	} else if (numready) {
+		if (SDLNet_SocketReady(_serverSocket)) {
+			TCPsocket client = SDLNet_TCP_Accept(_serverSocket);
+			if (client) {
+				if (_clients == MAX_CONNECTIONS) { //drop the connection
+					SDLNet_TCP_Close(client);
+				} else {
+					int numused = SDLNet_TCP_AddSocket(_set, _serverSocket);
+					if (numused == -1) {
+						error("SDLNet_AddSocket: %s\n", SDLNet_GetError());
+					}					
+					_clientSocket[_clients++] = client;
+				}
+			}
+		}
+
+		for (uint32 i = 0; i < MAX_CONNECTIONS; ++i) {
+			if (!_clientSocket[i]) continue;
+			if (!SDLNet_SocketReady(_clientSocket[i])) continue;
+			//TODO: handle client
+		}
+	}
+}
+
+} // End of namespace Networking
diff --git a/backends/networking/sdl_net/localwebserver.h b/backends/networking/sdl_net/localwebserver.h
new file mode 100644
index 0000000000..a11be0a938
--- /dev/null
+++ b/backends/networking/sdl_net/localwebserver.h
@@ -0,0 +1,65 @@
+/* ScummVM - Graphic Adventure Engine
+*
+* ScummVM is the legal property of its developers, whose names
+* are too numerous to list here. Please refer to the COPYRIGHT
+* file distributed with this source distribution.
+*
+* This program is free software; you can redistribute it and/or
+* modify it under the terms of the GNU General Public License
+* as published by the Free Software Foundation; either version 2
+* of the License, or (at your option) any later version.
+*
+* This program is distributed in the hope that it will be useful,
+* but WITHOUT ANY WARRANTY; without even the implied warranty of
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+* GNU General Public License for more details.
+*
+* You should have received a copy of the GNU General Public License
+* along with this program; if not, write to the Free Software
+* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA.
+*
+*/
+
+#ifndef BACKENDS_NETWORKING_SDL_NET_LOCALWEBSERVER_H
+#define BACKENDS_NETWORKING_SDL_NET_LOCALWEBSERVER_H
+
+#include "common/singleton.h"
+#include "common/scummsys.h"
+
+typedef struct _SDLNet_SocketSet *SDLNet_SocketSet;
+typedef struct _TCPsocket *TCPsocket;
+
+namespace Networking {
+
+class LocalWebserver : public Common::Singleton<LocalWebserver> {
+	static const uint32 FRAMES_PER_SECOND = 20;
+	static const uint32 TIMER_INTERVAL = 1000000 / FRAMES_PER_SECOND;
+	static const uint32 SERVER_PORT = 12345;
+	static const uint32 MAX_CONNECTIONS = 10;
+
+	friend void localWebserverTimer(void *); //calls handle()
+
+	SDLNet_SocketSet _set;
+	TCPsocket _serverSocket;
+	TCPsocket _clientSocket[MAX_CONNECTIONS];
+	int _clients;
+	bool _timerStarted;
+
+	void startTimer(int interval = TIMER_INTERVAL);
+	void stopTimer();
+	void handle();
+
+public:
+	LocalWebserver();
+	virtual ~LocalWebserver();
+
+	void start();
+	void stop();
+};
+
+/** Shortcut for accessing the local webserver. */
+#define LocalServer		Networking::LocalWebserver::instance()
+
+} // End of namespace Networking
+
+#endif