diff --git a/resolvers/editor.py b/resolvers/editor.py index 86e7654c..27f9c494 100644 --- a/resolvers/editor.py +++ b/resolvers/editor.py @@ -1,6 +1,7 @@ from orm import Shout, ShoutRating, ShoutRatingStorage from orm.base import local_session from resolvers.base import mutation, query, subscription +from resolvers.comments import comments_subscribe from auth.authenticate import login_required import asyncio from datetime import datetime @@ -19,7 +20,9 @@ async def create_shout(_, info, input): ShoutAuthor.create( shout = new_shout.slug, user = user.slug) - + + comments_subscribe(user, new_shout.slug, True) + if "mainTopic" in input: topic_slugs.append(input["mainTopic"]) @@ -106,4 +109,4 @@ async def delete_shout(_, info, slug): shout.deletedAt = datetime.now() session.commit() - return {} \ No newline at end of file + return {}