From b55229eee88106065354b60b00e932fbd4088534 Mon Sep 17 00:00:00 2001
From: dickreckard <dickreckard@dickey>
Date: Wed, 5 Nov 2014 17:42:51 +0100
Subject: [PATCH 1/7] dennis makes me hot

---
 main.py     | 19 ++++++++++-----
 webapp.html | 68 +++++++++++++++++++++++++++++------------------------
 2 files changed, 50 insertions(+), 37 deletions(-)

diff --git a/main.py b/main.py
index 66ae3fa..3cde680 100755
--- a/main.py
+++ b/main.py
@@ -1,6 +1,6 @@
 #!/usr/bin/python
 
-import socket, os, time, select, urllib, sys, threading
+import socket, os, time, select, urllib, sys, threading, json
 
 class Meshenger:
   devices = {} #the dictionary of all the nodes this this node has seen
@@ -63,9 +63,9 @@ class Meshenger:
         print 'found', len(self.devices),'device(s)'
 
         for device in self.devices.keys():
-          nodepath = self.ip_to_hash_path(device) #make a folder for the node (nodes/'hash'/)
-          nodeupdatepath = os.path.join(self.ip_to_hash_path(device), 'lastupdate')
-
+          nodehash = self.hasj(device)
+	  nodepath = os.path.join(os.path.abspath('nodes'), nodehash)
+          nodeupdatepath = os.path.join(nodepath, 'lastupdate')
 
           print 'Checking age of foreign node index'
           print self.devices[device], 'Foreign announce timestamp'
@@ -81,7 +81,7 @@ class Meshenger:
             print 'Foreign node"s index is newer, proceed to download index'
             self.get_index(device, nodepath)
             print 'downloading messages'
-            self.get_messages(device, nodepath)
+            self.get_messages(device, nodepath, nodehash)
           self.node_timestamp(device)
 
       time.sleep(5) #free process or ctrl+c
@@ -194,7 +194,7 @@ Download the indices from other nodes.
     os.system('wget http://['+ip+'%adhoc0]:'+self.serve_port+'/index -O '+os.path.join(path,'index'))
 
 
-  def get_messages(self, ip, path):
+  def get_messages(self, ip, path, hash):
     """
 Get new messages from other node based on it's index file
 """
@@ -206,6 +206,12 @@ Get new messages from other node based on it's index file
           if not os.path.exists(messagepath):
             print 'downloading', message, 'to', messagepath
             os.system('wget http://['+ip+'%adhoc0]:'+self.serve_port+'/msg/'+message+' -O '+messagepath)
+	    with open(messagepath, 'r+') as f:
+		data=json.load(f)
+	    	data['hops']=str(int(data['hops'])+1)
+		data['node']=hash
+	        f.seek(0)
+		json.dump(data, f)
     except:
       print 'Failed to download messages'
       pass
@@ -223,6 +229,7 @@ Convert a node's ip into a hash and make a directory to store it's files
 
     return nodepath
 
