Update main.py

main.py

@@ -131,6 +131,20 @@ def update_db(user_id, conversation_id, message, response):
 # Utility Functions
 # ============================================================================
 
+def extract_data_from_tag(input_string, tag):
+    # Create the regex pattern
+    pattern = f'<{tag}.*?>(.*?)</{tag}>'
+    
+    # Find all matches
+    matches = re.findall(pattern, input_string, re.DOTALL)
+    
+    # If matches are found, return them joined by newlines
+    if matches:
+        out = '\n'.join(match.strip() for match in matches)
+        return out
+    else:
+        return input_string
+
 def calculate_tokens(msgs):
     return sum(len(encoding.encode(str(m))) for m in msgs)
 
@@ -197,8 +211,7 @@ async def clear_inactive_conversations():
                 del conversations[conv_id]
             if conv_id in last_activity:
                 del last_activity[conv_id]
-        logger.info(f"Cleared {len(inactive_convos)} inactive conversations")
-        await asyncio.sleep(60)  # Check every minute
+        await asyncio.sleep(600)  # Check every hour
 
 # ============================================================================
 # FastAPI Events and Endpoints