feat: refresh token in middleware, no polling

this should make fly suspend + resume work

mona/app.py

@@ -3,10 +3,11 @@
 import random
 import re
 from contextlib import asynccontextmanager
+from datetime import datetime
 
 import anitopy
 import httpx
-from fastapi import FastAPI, HTTPException
+from fastapi import FastAPI, HTTPException, Request
 from fastapi.responses import RedirectResponse
 from fastapi_cache import FastAPICache
 from fastapi_cache.backends.inmemory import InMemoryBackend
@@ -20,7 +21,6 @@
 @asynccontextmanager
 async def lifespan(app: FastAPI):
     FastAPICache.init(InMemoryBackend())
-    await tvdb.login()
     yield
 
 
@@ -29,6 +29,16 @@ async def lifespan(app: FastAPI):
 tvdb = TVDB(os.environ["TVDB_API_KEY"])
 
 
+@app.middleware("http")
+async def tvdb_login(request: Request, call_next):
+    if tvdb.token is None:
+        await tvdb.login()
+    elif datetime.now().timestamp() > tvdb.token_expires:
+        await tvdb.login()
+    response = await call_next(request)
+    return response
+
+
 def slugify(text: str) -> str:
     # lowercase
     text = text.lower()

mona/tvdb.py

@@ -1,6 +1,7 @@
 #!/usr/bin/env python3
 import asyncio
 import os
+from datetime import datetime
 
 import httpx
 from loguru import logger
@@ -9,22 +10,21 @@
 class TVDB:
     def __init__(self, apikey: str, pin: str = "hello world"):
         self.token: str | None = None
+        self.token_expires: int | None = None
         self.apikey: str = apikey
         self.pin: str = pin
         self.api_base: str = "https://api4.thetvdb.com/v4"
 
     async def login(self) -> str | None:
-        # refresh token every hour
-        asyncio.get_event_loop().call_later(
-            3600, lambda: asyncio.create_task(self.login())
-        )
         async with httpx.AsyncClient(http2=True) as client:
             response = await client.post(
                 f"{self.api_base}/login",
                 json={"apikey": self.apikey, "pin": self.pin},
             )
             if response.status_code == 200:
                 self.token = response.json().get("data", {}).get("token")
+                # set token to expire in an hour
+                self.token_expires = datetime.now().timestamp() + 3600
                 logger.info("TVDB token refreshed!")
             else:
                 logger.error("TVDB token refresh failed!")