12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182 |
- /*
- ** © 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;
|