Sitzungsdauer einstellbar, bis hin zu unbegrenzt
Die Anmeldung galt fest 7 Tage - und die Frist lief ab dem *Anmelden*, nicht ab der letzten Nutzung. Wer die App taeglich benutzte, flog trotzdem punktgenau nach einer Woche hinaus. Beides ist jetzt geregelt: - Einstellungen -> Anmeldung: 7 Tage bis 1 Jahr oder unbegrenzt. Gilt fuer Website und App gemeinsam, weil beide dasselbe Token bekommen - auch nach Single Sign-on. - POST /auth/refresh schiebt die Frist beim Start nach vorn. Damit zaehlt die eingestellte Dauer ab dem letzten Besuch, und eine geaenderte Einstellung greift ohne Neuanmeldung. "Unbegrenzt" heisst ein Token ganz ohne exp. Das ist bewusst folgenreich: Es gibt keine Sperrliste, eine erteilte Anmeldung laesst sich nicht einzeln zurueckziehen. Die Oberflaeche sagt das dazu und nennt den einzigen Ausweg (JWT_SECRET aendern). /auth/refresh nimmt bewusst nur JWTs an, keine langlebigen API-Token: aus einem jederzeit widerrufbaren Zugang (Home Assistant) waere sonst ein unwiderruflicher geworden. Der Rueckfallwert aus der Umgebung steigt von 7 auf 30 Tage - er gilt nur noch, solange nichts eingestellt ist. Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
This commit is contained in:
co-authored by
Claude Opus 5
parent
2b9b98dd14
commit
254737086e
@@ -12,7 +12,10 @@ class Settings(BaseSettings):
|
||||
# Auth / JWT
|
||||
jwt_secret: str = "change-me-in-production"
|
||||
jwt_algorithm: str = "HS256"
|
||||
jwt_expire_minutes: int = 60 * 24 * 7 # 7 days
|
||||
# Rueckfallwert fuer die Sitzungsdauer. Im Betrieb entscheidet die
|
||||
# Einstellung "session_days" (Verwaltung -> Einstellungen); dieser Wert gilt
|
||||
# nur, solange dort nichts gesetzt ist.
|
||||
jwt_expire_minutes: int = 60 * 24 * 30 # 30 Tage
|
||||
|
||||
# First admin, created on startup if no users exist
|
||||
admin_username: str = "admin"
|
||||
|
||||
+2
-2
@@ -17,7 +17,7 @@ _credentials_exc = HTTPException(
|
||||
)
|
||||
|
||||
|
||||
def _nutzer_aus_payload(db: Session, payload: dict) -> User | None:
|
||||
def nutzer_aus_payload(db: Session, payload: dict) -> User | None:
|
||||
"""Loest die Sitzung auf – bevorzugt ueber die Benutzer-ID.
|
||||
|
||||
Der Benutzername ist Anzeige und darf sich aendern; die ID nicht. Deshalb
|
||||
@@ -44,7 +44,7 @@ def get_current_user(
|
||||
"""Akzeptiert ein JWT aus dem Login oder ein langlebiges API-Token."""
|
||||
payload = decode_access_token(token)
|
||||
if payload is not None:
|
||||
user = _nutzer_aus_payload(db, payload)
|
||||
user = nutzer_aus_payload(db, payload)
|
||||
if user is None:
|
||||
raise _credentials_exc
|
||||
return user
|
||||
|
||||
@@ -3,10 +3,11 @@ from fastapi.security import OAuth2PasswordRequestForm
|
||||
from sqlalchemy.orm import Session
|
||||
|
||||
from ..database import get_db
|
||||
from ..deps import get_current_user
|
||||
from ..deps import get_current_user, nutzer_aus_payload, oauth2_scheme
|
||||
from ..models import User
|
||||
from ..schemas import Token, UserOut
|
||||
from ..security import create_access_token, verify_password
|
||||
from ..security import create_access_token, decode_access_token, verify_password
|
||||
from .settings import get_session_minutes
|
||||
|
||||
router = APIRouter(prefix="/auth", tags=["auth"])
|
||||
|
||||
@@ -21,10 +22,42 @@ def login(
|
||||
status_code=status.HTTP_401_UNAUTHORIZED,
|
||||
detail="Benutzername oder Passwort falsch",
|
||||
)
|
||||
token = create_access_token(user_id=user.id, role=user.role.value)
|
||||
token = create_access_token(
|
||||
user_id=user.id, role=user.role.value, gueltig_minuten=get_session_minutes(db)
|
||||
)
|
||||
return Token(access_token=token, role=user.role, username=user.username)
|
||||
|
||||
|
||||
@router.post("/refresh", response_model=Token)
|
||||
def refresh(
|
||||
token: str = Depends(oauth2_scheme), db: Session = Depends(get_db)
|
||||
) -> Token:
|
||||
"""Stellt der laufenden Sitzung ein frisches Token aus.
|
||||
|
||||
Ohne das laeuft die Frist ab dem *Anmelden*, nicht ab der letzten Nutzung:
|
||||
Wer die App taeglich benutzt, fliegt trotzdem punktgenau nach Ablauf
|
||||
hinaus. Weboberflaeche und App rufen das beim Start auf; damit zaehlt die
|
||||
eingestellte Dauer ab dem letzten Besuch.
|
||||
|
||||
Bewusst NICHT ueber ``get_current_user``: das nimmt auch langlebige
|
||||
API-Token an (Home Assistant). Aus so einem Token hier ein JWT zu machen,
|
||||
haette aus einem jederzeit widerrufbaren Zugang einen unwiderruflichen
|
||||
gemacht.
|
||||
"""
|
||||
payload = decode_access_token(token)
|
||||
user = nutzer_aus_payload(db, payload) if payload is not None else None
|
||||
if user is None:
|
||||
raise HTTPException(
|
||||
status_code=status.HTTP_401_UNAUTHORIZED,
|
||||
detail="Ungültige oder abgelaufene Anmeldung",
|
||||
headers={"WWW-Authenticate": "Bearer"},
|
||||
)
|
||||
neu = create_access_token(
|
||||
user_id=user.id, role=user.role.value, gueltig_minuten=get_session_minutes(db)
|
||||
)
|
||||
return Token(access_token=neu, role=user.role, username=user.username)
|
||||
|
||||
|
||||
@router.get("/me", response_model=UserOut)
|
||||
def me(current_user: User = Depends(get_current_user)) -> User:
|
||||
return current_user
|
||||
|
||||
@@ -35,6 +35,7 @@ from ..schemas import (
|
||||
Token,
|
||||
)
|
||||
from ..security import create_access_token
|
||||
from .settings import get_session_minutes
|
||||
from ..services import oidc as dienst
|
||||
from ..services import oidc_state
|
||||
|
||||
@@ -63,8 +64,12 @@ def _provider_oder_404(slug: str) -> OidcProvider:
|
||||
return provider
|
||||
|
||||
|
||||
def _token_fuer(user: User) -> Token:
|
||||
token = create_access_token(user_id=user.id, role=user.role.value)
|
||||
def _token_fuer(user: User, db: Session) -> Token:
|
||||
# Die Sitzungsdauer steht in den Einstellungen und gilt fuer JEDEN Weg
|
||||
# herein - nach Single Sign-on genauso wie nach dem Passwort-Login.
|
||||
token = create_access_token(
|
||||
user_id=user.id, role=user.role.value, gueltig_minuten=get_session_minutes(db)
|
||||
)
|
||||
return Token(access_token=token, role=user.role, username=user.username)
|
||||
|
||||
|
||||
@@ -209,7 +214,7 @@ def anmeldung_abschliessen(
|
||||
logger.warning("SSO '%s' gescheitert: %s", slug, fehler)
|
||||
return _fehler_weiterleitung(fehler.schluessel, verknuepfung=verknuepfen_fuer is not None)
|
||||
|
||||
token = _token_fuer(nutzer)
|
||||
token = _token_fuer(nutzer, db)
|
||||
logger.info("SSO '%s': '%s' angemeldet.", slug, nutzer.username)
|
||||
# Token im Fragment, nicht in der Abfragezeichenkette: Fragmente werden nicht
|
||||
# an den Server geschickt und landen damit auch nicht in den nginx-Logs.
|
||||
@@ -253,7 +258,7 @@ def anmeldung_app(slug: str, payload: OidcNativeLogin, db: Session = Depends(get
|
||||
raise HTTPException(status.HTTP_401_UNAUTHORIZED, str(fehler)) from fehler
|
||||
|
||||
logger.info("SSO '%s' (App): '%s' angemeldet.", slug, nutzer.username)
|
||||
return _token_fuer(nutzer)
|
||||
return _token_fuer(nutzer, db)
|
||||
|
||||
|
||||
# ---------------------------------------------------------------------------
|
||||
@@ -394,7 +399,7 @@ def offene_anmeldung_neues_konto(code: str, db: Session = Depends(get_db)) -> To
|
||||
except dienst.OidcFehler as fehler:
|
||||
raise HTTPException(status.HTTP_403_FORBIDDEN, str(fehler)) from fehler
|
||||
logger.info("SSO '%s': neues Konto '%s' auf Wunsch angelegt.", provider.slug, nutzer.username)
|
||||
return _token_fuer(nutzer)
|
||||
return _token_fuer(nutzer, db)
|
||||
|
||||
|
||||
@router.post("/pending/{code}/verknuepfen", response_model=Token)
|
||||
@@ -417,4 +422,4 @@ def offene_anmeldung_verknuepfen(
|
||||
)
|
||||
raise HTTPException(code_http, str(fehler)) from fehler
|
||||
logger.info("SSO '%s': mit bestehendem Konto '%s' verknuepft.", provider.slug, nutzer.username)
|
||||
return _token_fuer(nutzer)
|
||||
return _token_fuer(nutzer, db)
|
||||
|
||||
@@ -1,4 +1,4 @@
|
||||
from fastapi import APIRouter, Depends
|
||||
from fastapi import APIRouter, Depends, HTTPException
|
||||
from sqlalchemy.orm import Session
|
||||
|
||||
from ..config import get_settings
|
||||
@@ -14,6 +14,11 @@ EXPIRY_WARNING_KEY = "expiry_warning_days"
|
||||
# Treffer vorgeschlagen wird.
|
||||
RECEIPT_THRESHOLD_KEY = "receipt_match_threshold"
|
||||
RECEIPT_THRESHOLD_DEFAULT = 45
|
||||
# Wie lange eine Anmeldung gilt, in Tagen. 0 = unbegrenzt.
|
||||
SESSION_DAYS_KEY = "session_days"
|
||||
# Zehn Jahre. Wer laenger will, nimmt "unbegrenzt" – ein Token mit einem
|
||||
# Ablauf im naechsten Jahrhundert waere dasselbe, nur unehrlicher.
|
||||
SESSION_DAYS_MAX = 3650
|
||||
|
||||
|
||||
def get_expiry_warning_days(db: Session) -> int:
|
||||
@@ -37,6 +42,31 @@ def get_receipt_match_threshold(db: Session) -> int:
|
||||
return RECEIPT_THRESHOLD_DEFAULT
|
||||
|
||||
|
||||
def get_session_days(db: Session) -> int:
|
||||
"""Gueltigkeitsdauer einer Anmeldung in Tagen; **0 heisst unbegrenzt**.
|
||||
|
||||
Ohne Eintrag gilt der Rueckfallwert aus der Umgebung
|
||||
(``JWT_EXPIRE_MINUTES``), damit eine frische Installation nicht erst
|
||||
eingestellt werden muss.
|
||||
"""
|
||||
vorgabe = max(1, round(get_settings().jwt_expire_minutes / (60 * 24)))
|
||||
row = db.get(Setting, SESSION_DAYS_KEY)
|
||||
if row is None:
|
||||
return vorgabe
|
||||
try:
|
||||
return max(0, min(SESSION_DAYS_MAX, int(row.value)))
|
||||
except ValueError:
|
||||
return vorgabe
|
||||
|
||||
|
||||
def get_session_minutes(db: Session) -> int:
|
||||
"""Dasselbe in Minuten, wie :func:`create_access_token` es erwartet.
|
||||
|
||||
Die 0 fuer "unbegrenzt" ueberlebt die Umrechnung unveraendert.
|
||||
"""
|
||||
return get_session_days(db) * 24 * 60
|
||||
|
||||
|
||||
@router.get("", response_model=list[SettingOut])
|
||||
def list_settings(
|
||||
db: Session = Depends(get_db), _: User = Depends(get_current_user)
|
||||
@@ -45,6 +75,7 @@ def list_settings(
|
||||
known = {r.key: r.value for r in rows}
|
||||
known.setdefault(EXPIRY_WARNING_KEY, str(get_expiry_warning_days(db)))
|
||||
known.setdefault(RECEIPT_THRESHOLD_KEY, str(get_receipt_match_threshold(db)))
|
||||
known.setdefault(SESSION_DAYS_KEY, str(get_session_days(db)))
|
||||
return [SettingOut(key=k, value=v) for k, v in known.items()]
|
||||
|
||||
|
||||
@@ -55,6 +86,17 @@ def set_setting(
|
||||
db: Session = Depends(get_db),
|
||||
_: User = Depends(require_admin),
|
||||
) -> SettingOut:
|
||||
if key == SESSION_DAYS_KEY:
|
||||
# Ohne diese Pruefung wuerde get_session_days einen Tippfehler still
|
||||
# auf die Vorgabe zurueckdrehen – und der Admin glaubte, es sei gesetzt.
|
||||
try:
|
||||
tage = int(value)
|
||||
except ValueError:
|
||||
raise HTTPException(400, "Sitzungsdauer muss eine Zahl in Tagen sein (0 = unbegrenzt)")
|
||||
if not 0 <= tage <= SESSION_DAYS_MAX:
|
||||
raise HTTPException(400, f"Sitzungsdauer: 0 (unbegrenzt) bis {SESSION_DAYS_MAX} Tage")
|
||||
value = str(tage)
|
||||
|
||||
row = db.get(Setting, key)
|
||||
if row is None:
|
||||
row = Setting(key=key, value=value)
|
||||
|
||||
+14
-3
@@ -31,7 +31,9 @@ def verify_password(password: str, password_hash: str | None) -> bool:
|
||||
return False
|
||||
|
||||
|
||||
def create_access_token(user_id: int, role: str) -> str:
|
||||
def create_access_token(
|
||||
user_id: int, role: str, gueltig_minuten: int | None = None
|
||||
) -> str:
|
||||
"""Stellt ein Sitzungs-Token aus, das den Benutzer ueber seine ID benennt.
|
||||
|
||||
Frueher stand hier der Benutzername. Damit war der Name die Kennung der
|
||||
@@ -41,9 +43,18 @@ def create_access_token(user_id: int, role: str) -> str:
|
||||
``uid`` steht zusaetzlich zu ``sub`` drin, damit sich alte Token (``sub`` =
|
||||
Name) eindeutig von neuen unterscheiden lassen – ein Benutzer koennte sonst
|
||||
schlicht "42" heissen.
|
||||
|
||||
``gueltig_minuten`` kommt aus der Einstellung ``session_days``; ``None``
|
||||
nimmt den Rueckfallwert aus der Umgebung. **0 heisst unbegrenzt** – dann
|
||||
bekommt das Token gar kein ``exp`` und laeuft nie ab. Diese Wahl ist
|
||||
bewusst folgenreich: Ein ausgestelltes Token laesst sich nicht
|
||||
zurueckrufen, es gibt keine Sperrliste. Wer alle Anmeldungen beenden will,
|
||||
muss JWT_SECRET aendern.
|
||||
"""
|
||||
expire = datetime.now(timezone.utc) + timedelta(minutes=settings.jwt_expire_minutes)
|
||||
payload = {"sub": str(user_id), "uid": user_id, "role": role, "exp": expire}
|
||||
minuten = settings.jwt_expire_minutes if gueltig_minuten is None else gueltig_minuten
|
||||
payload: dict = {"sub": str(user_id), "uid": user_id, "role": role}
|
||||
if minuten > 0:
|
||||
payload["exp"] = datetime.now(timezone.utc) + timedelta(minutes=minuten)
|
||||
return jwt.encode(payload, settings.jwt_secret, algorithm=settings.jwt_algorithm)
|
||||
|
||||
|
||||
|
||||
Reference in New Issue
Block a user