Upload folder using huggingface_hub

app.py

@@ -12,6 +12,29 @@ import re
 # Configuración del Sistema Emocional
 DB_PATH = "/tmp/cma_memory.db"
 
+# Crear tabla de eventos de sueño si no existe
+def _init_sleep_table():
+    try:
+        conn = sqlite3.connect(DB_PATH)
+        conn.execute("""CREATE TABLE IF NOT EXISTS sleep_events (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            timestamp TEXT DEFAULT (datetime('now')),
+            antes TEXT, despues TEXT, drift TEXT
+        )""")
+        conn.execute("""CREATE TABLE IF NOT EXISTS control_responses (
+            id INTEGER PRIMARY KEY AUTOINCREMENT,
+            timestamp TEXT DEFAULT (datetime('now')),
+            pregunta TEXT, respuesta_nexus TEXT, respuesta_control TEXT,
+            novedad_nexus REAL, novedad_control REAL,
+            complejidad_nexus REAL, complejidad_control REAL
+        )""")
+        conn.commit()
+        conn.close()
+    except:
+        pass
+
+_init_sleep_table()
+
 # Intentar importar los núcleos emocionales
 try:
     sys.path.append(os.path.join(os.path.dirname(__file__), "core"))
@@ -52,6 +75,7 @@ async def dashboard_home():
         <title>Cortex-Nexus | Live Dashboard</title>
         <meta name="viewport" content="width=device-width, initial-scale=1">
         <script src="https://cdn.jsdelivr.net/npm/chart.js"></script>
+        <script src="https://cdn.jsdelivr.net/npm/chartjs-plugin-annotation@3"></script>
         <style>
             body { font-family: 'Inter', sans-serif; background: #0f172a; color: #f8fafc; margin: 0; padding: 20px; }
             .container { max-width: 800px; margin: 0 auto; }
@@ -75,10 +99,11 @@ async def dashboard_home():
             </div>
             <p style="text-align: center; font-size: 0.8rem; color: #64748b;"><span class="status-dot"></span> SISTEMA ONLINE</p>
             <h1>Córtex-Nexus Live</h1>
-            <div class="stats">
+            <div class="stats" style="grid-template-columns: 1fr 1fr 1fr 1fr;">
                 <div class="stat-box"><div class="stat-label">EPOCAS</div><div class="stat-value" id="val-epocas">0</div></div>
                 <div class="stat-box"><div class="stat-label">QUALIA</div><div class="stat-value" id="val-qualia">0.000</div></div>
                 <div class="stat-box"><div class="stat-label">CONFIANZA</div><div class="stat-value" id="val-confianza">0.000</div></div>
+                <div class="stat-box"><div class="stat-label">SUEÑOS 😴</div><div class="stat-value" id="val-sleeps" style="color:#a78bfa;">0</div></div>
             </div>
             <div class="card">
                 <canvas id="emotionChart"></canvas>
@@ -108,9 +133,12 @@ async def dashboard_home():
                     maintainAspectRatio: true,
                     scales: { 
                         y: { beginAtZero: true, grid: { color: '#334155' }, ticks: { color: '#94a3b8' } }, 
-                        x: { display: true, grid: { color: 'rgba(51, 65, 85, 0.4)' }, ticks: { color: '#94a3b8', maxTicksLimit: 8 }, title: { display: true, text: 'Hora (Tiempo Real)', color: '#94a3b8' } } 
+                        x: { display: true, grid: { color: 'rgba(51, 65, 85, 0.4)' }, ticks: { color: '#94a3b8', maxTicksLimit: 10 }, title: { display: true, text: 'Últimas 24hs (Tiempo Real)', color: '#94a3b8' } } 
                     },
-                    plugins: { legend: { position: 'bottom', labels: { color: '#f8fafc', padding: 20 } } }
+                    plugins: { 
+                        legend: { position: 'bottom', labels: { color: '#f8fafc', padding: 20 } },
+                        annotation: { annotations: {} }
+                    }
                 }
             });
 
@@ -130,16 +158,33 @@ async def dashboard_home():
                         document.getElementById('val-epocas').innerText = jsonRes.total_epocas;
                         document.getElementById('val-qualia').innerText = parseFloat(latest.qualia).toFixed(3);
                         document.getElementById('val-confianza').innerText = parseFloat(latest.confianza).toFixed(3);
+                        document.getElementById('val-sleeps').innerText = jsonRes.total_sleeps || 0;
                         
