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

check-inner-logix
All checks were successful
Deploy on push / deploy (push) Successful in 5s
Details

Browse Source
This commit is contained in:
Untone 2024-12-12 00:32:27 +03:00
parent 3a819007c1
commit 87506b0478
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
resolvers/editor.py
View File

@ -235,8 +235,12 @@ async def update_shout(_, info, shout_id: int, shout_input=None, publish=False):
if author_id: if author_id:
logger.info(f"author for shout#{shout_id} detected author #{author_id}") logger.info(f"author for shout#{shout_id} detected author #{author_id}")
shout_by_id = session.query(Shout).filter(Shout.id == shout_id).first() shout_by_id = session.query(Shout).filter(Shout.id == shout_id).first()
if not shout_by_id: if not shout_by_id:
logger.error(f"shout#{shout_id} not found")
return {"error": "shout not found"} return {"error": "shout not found"}
logger.info(f"shout#{shout_id} found")
if slug != shout_by_id.slug: if slug != shout_by_id.slug:
same_slug_shout = session.query(Shout).filter(Shout.slug == slug).first() same_slug_shout = session.query(Shout).filter(Shout.slug == slug).first()
c = 1 c = 1
@ -245,11 +249,14 @@ async def update_shout(_, info, shout_id: int, shout_input=None, publish=False):
slug = f"{slug}-{c}" slug = f"{slug}-{c}"
same_slug_shout = session.query(Shout).filter(Shout.slug == slug).first() same_slug_shout = session.query(Shout).filter(Shout.slug == slug).first()
shout_input["slug"] = slug shout_input["slug"] = slug
logger.info(f"shout#{shout_id} slug patched")
if filter(lambda x: x.id == author_id, [x for x in shout_by_id.authors]) or "editor" in roles: if filter(lambda x: x.id == author_id, [x for x in shout_by_id.authors]) or "editor" in roles:
logger.info(f"shout#{shout_id} is author or editor")
# topics patch # topics patch
topics_input = shout_input.get("topics") topics_input = shout_input.get("topics")
if topics_input: if topics_input:
logger.info(f"topics_input: {topics_input}")
patch_topics(session, shout_by_id, topics_input) patch_topics(session, shout_by_id, topics_input)
del shout_input["topics"] del shout_input["topics"]
for tpc in topics_input: for tpc in topics_input:
@ -276,9 +283,10 @@ async def update_shout(_, info, shout_id: int, shout_input=None, publish=False):
search_service.index(shout_by_id) search_service.index(shout_by_id)
for a in shout_by_id.authors: for a in shout_by_id.authors:
await cache_by_id(Author, a.id, cache_author) await cache_by_id(Author, a.id, cache_author)
logger.info(f"shout#{shout_id} updated")
return {"shout": shout_dict, "error": None} return {"shout": shout_dict, "error": None}
else: else:
logger.warning(f"shout#{shout_id} is not author or editor")
return {"error": "access denied", "shout": None} return {"error": "access denied", "shout": None}
except Exception as exc: except Exception as exc: