syncer.h

Go to the documentation of this file.

#pragma once
 
#include "filesystem.h"
#include <atomic>
#include <functional>
#include <mutex>
#include <string>
#include <unordered_map>
#include <vector>
 
namespace fs
{
class syncer
{
public:
    using rename_pair_t = std::pair<fs::path, fs::path>;
 
    using on_sync_progress_t = std::function<void(size_t completed, size_t total, const std::string& current_job)>;
    using on_entry_created_t = std::function<void(const std::string&, const fs::path&, const std::vector<fs::path>&, bool)>;
    using on_entry_modified_t = std::function<void(const std::string&, const fs::path&, const std::vector<fs::path>&, bool)>;
    using on_entry_removed_t = std::function<void(const std::string&, const fs::path&, const std::vector<fs::path>&)>;
    using on_entry_renamed_t = std::function<void(const std::string&, const rename_pair_t&, const std::vector<rename_pair_t>&)>;
 
    struct mapping
    {
        std::vector<std::string> extensions;
        on_entry_created_t on_entry_created;
        on_entry_modified_t on_entry_modified;
        on_entry_removed_t on_entry_removed;
        on_entry_renamed_t on_entry_renamed;
    };
    using mapping_t = std::unordered_map<std::string, mapping>;
 
    syncer() = default;
    ~syncer();
 
    //-----------------------------------------------------------------------------
    //  Name : set_mapping ()
    //-----------------------------------------------------------------------------
    void set_mapping(const std::string& ref_ext,
                     const std::vector<std::string>& synced_ext,
                     on_entry_created_t on_entry_created,
                     on_entry_modified_t on_entry_modified,
                     on_entry_removed_t on_entry_removed,
                     on_entry_renamed_t on_entry_renamed);
 
    void set_directory_mapping(on_entry_created_t on_entry_created,
                               on_entry_modified_t on_entry_modified,
                               on_entry_removed_t on_entry_removed,
                               on_entry_renamed_t on_entry_renamed);
 
    //-----------------------------------------------------------------------------
    //  Name : sync ()
    //-----------------------------------------------------------------------------
    void sync(const fs::path& reference_dir, const fs::path& synced_dir, const on_sync_progress_t& on_progress = nullptr);
 
    //-----------------------------------------------------------------------------
    //  Name : unsync ()
    //-----------------------------------------------------------------------------
    void unsync();
 
private:
    auto get_mapping(const std::string& ext) -> mapping;
    auto get_on_created_callback(const std::string& ext) -> on_entry_created_t;
    auto get_on_modified_callback(const std::string& ext) -> on_entry_modified_t;
    auto get_on_removed_callback(const std::string& ext) -> on_entry_removed_t;
    auto get_on_renamed_callback(const std::string& ext) -> on_entry_renamed_t;
    //-----------------------------------------------------------------------------
    //  Name : get_synced_directory ()
    //-----------------------------------------------------------------------------
    auto get_synced_directory(const fs::path& path) -> fs::path;
 
    //-----------------------------------------------------------------------------
    //  Name : get_path_protocols ()
    //-----------------------------------------------------------------------------
    auto get_synced_entries(const fs::path& path, bool is_directory) -> std::vector<fs::path>;
 
    //-----------------------------------------------------------------------------
    //  Name : get_watch_path ()
    //-----------------------------------------------------------------------------
    auto get_watch_path() -> fs::path;
 
    std::mutex mutex_;
    mapping_t mapping_;
    fs::path reference_dir_;
    fs::path synced_dir_;
 
    std::atomic<std::uint64_t> watch_id_ = {0};
};
 
} // namespace fs