HotReload.h

浏览该文件的文档.

#pragma once
#include "common/Export.h"
 
 
#include "common/Module.h"
 
#include <atomic>
#include <condition_variable>
#include <cstdint>
#include <deque>
#include <map>
#include <mutex>
#include <string>
#include <thread>
#include <unordered_map>
#include <vector>
 
namespace eve::filesystem {
 
class EVENGINE_API_FOUNDATION HotReload : public Module {
public:
    Module_REG(HotReload);
 
    HotReload() = default;
    ~HotReload() override;
 
    void bind(std::string path, std::string kind = "auto");
    void unbind(std::string path);
 
    bool tryReload(std::string path);
 
    int watchTree(std::string root = ".");
 
    bool watchNewDirectory(std::string path);
 
    bool startRemoteSync(std::string url, int pollMs = 1000);
 
    void stopRemoteSync();
 
    void setRemoteHotDir(std::string dir);
 
    bool isRemoteSyncing() const;
 
    std::string remoteSyncStatus() const;
 
    std::string pollRemoteChange();
 
    static std::string normalizePath(std::string path);
 
private:
    struct RemoteFile {
        std::string path;
        int64_t     size  = -1;
        int64_t     mtime = -1;
    };
 
    // --- Remote sync internals ---
 
    std::string ensureHotDir();
 
    bool mountHotDir();
 
    bool fetchManifest(std::vector<RemoteFile> &out);
 
    bool downloadFile(const std::string &relPath);
 
    void applyManifest(const std::vector<RemoteFile> &manifest);
 
    std::map<std::string, std::pair<int64_t, int64_t>> loadRecord() const;
    void saveRecord(const std::map<std::string, std::pair<int64_t, int64_t>> &record) const;
 
    void syncLoop(int pollMs);
 
    void queueChange(std::string path);
 
    std::unordered_map<std::string, std::string> bindings_;  // norm path → kind
 
    // Remote sync state (guarded by syncMu_).
    mutable std::mutex              syncMu_;
    std::thread             syncThread_;
    std::condition_variable syncCv_;
    std::atomic<bool>       syncRunning_{false};
    bool                    syncStarted_ = false;
    bool                    hotDirMounted_ = false;
    std::string             syncUrl_;
    mutable std::string     syncStatus_ = "idle";
    mutable std::deque<std::string> changedQueue_;
    std::string             hotDir_;
};
 
}  // namespace eve::filesystem