FileSystemWatcher.h

/*
Copyright (c) 2026 Alexandr Kuzmuk
 
This file is part of the AsyncFw project. Licensed under the MIT License.
See {Link: LICENSE file https://mit-license.org} in the project root for full license information.
*/
 
#pragma once
 
#include <string>
#include "../core/FunctionConnector.h"
#include "../main/Instance.h"
 
namespace AsyncFw {
class FileSystemWatcher {
  friend LogStream &operator<<(LogStream &, const FileSystemWatcher &);
 
public:
  static FileSystemWatcher *instance() { return instance_.value; }
  FileSystemWatcher(const std::vector<std::string> & = {});
  ~FileSystemWatcher();
  bool addPath(const std::string &path);
  bool addPaths(const std::vector<std::string> &paths);
  bool removePath(const std::string &path);
  bool removePaths(const std::vector<std::string> &paths);
  std::vector<std::string> paths() const;

  FunctionConnectorProtected<FileSystemWatcher>::Connector<const std::string &, int> notify;
 
private:
  inline static AsyncFw::Instance<FileSystemWatcher> instance_ {"FileSystemWatcher"};
  struct WatchPath {
    WatchPath() = default;
    WatchPath(const std::string &);
    std::string directory;
    std::string name;
  };
  struct Watch : public WatchPath {
    using WatchPath::WatchPath;
    int d;
  };
  std::vector<Watch *> files_;
  std::vector<Watch *> wds_;
  int notifyfd_;
  AbstractThread *thread_;
 
  int timerid_;
  std::vector<const Watch *> we_;
  void append_(const Watch *);
  void remove_(const Watch *);
  struct CompareWatch {
    bool operator()(const Watch *, const Watch *) const;
    bool operator()(const WatchPath &, const Watch *) const;
    bool operator()(const Watch *, const WatchPath &) const;
  };
  struct CompareWatchDescriptor {
    bool operator()(const Watch *, const Watch *) const;
    bool operator()(const Watch *, int) const;
  };
};
}  // namespace AsyncFw