+
   def hasj(self, ip):
         """
         Convert a node's ip into a hash
diff --git a/webapp.html b/webapp.html
index ef25caf..3964ca7 100644
--- a/webapp.html
+++ b/webapp.html
@@ -110,7 +110,7 @@
 			//background:-moz-linear-gradient(top,  #fff,  #eee);
 		}
 		#outbox{
-			display:hidden;
+			display:none;
 		}
 		#header{
 			width:100%;
@@ -118,6 +118,9 @@
 		}
 		#name{
 
+		}
+		.hops .node{
+	//	display:hidden;
 		}
 
 		</style>
@@ -142,8 +145,6 @@
 			<option value="dateSend">Sort by Date Send</option>
 
 </select>
-
-
 		<ul id="inbox"></ul>
 
 		<!--<h2>outbox</h2>-->
@@ -152,6 +153,7 @@
 
 <script type="text/javascript">
 
+localStorage.clear();
 /*
  * OUTBOX STUFF
  */
@@ -165,8 +167,18 @@ document.getElementById( 'send' ).onclick = function() {
 	var namm= document.getElementById('name').value;
 	}
 	var mess = document.getElementById('message').value.replace(/\r?\n/g, "<br />");
-	outStr += new Date().getTime() + ' ' + namm + '///' + mess + '\n';
-	localStorage.setItem( 'outbox', outStr );
+	var newMsgs ={};
+	var ddata= new Date().getTime();
+	var contento = {
+	"time" : ddata,
+	"message" : mess,
+	"name" : namm,
+	"node" : "local",
+	"hops" : "0"
+	}
+	newMsgs.message = contento;	
+	
+	localStorage.setItem( 'outbox', JSON.stringify(newMsgs) );
 	updateOutboxView();
 	checkOutbox();
 	document.getElementById('message').value = '';
@@ -181,8 +193,10 @@ function checkOutbox() {
 		if ( lines[i].length === 0 ) {
 			continue;
 		}
-		var ts = lines[ i ].substr( 0, lines[ i ].indexOf( ' ' ));
-		var msg = lines[ i ].substr( lines[ i ].indexOf( ' ' ));
+		var obj = JSON.parse(lines[i]);
+		var ts = obj.message.time;
+		delete obj.message.time;
+		var msg = JSON.stringify(obj.message);
 		sendMessage( ts, msg );
 	}
 }
@@ -208,7 +222,8 @@ function removeOutboxItem( timestamp ) {
 	var outStr = localStorage.getItem( 'outbox' ) || '';
 	var lines = outStr.split( /\n/ );
 	for ( var i in lines ) {
-		var ts = lines[ i ].substr( 0, lines[ i ].indexOf( ' ' ));
+                var obj = JSON.parse(lines[i]);
+		var ts = obj.message.time;
 		if ( ts === timestamp ) {
 			lines.splice( i, 1 );
 			break;
@@ -226,30 +241,21 @@ function updateOutboxView() {
 		if ( lines[ i ].length === 0 ) {
 			continue;
 		}
-		var ts = lines[ i ].substr( 0, lines[ i ].indexOf( ' ' ));
-		var msg = lines[ i ].substr( lines[ i ].indexOf( ' ' ));
+               var obj = JSON.parse(lines[i]);
+                var ts = obj.message.time;
+                delete obj.message.time;
+                var msg = JSON.stringify(obj.message);
+
 		contentString += '<li><b>' + ts + ' </b>' + msg + '</li>';
 	}
 	document.getElementById( 'outbox' ).innerHTML = contentString;
 }
 
-function doStuffForEach( entriesString, stuffFunction ) {
-	if ( ! entriesString ) {
-		return;
-	}
-	var lines = entriesString.split( /\n/ );
-	for ( var i in lines ) {
-		var ts = lines[ i ].substr( 0, lines[ i ].indexOf( ' ' ));
-		var msg = lines[ i ].substr( lines[ i ].indexOf( ' ' ) + 1 );
-		stuffFunction( ts, msg );
-	}
-}
 /*
  * INBOX STUFF
  */
 
 
-
 function updateInboxView() {
 	var localStorageArray = new Array();
 	var contentString = '';
@@ -257,15 +263,15 @@ function updateInboxView() {
 	if (localStorage.length>0) {
 	for (i=0;i<localStorage.length;i++){
 
-
-	element=localStorage.getItem(localStorage.key(i))
-
-	elesplit=element.split('///');
-
-	if ( localStorage.key(i).length === 0 || element === 'outbox' ) {
-		continue;
+	element=localStorage.getItem(localStorage.key(i));
+	
+	if ( localStorage.key(i).length < 10 || element === 'outbox' ) {
+	continue;
 	}
-	localStorageArray[i] = { time:localStorage.key(i), user:elesplit[0], message:elesplit[1] };
+//	alert(element);	
+	elementj = JSON.parse(element);
+
+	localStorageArray[i] = { time:localStorage.key(i), user:elementj.name, message:elementj.message, node:elementj.node, hops:elementj.hops };
 	}
 	}
 	orderStorage = localStorageArray.sort(function(a,b) { return b.time - a.time } );
@@ -278,7 +284,7 @@ function updateInboxView() {
 		var date = new Date(parseInt(orderStorage[i].time));
 //		date.setHours(date.getHours() + 2);
 		var datereadable = date.getDate()+"/"+(date.getMonth()+1)+"/"+date.getFullYear()+" "+date.getHours()+":"+date.getMinutes();
-		contentString += '<li><b>' + datereadable + ' </b>' + ' <i>'+ orderStorage[i].user +'</i><br/> '+orderStorage[i].message+'</li>';
+		contentString += '<li><b>' + datereadable + ' </b>' + ' <i>'+ orderStorage[i].user +'</i><br/> '+orderStorage[i].message+' <span class="node '+orderStorage[i].node+'">'+orderStorage[i].node+'</span> <span class="hops '+orderStorage[i].hops+'">'+orderStorage[i].hops+'</span></li>';
 	}
 	document.getElementById( 'inbox' ).innerHTML = contentString;
 }

From ed861b90da0101512ff6a70523656c0ff984c77a Mon Sep 17 00:00:00 2001
From: dickreckard <dickreckard@dickey>
Date: Wed, 5 Nov 2014 18:00:07 +0100
Subject: [PATCH 2/7] tempfix while hard links go to /root/meshenger

---
 lazyinstall/lazyinstall2.sh | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lazyinstall/lazyinstall2.sh b/lazyinstall/lazyinstall2.sh
index 1ccda10..d9fef0a 100755
--- a/lazyinstall/lazyinstall2.sh
+++ b/lazyinstall/lazyinstall2.sh
@@ -32,7 +32,7 @@ sed -i -e "s/option 'interfaces' 'mesh'/option 'interfaces' 'adhoc0'/g" /etc/con
 
 opkg install python git
 sleep 1
-git clone git://github.com/jngrt/meshenger.git /meshenger
+git clone ://github.com/rscmbbng/meshenger /root/meshenger
 
 mv uhttpd /etc/config/uhttpd
 

From 65720bf3b692540204c0e82641f91094b6d71f46 Mon Sep 17 00:00:00 2001
From: dickreckard <dickreckard@dickey>
Date: Wed, 5 Nov 2014 20:11:33 +0100
Subject: [PATCH 3/7] added autostart.wq

---
 lazyinstall/lazyinstall2.sh | 1 +
 1 file changed, 1 insertion(+)

diff --git a/lazyinstall/lazyinstall2.sh b/lazyinstall/lazyinstall2.sh
index d9fef0a..d9cd6da 100755
--- a/lazyinstall/lazyinstall2.sh
+++ b/lazyinstall/lazyinstall2.sh
@@ -37,6 +37,7 @@ git clone ://github.com/rscmbbng/meshenger /root/meshenger
 mv uhttpd /etc/config/uhttpd
 
 mv meshenger /etc/init.d/meshenger
+/etc/init.d/meshenger enable
 
 echo 'my ip address is:' #klopt nog niet
 ifconfig  br-lan | grep 'inet addr'

From 943cbd3562cc2b5e4f89817c6caffaa0fc925e6d Mon Sep 17 00:00:00 2001
From: dickreckard <dickreckard@dickey>
Date: Thu, 6 Nov 2014 11:59:54 +0100
Subject: [PATCH 4/7] added line to prevent JSON errors to crash the whole
 thing

---
 webapp.html | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/webapp.html b/webapp.html
index 3964ca7..6a4dbd8 100644
--- a/webapp.html
+++ b/webapp.html
@@ -268,8 +268,12 @@ function updateInboxView() {
 	if ( localStorage.key(i).length < 10 || element === 'outbox' ) {
 	continue;
 	}
-//	alert(element);	
-	elementj = JSON.parse(element);
+//	alert(element);
+	try {
+        elementj = JSON.parse(element);
+    	} catch (e) {
+        continue;
+    	}	
 
 	localStorageArray[i] = { time:localStorage.key(i), user:elementj.name, message:elementj.message, node:elementj.node, hops:elementj.hops };
 	}

From e4e8b7cf00b6099f8e09723d8009afa0101592e5 Mon Sep 17 00:00:00 2001
From: jngrt <jangeertmunneke@gmail.com>
Date: Thu, 6 Nov 2014 15:01:39 +0100
Subject: [PATCH 5/7] replaced stdout print with logging to file and stdout

---
 .gitignore               |  1 +
 log/.gitignore           |  4 ++++
 main.py                  | 49 +++++++++++++++++++++-------------------
 meshenger_clientserve.py |  4 ++++
 meshenger_nodeserve.py   |  5 ++++
 pylog.conf               | 33 +++++++++++++++++++++++++++
 6 files changed, 73 insertions(+), 23 deletions(-)
 create mode 100644 log/.gitignore
 create mode 100644 pylog.conf

diff --git a/.gitignore b/.gitignore
index 4454fa2..9cdff31 100644
--- a/.gitignore
+++ b/.gitignore
@@ -4,3 +4,4 @@ msg/*
 index
 interfaceip6adress
 nodes/*
+*.log
diff --git a/log/.gitignore b/log/.gitignore
new file mode 100644
index 0000000..5e7d273
--- /dev/null
+++ b/log/.gitignore
@@ -0,0 +1,4 @@
+# Ignore everything in this directory
+*
+# Except this file
+!.gitignore
diff --git a/main.py b/main.py
index 3cde680..5df7181 100755
--- a/main.py
+++ b/main.py
@@ -1,6 +1,9 @@
 #!/usr/bin/python
 
-import socket, os, time, select, urllib, sys, threading, json
+import socket, os, time, select, urllib, sys, threading, json, logging, logging.config
+
+logging.config.fileConfig('pylog.conf')
+logger = logging.getLogger('meshenger'+'.main')
 
 class Meshenger:
   devices = {} #the dictionary of all the nodes this this node has seen
@@ -17,12 +20,12 @@ class Meshenger:
     os.system("echo 1 >> /proc/sys/net/ipv6/conf/br-hotspot/disable_ipv6")
 
     os.chdir(os.path.dirname(__file__)) # change present working directory to the one where this file is
-    
+
     self.own_ip = self.get_ip_adress().strip()
 
     if not os.path.exists(self.msg_dir):
       os.mkdir(self.msg_dir)
-      print 'Making message directory'
+      logger.info('Making message directory')
 
     try:
       d = threading.Thread(target=self.discover)
@@ -48,7 +51,7 @@ class Meshenger:
       #os.system("python meshenger_clientserve.py")
 
     except (KeyboardInterrupt, SystemExit):
-      print 'exiting discovery thread'
+      logger.info('exiting discovery thread')
       d.join()
       a.join()
       b.join()
@@ -57,30 +60,30 @@ class Meshenger:
       sys.exit()
 
     while True:
-      print 'Entering main loop'
+      logger.info('Entering main loop')
       #
       if len(self.devices) > 0:
-        print 'found', len(self.devices),'device(s)'
+        logger.info('found %s device(s)', len(self.devices))
 
         for device in self.devices.keys():
           nodehash = self.hasj(device)
 	  nodepath = os.path.join(os.path.abspath('nodes'), nodehash)
           nodeupdatepath = os.path.join(nodepath, 'lastupdate')
 
-          print 'Checking age of foreign node index'
-          print self.devices[device], 'Foreign announce timestamp'
+          logger.info('Checking age of foreign node index')
+          logger.info('%s Foreign announce timestamp', self.devices[device])
           try:
             foreign_node_update = open(nodeupdatepath).read()
           except:
             foreign_node_update = 0 #means it was never seen before
 
-          print foreign_node_update, 'Locally stored timestamp for device'
+          logger.info('%s Locally stored timestamp for device', foreign_node_update)
 
 
           if self.devices[device] > foreign_node_update:
-            print 'Foreign node"s index is newer, proceed to download index'
+            logger.info('Foreign node"s index is newer, proceed to download index')
             self.get_index(device, nodepath)
-            print 'downloading messages'
+            logger.info('downloading messages')
             self.get_messages(device, nodepath, nodehash)
           self.node_timestamp(device)
 
@@ -99,7 +102,7 @@ class Meshenger:
     """
 Announce the node's existance to other nodes
 """
-    print 'Announcing'
+    logger.info('Announcing')
     while not self.exitapp:
       sock = socket.socket(socket.AF_INET6, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
       sock.sendto(self.index_last_update, ("ff02::1", self.announce_port))
@@ -120,7 +123,7 @@ Discover other devices by listening to the Meshenger announce port
     while not self.exitapp:
       result = select.select([s],[],[])[0][0].recvfrom(bufferSize)
       ip = result[1][0]
-      print ip, "*"*45
+      logger.info('%s %s', ip, "*"*45)
       node_path = os.path.join(os.path.abspath('nodes'), self.hasj(ip))
 
       if not os.path.exists(node_path) and ip != self.own_ip: 
@@ -128,10 +131,10 @@ Discover other devices by listening to the Meshenger announce port
         self.ip_to_hash_path(ip) #make a folder /nodes/hash
         self.devices[ip] = result[0]
         #self.node_timestamp(ip) #make a local copy of the timestamp in /nodes/hash/updatetimestamp
-        print 'New node', ip
+        logger.info('New node %s', ip)
 
       elif os.path.exists(node_path) and ip != self.own_ip:
-        print 'Known node', ip
+        logger.info('Known node %s', ip)
         self.devices[ip] = result[0]
 
 
@@ -141,7 +144,7 @@ Discover other devices by listening to the Meshenger announce port
     """
 Initialize the nodeserver
 """
-    print 'Serving to nodes'
+    logger.info('Serving to nodes')
     import meshenger_nodeserve
     meshenger_nodeserve.main()
 
@@ -149,7 +152,7 @@ Initialize the nodeserver
     """
 Initialize the clientserver
 """
-    print 'Serving to client'
+    logger.info('Serving to client')
     import meshenger_clientserve
     meshenger_clientserve.main()
 
@@ -160,7 +163,7 @@ Make an index file of all the messages present on the node.
 Save the time of the last update.
 """
 
