/* ** © 2020 by Philipp Dunkel, Ben Noordhuis, Elan Shankar, Paul Miller ** Licensed under MIT License. */ /* jshint node:true */ "use strict"; if (process.platform !== "darwin") { throw new Error(`Module 'fsevents' is not compatible with platform '${process.platform}'`); } const Native = require("./fsevents.node"); const events = Native.constants; function watch(path, since, handler) { if (typeof path !== "string") { throw new TypeError(`fsevents argument 1 must be a string and not a ${typeof path}`); } if ("function" === typeof since && "undefined" === typeof handler) { handler = since; since = Native.flags.SinceNow; } if (typeof since !== "number") { throw new TypeError(`fsevents argument 2 must be a number and not a ${typeof since}`); } if (typeof handler !== "function") { throw new TypeError(`fsevents argument 3 must be a function and not a ${typeof handler}`); } let instance = Native.start(Native.global, path, since, handler); if (!instance) throw new Error(`could not watch: ${path}`); return () => { const result = instance ? Promise.resolve(instance).then(Native.stop) : Promise.resolve(undefined); instance = undefined; return result; }; } function getInfo(path, flags) { return { path, flags, event: getEventType(flags), type: getFileType(flags), changes: getFileChanges(flags), }; } function getFileType(flags) { if (events.ItemIsFile & flags) return "file"; if (events.ItemIsDir & flags) return "directory"; if (events.ItemIsSymlink & flags) return "symlink"; } function anyIsTrue(obj) { for (let key in obj) { if (obj[key]) return true; } return false; } function getEventType(flags) { if (events.ItemRemoved & flags) return "deleted"; if (events.ItemRenamed & flags) return "moved"; if (events.ItemCreated & flags) return "created"; if (events.ItemModified & flags) return "modified"; if (events.RootChanged & flags) return "root-changed"; if (events.ItemCloned & flags) return "cloned"; if (anyIsTrue(flags)) return "modified"; return "unknown"; } function getFileChanges(flags) { return { inode: !!(events.ItemInodeMetaMod & flags), finder: !!(events.ItemFinderInfoMod & flags), access: !!(events.ItemChangeOwner & flags), xattrs: !!(events.ItemXattrMod & flags), }; } exports.watch = watch; exports.getInfo = getInfo; exports.constants = events;