#include "KarteEditor.h"
#include <Datei.h>
#include <DateiSystem.h>
#include <Bild.h>
#include <Zeit.h>
#include "KsgsBeschreibung.h"
#include "KsgsShopSeite.h"
#include <unistd.h>
#define Sleep( x )               usleep( (x) * 1000 )
#include <dlfcn.h>
#define LoadLibrary( x )         dlopen( (x), RTLD_LAZY )
#define GetProcAddress           dlsym
#define FreeLibrary              dlclose

typedef ESEditorV* (*DllStart)();

// Inhalt der KarteEditor Klasse aus KarteEditor.h
// Konstruktor
KarteEditor::KarteEditor(int id, EdSDatenbank* datenbank, const char* pf, InitDatei* zIni)
	: ReferenceCounter()
{
	this->id = id;
	db = datenbank;
	ini = dynamic_cast<InitDatei*>(zIni->getThis());
	pfad = new Text(pf);
	pfad->append("/");
	pfad->append(id);
	if (!DateiExistiert(*pfad))
	{ // Karte erstellen
		// Client Daten
		Text dn = pfad->getText();
		dn += "/live/map/client/titel.ltdb";
		LTDBDatei bilder;
		bilder.setDatei(dynamic_cast<Text*>(dn.getThis()));
		bilder.erstellen();
		Bild* bild = new Bild();
		bild->neuBild(200, 100, 0x00000000);
		bilder.speichern(0, dynamic_cast<Bild*>(bild->getThis()), new Text("titel"));
		dn = pfad->getText();
		dn += "/live/map/client/minimap.ltdb";
		bilder.setDatei(dynamic_cast<Text*>(dn.getThis()));
		bilder.erstellen();
		bild->neuBild(348, 348, 0x00000000);
		bilder.speichern(0, dynamic_cast<Bild*>(bild->getThis()), new Text("vorschau"));
		dn = pfad->getText();
		dn += "/live/map/client/ladebild.ltdb";
		bilder.setDatei(dynamic_cast<Text*>(dn.getThis()));
		bilder.erstellen();
		bild->neuBild(1300, 900, 0x00000000);
		bilder.speichern(0, bild, new Text("spielladen"));
		dn = pfad->getText();
		dn += "/live/map/client/beschreibung.ksgs";
		Datei d;
		d.setDatei(dn);
		d.erstellen();
		d.open(Datei::Style::schreiben);
		d.schreibe((char*)_neu_karte_ksgs_beschreibung, textLength(_neu_karte_ksgs_beschreibung));
		d.close();
		dn = pfad->getText();
		dn += "/live/map/client/map/data/data.sts";
		d.setDatei(dn);
		d.erstellen();
		d.open(Datei::Style::schreiben);
		int i = 0;
		d.schreibe((char*)&i, 4);
		d.schreibe((char*)&i, 4);
		d.close();
		// Shop Seite
		dn = pfad->getText();
		dn += "/live/shop/seite/seite.ksgs";
		d.setDatei(dn);
		d.erstellen();
		d.open(Datei::Style::schreiben);
		d.schreibe((char*)_neu_karte_ksgs_shop_seite, textLength(_neu_karte_ksgs_shop_seite));
		d.close();
		dn = pfad->getText();
		dn += "/live/shop/titelbg.ltdb";
		bilder.setDatei(dynamic_cast<Text*>(dn.getThis()));
		bilder.erstellen();
		bild->neuBild(200, 100, 0x00000000);
		bilder.speichern(0, dynamic_cast<Bild*>(bild->getThis()), new Text("auswbg.jpg"));
		// Server Daten
		dn = pfad->getText();
		dn += "/live/map/server/sts.ltgd";
		d.setDatei(dn);
		d.erstellen();
		d.open(Datei::Style::schreiben);
		i = 0;
		d.schreibe((char*)&i, 4);
		d.schreibe((char*)&i, 4);
		d.close();
		dn = pfad->getText();
		dn += "/live/map/server/...";

	}
	shop = new SSEditor(pfad->getText());
	beschreibung = new BeschreibungEditor(pfad->getText());
	teams = new TeamsEditor(id, pfad->getText(), dynamic_cast<EdSDatenbank*>(db->getThis()));
	dateien = new DateienEditor(pfad->getText(), zIni);
	editor = 0;
	editorDll = 0;
	fehler = "";
}