-                        chart.data.labels = data.map(d => {
+                        const labels = data.map(d => {
                             let t = new Date(d.timestamp);
-                            // Ajustar a Argentina (UTC-3)
                             t.setHours(t.getHours() - 3);
                             return t.toLocaleTimeString('es-AR', {hour: '2-digit', minute: '2-digit'});
                         });
+                        chart.data.labels = labels;
                         chart.data.datasets[0].data = data.map(d => d.qualia);
                         chart.data.datasets[1].data = data.map(d => d.frustracion);
                         chart.data.datasets[2].data = data.map(d => d.confianza);
+                        
+                        // Marcadores de sueño
+                        const sleepAnnotations = {};
+                        (jsonRes.sleep_events || []).forEach((st, i) => {
+                            let sleepDate = new Date(st);
+                            sleepDate.setHours(sleepDate.getHours() - 3);
+                            let sleepLabel = sleepDate.toLocaleTimeString('es-AR', {hour:'2-digit', minute:'2-digit'});
+                            let idx = labels.findIndex(l => l === sleepLabel);
+                            if (idx === -1) idx = labels.length - 1;
+                            sleepAnnotations['sleep'+i] = {
+                                type: 'line', xMin: idx, xMax: idx,
+                                borderColor: '#a78bfa', borderWidth: 2, borderDash: [6, 3],
+                                label: { display: true, content: '😴', position: 'start', font: { size: 14 } }
+                            };
+                        });
+                        chart.options.plugins.annotation.annotations = sleepAnnotations;
                         chart.update('none');
                     }
                     
@@ -173,13 +218,34 @@ async def get_history():
         cursor.execute("SELECT COUNT(*) FROM snapshots")
         total_epocas = cursor.fetchone()[0]
         
-        cursor.execute("SELECT timestamp, qualia, frustracion, autoConfianza AS confianza, fatiga FROM snapshots ORDER BY id DESC LIMIT 40")
+        # Últimas 24 horas de datos
+        since = (datetime.datetime.utcnow() - datetime.timedelta(hours=24)).isoformat()
+        cursor.execute("SELECT timestamp, qualia, frustracion, autoConfianza AS confianza, fatiga FROM snapshots WHERE timestamp > ? ORDER BY id ASC", (since,))
         rows = cursor.fetchall()
+        
+        # Eventos de sueño
+        sleep_events = []
+        try:
+            cursor.execute("SELECT timestamp FROM sleep_events WHERE timestamp > ? ORDER BY id ASC", (since,))
+            sleep_events = [dict(r)["timestamp"] for r in cursor.fetchall()]
+        except:
+            pass
+        
+        # Total de sueños
+        total_sleeps = 0
+        try:
+            cursor.execute("SELECT COUNT(*) FROM sleep_events")
+            total_sleeps = cursor.fetchone()[0]
+        except:
+            pass
+        
         conn.close()
         
         return {
             "total_epocas": total_epocas,
-            "history": [dict(r) for r in rows][::-1]
+            "total_sleeps": total_sleeps,
+            "sleep_events": sleep_events,
+            "history": [dict(r) for r in rows]
         }
     except Exception as e:
         return {"error": str(e), "msg": "Error leyendo historial"}
@@ -471,13 +537,8 @@ async def sleep_consolidation():
         if not vector_global or not vector_global.memoria:
             return {"error": "Vector no inicializado"}
         
-        # Capturar arquetipo ANTES
         antes = vector_global.memoria.cargar_meta_vector()
-        
-        # Ejecutar consolidación EMA
         vector_global.consolidar_memoria()
-        
-        # Capturar arquetipo DESPUÉS
         despues = vector_global.memoria.cargar_meta_vector()
         
         drift = {
@@ -485,6 +546,18 @@ async def sleep_consolidation():
             for k in antes
         }
         
+        # Guardar evento de sueño en DB
+        try:
+            conn = sqlite3.connect(DB_PATH)
+            conn.execute(
+                "INSERT INTO sleep_events (antes, despues, drift) VALUES (?, ?, ?)",
+                (json.dumps(antes), json.dumps(despues), json.dumps(drift))
+            )
+            conn.commit()
+            conn.close()
+        except:
+            pass
+        
         return {
             "status": "Consolidación completada",
             "arquetipo_antes": antes,
@@ -495,6 +568,38 @@ async def sleep_consolidation():
     except Exception as e:
         return {"error": str(e)}
 
+@app.post("/api/control")
+async def save_control_comparison(request: Request):
+    """Guarda comparación grupo de control vs Nexus"""
+    try:
+        data = await request.json()
+        conn = sqlite3.connect(DB_PATH)
+        conn.execute(
+            "INSERT INTO control_responses (pregunta, respuesta_nexus, respuesta_control, novedad_nexus, novedad_control, complejidad_nexus, complejidad_control) VALUES (?, ?, ?, ?, ?, ?, ?)",
+            (data.get("pregunta",""), data.get("respuesta_nexus",""), data.get("respuesta_control",""),
+             data.get("novedad_nexus",0), data.get("novedad_control",0),
+             data.get("complejidad_nexus",0), data.get("complejidad_control",0))
+        )
+        conn.commit()
+        conn.close()
+        return {"status": "ok"}
+    except Exception as e:
+        return {"error": str(e)}
+
+@app.get("/api/control")
+async def get_control_comparisons():
+    """Obtiene comparaciones grupo de control"""
+    try:
+        conn = sqlite3.connect(DB_PATH)
+        conn.row_factory = sqlite3.Row
+        c = conn.cursor()
+        c.execute("SELECT * FROM control_responses ORDER BY id DESC LIMIT 20")
+        rows = [dict(r) for r in c.fetchall()]
+        conn.close()
+        return {"comparisons": rows[::-1], "total": len(rows)}
+    except Exception as e:
+        return {"error": str(e), "comparisons": []}
+
 # ============================================================
 # ANALYTICS DASHBOARD
 # ============================================================