another relevant change to password security for the salt that is generated for every user Indivisdualy, to fix the temporary approach from before

This commit is contained in:
2026-06-24 19:41:22 +02:00
parent e1c284fc40
commit b270bc9367
2 changed files with 99 additions and 111 deletions
+90 -106
View File
@@ -20,6 +20,8 @@ import string
from bson.objectid import ObjectId from bson.objectid import ObjectId
import Web.modules.database.settings as cfg import Web.modules.database.settings as cfg
from Web.modules.database.settings import MongoClient from Web.modules.database.settings import MongoClient
import hmac
import os
logger = logging.getLogger('app') logger = logging.getLogger('app')
logger.setLevel(logging.DEBUG) logger.setLevel(logging.DEBUG)
@@ -430,104 +432,84 @@ def check_password_strength(password):
return True return True
def hashing(password): def hashing(password, salt=None):
""" """
Hash a password using scrypt. Hasht ein Passwort mit scrypt.
- Wenn kein Salt übergeben wird, wird ein sicherer, zufälliger Salt generiert (für neue Passwörter).
- Format für neue Hashes: v1$<salt_hex>$<hash_hex>
"""
password_bytes = password.encode('utf-8') # Explizit UTF-8 für Plattformunabhängigkeit
Args: if salt is None:
password (str): Password to hash # Neuer Benutzer / Passwortänderung -> Dynamischer Salt
random_salt = os.urandom(16)
Returns: hashed = hashlib.scrypt(password_bytes, salt=random_salt, n=16384, r=8, p=1)
str: Hexadecimal digest of the hashed password return f"v1${random_salt.hex()}${hashed.hex()}"
else:
# Bestehender Benutzer (wird zur Verifizierung aufgerufen)
hashed = hashlib.scrypt(password_bytes, salt=salt, n=16384, r=8, p=1)
return hashed.hex()
def verify_password(provided_password, stored_password_string):
""" """
hashed = hashlib.scrypt(password.encode(), salt=b'some_salt', n=16384, r=8, p=1) Verifiziert ein Passwort gegen einen gespeicherten Hash-String.
return hashed.hex() Unterstützt das alte Format (statischer Salt) und das neue Format (v1$...).
"""
if not stored_password_string:
return False
# Überprüfung für das neue, sichere Format
if stored_password_string.startswith("v1$"):
try:
_, salt_hex, hash_hex = stored_password_string.split("$")
salt_bytes = bytes.fromhex(salt_hex)
# Berechne den Hash des eingegebenen Passworts mit dem extrahierten Salt
calculated_hash = hashing(provided_password, salt=salt_bytes)
# Timing-Attack-sicherer Vergleich
return hmac.compare_digest(calculated_hash, hash_hex)
except (ValueError, TypeError):
logger.error("Ungültiges Hash-Format in der Datenbank entdeckt.")
return False
else:
# Abwärtskompatibilität: Altes Format mit statischem Salt b'some_salt'
old_static_salt = b'some_salt'
calculated_hash = hashing(provided_password, salt=old_static_salt)
return hmac.compare_digest(calculated_hash, stored_password_string)
def check_nm_pwd(username, password): def check_nm_pwd(username, password):
""" """
Verify username and password combination. Überprüft die Kombination aus Benutzername und Passwort (optimiert).
Args:
username (str): Username to check
password (str): Password to verify
Returns:
dict: User document if credentials are valid, None otherwise
""" """
db_name, tenant_id = _resolve_request_tenant_db() db_name, tenant_id = _resolve_request_tenant_db()
ctx = None
try:
from tenant import get_tenant_context
ctx = get_tenant_context()
except Exception:
ctx = None
if not db_name: if not db_name:
if _has_tenant_configs(): if _has_tenant_configs():
logger.warning( logger.warning("Default DB fallback verweigert, da Tenant-Konfigurationen existieren.")
"Refusing default DB fallback for login because tenant configs exist and no tenant was resolved."
)
return None return None
db_name = cfg.MONGODB_DB db_name = cfg.MONGODB_DB
logger.info(
"check_nm_pwd start: username=%r tenant=%r db=%r host=%r port=%r uri=%r",
username,
tenant_id,
db_name,
cfg.MONGODB_HOST,
cfg.MONGODB_PORT,
getattr(cfg, 'MONGODB_URI', None),
)
client = MongoClient(cfg.MONGODB_HOST, cfg.MONGODB_PORT) client = MongoClient(cfg.MONGODB_HOST, cfg.MONGODB_PORT)
try: try:
hashed_password = hashing(password)
logger.info("check_nm_pwd password hash for username=%r: %s", username, hashed_password)
available_dbs = []
try:
available_dbs = client.list_database_names()
logger.debug("MongoDB connected. Available databases=%s", available_dbs)
except Exception as exc:
logger.exception("Unable to list MongoDB databases: %s", exc)
db = client[db_name] db = client[db_name]
try:
existing_collections = db.list_collection_names()
except Exception as exc:
logger.exception("Unable to list collections for db=%r: %s", db_name, exc)
existing_collections = []
logger.debug("Tenant db=%r collections=%s", db_name, existing_collections)
users = db['users'] users = db['users']
query = {'$or': [{'Username': username}, {'username': username}]} query = {'$or': [{'Username': username}, {'username': username}]}
logger.debug("Running user lookup on %r: %s", db_name, query)
user_record = users.find_one(query) user_record = users.find_one(query)
if user_record is None: if user_record is None:
logger.warning("No user document found in db=%r for username=%r", db_name, username) logger.warning("Kein Benutzer für %r in DB %r gefunden.", username, db_name)
if db_name not in available_dbs:
logger.warning("Tenant database %r is missing from available MongoDB databases", db_name)
if 'users' not in existing_collections:
logger.warning("Tenant database %r has no users collection", db_name)
return None return None
logger.info("Found user document for username=%r in db=%r: %s", username, db_name, user_record)
stored_password = user_record.get('Password') or user_record.get('password') stored_password = user_record.get('Password') or user_record.get('password')
if stored_password is None:
logger.warning("User document for username=%r in db=%r has no password field", username, db_name) if not verify_password(password, stored_password):
logger.warning("Falsches Passwort für Benutzer %r in DB %r.", username, db_name)
return None return None
if stored_password != hashed_password: # Automatische Migration alter Hashes auf das neue Format
logger.warning( if not stored_password.startswith("v1$"):
"Password mismatch for username=%r in db=%r: provided_hash=%s stored_hash=%s", users.update_one({'_id': user_record['_id']}, {'$set': {'Password': hashing(password)}})
username,
db_name,
hashed_password,
stored_password,
)
return None
return user_record return user_record
finally: finally:
@@ -557,44 +539,46 @@ def add_user(
bool: True if user was added successfully, False if password was too weak bool: True if user was added successfully, False if password was too weak
""" """
client = MongoClient(cfg.MONGODB_HOST, cfg.MONGODB_PORT) client = MongoClient(cfg.MONGODB_HOST, cfg.MONGODB_PORT)
db = _get_tenant_db(client) try:
users = db['users'] db = _get_tenant_db(client)
if not check_password_strength(password): users = db['users']
return False if not check_password_strength(password):
permission_defaults = build_default_permission_payload(permission_preset) return False
if isinstance(action_permissions, dict): permission_defaults = build_default_permission_payload(permission_preset)
for key, value in action_permissions.items(): if isinstance(action_permissions, dict):
permission_defaults['actions'][str(key)] = bool(value) for key, value in action_permissions.items():
if isinstance(page_permissions, dict): permission_defaults['actions'][str(key)] = bool(value)
for key, value in page_permissions.items(): if isinstance(page_permissions, dict):
permission_defaults['pages'][str(key)] = bool(value) for key, value in page_permissions.items():
permission_defaults['pages'][str(key)] = bool(value)
user_doc = { user_doc = {
'Username': username, 'Username': username,
'Password': hashing(password), 'Password': hashing(password),
'Admin': False, 'Admin': False,
'active_ausleihung': None, 'active_ausleihung': None,
'name': name.strip() if name else '', 'name': name.strip() if name else '',
'last_name': last_name.strip() if last_name else '', 'last_name': last_name.strip() if last_name else '',
'IsStudent': bool(is_student), 'IsStudent': bool(is_student),
'PermissionPreset': permission_defaults['preset'], 'PermissionPreset': permission_defaults['preset'],
'ActionPermissions': permission_defaults['actions'], 'ActionPermissions': permission_defaults['actions'],
'PagePermissions': permission_defaults['pages'], 'PagePermissions': permission_defaults['pages'],
} }
normalized_card = normalize_student_card_id(student_card_id) normalized_card = normalize_student_card_id(student_card_id)
if bool(is_student): if bool(is_student):
if normalized_card: if normalized_card:
user_doc['StudentCardId'] = normalized_card user_doc['StudentCardId'] = normalized_card
if max_borrow_days is not None: if max_borrow_days is not None:
try: try:
user_doc['MaxBorrowDays'] = int(max_borrow_days) user_doc['MaxBorrowDays'] = int(max_borrow_days)
except (TypeError, ValueError): except (TypeError, ValueError):
pass pass
users.insert_one(user_doc) users.insert_one(user_doc)
client.close() return True
return True finally:
client.close()
def student_card_exists(student_card_id): def student_card_exists(student_card_id):
+9 -5
View File
@@ -194,8 +194,8 @@ initialize_tenant_database() {
return 0 return 0
fi fi
docker exec "$APP_CONTAINER" python3 -c ' docker exec -i "$APP_CONTAINER" python3 - "$tenant_id" "$mode" <<'PY'
import sys, re, datetime, hashlib import sys, os, re, datetime, hashlib
sys.path.insert(0, "/app") sys.path.insert(0, "/app")
sys.path.insert(0, "/app/Web") sys.path.insert(0, "/app/Web")
from Web.modules.database import settings from Web.modules.database import settings
@@ -207,7 +207,11 @@ sanitized = "".join(c for c in tenant_id if c.isalnum() or c == "_")
db_name = f"inventar_{sanitized}" db_name = f"inventar_{sanitized}"
client = MongoClient(settings.MONGODB_HOST, int(settings.MONGODB_PORT)) client = MongoClient(settings.MONGODB_HOST, int(settings.MONGODB_PORT))
db = client[db_name] db = client[db_name]
hashed_pw = hashlib.scrypt("admin123", salt=b"some_salt", n=16384, r=8, p=1).hex()
pw_bytes = "admin123".encode("utf-8")
random_salt = os.urandom(16)
hashed = hashlib.scrypt(pw_bytes, salt=random_salt, n=16384, r=8, p=1)
hashed_pw_string = f"v1${random_salt.hex()}${hashed.hex()}"
action_permissions = { action_permissions = {
"can_borrow": True, "can_borrow": True,
@@ -243,7 +247,7 @@ page_permissions = {
if db.users.count_documents({"Username": "admin"}) == 0: if db.users.count_documents({"Username": "admin"}) == 0:
db.users.insert_one({ db.users.insert_one({
"Username": "admin", "Username": "admin",
"Password": hashed_pw, "Password": hashed_pw_string,
"Admin": True, "Admin": True,
"active_ausleihung": None, "active_ausleihung": None,
"name": "Admin", "name": "Admin",
@@ -268,7 +272,7 @@ if mode == "trial":
) )
print(f"Tenant {sys.argv[1]} database initialized. Default admin: admin / admin123") print(f"Tenant {sys.argv[1]} database initialized. Default admin: admin / admin123")
' "$tenant_id" "$mode" PY
} }
update_runtime_ports() { update_runtime_ports() {