/*
Copyright 2021-2023 Peter Repukat - FlatspotSoftware

Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/

#include <httplib.h>

#include "../common/util.h"


#include <filesystem>

#include <spdlog/sinks/basic_file_sink.h>
#include <spdlog/sinks/stdout_color_sinks.h>
#include <spdlog/spdlog.h>

#include <nlohmann/json.hpp>


#include "../version.hpp"
#include "../common/Settings.h"
#include "../common/HidHide.h"

bool IsProcessRunning(DWORD pid)
{
	const HANDLE process = OpenProcess(SYNCHRONIZE, FALSE, pid);
	if (process == nullptr)
		return false;
	const DWORD ret = WaitForSingleObject(process, 0);
	CloseHandle(process);
	return ret == WAIT_TIMEOUT;
}

void fetchSettings(httplib::Client& http_client, int retried_count = 0) {
	http_client.set_connection_timeout(1 + (retried_count > 0 ? 2 : 0));

	auto http_res = http_client.Get("/settings");
	if (http_res.error() == httplib::Error::Success && http_res->status == 200)
	{
		const auto json = nlohmann::json::parse(http_res->body);
		spdlog::debug("Received settings from GlosSITarget: {}", json.dump());
		Settings::Parse(json);
	}
	else
	{
		spdlog::error("Couldn't get settings from GlosSITarget. Error: {}", (int)http_res.error());
		if (retried_count < 2)
		{
			spdlog::info("Retrying... {}", retried_count);
			fetchSettings(http_client, retried_count + 1);
		}
	}
}

DWORD WINAPI watchdog(HMODULE hModule)
{
	auto configDirPath = util::path::getDataDirPath();
	auto logPath = configDirPath;
	logPath /= "GlosSIWatchdog.log";
	const auto file_sink = std::make_shared<spdlog::sinks::basic_file_sink_mt>(logPath.wstring(), true);
	std::vector<spdlog::sink_ptr> sinks{ file_sink };
	auto logger = std::make_shared<spdlog::logger>("log", sinks.begin(), sinks.end());
	logger->set_level(spdlog::level::trace);
	logger->flush_on(spdlog::level::trace);
	spdlog::set_default_logger(logger);

	spdlog::info("GlosSIWatchdog loaded");
	spdlog::info("Version: {}", version::VERSION_STR);

	auto glossi_hwnd = FindWindowA(nullptr, "GlosSITarget");
	if (!glossi_hwnd)
	{
		spdlog::error("Couldn't find GlosSITarget window. Exiting...");
		FreeLibraryAndExitThread(hModule, 1);
		return 1;
	}
	spdlog::debug("Found GlosSITarget window; Starting watch loop");

	httplib::Client http_client("http://localhost:8756");

	fetchSettings(http_client);

	std::vector<DWORD> pids;
	while (glossi_hwnd)
	{
		http_client.set_connection_timeout(120);
		const auto http_res = http_client.Get("/launched-pids");
		if (http_res.error() == httplib::Error::Success && http_res->status == 200)
		{
			const auto json = nlohmann::json::parse(http_res->body);
			if (Settings::common.extendedLogging)
			{
				spdlog::trace("Received pids: {}", json.dump());
			}
			pids = json.get<std::vector<DWORD>>();
		}
		else {
			spdlog::error("Couldn't fetch launched PIDs: {}", (int)http_res.error());
		}

		glossi_hwnd = FindWindowA(nullptr, "GlosSITarget");

		Sleep(333);
	}
	spdlog::info("GlosSITarget was closed. Resetting HidHide state...");
	HidHide hidhide;
	hidhide.disableHidHide();

	if (Settings::launch.closeOnExit)
	{
		spdlog::info("Closing launched processes");

		for (const auto pid : pids)
		{
			if (Settings::common.extendedLogging)
			{
				spdlog::debug("Checking if process {} is running", pid);
			}
			if (IsProcessRunning(pid))
			{
				util::win::process::KillProcess(pid);
			}
			else
			{
				if (Settings::common.extendedLogging)
				{
					spdlog::debug("Process {} is not running", pid);
				}
			}
		}
	}

	spdlog::info("Unloading Watchdog...");
	FreeLibraryAndExitThread(hModule, 0);
}

BOOL APIENTRY DllMain(HMODULE hModule,
	DWORD  ul_reason_for_call,
	LPVOID lpReserved
)
{
	if (ul_reason_for_call == DLL_PROCESS_ATTACH)
	{
		CloseHandle(CreateThread(nullptr, 0, (LPTHREAD_START_ROUTINE)watchdog, hModule, 0, nullptr));
	}
	else if (ul_reason_for_call == DLL_PROCESS_DETACH) {
	}
	return TRUE;

	return 0;
}