Function WatcherThread

src/Utils/Config/LuaFileWatcher.cpp:121–197

}

void WatcherThread() {
    const size_t numDirs = g_watchDirs.size();
    std::vector<OSTPlatform::DirectoryWatch::Watch> watches(numDirs);
    std::vector<OSTPlatform::DirectoryWatch::Watch*> watchPtrs(numDirs, nullptr);

    for (size_t i = 0; i < numDirs; ++i) {
        if (!watches[i].Open(g_watchDirs[i], 65536)) {
            LOG_PACKAGE_WARN("Failed to open Lua watch directory: {}", g_watchDirs[i]);
            continue;
        }
        if (!watches[i].IssueRead()) {
            watches[i].Cancel();
            continue;
        }

        watchPtrs[i] = &watches[i];
        LOG_PACKAGE_DEBUG("Watching Lua directory: {}", g_watchDirs[i]);
    }

    bool allFailed = true;
    for (auto* watch : watchPtrs) {
        if (watch && watch->IsOpen()) {
            allFailed = false;
            break;
        }
    }
    if (allFailed) {
        LOG_PACKAGE_WARN("No Lua watch directories could be opened");
        return;
    }

    auto drainEvent = [&](size_t idx,
                          std::unordered_map<std::string, ChangeAction>& accumulated,
                          std::vector<std::string>& order) {
        auto* watch = idx < watchPtrs.size() ? watchPtrs[idx] : nullptr;
        if (!watch || !watch->IsOpen()) return;

        MergeChanges(accumulated, order, ToFileChanges(g_watchDirs[idx], watch->Drain()));
        watch->IssueRead();
    };

    while (g_running) {
        auto waitResult = OSTPlatform::DirectoryWatch::WaitAny(watchPtrs, 1000);

        if (!g_running) break;
        if (waitResult.status == OSTPlatform::DirectoryWatch::WaitStatus::Timeout) continue;
        if (waitResult.status != OSTPlatform::DirectoryWatch::WaitStatus::Signaled ||
            waitResult.index >= numDirs) {
            continue;
        }

        std::unordered_map<std::string, ChangeAction> accumulated;
        std::vector<std::string> order;

        drainEvent(waitResult.index, accumulated, order);

        while (g_running) {
            auto debounceResult = OSTPlatform::DirectoryWatch::WaitAny(watchPtrs, kDebounceMs);