52 lines
1.7 KiB
Python
52 lines
1.7 KiB
Python
import logging
|
|
|
|
from app import app
|
|
from data.database import Repository, LogEntry, RepositoryActionCount, db_random_func
|
|
from datetime import date, timedelta
|
|
from workers.worker import Worker
|
|
|
|
POLL_PERIOD_SECONDS = 10
|
|
|
|
logger = logging.getLogger(__name__)
|
|
|
|
def count_repository_actions():
|
|
try:
|
|
# Get a random repository to count.
|
|
today = date.today()
|
|
yesterday = today - timedelta(days=1)
|
|
has_yesterday_actions = (RepositoryActionCount.select(RepositoryActionCount.repository)
|
|
.where(RepositoryActionCount.date == yesterday))
|
|
|
|
to_count = (Repository.select()
|
|
.where(~(Repository.id << (has_yesterday_actions)))
|
|
.order_by(db_random_func()).get())
|
|
|
|
logger.debug('Counting: %s', to_count.id)
|
|
|
|
actions = (LogEntry.select()
|
|
.where(LogEntry.repository == to_count,
|
|
LogEntry.datetime >= yesterday,
|
|
LogEntry.datetime < today)
|
|
.count())
|
|
|
|
# Create the row.
|
|
try:
|
|
RepositoryActionCount.create(repository=to_count, date=yesterday, count=actions)
|
|
except:
|
|
logger.exception('Exception when writing count')
|
|
except Repository.DoesNotExist:
|
|
logger.debug('No further repositories to count')
|
|
|
|
|
|
class RepositoryActionCountWorker(Worker):
|
|
def __init__(self):
|
|
super(RepositoryActionCountWorker, self).__init__()
|
|
self.add_operation(self._count_repository_actions, POLL_PERIOD_SECONDS)
|
|
|
|
def _count_repository_actions(self):
|
|
""" Counts actions for a random repository for the previous day. """
|
|
count_repository_actions()
|
|
|
|
if __name__ == "__main__":
|
|
worker = RepositoryActionCountWorker()
|
|
worker.start()
|