FileWatch.h

浏览该文件的文档.

#pragma once
 
#include "common/config.h"
 
#ifndef EVENGINE_WEBGPU
#include <Poco/DirectoryWatcher.h>
#endif
 
#include <memory>
#include <mutex>
#include <string>
#include <unordered_map>
#include <vector>
 
namespace eve::filesystem {
 
class FileWatch {
public:
    struct Event {
        std::string kind;  // "added" | "removed" | "modified" | "movedFrom" | "movedTo"
        std::string path;  // report path (usually the path passed to watch())
        std::string realPath;
    };
 
    FileWatch();
    ~FileWatch();
 
    FileWatch(const FileWatch &) = delete;
    FileWatch &operator=(const FileWatch &) = delete;
 
    bool add(const std::string &realDir, const std::string &filterName, const std::string &reportPath,
             int scanInterval = 1);
 
    bool remove(const std::string &reportPath);
    void clear();
 
    int count() const;
 
    bool poll(Event &out);
 
private:
    struct DirWatch;
 
#ifndef EVENGINE_WEBGPU
    void onAdded(const void *sender, const Poco::DirectoryWatcher::DirectoryEvent &event);
    void onRemoved(const void *sender, const Poco::DirectoryWatcher::DirectoryEvent &event);
    void onModified(const void *sender, const Poco::DirectoryWatcher::DirectoryEvent &event);
    void onMovedFrom(const void *sender, const Poco::DirectoryWatcher::DirectoryEvent &event);
    void onMovedTo(const void *sender, const Poco::DirectoryWatcher::DirectoryEvent &event);
 
    void unsubscribeDelegates(DirWatch *dw);
#endif
 
    void handlePocoEvent(const std::string &kind, const std::string &itemPath);
 
    mutable std::mutex mu_;
    std::vector<Event> queue_;
    std::unordered_map<std::string, std::unique_ptr<DirWatch>> byDir_;
    std::unordered_map<std::string, std::string> reportToDir_;
};
 
}  // namespace eve::filesystem