62 lines
2.0 KiB
Python
62 lines
2.0 KiB
Python
import asyncio
|
|
from datetime import datetime, timedelta
|
|
|
|
from logbook import Logger
|
|
from sqlalchemy import func
|
|
|
|
from .models import User, context_session
|
|
|
|
logger = Logger(__name__)
|
|
|
|
|
|
class Refresher:
|
|
def __init__(self, config, wallabag, sender):
|
|
self.sessionmaker = context_session(config)
|
|
self.wallabag = wallabag
|
|
self.grace = config.refresh_grace
|
|
self.sender = sender
|
|
self.config = config
|
|
|
|
self._running = True
|
|
self._wait_fut = None # type: asyncio.Future
|
|
|
|
def _wait_time(self, session):
|
|
next = session.query(func.min(User.token_valid).label("min")).filter(User.active == True).first()
|
|
if next is None or next.min is None:
|
|
return 3
|
|
delta = next.min - datetime.utcnow()
|
|
if delta < timedelta(seconds=self.grace):
|
|
return 0
|
|
|
|
calculated = delta - timedelta(seconds=self.grace)
|
|
return calculated.total_seconds()
|
|
|
|
async def refresh(self):
|
|
while self._running:
|
|
with self.sessionmaker as session:
|
|
self._wait_fut = asyncio.sleep(self._wait_time(session))
|
|
try:
|
|
await self._wait_fut
|
|
except asyncio.CancelledError:
|
|
continue
|
|
finally:
|
|
self._wait_fut = None
|
|
|
|
ts = datetime.utcnow() + timedelta(seconds=self.grace)
|
|
refreshes = [self._refresh_user(user) for user
|
|
in session.query(User).filter(User.active == True).filter(User.token_valid < ts).all()]
|
|
await asyncio.gather(*refreshes)
|
|
|
|
session.commit()
|
|
|
|
async def _refresh_user(self, user):
|
|
logger.info("Refresh token for {}", user.name)
|
|
if not await self.wallabag.refresh_token(user):
|
|
await self.sender.send_warning(user, self.config)
|
|
user.active = False
|
|
|
|
def stop(self):
|
|
self._running = False
|
|
if self._wait_fut is not None:
|
|
self._wait_fut.cancel()
|