// Destruktor
KarteEditor::~KarteEditor()
{
	shop->release();
	beschreibung->release();
	teams->release();
	dateien->release();
	db->release();
	pfad->release();
	if (editor)
		editor->release();
	if (editorDll)
		FreeLibrary(editorDll);
	ini->release();
}

// private
int KarteEditor::findeDateien(const char* pf, RCArray< Text >* pfad)
{
	Datei d;
	d.setDatei(pf);
	if (d.existiert() && !d.istOrdner())
	{
		pfad->add(new Text(pf));
		return 1;
	}
	if (d.istOrdner())
	{
		RCArray< Text >* list = d.getDateiListe();
		int anz = list->getEintragAnzahl();
		int ret = 0;
		for (int i = 0; i < anz; i++)
		{
			Text p = pf;
			p += "/";
			p += list->z(i)->getText();
			ret += findeDateien(p, pfad);
		}
		list->release();
		return ret;
	}
	return 0;
}

// nicht constant
bool KarteEditor::getAbbildListe(RCArray< Text >* name, RCArray< Zeit >* datum)
{
	name->leeren();
	datum->leeren();
	Text pf = pfad->getText();
	pf += "/abbilder";
	Datei d;
	d.setDatei(pf);
	if (!d.existiert() || !d.istOrdner())
		return 1;
	RCArray< Text >* list = d.getDateiListe();
	if (!list)
		return 0;
	int anz = list->getEintragAnzahl();
	for (int i = 0; i < anz; i++)
	{
		Text p = pf.getText();
		p += "/";
		p += list->z(i)->getText();
		d.setDatei(p);
		Zeit* z = d.getLastChange();
		if (z)
		{
			name->add(list->get(i));
			datum->add(z);
		}
	}
	list->release();
	return 1;
}

int KarteEditor::getDateiUpdateListe(const char* p, RCArray< Text >* pfad)
{
	pfad->leeren();
	Text pf = this->pfad->getText();
	pf += "/live/";
	pf += p;
	RCArray< Text >* list = new RCArray< Text >();
	int anz = findeDateien(pf, list);
	for (int i = 0; i < anz; i++)
	{
		list->z(i)->remove(pf.getText());
		pfad->add(list->get(i));
	}
	list->release();
	return anz;
}

bool KarteEditor::abbildErstellen(const char* name)
{
	Text pf = pfad->getText();
	pf += "/abbilder/";
	pf += name;
	if (DateiExistiert(pf))
	{
		fehler = "Es existiert bereits ein Abbild mit diesem Namen. Du musst es vorher remove, oder einen anderen Namen angeben.";
		return 0;
	}
	Text live = pfad->getText();
	live += "/live";
	RCArray< Text >* list = new RCArray< Text >();
	int anz = findeDateien(live, list);
	bool ret = 1;
	for (int i = 0; i < anz; i++)
	{
		Datei alt;
		Datei neu;
		alt.setDatei(list->z(i)->getText());
		Text pfNeu = pf.getText();
		pfNeu += (list->z(i)->getText() + live.getLength());
		neu.setDatei(pfNeu);
		neu.erstellen();
		ret &= alt.open(Datei::Style::lesen);
		ret &= neu.open(Datei::Style::schreiben);
		__int64 size = alt.getSize();
		char* buffer = new char[2048];
		while (size > 0)
		{
			int l = size > 2048 ? 2048 : (int)size;
			alt.lese(buffer, l);
			neu.schreibe(buffer, l);
			size -= l;
		}
		delete[] buffer;
		alt.close();
		neu.close();
	}
	list->release();
	if (!ret)
	{
		DateiRemove(pf);
		fehler = "Es ist ein Fehler beim Lesen oder Schreiben einer Datei aufgetreten.";
	}
	return ret;
}

bool KarteEditor::abbildRemove(const char* name)
{
	Text pf = pfad->getText();
	pf += "/abbilder/";
	pf += name;
	if (!DateiRemove(pf))
	{
		fehler = "Es ist ein Fehler beim Löschen des Abbildes aufgetreten.";
		return 0;
	}
	return 1;
}

