# HG changeset patch
# User Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
# Date 1288575664 -3600
# Node ID a36a514e8be8b97889ea3f7799449f75ec749292
# Parent  f2e9365bc8ec9781fbe4ae4f4ca15e3ae6a0c5d5
Learned that “hg addremove” can be good, sometimes.

diff --git a/backends/directory.js b/backends/directory.js
new file mode 100644
--- /dev/null
+++ b/backends/directory.js
@@ -0,0 +1,136 @@
+/*
+ *  Copyright (C) 2010  Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
+ *
+ *  This file is part of PSĜS, a PubSub server written in JavaScript.
+ *
+ *  PSĜS is free software: you can redistribute it and/or modify
+ *  it under the terms of the GNU Affero General Public License as
+ *  published by the Free Software Foundation, either version 3 of the
+ *  License.
+ *
+ *  PSĜS is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU Affero General Public License for more details.
+ *
+ *  You should have received a copy of the GNU Affero General Public License
+ *  along with PSĜS.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+var fs = require('fs');
+var backend = exports;
+
+backend.save = function(dir) {
+	if (!dir)
+		dir = 'storage';
+
+	fs.stat(dir, function(err, stats) {
+		if (err)
+			fs.mkdir(dir, 0755);
+		else if (!stats.isDirectory()) {
+			console.log('\033[1;41mThe file “' + dir + '” isn’t a directory. Exiting.\033[0m');
+			process.exit(1);
+		}
+
+		fs.readdir(dir, function(err, files) {
+			function sanitize(o) {
+				var n = {};
+				for (var i in o) {
+					if (i == 'content' || o[i].setISO8601)
+						n[i] = o[i].toString();
+					else if (o[i] instanceof Array)
+						n[i] = o[i];
+					else if (typeof o[i] == 'object')
+						n[i] = sanitize(o[i]);
+					else if (typeof o[i] == 'function')
+						;
+					else
+						n[i] = o[i];
+				}
+				return n;
+			}
+			var data = sanitize(backend.list);
+
+			var inspect = require('sys').inspect;
+
+			var toDelete = [];
+
+			for (var i in files) {
+				var nodeID = files[i];
+				if (nodeID in data) {
+					fs.writeFile(dir+'/'+nodeID+'.json', inspect(data[nodeID], false, null));
+					delete data[nodeID];
+				} else
+					toDelete.push(nodeID);
+			}
+
+			for (var nodeID in data) {
+				inspect(nodeID);
+				inspect(data[nodeID]);
+				fs.writeFile(dir+'/'+nodeID+'.json', inspect(data[nodeID], false, null));
+			}
+
+			for (var nodeID in toDelete) {
+				fs.unlink(toDelete[nodeID]);
+			}
+		});
+	});
+}
+
+backend.load = function(dir) {
+	if (!dir)
+		dir = 'storage';
+
+	fs.stat(dir, function(err, stats) {
+		if (err)
+			fs.mkdir(dir, 0755);
+		else if (!stats.isDirectory()) {
+			console.log('\033[1;41mThe file “' + dir + '” isn’t a directory. Exiting.\033[0m');
+			process.exit(1);
+		}
+
+		fs.readdir(dir, function(err, files) {
+			var xmpp = require('xmpp');
+			function parseStanza(path, content) {
+				var stanza = null;
+				var stream = new xmpp.Stream({
+					stanza: function (stanza) {
+						path[content] = stanza;
+					}
+				});
+				stream.opened = true;
+				stream.data(path[content]);
+			}
+
+			function endParsing(o) {
+				var regexp = /\d{4}-\d\d-\d\dT\d\d:\d\d:\d\dZ/;
+				for (var i in o) {
+					if (typeof o[i] == 'string' && i == 'content')
+						parseStanza(o, i);
+					else if (typeof o[i] == 'string' && regexp(o[i])) {
+						var today = new Date();
+						today.setISO8601(o[i]);
+						o[i] = today;
+					} else if (typeof o[i] == 'object')
+						endParsing(o[i]);
+				}
+				return o;
+			}
+
+			backend.list = {};
+
+			for (var i in files) {
+				var file = files[i];
+				var nodeID = file.replace(/\.json$/, '');
+
+				var data = fs.readFileSync(dir+'/'+file);
+
+				var obj = eval('('+data+')');
+				backend.list[nodeID] = endParsing(obj);
+
+				for (var j in Node.prototype)
+					backend.list[nodeID][j] = Node.prototype[j];
+			}
+		});
+	});
+}
diff --git a/backends/file.js b/backends/file.js
new file mode 100644
--- /dev/null
+++ b/backends/file.js
@@ -0,0 +1,96 @@
+/*
+ *  Copyright (C) 2010  Emmanuel Gil Peyrot <linkmauve@linkmauve.fr>
+ *
+ *  This file is part of PSĜS, a PubSub server written in JavaScript.
+ *
+ *  PSĜS is free software: you can redistribute it and/or modify
+ *  it under the terms of the GNU Affero General Public License as
+ *  published by the Free Software Foundation, either version 3 of the
+ *  License.
+ *
+ *  PSĜS is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU Affero General Public License for more details.
+ *
+ *  You should have received a copy of the GNU Affero General Public License
+ *  along with PSĜS.  If not, see <http://www.gnu.org/licenses/>.
+ */
+
+var fs = require('fs');
+var backend = exports;
+
+backend.save = function(file) {
+	function sanitize(o) {
+		var n = {};
+		for (var i in o) {
+			if (i == 'content' || o[i].setISO8601)
+				n[i] = o[i].toString();
+			else if (o[i] instanceof Array)
+				n[i] = o[i];
+			else if (typeof o[i] == 'object')
+				n[i] = sanitize(o[i]);
+			else if (typeof o[i] == 'function')
+				;
+			else
+				n[i] = o[i];
+		}
+		return n;
+	}
+
+	var data = sanitize(backend.list);
+
+	if (!file)
+		file = 'save.json';
+
+	fs.writeFile(file, require('sys').inspect(data, null, null));
+}
+
+backend.load = function(file) {
+	var xmpp = require('xmpp');
+	function parseStanza(path, content) {
+		var stanza = null;
+		var stream = new xmpp.Stream({
+			stanza: function (stanza) {
+				path[content] = stanza;
+			}
+		});
+		stream.opened = true;
+		stream.data(path[content]);
+	}
+
+	function endParsing(o) {
+		var regexp = /\d{4}-\d\d-\d\dT\d\d:\d\d:\d\dZ/;
+		for (var i in o) {
+			if (typeof o[i] == 'string' && i == 'content')
+				parseStanza(o, i);
+			else if (typeof o[i] == 'string' && regexp(o[i])) {
+				var today = new Date();
+				today.setISO8601(o[i]);
+				o[i] = today;
+			} else if (typeof o[i] == 'object')
+				endParsing(o[i]);
+		}
+		return o;
+	}
+
+	if (!file)
+		file = 'save.json';
+
+	fs.stat(file, function(err, stats) {
+		if (err)
+			fs.writeFileSync(file, '{}');
+		else if (!stats.isFile()) {
+			console.log('\033[1;41mThe file “' + file + '” isn’t a regular file. Exiting.\033[0m');
+			process.exit(1);
+		}
+
+		var data = fs.readFileSync(file);
+		var obj = eval('('+data+')');
+		backend.list = endParsing(obj);
+
+		for (var i in backend.list)
+			for (var j in Node.prototype)
+				backend.list[i][j] = Node.prototype[j];
+	});
+}
diff --git a/save.json b/save.json
deleted file mode 100644
--- a/save.json
+++ /dev/null
@@ -1,1 +0,0 @@
-{}