RecursiveWatch.hpp

#pragma once
#include <ossia/detail/string_map.hpp>
 
#include <QDebug>
#include <QDir>
#include <QString>
 
#include <score_lib_base_export.h>
#include <smallfun.hpp>
 
#include <functional>
#include <memory>
#include <vector>
 
class QObject;
 
namespace score
{
class SCORE_LIB_BASE_EXPORT RecursiveWatch
{
public:
  struct Callbacks
  {
    std::function<void(std::string_view)> added;
    std::function<void(std::string_view)> removed;
  };
 
  struct Watched
  {
    std::string ext;
    Callbacks callbacks;
  };
 
  struct AsyncCallbacks
  {
    using Filter = smallfun::function<
        std::function<void()>(std::string_view),
#if defined(_MSC_VER) && !defined(NDEBUG)
        128,
#else
        64,
#endif
        smallfun::DefaultAlign, smallfun::Methods::Move>;
 
    Filter filter;
  };
 
  void setWatchedFolder(std::string root) { m_root = root; }
 
  void registerWatch(std::string extension, Callbacks callbacks)
  {
    m_watched[extension].push_back(std::move(callbacks));
  }
 
  void registerWatch(std::string extension, AsyncCallbacks callbacks)
  {
    m_asyncWatched[extension].push_back(std::move(callbacks));
  }
 
  void scan() const;
 
  void scanAsync(QObject* context);
 
  void cancelAsync() noexcept;
 
  void reset();
 
  static void cancelAll() noexcept;
 
  RecursiveWatch();
  RecursiveWatch(const RecursiveWatch&) = delete;
  RecursiveWatch& operator=(const RecursiveWatch&) = delete;
  ~RecursiveWatch();
 
  struct AsyncScan;
 
private:
  std::string m_root;
  ossia::string_map<std::vector<Callbacks>> m_watched;
  ossia::string_map<std::vector<AsyncCallbacks>> m_asyncWatched;
  std::shared_ptr<AsyncScan> m_scan;
};
 
SCORE_LIB_BASE_EXPORT
void for_all_files(std::string_view root, std::function<void(std::string_view)> f);
}