Merge pull request #32 from jaicis/codefixes

Kivy database and safegetint issues

src/bitmessagekivy/mpybit.py

@@ -647,8 +647,8 @@ class DropDownWidget(BoxLayout):
                             0,
                             'sent',
                             encoding,
-                            int(BMConfigParser().safeGet(
+                            BMConfigParser().safeGetInt(
-                                'bitmessagesettings', 'ttl')))
+                                'bitmessagesettings', 'ttl'))
                     state.check_sent_acc = fromAddress
                     # state.msg_counter_objs = self.parent.parent.parent.parent\
                     #     .parent.parent.children[2].children[0].ids
@@ -2331,7 +2331,7 @@ class Draft(Screen):
                 0,
                 'draft',
                 encoding,
-                int(BMConfigParser().safeGet('bitmessagesettings', 'ttl')))
+                BMConfigParser().safeGetInt('bitmessagesettings', 'ttl'))
             state.msg_counter_objs = src_object.children[2].children[0].ids
             state.draft_count = str(int(state.draft_count) + 1)
             src_object.ids.sc16.clear_widgets()

src/class_addressGenerator.py

@@ -116,9 +116,7 @@ class addressGenerator(StoppableThread):
                 payloadLengthExtraBytes = \
                     defaults.networkDefaultPayloadLengthExtraBytes
             if command == 'createRandomAddress':
-                queues.UISignalQueue.put((
+                queues.UISignalQueue.put(('updateStatusBar', None))
-                    'updateStatusBar'
-                ))
                 # This next section is a little bit strange. We're going
                 # to generate keys over and over until we find one
                 # that starts with either \x00 or \x00\x00. Then when
@@ -192,10 +190,7 @@ class addressGenerator(StoppableThread):
                 # The API and the join and create Chan functionality
                 # both need information back from the address generator.
                 queues.apiAddressGeneratorReturnQueue.put(address)
-
+                queues.UISignalQueue.put(('updateStatusBar', None))
-                queues.UISignalQueue.put((
-                    'updateStatusBar'
-                ))
                 queues.UISignalQueue.put(('writeNewAddressToTable', (
                     label, address, streamNumber)))
                 shared.reloadMyAddressHashes()

src/knownnodes.py

@@ -49,9 +49,14 @@ def json_serialize_knownnodes(output):
     for stream, peers in iter(knownNodes.items()):
         for peer, info in iter(peers.items()):
             info.update(rating=round(info.get('rating', 0), 2))
-            _serialized.append({
+            if type(peer[0]) != bytes:
-                'stream': stream, 'peer': peer._asdict(), 'info': info
+                _serialized.append({'stream': stream, 'peer': peer._asdict(), 'info': info})
-            })
+            else:
+                from collections import OrderedDict
+                _serialized.append({
+                    'stream': stream,
+                    'peer': OrderedDict({'host': str(peer[0].decode()), 'port': int(peer[1])}),
+                    'info': info})
     json.dump(_serialized, output, indent=4)
 
 
@@ -171,7 +176,7 @@ def decreaseRating(peer):
 def trimKnownNodes(recAddrStream=1):
     """Triming Knownnodes"""
     if len(knownNodes[recAddrStream]) < \
-            int(BMConfigParser().safeGet("knownnodes", "maxnodes")):
+            BMConfigParser().safeGetInt("knownnodes", "maxnodes"):
         return
     with knownNodesLock:
         oldestList = sorted(

src/network/bmproto.py

@@ -480,7 +480,7 @@ class BMProto(AdvancedDispatcher, ObjectTracker):
                         continue
                 except KeyError:
                     pass
-                if len(knownnodes.knownNodes[stream]) < int(BMConfigParser().safeGet("knownnodes", "maxnodes")):
+                if len(knownnodes.knownNodes[stream]) < BMConfigParser().safeGetInt("knownnodes", "maxnodes"):
                     with knownnodes.knownNodesLock:
                         try:
                             knownnodes.knownNodes[stream][peer]["lastseen"] = \

src/network/connectionpool.py

@@ -192,7 +192,7 @@ class BMConnectionPool(object):
         if bind is None:
             "this return blank host"
             bind = self.getListeningIP()
-        port = int(BMConfigParser().safeGet("bitmessagesettings", "port"))
+        port = BMConfigParser().safeGetInt("bitmessagesettings", "port")
         # correct port even if it changed
         ls = TCPServer(host=bind, port=port)
         self.listeningSockets[ls.destination] = ls
@@ -274,8 +274,8 @@ class BMConnectionPool(object):
                 Proxy.proxy = (
                     BMConfigParser().safeGet(
                         'bitmessagesettings', 'sockshostname'),
-                    int(BMConfigParser().safeGet(
+                    BMConfigParser().safeGetInt(
-                        'bitmessagesettings', 'socksport'))
+                        'bitmessagesettings', 'socksport')
                 )
                 # TODO AUTH
                 # TODO reset based on GUI settings changes
@@ -294,8 +294,8 @@ class BMConnectionPool(object):
                 1 for c in [outboundConnections for outboundConnections in self.outboundConnections.values()]
                 if (c.connected and c.fullyEstablished))
             pending = len(self.outboundConnections) - established
-            if established < int(BMConfigParser().safeGet(
+            if established < BMConfigParser().safeGetInt(
-                    'bitmessagesettings', 'maxoutboundconnections')):
+                    'bitmessagesettings', 'maxoutboundconnections'):
                 for i in range(
                         state.maximumNumberOfHalfOpenConnections - pending):
                     try:

src/shared.py

@@ -241,7 +241,7 @@ def checkSensitiveFilePermissions(filename):
             shell=True,
             stderr=subprocess.STDOUT
         )
-        if 'fuseblk' in fstype:
+        if 'fuseblk'.encode() in fstype:
             logger.info(
                 'Skipping file permissions check for %s.'
                 ' Filesystem fuseblk detected.', filename)