Update app.py

app.py

@@ -23,9 +23,17 @@ from appStore.region_utils import (
 # from appStore.tfidf_extraction import extract_top_keywords
 
 # Import helper modules
-from appStore.rag_utils import highlight_query, get_rag_answer, compute_title, format_project_id
-
-from appStore.filter_utils import  parse_budget, filter_results, get_crs_options
+from appStore.rag_utils import (
+    highlight_query,
+    get_rag_answer,
+    compute_title,
+    format_project_id  # <-- Imported formatting function
+)
+from appStore.filter_utils import (
+    parse_budget,
+    filter_results,
+    get_crs_options
+)
 
 from appStore.crs_utils import lookup_crs_value
 
@@ -119,14 +127,14 @@ unique_country_names = sorted(country_name_mapping.keys())
 # Define reset_filters function using session_state
 ###########################################
 def reset_filters():
-    st.session_state["region_filter"] = "All/Not allocated"
-    st.session_state["country_filter"] = "All/Not allocated"
+    st.session_state["region_filter"] = ["All/Not allocated"]
+    st.session_state["country_filter"] = ["All/Not allocated"]
     current_year = datetime.now().year
     default_start_year = current_year - 4
     st.session_state["end_year_range"] = (default_start_year, max_end_year)
-    st.session_state["crs_filter"] = "All/Not allocated"
+    st.session_state["crs_filter"] = ["All/Not allocated"]
     st.session_state["min_budget"] = min_budget_val
-    st.session_state["client_filter"] = "All/Not allocated"
+    st.session_state["client_filter"] = ["All/Not allocated"]
     st.session_state["query"] = ""
     st.session_state["show_exact_matches"] = False
     st.session_state["page"] = 1
@@ -137,17 +145,19 @@ def reset_filters():
 col1, col2, col3, col4, col5 = st.columns([1, 1, 1, 1, 1])
 
 with col1:
-    region_filter = st.selectbox("Region", ["All/Not allocated"] + sorted(unique_sub_regions), key="region_filter")
-if region_filter == "All/Not allocated":
+    region_filter = st.multiselect("Region", options=["All/Not allocated"] + sorted(unique_sub_regions),
+                                   default=["All/Not allocated"], key="region_filter")
+if "All/Not allocated" in region_filter or not region_filter:
     filtered_country_names = unique_country_names
 else:
     filtered_country_names = [
         name for name, code in country_name_mapping.items() 
-        if iso_code_to_sub_region.get(code) == region_filter
+        if iso_code_to_sub_region.get(code) in region_filter
     ]
 
 with col2:
-    country_filter = st.selectbox("Country", ["All/Not allocated"] + filtered_country_names, key="country_filter")
+    country_filter = st.multiselect("Country", options=["All/Not allocated"] + filtered_country_names,
+                                    default=["All/Not allocated"], key="country_filter")
 
 with col3:
     current_year = datetime.now().year
@@ -162,7 +172,8 @@ with col3:
 
 with col4:
     crs_options = ["All/Not allocated"] + get_crs_options(client, collection_name)
-    crs_filter = st.selectbox("CRS", crs_options, key="crs_filter")
+    crs_filter = st.multiselect("CRS", options=crs_options,
+                                default=["All/Not allocated"], key="crs_filter")
 
 with col5:
     min_budget = st.slider(
@@ -180,7 +191,8 @@ col1_2, col2_2, col3_2, col4_2, col5_2 = st.columns(5)
 
 with col1_2:
     client_options = sorted(project_data["client"].dropna().unique().tolist())
-    client_filter = st.selectbox("Client", ["All/Not allocated"] + client_options, key="client_filter")
+    client_filter = st.multiselect("Client", options=["All/Not allocated"] + client_options,
+                                   default=["All/Not allocated"], key="client_filter")
 with col2_2:
     st.empty()
 with col3_2:
@@ -188,30 +200,25 @@ with col3_2:
 with col4_2:
     st.empty()
 with col5_2:
-    # Plain reset button (will be moved to row 3 as well)
-    st.button("Reset Filters", on_click=reset_filters, key="reset_button_row2")
+    st.empty()
+
 
 ###########################################
 # Filter Controls - Row 3 (Remaining Filter)
 ###########################################
-col1_3, col2_3, col3_3, col4_3, col5_3 = st.columns(5)
+col1_3, col2_3, col3_3 = st.columns([7, 23, 5])
 with col1_3:
     # Place the "Show only exact matches" checkbox here
     show_exact_matches = st.checkbox("Show only exact matches", key="show_exact_matches")
 with col2_3:
     st.empty()
 with col3_3:
-    st.empty()
-with col4_3:
-    st.empty()
-with col5_3:
     # Right-align a more prominent reset button
     with st.container():
         st.markdown("<div style='text-align: right;'>", unsafe_allow_html=True)
         if st.button("**Reset Filters**", key="reset_button_row3"):
             reset_filters()
         st.markdown("</div>", unsafe_allow_html=True)
-
 ###########################################
 # Main Search / Results
 ###########################################
@@ -230,6 +237,7 @@ else:
     semantic_thresholded = [r for r in semantic_all if r.score >= 0.0]
 
     # 2) Filter results based on the user’s selections
+    # (Assuming filter_results can handle a string "All/Not allocated" as meaning "no filter")
     filtered_semantic = filter_results(
         semantic_thresholded, 
         country_filter, 
@@ -255,10 +263,10 @@ else:
         get_country_name
     )
 
-    # Additional filter by client
-    if client_filter != "All/Not allocated":
-        filtered_semantic = [r for r in filtered_semantic if r.payload.get("metadata", {}).get("client", "Unknown Client") == client_filter]
-        filtered_lexical = [r for r in filtered_lexical if r.payload.get("metadata", {}).get("client", "Unknown Client") == client_filter]
+    # Additional filter by client (if "All/Not allocated" is not selected)
+    if "All/Not allocated" not in client_filter:
+        filtered_semantic = [r for r in filtered_semantic if r.payload.get("metadata", {}).get("client", "Unknown Client") in client_filter]
+        filtered_lexical = [r for r in filtered_lexical if r.payload.get("metadata", {}).get("client", "Unknown Client") in client_filter]
 
     # Remove duplicates
     filtered_semantic_no_dupe = remove_duplicates(filtered_semantic)
@@ -270,11 +278,9 @@ else:
         except (ValueError, TypeError):
             return value
 
-    # --- Reprint Query (Right Aligned with "Query:") ---
-    st.markdown(
-        f"<div style='text-align: left; font-size:2.1em; font-style: italic; font-weight: bold;'>Query: {var}</div>",
-        unsafe_allow_html=True
-    )
+    # --- Reprint Query (Left aligned with "Query:") ---
+    st.markdown(f"<div style='text-align: left; font-size:2.1em; font-style: italic; font-weight: bold;'>Query: {var}</div>", unsafe_allow_html=True)
+
     # 3) Display results
     # Lexical Search Results Branch
     if show_exact_matches:
@@ -297,7 +303,7 @@ else:
             if "page" not in st.session_state:
                 st.session_state.page = 1
             current_page = st.session_state.page
-            # Top pagination widget (right aligned, 1/7 width)
+            # Top pagination widget (right aligned, occupying 1/7 of page width)
             col_pag_top = st.columns([6, 1])[1]
             new_page_top = col_pag_top.selectbox("Select Page", list(range(1, total_pages + 1)), index=current_page - 1, key="page_top")
             st.session_state.page = new_page_top
@@ -312,7 +318,7 @@ else:
                     metadata["title"] = compute_title(metadata)
                 title_html = highlight_query(metadata["title"], var) if var.strip() else metadata["title"]
                 title_clean = re.sub(r'<a.*?>|</a>', '', title_html)
-                # Prepend the result number
+                # Prepend the result number and make title bold
                 st.markdown(f"#### {i}. **{title_clean}**", unsafe_allow_html=True)
 
                 objective = metadata.get("objective", "None")
@@ -346,25 +352,28 @@ else:
                     new_crs_value_clean = re.sub(r'\.0$', '', str(new_crs_value))
                     crs_combined = f"{crs_key_clean}: {new_crs_value_clean}" if crs_key_clean else "Unknown"
                     
-                    # Insert Predecessor/Successor line if available
-                    predecessor = metadata.get("predecessor_id", "")
-                    successor = metadata.get("successor_id", "")
+                    # Extract and format predecessor and successor project IDs
+                    predecessor_raw = metadata.get("predecessor_id", "")
+                    successor_raw = metadata.get("successor_id", "")
+                    predecessor = safe_format_project_id(predecessor_raw)
+                    successor = safe_format_project_id(successor_raw)
+                    
                     pred_success_ids = ""
                     if predecessor or successor:
-                        extra_line = "<br>"
                         parts = []
                         if predecessor:
-                            parts.append(f"**Predecessor Project:** {format_project_id(predecessor)}")
+                            parts.append(f"**Predecessor Project:** {predecessor}")
                         if successor:
-                            parts.append(f"**Successor Project:** {format_project_id(successor)}")
-                        pred_success_ids += " ".join(parts)
+                            parts.append(f"**Successor Project:** {successor}")
+                        pred_success_ids = "<br>" + " ".join(parts)
+                    
                     
                     additional_text = (
                         f"**Objective:** {highlight_query(objective, var)}<br>"
                         f"**Commissioned by:** {metadata.get('client', 'Unknown Client')}<br>"
                         f"**Projekt duration:** {start_year_str}-{end_year_str}<br>"
-                        f"**Budget:** Project: <b>{formatted_project_budget}</b>, Total volume: <b>{formatted_total_volume}</b><br>"
-                        + pred_success_ids +
+                        f"**Budget:** Project: <b>{formatted_project_budget}</b>, Total volume: <b>{formatted_total_volume}</b>"
+                        + extra_line +
                         f"<br>**Country:** {country_raw}<br>"
                         f"**Sector:** {crs_combined}"
                     )
@@ -392,7 +401,7 @@ else:
                 st.session_state.page = 1
             current_page = st.session_state.page
 
-            # Top pagination widget (right aligned, 1/7 width)
+            # Top pagination widget (right aligned, occupying 1/7 of page width)
             col_pag_top = st.columns([6, 1])[1]
             new_page_top = col_pag_top.selectbox("Select Page", list(range(1, total_pages + 1)), index=current_page - 1, key="page_top_sem")
             st.session_state.page = new_page_top
@@ -401,24 +410,19 @@ else:
             end_index = start_index + page_size
             top_results = filtered_semantic_no_dupe[start_index:end_index]
 
-            # Prominent page info with bold numbers and green highlight if current page is not 1
+            # Prominent page info with bold numbers (green if current page != 1)
             page_num = f"<b style='color: green;'>{st.session_state.page}</b>" if st.session_state.page != 1 else f"<b>{st.session_state.page}</b>"
             total_pages_str = f"<b>{total_pages}</b>"
             st.markdown(f"Showing **{len(top_results)}** Semantic Search results (Page {page_num} of {total_pages_str})", unsafe_allow_html=True)
 
-            # --- RAG Answer (Right aligned, bullet points, bold numbers) ---
+            # --- RAG Answer (Left aligned, bullet points, with bold numbers) ---
             rag_answer = get_rag_answer(var, top_results, DEDICATED_ENDPOINT, WRITE_ACCESS_TOKEN)
             bullet_lines = []
             for line in rag_answer.splitlines():
                 if line.strip():
-                    # Bold any numbers in the line
                     line_bold = re.sub(r'(\d+)', r'<b>\1</b>', line)
                     bullet_lines.append(f"<li>{line_bold}</li>")
-            formatted_rag_answer = (
-                "<ul style='text-align: left; list-style-position: inside;'>"
-                + "".join(bullet_lines)
-                + "</ul>"
-            )
+            formatted_rag_answer = "<ul style='text-align: left; list-style-position: inside;'>" + "".join(bullet_lines) + "</ul>"
             st.markdown(formatted_rag_answer, unsafe_allow_html=True)
             st.divider()
 
@@ -427,7 +431,6 @@ else:
                 if "title" not in metadata:
                     metadata["title"] = compute_title(metadata)
                 title_clean = re.sub(r'<a.*?>|</a>', '', metadata["title"])
-                # Prepend result number and make title bold
                 st.markdown(f"#### {i}. **{title_clean}**", unsafe_allow_html=True)
 
                 desc_en = metadata.get("description.en", "").strip()
@@ -460,25 +463,28 @@ else:
                     new_crs_value = lookup_crs_value(crs_key_clean)
                     new_crs_value_clean = re.sub(r'\.0$', '', str(new_crs_value))
                     crs_combined = f"{crs_key_clean}: {new_crs_value_clean}" if crs_key_clean else "Unknown"
+
+                    # Extract and format predecessor and successor project IDs
+                    predecessor_raw = metadata.get("predecessor_id", "")
+                    successor_raw = metadata.get("successor_id", "")
+                    predecessor = safe_format_project_id(predecessor_raw)
+                    successor = safe_format_project_id(successor_raw)
                     
-                    predecessor = metadata.get("predecessor_id", "").strip()
-                    successor = metadata.get("successor_id", "").strip()
                     pred_success_ids = ""
                     if predecessor or successor:
-                        extra_line = "<br>"
                         parts = []
                         if predecessor:
-                            parts.append(f"**Predecessor Project:** {format_project_id(predecessor)}")
+                            parts.append(f"**Predecessor Project:** {predecessor}")
                         if successor:
-                            parts.append(f"**Successor Project:** {format_project_id(successor)}")
-                        pred_success_ids += " ".join(parts)
+                            parts.append(f"**Successor Project:** {successor}")
+                        pred_success_ids = "<br>" + " ".join(parts)
                     
                     additional_text = (
                         f"**Objective:** {metadata.get('objective', '')}<br>"
                         f"**Commissioned by:** {metadata.get('client', 'Unknown Client')}<br>"
                         f"**Projekt duration:** {start_year_str}-{end_year_str}<br>"
-                        f"**Budget:** Project: <b>{formatted_project_budget}</b>, Total volume: <b>{formatted_total_volume}</b><br>"
-                        + pred_success_ids +
+                        f"**Budget:** Project: <b>{formatted_project_budget}</b>, Total volume: <b>{formatted_total_volume}</b>"
+                        + extra_line +
                         f"<br>**Country:** {country_raw}<br>"
                         f"**Sector:** {crs_combined}"
                     )
@@ -488,7 +494,7 @@ else:
                     st.markdown(additional_text, unsafe_allow_html=True)
                 st.divider()
 
-            # Bottom pagination widget (right aligned, 1/7 width)
+            # Bottom pagination widget (right aligned, occupying 1/7 width)
             col_pag_bot = st.columns([6, 1])[1]
             new_page_bot = col_pag_bot.selectbox("Select Page", list(range(1, total_pages + 1)), index=st.session_state.page - 1, key="page_bot_sem")
             st.session_state.page = new_page_bot