326 lines
10 KiB
Python
326 lines
10 KiB
Python
import json
|
|
import time
|
|
|
|
from sqlalchemy import and_, desc, select, or_, distinct, func
|
|
from sqlalchemy.orm import aliased
|
|
|
|
from orm.author import Author, AuthorFollower, AuthorRating
|
|
from orm.reaction import Reaction, ReactionKind
|
|
from orm.shout import Shout, ShoutAuthor, ShoutTopic
|
|
from orm.topic import Topic
|
|
from resolvers.follower import query_follows
|
|
from resolvers.stat import get_authors_with_stat, execute_with_ministat, author_follows_authors, author_follows_topics
|
|
from services.auth import login_required
|
|
from services.db import local_session
|
|
from services.rediscache import redis
|
|
from services.schema import mutation, query
|
|
from services.logger import root_logger as logger
|
|
|
|
|
|
@mutation.field('update_author')
|
|
@login_required
|
|
def update_author(_, info, profile):
|
|
user_id = info.context['user_id']
|
|
with local_session() as session:
|
|
author = session.query(Author).where(Author.user == user_id).first()
|
|
Author.update(author, profile)
|
|
session.add(author)
|
|
session.commit()
|
|
return {'error': None, 'author': author}
|
|
|
|
|
|
# TODO: caching query
|
|
@query.field('get_authors_all')
|
|
def get_authors_all(_, _info):
|
|
with local_session() as session:
|
|
authors = session.query(Author).all()
|
|
return authors
|
|
|
|
|
|
def count_author_comments_rating(session, author_id) -> int:
|
|
replied_alias = aliased(Reaction)
|
|
replies_likes = (
|
|
session.query(replied_alias)
|
|
.join(Reaction, replied_alias.id == Reaction.reply_to)
|
|
.where(
|
|
and_(
|
|
replied_alias.created_by == author_id,
|
|
replied_alias.kind == ReactionKind.COMMENT.value,
|
|
)
|
|
)
|
|
.filter(replied_alias.kind == ReactionKind.LIKE.value)
|
|
.count()
|
|
) or 0
|
|
replies_dislikes = (
|
|
session.query(replied_alias)
|
|
.join(Reaction, replied_alias.id == Reaction.reply_to)
|
|
.where(
|
|
and_(
|
|
replied_alias.created_by == author_id,
|
|
replied_alias.kind == ReactionKind.COMMENT.value,
|
|
)
|
|
)
|
|
.filter(replied_alias.kind == ReactionKind.DISLIKE.value)
|
|
.count()
|
|
) or 0
|
|
|
|
return replies_likes - replies_dislikes
|
|
|
|
|
|
def count_author_shouts_rating(session, author_id) -> int:
|
|
shouts_likes = (
|
|
session.query(Reaction, Shout)
|
|
.join(Shout, Shout.id == Reaction.shout)
|
|
.filter(
|
|
and_(
|
|
Shout.authors.any(id=author_id),
|
|
Reaction.kind == ReactionKind.LIKE.value,
|
|
)
|
|
)
|
|
.count()
|
|
or 0
|
|
)
|
|
shouts_dislikes = (
|
|
session.query(Reaction, Shout)
|
|
.join(Shout, Shout.id == Reaction.shout)
|
|
.filter(
|
|
and_(
|
|
Shout.authors.any(id=author_id),
|
|
Reaction.kind == ReactionKind.DISLIKE.value,
|
|
)
|
|
)
|
|
.count()
|
|
or 0
|
|
)
|
|
return shouts_likes - shouts_dislikes
|
|
|
|
|
|
def load_author_ratings(author):
|
|
with local_session() as session:
|
|
comments_count = (
|
|
session.query(Reaction)
|
|
.filter(
|
|
and_(
|
|
Reaction.created_by == author.id,
|
|
Reaction.kind == ReactionKind.COMMENT.value,
|
|
Reaction.deleted_at.is_(None),
|
|
)
|
|
)
|
|
.count()
|
|
)
|
|
likes_count = (
|
|
session.query(AuthorRating)
|
|
.filter(
|
|
and_(AuthorRating.author == author.id, AuthorRating.plus.is_(True))
|
|
)
|
|
.count()
|
|
)
|
|
dislikes_count = (
|
|
session.query(AuthorRating)
|
|
.filter(
|
|
and_(
|
|
AuthorRating.author == author.id, AuthorRating.plus.is_not(True)
|
|
)
|
|
)
|
|
.count()
|
|
)
|
|
author.stat['rating'] = likes_count - dislikes_count
|
|
author.stat['rating_shouts'] = count_author_shouts_rating(
|
|
session, author.id
|
|
)
|
|
author.stat['rating_comments'] = count_author_comments_rating(
|
|
session, author.id
|
|
)
|
|
author.stat['commented'] = comments_count
|
|
return author
|
|
|
|
|
|
@query.field('get_author')
|
|
def get_author(_, _info, slug='', author_id=None):
|
|
q = None
|
|
author = None
|
|
try:
|
|
if slug or author_id:
|
|
if bool(slug):
|
|
q = select(Author).where(Author.slug == slug)
|
|
if author_id:
|
|
q = select(Author).where(Author.id == int(author_id))
|
|
|
|
[author, ] = get_authors_with_stat(q)
|
|
author = load_author_ratings(author)
|
|
except Exception as exc:
|
|
logger.error(exc)
|
|
return author
|
|
|
|
|
|
async def get_author_by_user_id(user_id: str):
|
|
redis_key = f'user:{user_id}:author'
|
|
author = None
|
|
try:
|
|
res = await redis.execute('GET', redis_key)
|
|
if isinstance(res, str):
|
|
author = json.loads(res)
|
|
if author.get('id'):
|
|
logger.debug(f'got cached author: {author}')
|
|
return author
|
|
|
|
logger.info(f'getting author id for {user_id}')
|
|
q = select(Author).filter(Author.user == user_id)
|
|
|
|
[author, ] = get_authors_with_stat(q)
|
|
author = load_author_ratings(author)
|
|
update_author(author)
|
|
except Exception as exc:
|
|
logger.error(exc)
|
|
return author
|
|
|
|
|
|
@query.field('get_author_id')
|
|
async def get_author_id(_, _info, user: str):
|
|
return await get_author_by_user_id(user)
|
|
|
|
|
|
@query.field('load_authors_by')
|
|
def load_authors_by(_, _info, by, limit, offset):
|
|
q = select(Author)
|
|
if by.get('slug'):
|
|
q = q.filter(Author.slug.ilike(f"%{by['slug']}%"))
|
|
elif by.get('name'):
|
|
q = q.filter(Author.name.ilike(f"%{by['name']}%"))
|
|
elif by.get('topic'):
|
|
q = (
|
|
q.join(ShoutAuthor)
|
|
.join(ShoutTopic)
|
|
.join(Topic)
|
|
.where(Topic.slug == str(by['topic']))
|
|
)
|
|
|
|
if by.get('last_seen'): # in unix time
|
|
before = int(time.time()) - by['last_seen']
|
|
q = q.filter(Author.last_seen > before)
|
|
elif by.get('created_at'): # in unix time
|
|
before = int(time.time()) - by['created_at']
|
|
q = q.filter(Author.created_at > before)
|
|
|
|
order = by.get('order')
|
|
if order == 'followers' or order == 'shouts':
|
|
q = q.order_by(desc(f'{order}_stat'))
|
|
|
|
q = q.limit(limit).offset(offset)
|
|
q = q.group_by(Author.id)
|
|
authors = get_authors_with_stat(q)
|
|
|
|
return authors
|
|
|
|
|
|
@query.field('get_author_follows')
|
|
def get_author_follows(_, _info, slug='', user=None, author_id=None):
|
|
with local_session() as session:
|
|
if user or slug:
|
|
author_id_result = session.query(Author.id).filter(or_(Author.user == user, Author.slug == slug)).first()
|
|
author_id = author_id_result[0] if author_id_result else None
|
|
if author_id:
|
|
follows = query_follows(author_id)
|
|
return follows
|
|
else:
|
|
raise ValueError('Author not found')
|
|
|
|
|
|
@query.field('get_author_follows_topics')
|
|
def get_author_follows_topics(_, _info, slug='', user=None, author_id=None):
|
|
with local_session() as session:
|
|
if user or slug:
|
|
author_id_result = session.query(Author.id).filter(or_(Author.user == user, Author.slug == slug)).first()
|
|
author_id = author_id_result[0] if author_id_result else None
|
|
if author_id:
|
|
follows = author_follows_authors(author_id)
|
|
return follows
|
|
else:
|
|
raise ValueError('Author not found')
|
|
|
|
|
|
@query.field('get_author_follows_authors')
|
|
def get_author_follows_authors(_, _info, slug='', user=None, author_id=None):
|
|
with local_session() as session:
|
|
if user or slug:
|
|
author_id_result = session.query(Author.id).filter(or_(Author.user == user, Author.slug == slug)).first()
|
|
author_id = author_id_result[0] if author_id_result else None
|
|
if author_id:
|
|
follows = author_follows_topics(author_id)
|
|
return follows
|
|
else:
|
|
raise ValueError('Author not found')
|
|
|
|
|
|
@mutation.field('rate_author')
|
|
@login_required
|
|
def rate_author(_, info, rated_slug, value):
|
|
user_id = info.context['user_id']
|
|
|
|
with local_session() as session:
|
|
rated_author = session.query(Author).filter(Author.slug == rated_slug).first()
|
|
rater = session.query(Author).filter(Author.slug == user_id).first()
|
|
if rater and rated_author:
|
|
rating: AuthorRating = (
|
|
session.query(AuthorRating)
|
|
.filter(
|
|
and_(
|
|
AuthorRating.rater == rater.id,
|
|
AuthorRating.author == rated_author.id,
|
|
)
|
|
)
|
|
.first()
|
|
)
|
|
if rating:
|
|
rating.plus = value > 0
|
|
session.add(rating)
|
|
session.commit()
|
|
return {}
|
|
else:
|
|
try:
|
|
rating = AuthorRating(
|
|
rater=rater.id, author=rated_author.id, plus=value > 0
|
|
)
|
|
session.add(rating)
|
|
session.commit()
|
|
except Exception as err:
|
|
return {'error': err}
|
|
return {}
|
|
|
|
|
|
def create_author(user_id: str, slug: str, name: str = ''):
|
|
with local_session() as session:
|
|
new_author = Author(user=user_id, slug=slug, name=name)
|
|
session.add(new_author)
|
|
session.commit()
|
|
logger.info(f'author created by webhook {new_author.dict()}')
|
|
|
|
|
|
@query.field('get_author_followers')
|
|
def get_author_followers(_, _info, slug: str):
|
|
author_alias = aliased(Author)
|
|
alias_author_followers = aliased(AuthorFollower)
|
|
alias_author_authors = aliased(AuthorFollower)
|
|
alias_author_follower_followers = aliased(AuthorFollower)
|
|
alias_shout_author = aliased(ShoutAuthor)
|
|
|
|
q = (
|
|
select(author_alias)
|
|
.join(alias_author_authors, alias_author_authors.follower == int(author_alias.id))
|
|
.join(
|
|
alias_author_followers, alias_author_followers.author == int(author_alias.id)
|
|
)
|
|
.filter(author_alias.slug == slug)
|
|
.add_columns(
|
|
func.count(distinct(alias_shout_author.shout)).label('shouts_stat'),
|
|
func.count(distinct(alias_author_authors.author)).label('authors_stat'),
|
|
func.count(distinct(alias_author_follower_followers.follower)).label(
|
|
'followers_stat'
|
|
),
|
|
)
|
|
.outerjoin(alias_shout_author, author_alias.id == int(alias_shout_author.author))
|
|
.group_by(author_alias.id)
|
|
)
|
|
|
|
return execute_with_ministat(q)
|