#include <CtrlLib/CtrlLib.h>
#include <Sql/sch_schema.h>
#include <Sql/sch_source.h>
//Other includes

using namespace Upp;

GUI_APP_MAIN
{
	String User, Pass, Schema, IP;
	int port;
	
	User = "fooo";
	Pass = "bar";
	Schema = "test";
	IP = "192.168.1.2";
	port = 3306;

	//Connection to the DB
		MySqlSession session;
		if(err_conn = session.Connect(User, Pass, Schema, IP, port)) {
			SQL = session;
			SqlSchema sch(MY_SQL);
			All_Tables(sch);
		}
		else {
			SetExitCode(1);
		}

	//Main window of the GUI
	HomeScreen hs;
	hs.Run();
	
}

void tagidSocket()
{
	//Socket
	RLOG("Socket's thread started");
	for(;;) {
		if(Thread::IsShutdownThreads())
			return;
		RLOG("I'm still alive");
		Sleep(1000);
	}
}

GUI_APP_MAIN{
	//Reading a .ini file, connection to a db
	[...]

	Thread t;
	t.Run(callback(tagidSocket));
	app.Run();
    
	RLOG("Exiting, terminating socket");
	Thread::ShutdownThreads();
}

void tagidSocket()
{
	TcpSocket server;
	if(!server.Listen(23456, 5)) {
		RLOG("Unable to initialize server socket");
		return;
	}
	RLOG("Socket started, waiting for requests...");
	for(;;) {
		if(Thread::IsShutdownThreads())
			return;
		TcpSocket s;
		if(s.Accept(server)) {
			String w = s.GetLine();
			//Cout() << "Request: " << w << " from: " << s.GetPeerAddr() << '\n';
			RLOG("Request: " + w + " from: " + s.GetPeerAddr() + '\n');
			if(w == "time")
				s.Put(AsString(GetSysTime()));
			else
				s.Put(AsString(3 * atoi(~w)));
			s.Put("\n");
			
		}
	}
}

void tagidSocket()
{
	TcpSocket server;
	if(!server.Listen(23456, 5)) {
		RLOG("Unable to initialize server socket");
		return;
	}
	RLOG("Socket started, waiting for requests...");
	try {
		while(!Thread::IsShutdownThreads()) {
			TcpSocket s;
			s.WhenWait = [=]
			{
				if(Thread::IsShutdownThreads())
					throw Exc("Thread is shut down.");
			};
			if(s.Accept(server)) {
				String w = s.GetLine();
				RLOG("Request: " + w + " from: " + s.GetPeerAddr() + '\n');
				if(w == "time")
					s.Put(AsString(GetSysTime()));
				else
					s.Put(AsString(3 * atoi(~w)));
				s.Put("\n");
				
			}
		}
	}
	catch(const Exc& e) {
		RLOG(e);
	}
}