Skip to content
This repository was archived by the owner on May 16, 2019. It is now read-only.

Commit 0242349

Browse files
diego-Gcpacia
authored andcommitted
Update ws.py
Improving get vendors with an argument to get the desired quantity.
1 parent 72445ef commit 0242349

File tree

1 file changed

+12
-3
lines changed

1 file changed

+12
-3
lines changed

api/ws.py

Lines changed: 12 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ def connectionMade(self):
4141
def connectionLost(self, reason=connectionDone):
4242
self.factory.unregister(self)
4343

44-
def get_vendors(self, message_id):
44+
def get_vendors(self, message_id, quantity):
4545
if message_id in self.factory.outstanding_vendors:
4646
queried = self.factory.outstanding_vendors[message_id]
4747
else:
@@ -80,8 +80,13 @@ def handle_response(metadata, node):
8080
del self.factory.mserver.protocol.multiplexer.vendors[node.id]
8181
self.factory.db.vendors.delete_vendor(node.id.encode("hex"))
8282
return False
83+
84+
if quantity == 0:
85+
pass;
86+
else:
87+
to_query = to_query[:quantity]
8388

84-
for node in to_query[:30]:
89+
for node in to_query:
8590
self.factory.mserver.get_user_metadata(node).addCallback(handle_response, node)
8691

8792
def get_moderators(self, message_id):
@@ -298,8 +303,12 @@ def dataReceived(self, payload):
298303

299304
message_id = str(request_json["request"]["id"])
300305

306+
quantity = 30;
307+
if request_json["request"]["quantity"]:
308+
quantity = int(request_json["request"]["quantity"])
309+
301310
if request_json["request"]["command"] == "get_vendors":
302-
self.get_vendors(message_id)
311+
self.get_vendors(message_id, quantity)
303312

304313
if request_json["request"]["command"] == "get_moderators":
305314
self.get_moderators(message_id)

0 commit comments

Comments
 (0)