discours.io/core
5
0
Fork 0
Code Pull Requests Actions Projects Activity

sortfix

Browse Source
This commit is contained in:
tonyrewin 2022-07-21 15:05:38 +03:00
parent 6cb5061ce5
commit 4d67ad94b2
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
storages/reactions.py
View File

@ -41,6 +41,7 @@ class ReactionsStorage:
for row in session.execute(stmt): for row in session.execute(stmt):
reaction = row.Reaction reaction = row.Reaction
reactions.append(reaction) reactions.append(reaction)
reactions.sort(key=lambda x: x.createdAt, reverse=True)
async with ReactionsStorage.lock: async with ReactionsStorage.lock:
print("[storage.reactions] %d recently published reactions " % len(reactions)) print("[storage.reactions] %d recently published reactions " % len(reactions))
ReactionsStorage.reactions = reactions ReactionsStorage.reactions = reactions
@ -102,17 +103,17 @@ class ReactionsStorage:
ReactionsStorage.reactions_by_topic = reactions_by_topic ReactionsStorage.reactions_by_topic = reactions_by_topic
@staticmethod @staticmethod
async def recent() -> list[Reaction]: async def recent():
async with ReactionsStorage.lock: async with ReactionsStorage.lock:
return ReactionsStorage.reactions.sort(key=lambda x: x.createdAt, reverse=True) return ReactionsStorage.reactions
@staticmethod @staticmethod
async def total() -> int: async def total():
async with ReactionsStorage.lock: async with ReactionsStorage.lock:
return len(ReactionsStorage.reactions) return len(ReactionsStorage.reactions)
@staticmethod @staticmethod
async def by_shout(shout) -> int: async def by_shout(shout):
async with ReactionsStorage.lock: async with ReactionsStorage.lock:
stat = ReactionsStorage.reactions_by_shout.get(shout) stat = ReactionsStorage.reactions_by_shout.get(shout)
stat = stat if stat else 0 stat = stat if stat else 0
@ -124,14 +125,14 @@ class ReactionsStorage:
return ReactionsStorage.rating_by_shout.get(shout) return ReactionsStorage.rating_by_shout.get(shout)
@staticmethod @staticmethod
async def by_author(slug) -> int: async def by_author(slug):
async with ReactionsStorage.lock: async with ReactionsStorage.lock:
stat = ReactionsStorage.reactions_by_author.get(slug) stat = ReactionsStorage.reactions_by_author.get(slug)
stat = stat if stat else 0 stat = stat if stat else 0
return stat return stat
@staticmethod @staticmethod
async def by_topic(topic) -> int: async def by_topic(topic):
async with ReactionsStorage.lock: async with ReactionsStorage.lock:
stat = ReactionsStorage.reactions_by_topic.get(topic) stat = ReactionsStorage.reactions_by_topic.get(topic)
stat = stat if stat else 0 stat = stat if stat else 0