-    print 'Building own index for the first time\n'
+    logger.info('Building own index for the first time\n')
 
     if not os.path.exists('index'):
       with open('index','wb') as index:
@@ -178,9 +181,9 @@ Save the time of the last update.
             index.write('\n')
         self.index_last_update = str(int(time.time()))
 
-        print 'Index updated:', current_index
+        logger.info('Index updated: %s', current_index)
 
-        with open('index_last_update', 'wb') as indexupdate: 
+        with open('index_last_update', 'wb') as indexupdate:
           indexupdate.write(self.index_last_update) ### misschien moet dit index_last_update zijn
 
       previous_index = current_index
@@ -204,7 +207,7 @@ Get new messages from other node based on it's index file
         for message in index:
           messagepath = os.path.join(os.path.abspath(self.msg_dir), message)
           if not os.path.exists(messagepath):
-            print 'downloading', message, 'to', messagepath
+            logger.info('downloading %s to %s', message, messagepath)
             os.system('wget http://['+ip+'%adhoc0]:'+self.serve_port+'/msg/'+message+' -O '+messagepath)
 	    with open(messagepath, 'r+') as f:
 		data=json.load(f)
@@ -213,7 +216,7 @@ Get new messages from other node based on it's index file
 	        f.seek(0)
 		json.dump(data, f)
     except:
