Database Operations

• Agent Operations
  • count_analyses_for_user()
  • count_relevant_analyses_for_user()
  • get_agent_status()
  • list_recent_analyses_for_user()
  • swap_user_active_topics()
  • update_agent_status()
• Generic Task Operations
  • create_task()
  • get_task()
  • list_completed_tasks_since()
  • list_pending_tasks()
  • mark_task_completed()
  • mark_task_failed()
  • mark_task_sent()
• Integration Operations
  • complete_task_processing()
  • create_research_topic_for_user_task()
  • create_user_task()
  • get_next_queued_task()
  • get_user_task_results()
  • link_analysis_to_user_task()
  • start_task_processing()
• Legacy Operations
  • create_research_topic()
  • deactivate_user_topics()
  • get_active_topic_by_user()
  • get_or_create_user_settings()
  • get_topic_by_user_and_text()
  • get_user_settings()
  • list_active_topics()
  • update_user_settings()
• Paper Operations
  • create_arxiv_paper()
  • create_paper_analysis()
  • get_analysis_with_entities()
  • get_arxiv_paper_by_arxiv_id()
  • has_paper_analysis()
  • list_new_analyses_since()
  • mark_analysis_notified()
  • mark_analysis_queued()
• Queue Operations
  • add_task_to_queue()
  • get_next_task_from_queue()
  • update_queue_positions()
• Rate Limit Operations
  • check_rate_limit()
• Search Operations
  • create_search_query()
  • list_active_queries_for_task()
  • record_finding()
  • update_search_query_stats()
• Task Operations
  • create_user_task_with_queue()
  • deactivate_user_tasks()
  • get_most_recent_active_user_task()
  • get_user_tasks()
  • list_active_user_tasks()
  • list_user_tasks()
  • update_user_task_status()
  • update_user_task_status_for_user()
• Task Statistics Operations
  • get_or_create_task_statistics()
  • update_task_statistics()
• User Operations
  • check_user_can_create_task()
  • get_or_create_user()
  • reset_daily_counters_if_needed()
  • upgrade_user_plan()