tweak doc

examples/docs.html

@@ -42,7 +42,7 @@ var gun = Gun(['https://guntest.herokuapp.com/gun', 'http://localhost:8765/gun']
 ;(window.onhashchange = function(){
 	var file = (location.hash||'').slice(1);
 	var S = +new Date;
-	$('#page').empty();
+	$('#page').empty().attr('contenteditable', 'false');
 	gun.get('test/gun/docs/'+file).get('what').map().on(function render(data, i){
 		if(window.LOCK){ return }
 		var p = $('#page').children().get(i);
@@ -68,11 +68,7 @@ meta.edit({
 		if($(eve.target).closest('p').length){ return }
 		var edit = this;
 		setTimeout(function(){ meta.flip(false) },1);
-		var doc = $('#page').attr('contenteditable', 'true');
-		if(!doc.text()){
-			doc.html('<p class="loud crack"></p>');
-		}
-		edit.select(doc.children().first().get(0));
+		edit.init();
 		$(document).on('keydown.tmp', '[contenteditable]', function(eve){
 			if(eve.which != 13){ return }
 			eve.preventDefault();
@@ -94,10 +90,13 @@ meta.edit({
       	edit.save(this);
       });
 		}).on('keyup.tmp', '[contenteditable]', function(eve){
-			$('#debug').val(doc.html());
+			//$('#debug').val(doc.html());
 			var p = $(window.getSelection().anchorNode).closest('p');
 			var r = monotype(p);
 			var html = p.html() || '';
+			if(!html && !p.prev().length && !p.next().length && !$('#page').html()){
+				edit.init();
+			}
 			var safe = $.normalize(html);
 			p.html(safe);
 			r.restore();
@@ -108,11 +107,19 @@ meta.edit({
 		console.log("UP");
 		$('[contenteditable=true]').off('.tmp');
 	},
+	init: function(){
+		var edit = this;
+		var doc = $('#page').attr('contenteditable', 'true');
+		if(!doc.text()){
+			doc.html('<p class="loud crack"></p>');
+		}
+		edit.select(doc.children().first().get(0));
+	},
 	save: function(p){
 		p = $(p);
 		var i = p.index();// = Array.prototype.indexOf.call(parent.children, child);
 		var file = (location.hash||'').slice(1);
-		var data = p.get(0).outerHTML;
+		var data = (p.get(0)||{}).outerHTML||'';
 		window.LOCK = true;
 		gun.get('test/gun/docs/'+file).get('what').get(i).put(data);
 		window.LOCK = false;

sea.js

@@ -190,8 +190,8 @@
         //console.log("node-webcrypto-ossl is optionally needed for ECDH, please install if needed.");
       //}
     }catch(e){
-      console.log("node-webcrypto-ossl and text-encoding may not be included by default, please add it to your package.json!");
-      OSSL_WEBCRYPTO_OR_TEXT_ENCODING_NOT_INSTALLED;
+      console.log("text-encoding and @peculiar/webcrypto may not be included by default, please add it to your package.json!");
+      TEXT_ENCODING_OR_PECULIAR_WEBCRYPTO_NOT_INSTALLED;
     }}
 
     module.exports = api

test/panic/bulkimport.js

@@ -0,0 +1,137 @@
+/*
+This is the first in a series of basic networking correctness tests.
+Each test itself might be dumb and simple, but built up together,
+they prove desired end goals for behavior at scale.
+1. (this file) Is a browser write is confirmed as save by multiple peers even if by daisy chain.
+2. 
+*/
+
+var config = {
+	IP: require('ip').address(),
+	port: 8765,
+	servers: 1,
+	browsers: 2,
+	puts: 1000,
+	route: {
+		'/': __dirname + '/index.html',
+		'/gun.js': __dirname + '/../../gun.js',
+		'/jquery.js': __dirname + '/../../examples/jquery.js'
+	}
+}
+
+var panic = require('panic-server');
+panic.server().on('request', function(req, res){
+	config.route[req.url] && require('fs').createReadStream(config.route[req.url]).pipe(res);
+}).listen(config.port);
+
+var clients = panic.clients;
+var manager = require('panic-manager')();
+
+manager.start({
+    clients: Array(config.servers).fill().map(function(u, i){
+			return {
+				type: 'node',
+				port: config.port + (i + 1)
+			}
+    }),
+    panic: 'http://' + config.IP + ':' + config.port
+});
+
+var servers = clients.filter('Node.js');
+var bob = servers.pluck(1);
+var browsers = clients.excluding(servers);
+var alice = browsers.pluck(1);
+var carl = browsers.excluding(alice).pluck(1);
+
+describe("Put ACK", function(){
+	//this.timeout(5 * 60 * 1000);
+	this.timeout(10 * 60 * 1000);
+
+	it("Servers have joined!", function(){
+		return servers.atLeast(config.servers);
+	});
+
+	it("GUN started!", function(){
+		var tests = [], i = 0;
+		servers.each(function(client){
+			tests.push(client.run(function(test){
+				var env = test.props;
+				test.async();
+				try{ require('fs').unlinkSync(env.i+'data') }catch(e){}
+  			try{ require('gun/lib/fsrm')(env.i+'data') }catch(e){}
+				var server = require('http').createServer(function(req, res){
+					res.end("I am "+ env.i +"!");
+				});
+				var port = env.config.port + env.i;
+				var Gun = require('gun');
+				var peers = [], i = env.config.servers;
+				while(i--){
+					var tmp = (env.config.port + (i + 1));
+					if(port != tmp){ // ignore ourselves
+						peers.push('http://'+ env.config.IP + ':' + tmp + '/gun');
+					}
+				}
+				console.log(port, " connect to ", peers);
+				var gun = Gun({file: env.i+'data', peers: peers, web: server});
+				server.listen(port, function(){
+					test.done();
+				});
+			}, {i: i += 1, config: config})); 
+		});
+		return Promise.all(tests);
+	});
+
+	it(config.browsers +" browser(s) have joined!", function(){
+		console.log("PLEASE OPEN http://"+ config.IP +":"+ config.port +" IN "+ config.browsers +" BROWSER(S)!");
+		return browsers.atLeast(config.browsers);
+	});
+
+	it("Browsers initialized gun!", function(){
+		var tests = [], i = 0;
+		browsers.each(function(client, id){
+			tests.push(client.run(function(test){
+				try{ localStorage.clear() }catch(e){}
+				try{ indexedDB.deleteDatabase('radata') }catch(e){}
+				var env = test.props;
+				var gun = Gun('http://'+ env.config.IP + ':' + (env.config.port + 1) + '/gun');
+				window.ref = gun.get('test');
+			}, {i: i += 1, config: config})); 
+		});
+		return Promise.all(tests);
+	});
+
+	it("Puts", function(){
+		return alice.run(function(test){
+			console.log("I AM ALICE");
+			test.async();
+			var i = test.props.puts, d = 0;
+			while(i--){ go(i) }
+			function go(i){
+				ref.get(i).put({hello: 'world'}, function(ack){
+					if(ack.err){ put_failed }
+					if(++d !== test.props.puts){ return }
+					console.log("all success", d);
+					test.done();
+				});
+			}
+		}, {puts: config.puts});
+	});
+
+	it("All finished!", function(done){
+		console.log("Done! Cleaning things up...");
+		setTimeout(function(){
+			done();
+		},1000);
+	});
+
+	after("Everything shut down.", function(){
+		browsers.run(function(){
+			//location.reload();
+			//setTimeout(function(){
+			//}, 15 * 1000);
+		});
+		return servers.run(function(){
+			process.exit();
+		});
+	});
+});