-      print 'Failed to download messages'
+      logger.info('Failed to download messages')
       pass
 
   def ip_to_hash_path(self, ip):
@@ -250,7 +253,7 @@ Hack to adhoc0's inet6 adress
 
 
 if __name__ == "__main__":
-  print "test"
+  logger.info("starting main...")
   try:
     meshenger = Meshenger()
   except (KeyboardInterrupt, SystemExit):
diff --git a/meshenger_clientserve.py b/meshenger_clientserve.py
index 2f4ef7e..40dea81 100644
--- a/meshenger_clientserve.py
+++ b/meshenger_clientserve.py
@@ -8,6 +8,10 @@ from BaseHTTPServer import HTTPServer
 import SimpleHTTPServer
 import urlparse
 import unicodedata
+import logging, logging.config
+
+logging.config.fileConfig('pylog.conf')
+logger = logging.getLogger('meshenger'+'.clientserve')
 
 
 class ClientServeHandler(SimpleHTTPServer.SimpleHTTPRequestHandler):
diff --git a/meshenger_nodeserve.py b/meshenger_nodeserve.py
index 420c3fa..80ffd2b 100755
--- a/meshenger_nodeserve.py
+++ b/meshenger_nodeserve.py
@@ -7,6 +7,11 @@ import socket
 import BaseHTTPServer
 import SimpleHTTPServer
 import urlparse
