core/resolvers/create/editor.py

141 lines
4.7 KiB
Python
Raw Normal View History

2022-11-23 14:09:35 +00:00
from datetime import datetime, timezone
2022-11-29 12:36:46 +00:00
from sqlalchemy import and_
from auth.authenticate import login_required
2022-08-11 05:53:14 +00:00
from base.orm import local_session
from base.resolvers import mutation
2022-07-10 18:52:57 +00:00
from orm.rbac import Resource
2022-09-22 10:31:44 +00:00
from orm.shout import Shout, ShoutAuthor, ShoutTopic
2022-11-29 12:36:46 +00:00
from orm.topic import TopicFollower, Topic
2022-07-10 18:52:57 +00:00
from orm.user import User
2022-11-21 08:13:57 +00:00
from resolvers.zine.reactions import reactions_follow, reactions_unfollow
2022-08-11 09:09:57 +00:00
from services.zine.gittask import GitTask
2022-11-24 16:26:12 +00:00
from resolvers.inbox.chats import create_chat
2022-07-10 18:52:57 +00:00
2022-06-19 11:11:14 +00:00
2022-06-19 17:54:39 +00:00
@mutation.field("createShout")
2022-06-19 11:11:14 +00:00
@login_required
async def create_shout(_, info, inp):
2022-09-03 10:50:14 +00:00
user = info.context["request"].user
topic_slugs = inp.get("topic_slugs", [])
2022-09-03 10:50:14 +00:00
if topic_slugs:
del inp["topic_slugs"]
2022-11-24 16:26:12 +00:00
body = inp.get("body")
2022-09-22 10:31:44 +00:00
with local_session() as session:
2022-11-24 16:26:12 +00:00
if body:
# now we should create a draft shout (can be viewed only by authors)
authors = inp.get("authors", [])
new_shout = Shout.create({
"title": inp.get("title", body[:12] + '...'),
"body": body,
2022-11-24 17:53:39 +00:00
"authors": authors,
"topics": inp.get("topics", []),
"mainTopic": inp.get("topics", []).pop(),
"visibility": "authors"
2022-11-24 16:26:12 +00:00
})
authors.remove(user.slug)
if authors:
chat = create_chat(None, info, new_shout.title, members=authors)
# create a cooperative chatroom
MessagesStorage.register_chat(chat)
# now we should create a collab
new_collab = Collab.create({
"shout": new_shout.id,
"authors": [user.slug, ],
"invites": authors
})
session.add(new_collab)
2022-09-03 10:50:14 +00:00
2022-09-22 10:31:44 +00:00
# NOTE: shout made by one first author
2022-11-30 06:27:12 +00:00
sa = ShoutAuthor.create(shout=new_shout.id, user=user.id)
2022-09-22 10:31:44 +00:00
session.add(sa)
2022-09-03 10:50:14 +00:00
2022-09-22 10:31:44 +00:00
reactions_follow(user, new_shout.slug, True)
2022-09-03 10:50:14 +00:00
2022-09-22 10:31:44 +00:00
if "mainTopic" in inp:
topic_slugs.append(inp["mainTopic"])
2022-09-03 10:50:14 +00:00
2022-09-22 10:31:44 +00:00
for slug in topic_slugs:
2022-11-29 12:36:46 +00:00
topic = session.query(Topic).where(Topic.slug == slug).one()
2022-11-30 06:27:12 +00:00
st = ShoutTopic.create(shout=new_shout.id, topic=topic.id)
2022-09-22 10:31:44 +00:00
session.add(st)
2022-11-29 12:36:46 +00:00
tf = session.query(TopicFollower).where(
2022-11-30 06:27:12 +00:00
and_(TopicFollower.follower == user.id, TopicFollower.topic == topic.id)
2022-11-29 12:36:46 +00:00
)
2022-09-22 10:31:44 +00:00
if not tf:
2022-11-30 06:27:12 +00:00
tf = TopicFollower.create(follower=user.id, topic=topic.id, auto=True)
2022-09-22 10:31:44 +00:00
session.add(tf)
new_shout.topic_slugs = topic_slugs
session.add(new_shout)
session.commit()
2022-09-03 10:50:14 +00:00
2022-11-29 12:36:46 +00:00
GitTask(inp, user.username, user.email, "new shout %s" % new_shout.slug)
2022-09-03 10:50:14 +00:00
return {"shout": new_shout}
2022-06-19 11:11:14 +00:00
2022-06-19 17:54:39 +00:00
@mutation.field("updateShout")
2022-06-19 11:11:14 +00:00
@login_required
async def update_shout(_, info, inp):
2022-09-03 10:50:14 +00:00
auth = info.context["request"].auth
user_id = auth.user_id
slug = inp["slug"]
2022-09-03 10:50:14 +00:00
2022-09-22 10:31:44 +00:00
with local_session() as session:
user = session.query(User).filter(User.id == user_id).first()
shout = session.query(Shout).filter(Shout.slug == slug).first()
if not shout:
return {"error": "shout not found"}
2022-09-03 10:50:14 +00:00
2022-09-22 10:31:44 +00:00
authors = [author.id for author in shout.authors]
if user_id not in authors:
scopes = auth.scopes
print(scopes)
2022-11-30 06:27:12 +00:00
if Resource.shout not in scopes:
2022-09-22 10:31:44 +00:00
return {"error": "access denied"}
else:
shout.update(inp)
2022-11-23 14:09:35 +00:00
shout.updatedAt = datetime.now(tz=timezone.utc)
2022-09-22 10:31:44 +00:00
session.add(shout)
2022-11-15 02:36:30 +00:00
if inp.get("topics"):
# remove old links
2022-11-30 06:27:12 +00:00
links = session.query(ShoutTopic).where(ShoutTopic.shout == shout.id).all()
2022-11-15 02:36:30 +00:00
for topiclink in links:
session.delete(topiclink)
# add new topic links
for topic in inp.get("topics", []):
ShoutTopic.create(shout=slug, topic=topic)
2022-09-22 10:31:44 +00:00
session.commit()
2022-09-03 10:50:14 +00:00
GitTask(inp, user.username, user.email, "update shout %s" % (slug))
2022-09-03 10:50:14 +00:00
return {"shout": shout}
2022-06-19 11:11:14 +00:00
2022-06-19 17:54:39 +00:00
@mutation.field("deleteShout")
2022-06-19 11:11:14 +00:00
@login_required
2022-06-19 17:54:39 +00:00
async def delete_shout(_, info, slug):
2022-09-03 10:50:14 +00:00
auth = info.context["request"].auth
user_id = auth.user_id
with local_session() as session:
shout = session.query(Shout).filter(Shout.slug == slug).first()
authors = [a.id for a in shout.authors]
if not shout:
return {"error": "invalid shout slug"}
if user_id not in authors:
return {"error": "access denied"}
for a in authors:
reactions_unfollow(a.slug, slug, True)
2022-11-23 14:09:35 +00:00
shout.deletedAt = datetime.now(tz=timezone.utc)
session.add(shout)
2022-09-03 10:50:14 +00:00
session.commit()
return {}