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

create-reaction-fix
All checks were successful
Deploy on push / deploy (push) Successful in 6s
Details

Browse Source
This commit is contained in:
Untone 2024-11-02 19:16:52 +03:00
parent 2c981bc972
commit f4a8a653d0
2 changed files with 9 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
resolvers/reaction.py
View File

@ -190,7 +190,7 @@ def set_unfeatured(session, shout_id):
session.commit() session.commit()
async def _create_reaction(session, shout_dict, author_id: int, reaction) -> dict: async def _create_reaction(session, shout_id: int, is_author: bool, author_id: int, reaction) -> dict:
""" """
Create a new reaction and perform related actions such as updating counters and notification. Create a new reaction and perform related actions such as updating counters and notification.
@ -211,16 +211,15 @@ async def _create_reaction(session, shout_dict, author_id: int, reaction) -> dic
update_author_stat(author_id) update_author_stat(author_id)
# Handle proposal # Handle proposal
is_author = bool(list(filter(lambda x: x["id"] == int(author_id), [x for x in shout_dict["authors"]])))
if r.reply_to and r.kind in PROPOSAL_REACTIONS and is_author: if r.reply_to and r.kind in PROPOSAL_REACTIONS and is_author:
handle_proposing(r.kind, r.reply_to, shout_dict["id"]) handle_proposing(r.kind, r.reply_to, shout_id)
# Handle rating # Handle rating
if r.kind in RATING_REACTIONS: if r.kind in RATING_REACTIONS:
if check_to_unfeature(session, author_id, r): if check_to_unfeature(session, author_id, r):
set_unfeatured(session, shout_dict["id"]) set_unfeatured(session, shout_id)
elif check_to_feature(session, author_id, r): elif check_to_feature(session, author_id, r):
await set_featured(session, shout_dict["id"]) await set_featured(session, shout_id)
# Notify creation # Notify creation
await notify_reaction(rdict, "create") await notify_reaction(rdict, "create")
@ -287,7 +286,8 @@ async def create_reaction(_, info, reaction):
try: try:
with local_session() as session: with local_session() as session:
shout = session.query(Shout).filter(Shout.id == shout_id).first() shout = session.query(Shout).filter(Shout.id == shout_id).first()
authors = [a.id for a in shout.authors]
is_author = bool(list(filter(lambda x: x == int(author_id), authors)))
logger.debug(f"Loaded shout: {shout and shout.id}") logger.debug(f"Loaded shout: {shout and shout.id}")
if shout: if shout:
@ -306,7 +306,7 @@ async def create_reaction(_, info, reaction):
return error_result return error_result
logger.debug(f"Creating reaction for shout: {shout_dict['id']}") logger.debug(f"Creating reaction for shout: {shout_dict['id']}")
rdict = await _create_reaction(session, shout_dict, author_id, reaction_input) rdict = await _create_reaction(session, shout_id, is_author, author_id, reaction_input)
logger.debug(f"Created reaction result: {rdict}") logger.debug(f"Created reaction result: {rdict}")
# follow if liked # follow if liked

7
services/redis.py
View File

@ -1,9 +1,8 @@
import logging import logging
from fakeredis.aioredis import FakeRedis
from redis.asyncio import Redis from redis.asyncio import Redis
from settings import MODE, REDIS_URL from settings import REDIS_URL
# Set redis logging level to suppress DEBUG messages # Set redis logging level to suppress DEBUG messages
logger = logging.getLogger("redis") logger = logging.getLogger("redis")
@ -17,9 +16,7 @@ class RedisService:
self._client = None self._client = None
async def connect(self): async def connect(self):
if MODE == "development": if self._uri:
self._client = FakeRedis(decode_responses=True)
else:
self._client = await Redis.from_url(self._uri, decode_responses=True) self._client = await Redis.from_url(self._uri, decode_responses=True)
logger.info("Redis connection was established.") logger.info("Redis connection was established.")