Rudimentary fs.watch usage in filesystemadaptor

Will only watch for changes on wiki files loaded during startup or created by runtime
    (Does not yet track renames/deletes)
    (Will not notice new files)
  May become confused by directory structure changes on some platforms
    (see node docs on fs.watch for caveats!)
This commit is contained in:
natecain 2013-10-11 17:10:10 -04:00
parent d3d72eff1b
commit ee236060c7
1 changed files with 36 additions and 2 deletions

View File

@ -15,8 +15,30 @@ A sync adaptor module for synchronising with the local filesystem via node.js AP
// Get a reference to the file system
var fs = !$tw.browser ? require("fs") : null;
function FileSystemAdaptor(syncer) {
this.syncer = syncer;
this.watchers = {};
this.pending = {};
this.setwatcher = function(filename, title) {
return this.watchers[filename] = this.watchers[filename] ||
fs.watch(filename, {persistent: false}, function(e) {
console.log("Filesystem:", e, filename);
if(e === "change") {
var tiddlers = $tw.loadTiddlersFromFile(filename).tiddlers;
for(var t in tiddlers) {
$tw.wiki.tiddlers[tiddlers[t].title] = new $tw.Tiddler(tiddlers[t]);
}
}
});
}
for(var f in $tw.boot.files) {
var fileInfo = $tw.boot.files[f];
this.setwatcher(fileInfo.filepath, f);
}
}
FileSystemAdaptor.prototype.getTiddlerInfo = function(tiddler) {
@ -63,6 +85,7 @@ FileSystemAdaptor.prototype.getTiddlerFileInfo = function(tiddler,callback) {
fileInfo.hasMetaFile = typeInfo.hasMetaFile;
// Save the newly created fileInfo
$tw.boot.files[title] = fileInfo;
self.pending[fileInfo.filepath] = title;
// Pass it to the callback
callback(null,fileInfo);
});
@ -96,8 +119,16 @@ FileSystemAdaptor.prototype.generateTiddlerFilename = function(title,extension,e
Save a tiddler and invoke the callback with (err,adaptorInfo,revision)
*/
FileSystemAdaptor.prototype.saveTiddler = function(tiddler,callback) {
var self = this;
this.getTiddlerFileInfo(tiddler,function(err,fileInfo) {
var template, content, encoding;
function _finish() {
if(self.pending[fileInfo.filepath]) {
self.setwatcher(fileInfo.filepath, tiddler.fields.title);
delete self.pending[fileInfo.filepath];
}
callback(null, {}, 0);
}
if(err) {
return callback(err);
}
@ -117,7 +148,7 @@ FileSystemAdaptor.prototype.saveTiddler = function(tiddler,callback) {
return callback(err);
}
console.log("FileSystem: Saved file",fileInfo.filepath);
callback(null,{},0);
_finish();
});
});
} else {
@ -129,7 +160,7 @@ console.log("FileSystem: Saved file",fileInfo.filepath);
return callback(err);
}
console.log("FileSystem: Saved file",fileInfo.filepath);
callback(null,{},0);
_finish();
});
}
});
@ -155,6 +186,9 @@ FileSystemAdaptor.prototype.deleteTiddler = function(title,callback) {
// Don't delete the tiddler if it is on the blacklist
callback(null);
} else {
if(this.watchers[fileInfo.filepath]) {
this.watchers[fileInfo.filepath].close();
}
// Delete the file
fs.unlink(fileInfo.filepath,function(err) {
if(err) {