Handle atomic writes when using fsevents

Closes gh-161
paulmillr · Oct 19, 2014 · 95c6dfc · 95c6dfc
1 parent 30a7d9e
commit 95c6dfc
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/index.js b/index.js
@@ -240,7 +240,10 @@ FSWatcher.prototype._watchWithFsEvents = function(watchPath) {
       if (event === 'add') {
         this._addToWatchedDir(parent, item);
       } else if (event === 'unlink') {
-        this._remove(parent, item);
+        // suppress unlink events on never before seen files (from atomic write)
+        if (info.type === 'directory' || watchedDir.indexOf(item) !== -1) {
+          this._remove(parent, item);
+        }
         return; // Don't emit event twice.
       }
       var eventName = info.type === 'file' ? event : event + 'Dir';
@@ -276,7 +279,7 @@ FSWatcher.prototype._watchWithFsEvents = function(watchPath) {
       return handleEvent('unlink');
     case 'moved':
       return fs.stat(path, function(error, stats) {
-        handleEvent(stats ? flags === 72960 ? 'change' : 'add' : 'unlink');
+        stats ? addOrChange() : handleEvent('unlink');
       });
     }
   }.bind(this));