#include <main.h>
#include <Datei.h>
#include <Fenster.h>
#include <Globals.h>
#include <InitDatei.h>
#include <KSGNetwork.h> 
#include <Network.h>

int KSGStart Framework::Start(Startparam p)
{
	Network::Start(10);
	char serverReturn = 0;

	HANDLE Mutex = OpenMutex(MUTEX_ALL_ACCESS, false, "KSG_Client");
	if (Mutex == NULL)
	{
		Mutex = CreateMutex(NULL, true, "KSG_Client");
		DateiRemove(new Text("data/tmp/k.id"));
		DateiRemove(new Text("data/tmp/keinabsturz"));
	}
	else
	{
		WMessageBox(0, new Text("Fehler"), new Text("Das Programm läuft bereits. Wenn dieß nicht der Fall ist,\nmusst du den Komputer neu starten."), MB_ICONERROR);
		Network::Exit();
		return 0;
	}

	if (DateiExistiert(new Text("data/update/unable/list.patch")))
	{
		PROCESS_INFORMATION prozessinfo3;
		STARTUPINFO startinfo3;
		ZeroMemory(&startinfo3, sizeof(STARTUPINFOW));
		startinfo3.cb = sizeof(STARTUPINFOW);

		if (CreateProcess(0, "data/patch/bin/übernehmen.exe", 0, 0, 0, 0, 0, 0, &startinfo3, &prozessinfo3) == 1)
		{
			Network::Exit();
			DateiRemove(new Text("data/tmp"));
			exit(0);
		}
		else
		{
			WMessageBox(0, new Text("Fehler"), new Text("Bei dem Übernehen der Änderungen ist ein Fehler aufgetreten.\nBitte starte den Komputer neu. Sollte diese Meldung weiterhin\nerscheinen, so musst du das Spiel neu Installieren."), MB_ICONERROR);
			exit(0);
		}
	}

	PROCESS_INFORMATION prozessinfo1;
	STARTUPINFO startinfo1;
	startinfo1.cb = sizeof(STARTUPINFOW);
	ZeroMemory(&startinfo1, sizeof(STARTUPINFOW));
	bool pe = 0;

	if (CreateProcess(0, "data/start/icon.exe", 0, 0, 0, 0, 0, 0, &startinfo1, &prozessinfo1) == 1)
	{
		CloseHandle(prozessinfo1.hThread);
		pe = 1;
	}

	// Laden des Main Clients
	HINSTANCE networkDLL = LoadLibrary("data/bin/KSGNetwork.dll");
	if (!networkDLL)
	{
		WMessageBox(0, new Text("Fehler"), new Text("Die DLL Datei 'data/bin/KSGNetwork.dll' konnte nicht geladen werden. Fallst diese Datei nicht existiert muss das Spiel neu Installiert werden."), MB_ICONERROR);
		exit(0);
	}
	KSGClient::KSGNetworkCreateMain getMainClient = (KSGClient::KSGNetworkCreateMain)GetProcAddress(networkDLL, KSGNETWORK_CREATE_MAIN);
	if (!getMainClient)
	{
		WMessageBox(0, new Text("Fehler"), new Text("Der Einstiegspunkt '" KSGNETWORK_CREATE_MAIN "' wurde in der DLL Datei 'data/bin/KSGNetwork.dll' nicht gefunden. Fallst dieses Problem weiterhin auftritt muss das Spiel neu Installiert werden."), MB_ICONERROR);
		exit(0);
	}
	KSGClient::MainServerClient* mainClient = getMainClient();
	if (!mainClient)
	{
		WMessageBox(0, new Text("Fehler"), new Text("Die DLL Datei 'data/bin/KSGNetwork.dll' scheint fehlerhaft zu sein. Fallst dieses Problem weiterhin auftritt muss das Spiel neu Installiert werden."), MB_ICONERROR);
		exit(0);
	}

	// Laden der Adresse des Main Servers
	InitDatei* iDat = new InitDatei("data/optionen.ini");
	iDat->laden();
	if (!iDat->zWert("ServerIP"))
		iDat->addWert("ServerIP", "127.0.0.1");
	if (!iDat->zWert("ServerPort"))
		iDat->addWert("ServerPort", "4225");
	iDat->speichern();
	Text* ipT = iDat->zWert("ServerIP");
	unsigned short port = (unsigned short)TextZuInt(iDat->zWert("ServerPort")->getText(), 10);

	// Registrieren beim Server
	if (!mainClient->registerSSL(ipT->getText(), port))
	{
		iDat->release();
		Text err = "Fehler beim Registrieren des Clients: ";
		err += mainClient->getLetzterFehler();
		WMessageBox(0, new Text("Fehler"), dynamic_cast<Text*>(err.getThis()), MB_ICONERROR);
		exit(0);
	}
	iDat->release();

	// Speichere Server Adresse für andere Anwendungen
	int klientNummer = mainClient->getClientId();
	Datei* dat = new Datei();
	dat->setDatei("data/tmp/k.id");
	dat->erstellen();
	dat->open(Datei::Style::schreiben);
	dat->schreibe((char*)&klientNummer, 4);
	dat->close();
	dat->setDatei("data/tmp/m.port");
	dat->erstellen();
	dat->open(Datei::Style::schreiben);
	int normPort = mainClient->getServerPort();
	dat->schreibe((char*)&normPort, 4);
	dat->close();
	dat->setDatei("data/tmp/m.ip");
	dat->erstellen();
	dat->open(Datei::Style::schreiben);
	const char* serverIp = mainClient->getServerIp();
	unsigned char len = (unsigned char)textLength(serverIp);
	dat->schreibe((char*)&len, 1);
	dat->schreibe(serverIp, len);
	dat->close();
	dat->setDatei("data/tmp/crypt.key");
	dat->erstellen();
	dat->open(Datei::Style::schreiben);
	len = mainClient->getKeyLen();
	dat->schreibe((char*)&len, 1);
	dat->schreibe(mainClient->zKey(), len);
	dat->close();
	dat->release();

	KSGClient::ErhaltungServerClient* erhaltung = mainClient->createErhaltungServerClient();
	if (!erhaltung)
	{
		Text err = "Fehler beim erstellen des Erhaltung Servers: ";
		err += mainClient->getLetzterFehler();
		WMessageBox(0, new Text("Warnung"), dynamic_cast<Text*>(err.getThis()), MB_ICONWARNING);
	}
	else
	{
		if (!erhaltung->verbinde())
		{
			Text err = "Fehler beim verbinden mit dem Erhaltung Server: ";
			err += erhaltung->getLetzterFehler();
			WMessageBox(0, new Text("Warnung"), dynamic_cast<Text*>(err.getThis()), MB_ICONWARNING);
		}
	}

	if (pe)
	{
		while (WaitForSingleObject(prozessinfo1.hProcess, 1000) == WAIT_TIMEOUT);
		CloseHandle(prozessinfo1.hProcess);
	}

	PROCESS_INFORMATION prozessinfo2;
	STARTUPINFO startinfo2;
	startinfo2.cb = sizeof(STARTUPINFOW);
	ZeroMemory(&startinfo2, sizeof(STARTUPINFOW));

	if (CreateProcess(0, "data/patch/bin/patcher.exe", 0, 0, 0, 0, 0, 0, &startinfo2, &prozessinfo2) == 1)
	{
		CloseHandle(prozessinfo2.hThread);
		while (WaitForSingleObject(prozessinfo2.hProcess, 5000) == WAIT_TIMEOUT);
		unsigned long erfolg = 0;
		GetExitCodeProcess(prozessinfo2.hProcess, &erfolg);
		if (erfolg != 0 && DateiExistiert(new Text("data/tmp/keinabsturz")))
		{
			bool gamestart = erfolg == 2;
			if (erfolg == 1)
			{
				PROCESS_INFORMATION prozessinfo3;
				STARTUPINFO startinfo3;
				startinfo3.cb = sizeof(STARTUPINFOW);
				ZeroMemory(&startinfo3, sizeof(STARTUPINFOW));

				if (CreateProcess(0, "data/patch/bin/übernehmen.exe", 0, 0, 0, 0, 0, 0, &startinfo3, &prozessinfo3) == 1)
				{
					// Trenne Verbindung zum Server
					if (erhaltung)
					{
						if (DateiExistiert(new Text("data/tmp/keinabsturz")))
							erhaltung->abmelden();
						erhaltung->trenne();
						erhaltung->release();
					}
					mainClient->unregister();
					mainClient->release();

					Network::Exit();

					DateiRemove(new Text("data/tmp"));

					exit(0);
				}
				else
					gamestart = 0;
				if (!gamestart)
					WMessageBox(0, new Text("Fehler"), new Text("Bei dem Übernehen der Änderungen ist ein Fehler aufgetreten."), MB_ICONERROR);
			}
			if (gamestart)
			{
				PROCESS_INFORMATION prozessinfo3;
				STARTUPINFO startinfo3;
				startinfo3.cb = sizeof(STARTUPINFOW);
				ZeroMemory(&startinfo3, sizeof(STARTUPINFOW));
				DateiRemove(new Text("data/tmp/keinabsturz"));

				if (CreateProcess(0, "\"data/client/bin/game client.exe\"", 0, 0, 0, 0, 0, 0, &startinfo3, &prozessinfo3) == 1)
				{
					CloseHandle(prozessinfo3.hThread);
					while (WaitForSingleObject(prozessinfo3.hProcess, 5000) == WAIT_TIMEOUT);
					CloseHandle(prozessinfo3.hProcess);
				}
				else
					WMessageBox(0, new Text("Fehler"), new Text("Das Spiel konnte nicht gestartet werden."), MB_ICONERROR);
			}
		}
		CloseHandle(prozessinfo2.hProcess);
	}
	else
	{
		WMessageBox(0, new Text("Fehler"), new Text("Der Patcher konnte nicht gestartet werden."), MB_ICONERROR);
	}
	// Verbindung zum Server Trennen
	if (DateiExistiert(new Text("data/tmp/keinabsturz")))
		erhaltung->abmelden();
	if (erhaltung)
	{
		erhaltung->trenne();
		erhaltung->release();
	}
	mainClient->unregister();
	mainClient->release();

	Network::Exit();

	DateiRemove(new Text("data/tmp"));

	return 0;
}