#include <FileWatcher.hpp>
#include <iostream>
#include <thread>

#ifdef GEODE_IS_WINDOWS

static constexpr auto const notifyAttributes =
    FILE_NOTIFY_CHANGE_LAST_WRITE | FILE_NOTIFY_CHANGE_ATTRIBUTES | FILE_NOTIFY_CHANGE_SIZE;

FileWatcher::FileWatcher(
    ghc::filesystem::path const& file, FileWatchCallback callback, ErrorCallback error
) {
    this->m_filemode = ghc::filesystem::is_regular_file(file);
    auto handle = FindFirstChangeNotificationW(
        (this->m_filemode ? file.parent_path() : file).wstring().c_str(), false, notifyAttributes
    );
    this->m_platform_handle = (void*)handle;

    this->m_file = file;
    this->m_callback = callback;
    this->m_error = error;
    if (handle != INVALID_HANDLE_VALUE) {
        std::thread(&FileWatcher::watch, this).detach();
    }
    else {
        if (this->m_error) this->m_error("Invalid handle");
    }
}

FileWatcher::~FileWatcher() {
    HANDLE handle = (HANDLE)this->m_platform_handle;
    FindCloseChangeNotification(handle);
    this->m_exiting = true;
}

void FileWatcher::watch() {
    HANDLE handle = (HANDLE)this->m_platform_handle;
    while (WaitForSingleObject(handle, 10000) == WAIT_OBJECT_0) {
        if (this->m_exiting) return;
        if (this->m_callback) {
            if (this->m_filemode) {
                auto file = CreateFileW(
                    this->m_file.parent_path().wstring().c_str(), FILE_LIST_DIRECTORY,
                    FILE_SHARE_READ | FILE_SHARE_WRITE | FILE_SHARE_DELETE, nullptr, OPEN_EXISTING,
                    FILE_FLAG_BACKUP_SEMANTICS | FILE_FLAG_OVERLAPPED, nullptr
                );
                if (file == INVALID_HANDLE_VALUE) {
                    handle = nullptr;
                    if (this->m_error) this->m_error("Reading dir failed");
                    return;
                }
                OVERLAPPED overlapped;
                overlapped.hEvent = CreateEvent(NULL, FALSE, 0, NULL);
                std::vector<DWORD> buffer;
                buffer.resize(1024);
                if (!ReadDirectoryChangesW(
                        file, buffer.data(), buffer.size(), false, notifyAttributes, nullptr,
                        &overlapped, nullptr
                    )) {
                    handle = nullptr;
                    if (this->m_error) this->m_error("Reading dir changes failed");
                    return;
                }
                DWORD result = WaitForSingleObject(overlapped.hEvent, 500);
                if (result != WAIT_OBJECT_0 && result != WAIT_TIMEOUT) {
                    handle = nullptr;
                    if (this->m_error) this->m_error("Overlap hEvent was not WAIT_OBJECT_0");
                    return;
                }
                DWORD bytes_transferred;
                GetOverlappedResult(file, &overlapped, &bytes_transferred, FALSE);
                auto info = reinterpret_cast<FILE_NOTIFY_INFORMATION*>(buffer.data());
                do {
                    auto filename = std::wstring(
                        info->FileName, info->FileName + info->FileNameLength / sizeof(wchar_t)
                    );
                    if (ghc::filesystem::exists(this->m_file) &&
                        ghc::filesystem::file_size(this->m_file) > 1000 &&
                        info->Action == FILE_ACTION_MODIFIED &&
                        this->m_file.filename().wstring() == filename) {
                        this->m_callback(this->m_file);
                    }
                } while (info->NextEntryOffset && (info = info + info->NextEntryOffset));
            }
            else {
                this->m_callback(this->m_file);
            }
        }
        if (!FindNextChangeNotification(handle)) {
            handle = nullptr;
            if (this->m_error) this->m_error("FindNextChangeNotification failed");
            return;
        }
    }
    handle = nullptr;
    if (this->m_error) this->m_error("WaitForSingleObject failed");
}

bool FileWatcher::watching() const {
    HANDLE handle = (HANDLE)this->m_platform_handle;
    return handle != INVALID_HANDLE_VALUE && handle != nullptr;
}

#endif