Bug fix to get_cases

Author: cpacia

api/restapi.py

@@ -1325,7 +1325,7 @@ def get_cases(self, request):
                 "vendor": case[7],
                 "validation": json.loads(case[8]),
                 "status": "closed" if case[10] == 1 else "open",
-                "unread": case[9]
+                "unread": case[11]
             }
             cases_list.append(purchase_json)
         request.setHeader('content-type', "application/json")

db/datastore.py

@@ -672,6 +672,7 @@ def delete_messages(self, guid):
             cursor = conn.cursor()
             cursor.execute('''DELETE FROM messages WHERE guid=? AND messageType="CHAT"''', (guid, ))
         conn.commit()
+        conn.close()
 
 
 class NotificationStore(object):

dht/protocol.py

@@ -228,7 +228,7 @@ def handleCallResponse(self, result, node):
         """
         if result[0]:
             if self.isNewConnection(node) and node.id not in self.recent_transfers:
-                if len(self.recent_transfers) == 10:
+                for i in range(len(self.recent_transfers) - 10):
                     self.recent_transfers.pop()
                 self.recent_transfers.add(node.id)
                 self.log.debug("call response from new node, transferring key/values")
@@ -246,7 +246,7 @@ def addToRouter(self, node):
         if they are new and within our neighborhood.
         """
         if self.isNewConnection(node) and node.id not in self.recent_transfers:
-            if len(self.recent_transfers) == 10:
+            for i in range(len(self.recent_transfers) - 10):
                 self.recent_transfers.pop()
             self.recent_transfers.add(node.id)
             self.log.debug("found a new node, transferring key/values")

net/rpcudp.py

@@ -50,7 +50,8 @@ def receive_message(self, message, sender, connection, ban_score):
             connection.shutdown()
             return False
 
-        self.multiplexer.vendors[sender.id] = sender
+        if sender.vendor:
+            self.multiplexer.vendors[sender.id] = sender
 
         msgID = message.messageID
         if message.command == NOT_FOUND:
@@ -60,10 +61,9 @@ def receive_message(self, message, sender, connection, ban_score):
         if msgID in self._outstanding:
             self._acceptResponse(msgID, data, sender)
         elif message.command != NOT_FOUND:
-            ban_score.process_message(connection.dest_addr, message)
+            #ban_score.process_message(connection.dest_addr, message)
             self._acceptRequest(msgID, str(Command.Name(message.command)).lower(), data, sender, connection)
-        else:
-            ban_score.process_message(connection.dest_addr, message)
+        #else: ban_score.process_message(connection.dest_addr, message)
 
     def _acceptResponse(self, msgID, data, sender):
         if data is not None:

net/wireprotocol.py

@@ -77,12 +77,12 @@ def on_connection_made(self):
             if self.connection.state == State.CONNECTED:
                 self.addr = str(self.connection.dest_addr[0]) + ":" + str(self.connection.dest_addr[1])
                 self.log.info("connected to %s" % self.addr)
-            self.ban_score.process_message(self.connection.dest_addr, 100)
+            #self.ban_score.process_message(self.connection.dest_addr, 100)
 
         def receive_message(self, datagram):
             if len(datagram) < 166:
                 self.log.warning("received datagram too small from %s, ignoring" % self.addr)
-                self.ban_score.process_message(self.connection.dest_addr, 110)
+                #self.ban_score.process_message(self.connection.dest_addr, 110)
                 return False
             try:
                 m = Message()
@@ -109,7 +109,7 @@ def receive_message(self, datagram):
             except Exception:
                 # If message isn't formatted property then ignore
                 self.log.warning("received an invalid message from %s, ignoring" % self.addr)
-                self.ban_score.process_message(self.connection.dest_addr, 110)
+                #self.ban_score.process_message(self.connection.dest_addr, 110)
                 return False
 
         def handle_shutdown(self):