fixes

p2p/api.py

@@ -48,7 +48,7 @@ def start_selfless_thread():
 
 async def _getdb(self=None,port=PORT_LISTEN):
     from kademlia.network import Server
-    
+
     if self: self.log('starting server..')
 
     import os
@@ -285,7 +285,7 @@ class Api(object):
 
         WDV={
             'time':float(time_b.decode()),
-            'val':base64.b64decode(msg).decode(),
+            'val':base64.b64decode(msg),
             'to':receiver_pubkey_b,
             'from':sender_pubkey_b,
             'sign':signature

p2p/kademlia/network.py

@@ -114,7 +114,9 @@ class Server:
         await asyncio.gather(*results)
 
         # now republish keys older than one hour
-        for dkey, value in self.storage.iter_older_than(3600):
+        # repub_every=3600
+        repub_every=3600
+        for dkey, value in self.storage.iter_older_than(repub_every):
             await self.set_digest(dkey, value)
 
     def bootstrappable_neighbors(self):
@@ -170,7 +172,12 @@ class Server:
             return None
         spider = ValueSpiderCrawl(self.protocol, node, nearest,
                                   self.ksize, self.alpha)
-        return await spider.find()
+        found = await spider.find()
+
+        # set it locally? @EDIT
+        self.storage.set(dkey,found)
+        
+        return found
 
     async def set(self, key, value):
         """

p2p/p2p.py

@@ -4,7 +4,8 @@ import shelve
 from collections import OrderedDict
 import pickle,os
 
-NODES_PRIME = [("128.232.229.63",8467), ("68.66.241.111",8467)]    
+NODES_PRIME = [("128.232.229.63",8467), ("68.66.241.111",8467)] 
+#68.66.224.46
 
 
 def boot_lonely_selfless_node(port=8467):