jnpf-web-datascreen-vue3-v6.x/node_modules/.pnpm-store/v3/files/ee/e1da713440119577901daaf956a858b70008ebd1d0d93b88e802a8d7498201272770810750aae4fa54de4e05e43a71d8eccd64b318a57786d273e6a26de747

#ifndef WATCHMAN_H
#define WATCHMAN_H

#include "../Backend.hh"
#include "./BSER.hh"
#include "../Signal.hh"
#include "./IPC.hh"

class WatchmanBackend : public Backend {
public:
  static bool checkAvailable();
  void start() override;
  WatchmanBackend() : mStopped(false) {};
  ~WatchmanBackend();
  void writeSnapshot(WatcherRef watcher, std::string *snapshotPath) override;
  void getEventsSince(WatcherRef watcher, std::string *snapshotPath) override;
  void subscribe(WatcherRef watcher) override;
  void unsubscribe(WatcherRef watcher) override;
private:
  std::unique_ptr<IPC> mIPC;
  Signal mRequestSignal;
  Signal mResponseSignal;
  BSER::Object mResponse;
  std::string mError;
  std::unordered_map<std::string, WatcherRef> mSubscriptions;
  bool mStopped;
  Signal mEndedSignal;

  std::string clock(WatcherRef watcher);
  void watchmanWatch(std::string dir);
  BSER::Object watchmanRequest(BSER cmd);
  void handleSubscription(BSER::Object obj);
};

#endif