Upload 3 files

auth.py

@@ -5,7 +5,7 @@ Gestiona usuarios, verificación de contraseñas y sincronización de usuarios p
 import sys
 import streamlit as st
 from datetime import datetime
-from database import get_user, create_user, update_user_password, get_all_users
+from databases import get_user, create_user, update_user_password, get_all_users
 from mobile_verification import (
     initialize_sms_state,
     render_mobile_verification_screen,

config.yaml

@@ -21,7 +21,7 @@ storage:
 
 sqlite:
   # base de datos SQLite local del space
-  path: "data/app.db"
+  path: "data/login.db"
 
 security:
   # coste de bcrypt (más alto = más seguro pero más lento)

databases.py

@@ -0,0 +1,191 @@
+import os
+import sqlite3
+from contextlib import contextmanager
+from typing import Optional, Dict, Any, List, Tuple
+from datetime import datetime
+
+# Reutilizamos la misma lógica que antes, pero centralizada en este módulo
+
+DEFAULT_DB_PATH = None  # set by set_db_path at runtime
+
+
+def set_db_path(db_path: str):
+    global DEFAULT_DB_PATH
+    DEFAULT_DB_PATH = db_path
+    os.makedirs(os.path.dirname(db_path), exist_ok=True)
+
+
+def get_connection():
+    if not DEFAULT_DB_PATH:
+        raise ValueError("Database path not set. Call set_db_path(path) first.")
+    return sqlite3.connect(DEFAULT_DB_PATH)
+
+
+@contextmanager
+def get_conn(db_path: Optional[str] = None):
+    path = db_path or DEFAULT_DB_PATH
+    conn = sqlite3.connect(path, check_same_thread=False)
+    conn.row_factory = sqlite3.Row
+    try:
+        yield conn
+        conn.commit()
+    finally:
+        conn.close()
+
+
+def init_schema():
+    with get_conn() as conn:
+        c = conn.cursor()
+        # (tus tablas existentes)
+        c.execute(
+            """
+        CREATE TABLE IF NOT EXISTS users (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            username TEXT UNIQUE NOT NULL,
+            password_hash TEXT,
+            role TEXT NOT NULL,
+            created_at TEXT NOT NULL
+        );
+        """
+        )
+        # Migraciones: asegurar columnas esperadas
+        try:
+            c.execute("PRAGMA table_info(users)")
+            cols = {row[1] for row in c.fetchall()}  # set de nombres de columnas
+            if "password_hash" not in cols:
+                c.execute("ALTER TABLE users ADD COLUMN password_hash TEXT")
+            if "role" not in cols:
+                c.execute("ALTER TABLE users ADD COLUMN role TEXT NOT NULL DEFAULT 'verd'")
+            if "created_at" not in cols:
+                c.execute("ALTER TABLE users ADD COLUMN created_at TEXT NOT NULL DEFAULT ''")
+        except sqlite3.OperationalError:
+            pass
+        # Intento de limpieza de columna antigua si existiera (SQLite no permite DROP COLUMN en versiones antiguas)
+        try:
+            c.execute("ALTER TABLE users DROP COLUMN pw_hash;")
+        except sqlite3.OperationalError:
+            pass
+        # (opcional: tus otras tablas)
+
+        # >>> TABLA PARA FEEDBACK DE AD (no depende de videos)
+        c.execute(
+            """
+        CREATE TABLE IF NOT EXISTS feedback_ad (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            video_name TEXT NOT NULL,          -- nombre de carpeta dentro de videos/completed
+            user_id INTEGER NOT NULL REFERENCES users(id) ON DELETE CASCADE,
+            transcripcio INTEGER NOT NULL,     -- 1..10
+            identificacio INTEGER NOT NULL,    -- 1..10
+            localitzacions INTEGER NOT NULL,   -- 1..10
+            activitats INTEGER NOT NULL,       -- 1..10
+            narracions INTEGER NOT NULL,       -- 1..10
+            expressivitat INTEGER NOT NULL,    -- 1..10
+            comments TEXT,
+            created_at TEXT NOT NULL
+        );
+        """
+        )
+        # Add column if it doesn't exist, for backwards compatibility
+        try:
+            c.execute(
+                "ALTER TABLE feedback_ad ADD COLUMN expressivitat INTEGER NOT NULL DEFAULT 7;"
+            )
+        except sqlite3.OperationalError:
+            pass  # column already exists
+
+
+def add_feedback_ad(
+    video_name: str,
+    user_id: int,
+    transcripcio: int,
+    identificacio: int,
+    localitzacions: int,
+    activitats: int,
+    narracions: int,
+    expressivitat: int,
+    comments: str | None,
+):
+    with get_conn() as conn:
+        conn.execute(
+            """INSERT INTO feedback_ad
+               (video_name, user_id, transcripcio, identificacio, localitzacions, activitats, narracions, expressivitat, comments, created_at)
+               VALUES (?,?,?,?,?,?,?,?,?,?)""",
+            (
+                video_name,
+                user_id,
+                transcripcio,
+                identificacio,
+                localitzacions,
+                activitats,
+                narracions,
+                expressivitat,
+                comments,
+                now_str(),
+            ),
+        )
+
+
+def get_feedback_ad_for_video(video_name: str):
+    with get_conn() as conn:
+        cur = conn.execute(
+            """SELECT * FROM feedback_ad WHERE video_name=? ORDER BY created_at DESC""",
+            (video_name,),
+        )
+        return cur.fetchall()
+
+
+def get_feedback_ad_stats():
+    # medias por vídeo y ranking
+    with get_conn() as conn:
+        cur = conn.execute(
+            """
+            SELECT
+              video_name,
+              COUNT(*) AS n,
+              AVG(transcripcio)   AS avg_transcripcio,
+              AVG(identificacio)  AS avg_identificacio,
+              AVG(localitzacions) AS avg_localitzacions,
+              AVG(activitats)     AS avg_activitats,
+              AVG(narracions)     AS avg_narracions,
+              AVG(expressivitat)  AS avg_expressivitat,
+              (AVG(transcripcio)+AVG(identificacio)+AVG(localitzacions)+AVG(activitats)+AVG(narracions)+AVG(expressivitat))/6.0 AS avg_global
+            FROM feedback_ad
+            GROUP BY video_name
+            ORDER BY avg_global DESC, n DESC;
+        """
+        )
+        return cur.fetchall()
+
+
+def now_str():
+    return datetime.utcnow().isoformat(timespec="seconds") + "Z"
+
+
+# Users
+
+def create_user(username: str, password_hash: str, role: str):
+    with get_conn() as conn:
+        conn.execute(
+            "INSERT INTO users(username, password_hash, role, created_at) VALUES (?,?,?,?)",
+            (username, password_hash, role, now_str()),
+        )
+
+
+def get_user(username: str):
+    with get_conn() as conn:
+        cur = conn.execute("SELECT * FROM users WHERE username=?", (username,))
+        return cur.fetchone()
+
+
+def get_all_users() -> List[Dict[str, Any]]:
+    with get_conn() as conn:
+        cur = conn.execute("SELECT id, username, role FROM users ORDER BY username")
+        return cur.fetchall()
+
+
+def update_user_password(username: str, password_hash: str):
+    with get_conn() as conn:
+        conn.execute(
+            "UPDATE users SET password_hash = ? WHERE username = ?",
+            (password_hash, username),
+        )