+import logging
+import logging.config
+
+logging.config.fileConfig('pylog.conf')
+logger = logging.getLogger('meshenger'+'.nodeserve')
 
 #GOTTMITTUNS
 
diff --git a/pylog.conf b/pylog.conf
new file mode 100644
index 0000000..bfb7337
--- /dev/null
+++ b/pylog.conf
@@ -0,0 +1,33 @@
+[loggers]
+keys=root,meshenger
+
+[handlers]
+keys=consoleHandler, fileHandler
+
+[formatters]
+keys=simpleFormatter
+
+[logger_root]
+level=DEBUG
+handlers=consoleHandler
+
+[logger_meshenger]
+level=DEBUG
+handlers=consoleHandler, fileHandler
+qualname=meshenger
+propagate=0
+
+[handler_fileHandler]
+class=handlers.RotatingFileHandler
+args=('log/meshenger.log','a','maxBytes=10000','backupCount=5')
+formatter=simpleFormatter
+
+[handler_consoleHandler]
+class=StreamHandler
+level=DEBUG
+formatter=simpleFormatter
+args=(sys.stdout,)
+
+[formatter_simpleFormatter]
+format=%(asctime)s - %(name)s - %(levelname)s - %(message)s
+datefmt=

From 857b1c4d8263e4de6e70ca008c5ae096ff3f8353 Mon Sep 17 00:00:00 2001
From: jngrt <jangeertmunneke@gmail.com>
Date: Thu, 6 Nov 2014 15:41:35 +0100
Subject: [PATCH 6/7] logging tweaks

