argggg

p2p/api.py

@@ -52,7 +52,7 @@ async def _getdb(self=None,port=PORT_LISTEN):
 
     import os
     if self: self.log(os.getcwd())
-    node = KadServer(storage=HalfForgetfulStorage(fn='../p2p/data.db',log=self.log))
+    node = KadServer(storage=HalfForgetfulStorage(fn='../p2p/data.db',log=(self.log if self else print)))
 
     if self: self.log('listening..')
     await node.listen(port)

p2p/p2p.py

@@ -46,23 +46,24 @@ def boot_selfless_node(port=8468, loop=None):
 
 
 def boot_lonely_selfless_node(port=8467):
-    # handler = logging.StreamHandler()
-    # formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
-    # handler.setFormatter(formatter)
-    # log = logging.getLogger('kademlia')
-    # log.addHandler(handler)
-    # log.setLevel(logging.DEBUG)
-
-    server,loop = boot_selfless_node(port,loop=None)
-    try:
-        loop.run_forever()
-    except KeyboardInterrupt:
-        pass
-    finally:
-        server.stop()
-        loop.close()
-
-
-
-
+    handler = logging.StreamHandler()
+    formatter = logging.Formatter('%(asctime)s - %(name)s - %(levelname)s - %(message)s')
+    handler.setFormatter(formatter)
+    log = logging.getLogger('kademlia')
+    log.addHandler(handler)
+    log.setLevel(logging.DEBUG)
+
+    async def go():
+        from api import _getdb
+        node = await _getdb()
+        i=0
+        while i+1:
+            if not i%10: print(node)
+            await asyncio.sleep(1)
+            i+=1
+    
+    asyncio.run(go())
+    
+    
 
+