recover.js
2.96 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
var root;
var Gun;
(function(){
var env;
if(typeof global !== 'undefined'){ env = global }
if(typeof window !== 'undefined'){ env = window }
root = env.window? env.window : global;
try{ env.window && root.localStorage && root.localStorage.clear() }catch(e){}
try{ indexedDB.deleteDatabase('radatatest') }catch(e){}
if(root.Gun){
root.Gun = root.Gun;
root.Gun.TESTING = true;
} else {
try{ require('fs').unlinkSync('data.json') }catch(e){}
try{ require('../../lib/fsrm')('radatatest') }catch(e){}
root.Gun = require('../../gun');
root.Gun.TESTING = true;
//require('../lib/file');
require('../../lib/store');
require('../../lib/rfs');
}
try{ var expect = global.expect = require("../expect") }catch(e){}
}(this));
;(function(){
Gun = root.Gun
if(Gun.window && !Gun.window.RindexedDB){ return }
var opt = {};
opt.file = 'radatatest';
var Radisk = (Gun.window && Gun.window.Radisk) || require('../../lib/radisk');
opt.store = ((Gun.window && Gun.window.RindexedDB) || require('../../lib/rfs'))(opt);
opt.chunk = 170;
var Radix = Radisk.Radix;
var rad = Radisk(opt), esc = String.fromCharCode(27);
describe('RAD Crashes', function(){
describe('If No File Added to Index, Recover', function(){
var gun = Gun({chunk: opt.chunk});
it('write initial', function(done){
var all = {}, to, start, tmp;
var names = ['al', 'alex', 'alexander', 'alice'];
names.forEach(function(v,i){
all[++i] = true;
tmp = v.toLowerCase();
gun.get('names').get(tmp).put(i, function(ack){
expect(ack.err).to.not.be.ok();
delete all[i];
if(!Gun.obj.empty(all)){ return }
done();
})
});
});
it('write alan', function(done){
var all = {}, to, start, tmp;
var names = ['alan'];
console.log("DID YOU ADD `Gun.CRASH` != 1%C to Radisk f.write list.add callback?");
Gun.CRASH = true; // add check for this in f.swap!
names.forEach(function(v,i){
all[++i] = true;
tmp = v.toLowerCase();
gun.get('names').get(tmp).put(i);
});
setTimeout(function(){
Gun.CRASH = false;
done();
}, 1000);
});
it('write zach', function(done){
gun.get('names').get('zach').put(9, function(ack){
expect(ack.err).to.not.be.ok();
done() ;
});
});
it('read names', function(done){
console.log("Better to .skip 1st run, .only 2nd run & prevent clearing radatatest.");
var g = Gun();
var all = {al: 1, alex: 2, alexander: 3, alice: 4, zach: 9};
//g.get('names').get('zach').put(9, function(ack){ done() }); return;
g.get('names').map().on(function(v,k){
//console.log("DATA:", k, v);
if(all[k] === v){ delete all[k] }
if(!Gun.obj.empty(all)){ return }
done();
});
});
});
});
}());