#include "data_handler.h"
#include <irrlicht.h>
#include "config.h"
#include "cli_args.h"
#include "utils_gui.h"
#include "deck_manager.h"
#include "replay.h"
#include "logging.h"
#include "fmt.h"
#include "utils.h"
#include "windbot.h"
#include "windbot_panel.h"
#if IRRLICHT_VERSION_MAJOR==1 && IRRLICHT_VERSION_MINOR==9
#include "IrrlichtCommonIncludes1.9/CFileSystem.h"
#else
#include "IrrlichtCommonIncludes/CFileSystem.h"
#endif
#include "porting.h"
#if EDOPRO_ANDROID
#include "Android/COSAndroidOperator.h"
#endif
#if EDOPRO_IOS
#include "iOS/COSiOSOperator.h"
#endif

namespace ygo {

void DataHandler::LoadDatabases() {
	if(Utils::FileExists(EPRO_TEXT("./cards.cdb"))) {
		if(dataManager->LoadDB(EPRO_TEXT("./cards.cdb")))
			WindBot::AddDatabase(EPRO_TEXT("./cards.cdb"));
	}
	for(auto& file : Utils::FindFiles(EPRO_TEXT("./expansions/"), { EPRO_TEXT("cdb") }, 2)) {
		epro::path_string db = EPRO_TEXT("./expansions/") + file;
		if(dataManager->LoadDB(db))
			WindBot::AddDatabase(db);
	}
	LoadArchivesDB();
}
void DataHandler::LoadArchivesDB() {
	for(auto& archive : Utils::archives) {
		std::lock_guard<epro::mutex> guard(*archive.mutex);
		auto files = Utils::FindFiles(archive.archive, EPRO_TEXT(""), { EPRO_TEXT("cdb") }, 3);
		for(auto& index : files) {
			auto reader = archive.archive->createAndOpenFile(index);
			if(reader == nullptr)
				continue;
			dataManager->LoadDB(reader);
			reader->drop();
		}
	}
}

void DataHandler::LoadPicUrls() {
	for(auto& _config : { &configs->user_configs, &configs->configs }) {
		const auto& config = *_config;
		auto it = config.find("urls");
		if(it != config.end() && it->is_array()) {
			for(const auto& obj : *it) {
				try {
					const auto& type = obj.at("type").get_ref<const std::string&>();
					const auto& url = obj.at("url").get_ref<const std::string&>();
					if(url == "default") {
						if(type == "pic") {
#ifdef DEFAULT_PIC_URL
							imageDownloader->AddDownloadResource({ DEFAULT_PIC_URL, imgType::ART });
#else
							continue;
#endif
						} else if(type == "field") {
#ifdef DEFAULT_FIELD_URL
							imageDownloader->AddDownloadResource({ DEFAULT_FIELD_URL, imgType::FIELD });
#else
							continue;
#endif
						} else if(type == "cover") {
#ifdef DEFAULT_COVER_URL
							imageDownloader->AddDownloadResource({ DEFAULT_COVER_URL, imgType::COVER });
#else
							continue;
#endif
						}
					} else {
						imageDownloader->AddDownloadResource({ url, type == "field" ?
																imgType::FIELD : (type == "pic") ?
																imgType::ART : imgType::COVER });
					}
				}
				catch(const std::exception& e) {
					ErrorLog("Exception occurred: {}", e.what());
				}
			}
		}
	}
}
void DataHandler::LoadZipArchives() {
	irr::io::IFileArchive* tmp_archive = nullptr;
	for(auto& file : Utils::FindFiles(EPRO_TEXT("./expansions/"), { EPRO_TEXT("zip") })) {
		filesystem->addFileArchive(epro::format(EPRO_TEXT("./expansions/{}"), file).data(), true, false, irr::io::EFAT_ZIP, "", &tmp_archive);
		if(tmp_archive) {
			Utils::archives.emplace_back(tmp_archive);
		}
	}
}
DataHandler::DataHandler() {
	configs = std::make_unique<GameConfig>();
	gGameConfig = configs.get();
#if !EDOPRO_ANDROID
	tmp_device = GUIUtils::CreateDevice(configs.get());
#endif
#if EDOPRO_IOS
	if(tmp_device->getVideoDriver())
		porting::exposed_data = &tmp_device->getVideoDriver()->getExposedVideoData();
	Utils::OSOperator = new irr::COSiOSOperator();
	configs->ssl_certificate_path = epro::format("{}/cacert.pem", Utils::GetWorkingDirectory());
#elif EDOPRO_ANDROID
	Utils::OSOperator = new irr::COSAndroidOperator();
	configs->ssl_certificate_path = epro::format("{}/cacert.pem", porting::internal_storage);
#else
	Utils::OSOperator = tmp_device->getGUIEnvironment()->getOSOperator();
	Utils::OSOperator->grab();
	if(configs->override_ssl_certificate_path.size()) {
		if(configs->override_ssl_certificate_path != "none" && Utils::FileExists(Utils::ToPathString(configs->override_ssl_certificate_path)))
			configs->ssl_certificate_path = configs->override_ssl_certificate_path;
	} else
		configs->ssl_certificate_path = epro::format("{}/cacert.pem", Utils::ToUTF8IfNeeded(Utils::GetWorkingDirectory()));
#endif
	filesystem = new irr::io::CFileSystem();
	dataManager = std::make_unique<DataManager>();
	auto strings_loaded = dataManager->LoadStrings(EPRO_TEXT("./config/strings.conf"));
	strings_loaded = dataManager->LoadStrings(EPRO_TEXT("./expansions/strings.conf")) || strings_loaded;
	if(!strings_loaded)
		throw std::runtime_error("Failed to load strings!");
	Utils::filesystem = filesystem;
	LoadZipArchives();
	deckManager = std::make_unique<DeckManager>();
	DeckManager::SetDeckFolder(Utils::GetUserFolderPathFor(EPRO_TEXT("./deck/")));
	Replay::SetReplayFolder(Utils::GetUserFolderPathFor(EPRO_TEXT("./replay/")));
	gitManager = std::make_unique<RepoManager>();
	auto sound_backend = SoundManager::DEFAULT;
	if constexpr(SoundManager::HasMultipleBackends()) {
		auto sound_backend_valid = [wanted_backend = configs->sound_backend]() -> bool {
			for(const auto& backend : SoundManager::GetSupportedBackends()) {
				if(backend == wanted_backend)
					return true;
			}
			return false;
		}();
		if(!sound_backend_valid) {
			auto old = std::exchange(configs->sound_backend, SoundManager::DEFAULT);
			epro::print("Wanted {} audio backend but not supported, using {} instead\n", old, SoundManager::GetDefaultBackend());
		}
		sound_backend = configs->sound_backend;
	}
	sounds = std::make_unique<SoundManager>(configs->soundVolume / 100.0, configs->musicVolume / 100.0, configs->enablesound, configs->enablemusic, sound_backend);
	gitManager->ToggleReadOnly(cli_args[REPOS_READ_ONLY].enabled);
	gitManager->LoadRepositoriesFromJson(configs->user_configs);
	gitManager->LoadRepositoriesFromJson(configs->configs);
	if(gitManager->TerminateIfNothingLoaded())
		deckManager->StopDummyLoading();
	imageDownloader = std::make_unique<ImageDownloader>();
	LoadDatabases();
	LoadPicUrls();
	deckManager->LoadLFList();
	dataManager->LoadIdsMapping(EPRO_TEXT("./config/mappings.json"));
}
DataHandler::~DataHandler() {
	if(filesystem)
		filesystem->drop();
	if(Utils::OSOperator)
		Utils::OSOperator->drop();
}

}