#ifndef EFSW_FILEWATCHERFSEVENTS_HPP
#define EFSW_FILEWATCHERFSEVENTS_HPP

#include <efsw/FileWatcherImpl.hpp>

#if EFSW_PLATFORM == EFSW_PLATFORM_FSEVENTS

#include <CoreFoundation/CoreFoundation.h>
#include <CoreServices/CoreServices.h>
#include <dispatch/dispatch.h>
#include <efsw/WatcherFSEvents.hpp>
#include <map>
#include <vector>
#include <condition_variable>
#include <mutex>

namespace efsw {

/// Implementation for Win32 based on ReadDirectoryChangesW.
/// @class FileWatcherFSEvents
class FileWatcherFSEvents : public FileWatcherImpl {
	friend class WatcherFSEvents;

  public:
	/// @return If FSEvents supports file-level notifications ( true if OS X >= 10.7 )
	static bool isGranular();

	/// type for a map from WatchID to WatcherWin32 pointer
	typedef std::map<WatchID, WatcherFSEvents*> WatchMap;

	FileWatcherFSEvents( FileWatcher* parent );

	virtual ~FileWatcherFSEvents();

	/// Add a directory watch
	/// On error returns WatchID with Error type.
	WatchID addWatch( const std::string& directory, FileWatchListener* watcher, bool recursive,
	                  const std::vector<WatcherOption> &options ) override;

	/// Remove a directory watch. This is a brute force lazy search O(nlogn).
	void removeWatch( const std::string& directory ) override;

	/// Remove a directory watch. This is a map lookup O(logn).
	void removeWatch( WatchID watchid ) override;

	/// Updates the watcher. Must be called often.
	void watch() override;

	/// Handles the action
	void handleAction( Watcher* watch, const std::string& filename, unsigned long action,
					   std::string oldFilename = "" ) override;

	/// @return Returns a list of the directories that are being watched
	std::vector<std::string> directories() override;

  protected:
	static void FSEventCallback( ConstFSEventStreamRef streamRef, void* userData, size_t numEvents,
								 void* eventPaths, const FSEventStreamEventFlags eventFlags[],
								 const FSEventStreamEventId eventIds[] );

	/// Vector of WatcherWin32 pointers
	WatchMap mWatches;

	/// The last watchid
	WatchID mLastWatchID;

	Mutex mWatchesLock;

	bool pathInWatches( const std::string& path ) override;

	std::mutex mWatchesMutex;
	std::condition_variable mWatchCond;

};

} // namespace efsw

#endif

#endif