---
 main.py    | 2 +-
 pylog.conf | 1 +
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git a/main.py b/main.py
index 5df7181..943b923 100755
--- a/main.py
+++ b/main.py
@@ -60,7 +60,7 @@ class Meshenger:
       sys.exit()
 
     while True:
-      logger.info('Entering main loop')
+      logger.debug('Entering main loop')
       #
       if len(self.devices) > 0:
         logger.info('found %s device(s)', len(self.devices))
diff --git a/pylog.conf b/pylog.conf
index bfb7337..47f3254 100644
--- a/pylog.conf
+++ b/pylog.conf
@@ -19,6 +19,7 @@ propagate=0
 
 [handler_fileHandler]
 class=handlers.RotatingFileHandler
+level=INFO
 args=('log/meshenger.log','a','maxBytes=10000','backupCount=5')
 formatter=simpleFormatter
 

From 71bbea8d0c285ad0943a27345109541aa9008bd3 Mon Sep 17 00:00:00 2001
From: jngrt <jangeertmunneke@gmail.com>
Date: Thu, 6 Nov 2014 16:01:46 +0100
Subject: [PATCH 7/7] serve logging on /log for clients

---
 meshenger_clientserve.py | 12 +++++++++---
 1 file changed, 9 insertions(+), 3 deletions(-)

diff --git a/meshenger_clientserve.py b/meshenger_clientserve.py
index 40dea81..9a9d7c7 100644
--- a/meshenger_clientserve.py
+++ b/meshenger_clientserve.py
@@ -27,14 +27,20 @@ class ClientServeHandler(SimpleHTTPServer.SimpleHTTPRequestHandler):
       self.send_response(200)
       self.send_header('Content-type', 'text/html')
       self.end_headers()
-
-      f = os.path.join('/root/meshenger/',"webapp.html")
+      f = os.path.relpath('webapp.html')
+      # f = os.path.join('/root/meshenger/',"webapp.html")
       with open( f, 'r') as the_file:
         self.wfile.write(the_file.read())
 
     elif self.path == '/index' or self.path.startswith( "/"+self.messageDir ):
       return SimpleHTTPServer.SimpleHTTPRequestHandler.do_GET(self)
-
+    elif self.path == '/log':
+      self.send_response(200)
+      self.send_header('Content-type', 'text-html')
+      self.end_headers()
+      f = os.path.relpath('log/meshenger.log')
+      with open( f, 'r') as the_file:
+        self.wfile.write(the_file.read())
     else:
       self.send_response(200) #serve the webapp on every url requested
       self.send_header('Content-type', 'text/html')