63 lines
2.1 KiB
Python
63 lines
2.1 KiB
Python
import asyncio
|
|
|
|
from base.orm import local_session
|
|
from orm.shout import Shout, ShoutTopic
|
|
from orm.topic import TopicFollower
|
|
from services.zine.shoutauthor import ShoutAuthorStorage
|
|
|
|
|
|
class TopicStat:
|
|
# by slugs
|
|
shouts_by_topic = {} # Shout object stored
|
|
authors_by_topic = {} # User
|
|
followers_by_topic = {} # User
|
|
#
|
|
lock = asyncio.Lock()
|
|
period = 30 * 60 # sec
|
|
|
|
@staticmethod
|
|
async def load_stat(session):
|
|
self = TopicStat
|
|
shout_topics = session.query(ShoutTopic).all()
|
|
print("[stat.topics] %d links for shouts" % len(shout_topics))
|
|
for shout_topic in shout_topics:
|
|
tpc = shout_topic.topic
|
|
# shouts by topics
|
|
shout = session.query(Shout).where(Shout.slug == shout_topic.shout).first()
|
|
self.shouts_by_topic[tpc] = self.shouts_by_topic.get(tpc, dict())
|
|
self.shouts_by_topic[tpc][shout.slug] = shout
|
|
|
|
# authors by topics
|
|
authors = await ShoutAuthorStorage.get_authors(shout.slug)
|
|
self.authors_by_topic[tpc] = self.authors_by_topic.get(tpc, dict())
|
|
for a in authors:
|
|
[aslug, acaption] = a
|
|
self.authors_by_topic[tpc][aslug] = acaption
|
|
|
|
self.followers_by_topic = {}
|
|
followings = session.query(TopicFollower).all()
|
|
print("[stat.topics] %d followings by users" % len(followings))
|
|
for flw in followings:
|
|
topic = flw.topic
|
|
userslug = flw.follower
|
|
self.followers_by_topic[topic] = self.followers_by_topic.get(topic, dict())
|
|
self.followers_by_topic[topic][userslug] = userslug
|
|
|
|
@staticmethod
|
|
async def get_shouts(topic):
|
|
self = TopicStat
|
|
async with self.lock:
|
|
return self.shouts_by_topic.get(topic, dict())
|
|
|
|
@staticmethod
|
|
async def worker():
|
|
self = TopicStat
|
|
while True:
|
|
try:
|
|
with local_session() as session:
|
|
async with self.lock:
|
|
await self.load_stat(session)
|
|
except Exception as err:
|
|
raise Exception(err)
|
|
await asyncio.sleep(self.period)
|