Upload main.py

main.py

@@ -878,6 +878,7 @@ async def update_cache_periodically():
                     cache["user_scammers"] = new_cache_data["user_scammers"]
                     cache["server_scammers"] = new_cache_data["server_scammers"]
                     cache["dwc"] = new_cache_data["dwc"]
+                    cache["trusted"] = new_cache_data["trusted"]
                     cache["dupes"] = new_cache_data["dupes"]
                     cache["value_changes"] = detected_value_changes_for_api # Store the detected changes
                     cache["last_updated"] = current_time
@@ -912,7 +913,7 @@ async def update_cache_periodically():
 
                     # Update scammer/DWC sections if their batch succeeded AND processing succeeded
                     if "scammer_dwc_batch" not in current_errors:
-                        for key in ["user_scammers", "server_scammers", "dwc"]:
+                        for key in ["user_scammers", "server_scammers", "dwc", "trusted"]: # Include "trusted" in this list
                             process_error_key = f"process_{key}"
                             if process_error_key not in current_errors:
                                  if cache.get(key) != new_cache_data[key]:
@@ -922,7 +923,7 @@ async def update_cache_periodically():
                             else:
                                 logger.warning(f"Skipping update for '{key}' due to processing error.")
                     else:
-                         logger.warning("Skipping update for 'user_scammers', 'server_scammers', 'dwc' due to batch fetch error.")
+                         logger.warning("Skipping update for 'user_scammers', 'server_scammers', 'dwc', 'trusted' due to batch fetch error.")
 
                     if update_occurred:
                          cache["last_updated"] = current_time # Mark partial update time