Skip to content
Snippets Groups Projects
Commit 04164779 authored by Holger's avatar Holger
Browse files

Fix issue #51

parent e5223731
No related branches found
No related tags found
No related merge requests found
...@@ -80,13 +80,15 @@ class Discussions(object): ...@@ -80,13 +80,15 @@ class Discussions(object):
elif limit < 100 and discussion_query["limit"] == 0: elif limit < 100 and discussion_query["limit"] == 0:
discussion_query["limit"] = limit discussion_query["limit"] = limit
query_count = 0 query_count = 0
found_more_than_start_entry = True
start_author = discussion_query["start_author"] start_author = discussion_query["start_author"]
start_permlink = discussion_query["start_permlink"] start_permlink = discussion_query["start_permlink"]
start_tag = discussion_query["start_permlink"] start_tag = discussion_query["start_tag"]
while (query_count < limit): while (query_count < limit and found_more_than_start_entry):
rpc_query_count = 0
discussion_query["start_author"] = start_author discussion_query["start_author"] = start_author
discussion_query["start_permlink"] = start_permlink discussion_query["start_permlink"] = start_permlink
discussion_query["start_permlink"] = start_tag discussion_query["start_tag"] = start_tag
if discussion_type == "trending": if discussion_type == "trending":
dd = Discussions_by_trending(discussion_query, steem_instance=self.steem, lazy=self.lazy) dd = Discussions_by_trending(discussion_query, steem_instance=self.steem, lazy=self.lazy)
elif discussion_type == "author_before_date": elif discussion_type == "author_before_date":
...@@ -121,16 +123,21 @@ class Discussions(object): ...@@ -121,16 +123,21 @@ class Discussions(object):
dd = Trending_tags(discussion_query, steem_instance=self.steem, lazy=self.lazy) dd = Trending_tags(discussion_query, steem_instance=self.steem, lazy=self.lazy)
for d in dd: for d in dd:
double_result = True double_result = False
if discussion_type == "tags": if discussion_type == "tags":
if query_count == 0 or (d["name"] != start_tag): if rpc_query_count == 0 and (d["name"] == start_tag):
double_result = False double_result = True
if len(dd) == 1:
found_more_than_start_entry = False
start_tag = d["name"] start_tag = d["name"]
else: else:
if query_count == 0 or (d["author"] != start_author and d["permlink"] != start_permlink): if rpc_query_count == 0 and (d["author"] == start_author and d["permlink"] == start_permlink):
double_result = False double_result = True
if len(dd) == 1:
found_more_than_start_entry = False
start_author = d["author"] start_author = d["author"]
start_permlink = d["permlink"] start_permlink = d["permlink"]
rpc_query_count += 1
if not double_result: if not double_result:
query_count += 1 query_count += 1
if query_count <= limit: if query_count <= limit:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment