Update src/streamlit_app.py

src/streamlit_app.py

@@ -562,7 +562,6 @@ def get_top_k_polarized_comments_for_users(user_ids, k=5):
             local_con.close()
 
 
-@lru_cache()
 def estimate_group_voting_diversity(user_ids, topic_id):
     """
     Estimates the diversity of voting within a group of users for a specific topic.
@@ -580,7 +579,10 @@ def estimate_group_voting_diversity(user_ids, topic_id):
                Returns 0.0 if the group has less than 2 users or if no comments
                were voted on by at least two users in the group.
     """
-    if not user_ids or len(user_ids) < 2:
+    # Convert list to tuple for caching purposes (tuples are hashable)
+    user_ids_tuple = tuple(user_ids)
+
+    if not user_ids_tuple or len(user_ids_tuple) < 2:
         return 0.0
 
     local_con = None
@@ -598,8 +600,8 @@ def estimate_group_voting_diversity(user_ids, topic_id):
             JOIN comments c ON v.comment_id = c.id
             WHERE c.topic_id = ? AND v.user_id IN (?)
         """
-        # DuckDB's Python API handles lists for IN clauses
-        results = local_con.execute(query, [topic_id, user_ids]).fetchall()
+        # DuckDB's Python API handles lists/tuples for IN clauses
+        results = local_con.execute(query, [topic_id, user_ids_tuple]).fetchall()
 
         if not results:
             return 0.0 # No votes found for this group on this topic
@@ -635,7 +637,7 @@ def estimate_group_voting_diversity(user_ids, topic_id):
 
     except Exception as e:
         # st.error is not available here, just print or log
-        print(f"Error estimating group voting diversity for topic {topic_id} and users {user_ids}: {e}")
+        print(f"Error estimating group voting diversity for topic {topic_id} and users {user_ids_tuple}: {e}")
         return 0.0 # Return 0.0 on error
     finally:
         if local_con:
@@ -669,8 +671,9 @@ def name_user_group(user_ids, topic_id):
         local_con = duckdb.connect(database=DB_PATH, read_only=True)
 
         # 1. Get total unique users who voted in the topic
+        # Specify v.user_id to avoid ambiguity
         total_voters_result = local_con.execute("""
-            SELECT COUNT(DISTINCT user_id)
+            SELECT COUNT(DISTINCT v.user_id)
             FROM votes v
             JOIN comments c ON v.comment_id = c.id
             WHERE c.topic_id = ?
@@ -679,13 +682,17 @@ def name_user_group(user_ids, topic_id):
 
         # 2. Get unique users from the input list who voted in the topic
         # Filter user_ids to only those present in the votes table for this topic
-        # DuckDB IN clause handles lists directly
-        group_voters_result = local_con.execute("""
-            SELECT COUNT(DISTINCT user_id)
+        # Construct the IN clause dynamically to avoid casting issues
+        # This part correctly uses the list by expanding placeholders
+        placeholders = ', '.join(['?'] * len(user_ids))
+        group_voters_query = f"""
+            SELECT COUNT(DISTINCT v.user_id)
             FROM votes v
             JOIN comments c ON v.comment_id = c.id
-            WHERE c.topic_id = ? AND v.user_id IN (?)
-        """, [topic_id, user_ids]).fetchone()
+            WHERE c.topic_id = ? AND v.user_id IN ({placeholders})
+        """
+        # Pass topic_id and then all user_ids as separate parameters
+        group_voters_result = local_con.execute(group_voters_query, [topic_id] + user_ids).fetchone()
         group_voters_count = group_voters_result[0] if group_voters_result else 0
 
         # Handle case where no one in the group has voted on this topic
@@ -747,7 +754,7 @@ def name_user_group(user_ids, topic_id):
                 return "Whispering Gallery", "A small group where many different ideas are quietly shared."
 
     except Exception as e:
-        print(f"Error naming user group for topic {topic_id} and users {user_ids}: {e}")
+        st.error(f"Error naming user group for topic {topic_id} and users {user_ids}: {e}")
         return "Mysterious Gathering", "An error occurred while trying to name this group." # Default name and description on error
     finally:
         if local_con:
@@ -1082,6 +1089,7 @@ def view_topic_page():
     if current_comment_id: # Only show voting if there's a comment to vote on
         # Display comment history and the current comment with the random intro
         if st.session_state.get('_show_new_area_message', True):
+            st.session_state._show_new_area_message = False
             _, user_ids = get_user_cluster_label(user_id, get_ttl_hash(10))
             new_area_name, desc = name_user_group(user_ids, topic_id)
             for statm in [
@@ -1089,7 +1097,6 @@ def view_topic_page():
                 f"🗺️ And yet, your journey leads you to a new place: **{new_area_name}**! {desc}"]:
                 st.markdown(statm)
                 st.session_state.comment_history += f"\n\n{statm}"
-            st.session_state._show_new_area_message = False
         st.markdown(f"[Collected new insight, {random_phrase}]:\n* {current_comment_content}")
 
         # Handle vote logic
@@ -1291,7 +1298,9 @@ if 'processed_url_params' not in st.session_state:
 
 # Initialize the database on first run
 initialize_database()
-add_dummy_topic()
+if st.session_state.get('_add_dummy', True):
+    add_dummy_topic()
+    st.session_state._add_dummy = False
 
 # Handle initial load from URL query parameters
 # Process only once per session load using the flag