Update database.py

database.py

@@ -92,10 +92,32 @@ def log_question(
         except sqlite3.OperationalError as e:
             # Fallback for older schema versions (shouldn't happen after migration)
             print(f"⚠️  Logging error: {e}. Falling back to basic logging.")
-            cur.execute("INSERT INTO question_logs (question) VALUES (?)", (question,))
-            
         conn.commit()
 
+def get_recent_history(session_id: str, limit: int = 5) -> List[Dict[str, str]]:
+    """Retrieve recent conversation history for a session from the logs."""
+    if not session_id:
+        return []
+        
+    with get_db_connection() as conn:
+        cur = conn.cursor()
+        cur.execute("""
+            SELECT question, answer 
+            FROM question_logs 
+            WHERE session_id = ? 
+            AND answer IS NOT NULL
+            ORDER BY timestamp DESC 
+            LIMIT ?
+        """, (session_id, limit))
+        rows = cur.fetchall()
+        
+    # Reverse to get chronological order
+    history = []
+    for row in reversed(rows):
+        history.append({"role": "user", "content": row['question']})
+        history.append({"role": "assistant", "content": row['answer']})
+    return history
+
 def get_session_state(session_id: str) -> Dict[str, Any]:
     """Get session state from DB"""
     with get_db_connection() as conn:
@@ -165,4 +187,89 @@ def update_session_state(session_id: str, preference: str = None, increment_coun
                 VALUES (?, ?, ?, ?, ?)
             """, (session_id, new_pref, new_count, new_clarification, new_knowledge_json))
             
-        conn.commit()
+        conn.commit()
+
+def update_faq_entry(faq_id: int, question: str, answer: str):
+    """Update an existing FAQ entry."""
+    with get_db_connection() as conn:
+        cur = conn.cursor()
+        cur.execute(
+            "UPDATE faq_entries SET question = ?, answer = ?, embedding = NULL WHERE id = ?",
+            (question, answer, faq_id)
+        )
+        conn.commit()
+
+def delete_faq_entry(faq_id: int):
+    """Delete an FAQ entry."""
+    with get_db_connection() as conn:
+        cur = conn.cursor()
+        cur.execute("DELETE FROM faq_entries WHERE id = ?", (faq_id,))
+        conn.commit()
+
+def add_faq_entry(question: str, answer: str):
+    """Add a new FAQ entry."""
+    with get_db_connection() as conn:
+        cur = conn.cursor()
+        cur.execute(
+            "INSERT INTO faq_entries (question, answer) VALUES (?, ?)",
+            (question, answer)
+        )
+        conn.commit()
+
+def bulk_update_faqs(entries: List[Dict[str, str]]):
+    """Bulk update FAQs from a list of dictionaries."""
+    with get_db_connection() as conn:
+        cur = conn.cursor()
+        for entry in entries:
+            question = entry.get('Question') or entry.get('question')
+            answer = entry.get('Answer') or entry.get('answer')
+            if question and answer:
+                cur.execute(
+                    "INSERT INTO faq_entries (question, answer) VALUES (?, ?)",
+                    (question, answer)
+                )
+        conn.commit()
+
+def bulk_update_podcasts(entries: List[Dict[str, str]]):
+    """Bulk update Podcasts from a list of dictionaries."""
+    with get_db_connection() as conn:
+        cur = conn.cursor()
+        for entry in entries:
+            guest = entry.get('Guest Name') or entry.get('guest_name')
+            url = entry.get('YouTube URL') or entry.get('youtube_url')
+            summary = entry.get('Summary') or entry.get('summary')
+            if guest and url and summary:
+                # Format full_text as required by the existing logic
+                full_text = f"Guest: {guest}. Summary: {summary}"
+                # Store summary in highlight_json as a simple list for compatibility
+                h_json = json.dumps([{"summary": summary}])
+                cur.execute(
+                    "INSERT INTO podcast_episodes (guest_name, youtube_url, highlight_json, full_text) VALUES (?, ?, ?, ?)",
+                    (guest, url, h_json, full_text)
+                )
+        conn.commit()
+
+def fetch_all_podcast_metadata() -> List[Dict[str, Any]]:
+    """Fetch all podcast metadata for the admin table."""
+    with get_db_connection() as conn:
+        cur = conn.cursor()
+        cur.execute("SELECT id, guest_name, youtube_url, highlight_json FROM podcast_episodes")
+        rows = cur.fetchall()
+        results = []
+        for row in rows:
+            d = dict(row)
+            # Try to extract plain summary from JSON for the table
+            try:
+                h = json.loads(d['highlight_json'])
+                d['summary'] = h[0]['summary'] if h and isinstance(h, list) else d['highlight_json']
+            except:
+                d['summary'] = d['highlight_json']
+            results.append(d)
+        return results
+
+def fetch_all_faq_metadata() -> List[Dict[str, Any]]:
+    """Fetch all FAQ metadata for the admin table."""
+    with get_db_connection() as conn:
+        cur = conn.cursor()
+        cur.execute("SELECT id, question, answer FROM faq_entries")
+        return [dict(row) for row in cur.fetchall()]