bool KarteEditor::abbildHerstellen(const char* name)
{
	if (inUpdate())
	{
		fehler = "Die Karte wird momentan aktualisiert. Bitte haben sie Geduld, bis dieser Vorgang abgeschlossen ist.";
		return 0;
	}
	Text pf = pfad->getText();
	pf += "/abbilder/";
	pf += name;
	if (!DateiExistiert(pf))
	{
		fehler = "Es existiert kein Abbild mit dem angegebenen Namen.";
		return 0;
	}
	Text live = pfad->getText();
	live += "/live";
	if (!DateiRemove(live))
	{
		fehler = "Es ist ein Fehler beim Löschen der aktuellen Version aufgetreten.";
		return 0;
	}
	RCArray< Text >* list = new RCArray< Text >();
	int anz = findeDateien(pf, list);
	bool ret = 1;
	for (int i = 0; i < anz; i++)
	{
		Datei alt;
		Datei neu;
		alt.setDatei(list->z(i)->getText());
		Text pfNeu = live.getText();
		pfNeu += (list->z(i)->getText() + pf.getLength());
		neu.setDatei(pfNeu);
		neu.erstellen();
		ret |= alt.open(Datei::Style::lesen);
		ret |= neu.open(Datei::Style::schreiben);
		__int64 size = alt.getSize();
		char* buffer = new char[2048];
		while (size > 0)
		{
			int l = size > 2048 ? 2048 : (int)size;
			alt.lese(buffer, l);
			neu.schreibe(buffer, l);
			size -= l;
		}
		delete[] buffer;
		alt.close();
		neu.close();
	}
	list->release();
	if (!ret)
	{
		DateiRemove(pf);
		fehler = "Es ist ein Fehler beim Lesen oder Schreiben einer Datei aufgetreten.";
	}
	return ret;
}

bool KarteEditor::startUpdate()
{
	if (inUpdate())
	{
		fehler = "Die Karte wird momentan aktualisiert. Bitte haben sie Geduld, bis dieser Vorgang abgeschlossen ist.";
		return 0;
	}
	if (!db->startKarteUpdate(id))
	{
		Text* t = db->getLetzterFehler();
		fehler = t->getText();
		t->release();
		return 0;
	}
	return 1;
}

bool KarteEditor::startShopUpdate()
{
	if (!db->startShopUpdate(id))
	{
		Text* t = db->getLetzterFehler();
		fehler = t->getText();
		t->release();
		return 0;
	}
	return 1;
}

