mirror of
https://github.com/amark/gun.git
synced 2025-03-30 15:08:33 +00:00
c35ae5e669
Since the file.js module is only for development or getting started, we shouldn't have to minify the data before persisting it. In fact, it may hurt things, since it obfuscates our data structure and makes it harder to understand what's going on under the hood. In this commit, I swapped `Gun.text.ify` with JSON's `stringify` and gave it a 2-space formatting option to make the data more readable.
94 lines
2.7 KiB
JavaScript
94 lines
2.7 KiB
JavaScript
// This was written by the wonderful Forrest Tait
|
|
// modified by Mark to be part of core for convenience
|
|
// twas not designed for production use
|
|
// only simple local development.
|
|
var Gun = require('../gun'),
|
|
file = {};
|
|
|
|
Gun.on('opt').event(function(gun, opts) {
|
|
if ((opts.file === false) || (opts.s3 && opts.s3.key)) {
|
|
return; // don't use this plugin if S3 is being used.
|
|
}
|
|
console.log("WARNING! This `file.js` module for gun is intended only for local development testing!")
|
|
opts.file = opts.file || 'data.json';
|
|
var fs = require('fs');
|
|
file.raw = file.raw || (fs.existsSync || require('path').existsSync)(opts.file) ? fs.readFileSync(opts.file).toString() : null;
|
|
var all = file.all = file.all || Gun.obj.ify(file.raw || {
|
|
nodes: {},
|
|
keys: {}
|
|
});
|
|
all.keys = all.keys || {};
|
|
all.nodes = all.nodes || {};
|
|
|
|
// queue writes, adapted from https://github.com/toolness/jsondown/blob/master/jsondown.js
|
|
var isWriting = false, queuedWrites = [];
|
|
function writeFile(cb) {
|
|
if(isWriting) return queuedWrites.push(cb);
|
|
isWriting = true;
|
|
var contents = JSON.stringify(all, null, 2);
|
|
fs.writeFile(opts.file, contents, function(err) {
|
|
var batch = queuedWrites.splice(0);
|
|
isWriting = false;
|
|
cb(err);
|
|
if(batch.length)
|
|
writeFile( function(err) {
|
|
batch.forEach( function(cb) { cb(err); } )
|
|
});
|
|
});
|
|
}
|
|
|
|
gun.opt({wire: {
|
|
get: function get(key, cb, o){
|
|
var node, soul = key;
|
|
node = all.nodes[soul];
|
|
if(!node){ return cb(null, null) }
|
|
cb(null, node);
|
|
node = Gun.is.node.ify({_: node._}, soul);
|
|
cb(null, node); // end.
|
|
cb(null, {}); // done.
|
|
},
|
|
put: function(graph, cb, o){
|
|
for (key in gun.__.graph) all.nodes[key]=gun.__.graph[key]||graph[key];
|
|
writeFile(cb);
|
|
}/*,
|
|
all: function(list, opt, cb) {
|
|
opt = opt || {};
|
|
opt.from = opt.from || '';
|
|
opt.start = opt.from + (opt.start || '');
|
|
if(opt.end){ opt.end = opt.from + opt.end }
|
|
var match = {};
|
|
cb = cb || function(){};
|
|
Gun.obj.map(list, function(soul, key){
|
|
var end = opt.end || key;
|
|
if(key.indexOf(opt.from) === 0 && opt.start <= key && (key <= end || key.indexOf(end) === 0)){
|
|
if(opt.upto){
|
|
if(key.slice(opt.from.length).indexOf(opt.upto) === -1){
|
|
yes(soul, key);
|
|
}
|
|
} else {
|
|
yes(soul, key);
|
|
}
|
|
}
|
|
});
|
|
function yes(soul, key){
|
|
cb(key);
|
|
match[key] = {};
|
|
match[key][Gun._.soul] = soul;
|
|
}
|
|
return match;
|
|
}*/
|
|
}}, true);
|
|
gun.all = gun.all || function(url, cb) {
|
|
url = require('url').parse(url, true);
|
|
var r = gun.__.opt.wire.all(all.keys, {
|
|
from: url.pathname,
|
|
upto: url.query['*'],
|
|
start: url.query['*>'],
|
|
end: url.query['*<']
|
|
});
|
|
console.log("All please", url.pathname, url.query['*'], r);
|
|
cb = cb || function() {};
|
|
cb(null, r);
|
|
}
|
|
}, 100);
|