bool KarteEditor::prozessMessage(SKlient* zKlient)
{
	char message = 0;
	zKlient->getNachrichtEncrypted(&message, 1);
	switch (message)
	{
	case 0x1: // Abbild Erstellen
	{
		zKlient->sendeEncrypted("\1", 1);
		unsigned char l = 0;
		zKlient->getNachrichtEncrypted((char*)&l, 1);
		char* name = new char[l + 1];
		name[(int)l] = 0;
		if (l)
			zKlient->getNachrichtEncrypted(name, l);
		if (!textLength(name))
		{
			delete[] name;
			fehler = "Du musst einen Namen angeben.";
			return 0;
		}
		if (!abbildErstellen(name))
		{
			delete[] name;
			return 0;
		}
		delete[] name;
		zKlient->sendeEncrypted("\1", 1);
		return 1;
	}
	case 0x2: // Abbild Löschen
	{
		zKlient->sendeEncrypted("\1", 1);
		unsigned char l = 0;
		zKlient->getNachrichtEncrypted((char*)&l, 1);
		char* name = new char[l + 1];
		name[(int)l] = 0;
		if (l)
			zKlient->getNachrichtEncrypted(name, l);
		if (!textLength(name))
		{
			delete[] name;
			fehler = "Du musst einen Namen angeben.";
			return 0;
		}
		if (!abbildRemove(name))
		{
			delete[] name;
			return 0;
		}
		delete[] name;
		zKlient->sendeEncrypted("\1", 1);
		return 1;
	}
	case 0x3: // Abbild Herstellen
	{
		zKlient->sendeEncrypted("\1", 1);
		unsigned char l = 0;
		zKlient->getNachrichtEncrypted((char*)&l, 1);
		char* name = new char[l + 1];
		name[(int)l] = 0;
		if (l)
			zKlient->getNachrichtEncrypted(name, l);
		if (!textLength(name))
		{
			delete[] name;
			fehler = "Du musst einen Namen angeben.";
			return 0;
		}
		if (!abbildHerstellen(name))
		{
			delete[] name;
			return 0;
		}
		delete[] name;
		zKlient->sendeEncrypted("\1", 1);
		return 1;
	}
	case 0x4: // Karte Veröffentlichen
	{
		zKlient->sendeEncrypted("\1", 1);
		if (!startUpdate())
			return 0;
		else
			zKlient->sendeEncrypted("\1", 1);
		return 1;
	}
	case 0x5: // get Abbild Liste
	{
		zKlient->sendeEncrypted("\1", 1);
		RCArray< Text >* name = new RCArray< Text >();
		RCArray< Zeit >* datum = new RCArray< Zeit >();
		getAbbildListe(name, datum);
		int anz = name->getEintragAnzahl();
		zKlient->sendeEncrypted((char*)&anz, 4);
		for (int i = 0; i < anz; i++)
		{
			Text n = name->z(i)->getText();
			char len = (char)n.getLength();
			zKlient->sendeEncrypted(&len, 1);
			zKlient->sendeEncrypted(n, len);
			int d = datum->z(i)->zDatum()->getJahr();
			zKlient->sendeEncrypted((char*)&d, 4);
			d = datum->z(i)->zDatum()->getMonat();
			zKlient->sendeEncrypted((char*)&d, 4);
			d = datum->z(i)->zDatum()->getTag();
			zKlient->sendeEncrypted((char*)&d, 4);
			d = datum->z(i)->zUhrzeit()->getStunde();
			zKlient->sendeEncrypted((char*)&d, 4);
			d = datum->z(i)->zUhrzeit()->getMinute();
			zKlient->sendeEncrypted((char*)&d, 4);
			d = datum->z(i)->zUhrzeit()->getSekunde();
			zKlient->sendeEncrypted((char*)&d, 4);
		}
		name->release();
		datum->release();
		return 1;
	}
	case 0x6: // Shop Seite Veröffentlichen
	{
		zKlient->sendeEncrypted("\1", 1);
		if (!startShopUpdate())
			return 0;
		else
			zKlient->sendeEncrypted("\1", 1);
		return 1;
	}
	case 0x7: // Shop Seite Nachricht
	{
		zKlient->sendeEncrypted("\1", 1);
		if (!shop->prozessMessage(zKlient))
			fehler = shop->getLetzterFehler();
		else
			return 1;
		return 0;
	}
	case 0x8: // Shop Seite herunterladen
	{
		zKlient->sendeEncrypted("\1", 1);
		RCArray< Text >* list = new RCArray< Text >();
		Text pf = pfad->getText();
		pf += "/live/shop";
		int anz = findeDateien(pf, list);
		zKlient->sendeEncrypted((char*)&anz, 4);
		for (int i = 0; i < anz; i++)
		{
			Text p = list->z(i)->getText();
			char l = (char)(p.getLength() - pf.getLength());
			zKlient->sendeEncrypted(&l, 1);
			zKlient->sendeEncrypted(p + pf.getLength(), l);
			Datei d;
			d.setDatei(p);
			__int64 size = d.getSize();
			zKlient->sendeEncrypted((char*)&size, 8);
			d.open(Datei::Style::lesen);
			char* buffer = new char[2048];
			while (size > 0)
			{
				int l = size > 2048 ? 2048 : (int)size;
				d.lese(buffer, l);
				zKlient->sende(buffer, l);
				size -= l;
			}
			delete[] buffer;
			d.close();
		}
		list->release();
		return 1;
	}
	case 0x9: // Shop Daten laden
	{
		int es = 0, tp = 0, vp = 0;
		if (!db->getKarteShopDaten(id, es, tp, vp))
		{
			fehler = "Fehler beim laden der Shop Informationen.";
			return 0;
		}
		zKlient->sendeEncrypted("\1", 1);
		zKlient->sendeEncrypted((char*)&es, 4);
		zKlient->sendeEncrypted((char*)&tp, 4);
		zKlient->sendeEncrypted((char*)&vp, 4);
		return 1;
	}
	case 0xA: // Set Shop Daten
	{
		zKlient->sendeEncrypted("\1", 1);
		int es = 0, tp = 0, vp = 0;
		zKlient->getNachrichtEncrypted((char*)&es, 4);
		zKlient->getNachrichtEncrypted((char*)&tp, 4);
		zKlient->getNachrichtEncrypted((char*)&vp, 4);
		if (db->setKarteShopDaten(id, es, tp, vp))
		{
			zKlient->sendeEncrypted("\1", 1);
			return 1;
		}
		fehler = "Fehler beim setzen der Shop Werte.";
		return 0;
	}
	case 0xB: // Beschreibung Nachricht
	{
		zKlient->sendeEncrypted("\1", 1);
		if (!beschreibung->prozessMessage(zKlient))
			fehler = beschreibung->getLetzterFehler();
		else
			return 1;
		return 0;
	}
	case 0xC: // Teams Nachricht
	{
		zKlient->sendeEncrypted("\1", 1);
		if (!teams->prozessMessage(zKlient))
			fehler = teams->getLetzterFehler();
		else
			return 1;
		return 0;
	}
	case 0xD: // Dateien Nachicht
	{
		zKlient->sendeEncrypted("\1", 1);
		if (!dateien->prozessMessage(zKlient))
			fehler = dateien->getLetzterFehler();
		else
			return 1;
		return 0;
	}
	case 0xE: // Init Editor
	{
		if (editorDll)
		{
			if (editor)
				editor = (ESEditorV*)editor->release();
			FreeLibrary(editorDll);
		}
		if (!ini->wertExistiert("SpielePfad"))
		{
			fehler = "Diese Option ist noch nicht verfügbar. Error Code: " __FILE__ ":";
			fehler += __LINE__;
			return 0;
		}
		Text pf = ini->zWert("SpielePfad")->getText();
		pf += "/";
		int said = db->getSpielArtId(id);
		if (!said)
		{
			fehler = "Diese Option ist noch nicht verfügbar. Error Code: " __FILE__ ":";
			fehler += __LINE__;
			return 0;
		}
		pf += said;
		pf += "/bin/game";
		pf += ".so";
		editorDll = LoadLibrary(pf.getText());
		if (!editorDll)
		{
			fehler = "Diese Option ist noch nicht verfügbar. Error Code: " __FILE__ ":";
			fehler += __LINE__;
			return 0;
		}
		DllStart getEditorKlasse = (DllStart)GetProcAddress(editorDll, "getEditorKlasse");
		if (!getEditorKlasse)
		{
			fehler = "Diese Option ist noch nicht verfügbar. Error Code: " __FILE__ ":";
			fehler += __LINE__;
			FreeLibrary(editorDll);
			editorDll = 0;
			return 0;
		}
		editor = getEditorKlasse();
		if (!editor)
		{
			fehler = "Diese Option ist noch nicht verfügbar. Error Code: " __FILE__ ":";
			fehler += __LINE__;
			FreeLibrary(editorDll);
			editorDll = 0;
			return 0;
		}
		zKlient->sendeEncrypted("\1", 1);
		Text p = pfad->getText();
		p += "/live";
		editor->setPfad(p);
		editor->open();
		return 1;
	}
	case 0xF:
	{ // Editor Nachricht
		if (!editor)
		{
			fehler = "Der Editor wurde nicht initialisiert. Error Code: " __FILE__ ":";
			fehler += __LINE__;
			editorDll = 0;
			return 0;
		}
		zKlient->sendeEncrypted("\1", 1);
		if (!editor->nachricht(zKlient))
			fehler = editor->getLetzterFehler();
		else
			return 1;
		return 0;
	}
	case 0x10:
	{ // Get Verkauf Statistik
		Array< int > einkommen;
		Array< int > verkauft;
		Array< int > spiele;
		if (db->getLast30DaysIncomeStatistik(id, &einkommen, &verkauft) && db->getLast30DaysSpielStatistik(id, &spiele))
		{
			zKlient->sendeEncrypted("\1", 1);
			int kaufAnz = db->getKaufAnz(id);
			zKlient->sendeEncrypted((char*)&kaufAnz, 4);
			char anz = (char)einkommen.getEintragAnzahl();
			zKlient->sendeEncrypted(&anz, 1);
			for (int i = 0; i < anz; i++)
			{
				int kupfer = einkommen.get(i);
				int kauf = verkauft.get(i);
				int games = spiele.get(i);
				zKlient->sendeEncrypted((char*)&kupfer, 4);
				zKlient->sendeEncrypted((char*)&kauf, 4);
				zKlient->sendeEncrypted((char*)&games, 4);
			}
			return 1;
		}
		fehler = "Die Statistik konnte nicht erstellt werden.";
		return 0;
	}
	default:
		fehler = "Unbekannte Nachricht. Eventuell ist der Client nicht auf dem neusten Stand.";
	}
	return 0;
}

void KarteEditor::removeError()
{
	fehler = "";
}

// constant
bool KarteEditor::inUpdate() const
{
	return db->istKarteInUpdate(id);
}

bool KarteEditor::istOk() const
{
	return fehler.getLength() == 0;
}

const char* KarteEditor::getLetzterFehler() const
{
	return fehler;
}

const char* KarteEditor::getPfad() const
{
	return pfad->getText();
}