+
- | ID |
- Subject |
- AI Summary |
- Account |
- Msgs |
- Requires Reply |
- Updated |
+ ID |
+ Subject |
+ AI Summary |
+ Account |
+ Msgs |
+ Requires Reply |
+ Last Message |
{% for t in threads %}
- | {{ t.id }} |
- {{ t.subject }} |
- {{ t.ai_summary or '' }} |
- {{ t.account_email }} |
- {{ t.messages|length }} |
+ {{ t.frontend_id }} |
+ {{ t.thread.subject }} |
+ {{ t.thread.ai_summary or '' }} |
+ {{ t.thread.account_email }} |
+ {{ t.thread.messages|length }} |
- {% if t.requires_reply %}
+ {% if t.thread.requires_reply %}
Needs reply
{% else %}
Up to date
{% endif %}
|
- {{ t.updated_at }} |
+ {{ t.formatted_date }} |
{% else %}
- | No threads yet |
+ | No threads yet |
{% endfor %}
diff --git a/test_ai_analysis.py b/test_ai_analysis.py
deleted file mode 100644
index fb41ff7..0000000
--- a/test_ai_analysis.py
+++ /dev/null
@@ -1,99 +0,0 @@
-#!/usr/bin/env python3
-"""
-Test script to demonstrate the AI analysis functionality.
-This script shows how to use the new async thread analysis function.
-"""
-
-import os
-import sys
-
-# Add the src directory to the path
-sys.path.insert(0, os.path.join(os.path.dirname(__file__), "src"))
-
-from database import (
- SessionLocal,
- Thread,
- analyze_and_update_threads,
- create_db_tables,
- get_threads_needing_analysis,
-)
-
-
-def main():
- """Main function to test the AI analysis."""
-
- # Create database tables if they don't exist
- create_db_tables()
-
- # Example account email - replace with your actual account
- account_email = "your-email@example.com"
-
- # Get a database session
- db = SessionLocal()
- try:
- # Check how many threads need analysis
- threads_needing_analysis = get_threads_needing_analysis(db, account_email)
- print(
- f"Found {len(threads_needing_analysis)} threads needing analysis for {account_email}"
- )
-
- if not threads_needing_analysis:
- print(
- "No threads need analysis. Make sure you have ingested some emails first."
- )
-
- # Show all threads for this account
- all_threads = (
- db.query(Thread)
- .filter(Thread.account_email == account_email.lower())
- .all()
- )
- print(f"Total threads for {account_email}: {len(all_threads)}")
-
- if all_threads:
- print("Sample threads:")
- for thread in all_threads[:3]:
- print(
- f" Thread {thread.id}: {thread.subject} (analyzed: {thread.last_analyzed_at is not None})"
- )
-
- return
-
- print(f"Starting AI analysis for {len(threads_needing_analysis)} threads...")
-
- # Run the analysis with max 3 concurrent tasks
- analyze_and_update_threads(
- account_email=account_email, max_concurrent=3, only_unanalyzed=True
- )
-
- print("Analysis complete!")
-
- # Show results
- analyzed_threads = (
- db.query(Thread)
- .filter(
- Thread.account_email == account_email.lower(),
- Thread.last_analyzed_at.isnot(None),
- )
- .all()
- )
-
- print(f"\nAnalyzed {len(analyzed_threads)} threads:")
- for thread in analyzed_threads[:5]: # Show first 5
- print(f" Thread {thread.id}: {thread.subject[:50]}...")
- print(f" Actionable: {thread.actionable}")
- print(f" Confidence: {thread.ai_confidence:.2f}")
- print(f" Summary: {thread.ai_summary[:100]}...")
- print()
-
- except Exception as e:
- print(f"Error: {e}")
- import traceback
-
- traceback.print_exc()
- finally:
- db.close()
-
-
-if __name__ == "__main__":
- main()
diff --git a/test_fetch_with_db.py b/test_fetch_with_db.py
deleted file mode 100644
index 3c88705..0000000
--- a/test_fetch_with_db.py
+++ /dev/null
@@ -1,57 +0,0 @@
-#!/usr/bin/env python3
-"""
-Test script to demonstrate the modified fetch_folder_emails function
-that uses database dates for intelligent email fetching.
-"""
-
-from src.database import SessionLocal, get_latest_email_date
-from src.zoho_client import ZohoClient
-
-
-def test_fetch_with_database():
- """Test the modified fetch function with database integration."""
-
- # Create database session
- db = SessionLocal()
-
- try:
- # Create Zoho client
- client = ZohoClient()
-
- # Example account email (replace with actual)
- account_email = client.email
-
- print("=== Testing fetch_folder_emails with database integration ===")
-
- # Check what's the latest date in database
- latest_date = get_latest_email_date(db, account_email, "INBOX")
- print(f"Latest email date in database: {latest_date}")
-
- # Fetch emails using the new function
- emails = client.fetch_folder_emails(
- folder="INBOX",
- max_results=10,
- days_back=30, # Fallback if no database date
- db_session=db,
- account_email=account_email,
- )
-
- print(f"Fetched {len(emails)} emails")
-
- # Display first few emails
- for i, email in enumerate(emails[:3]):
- print(f"\nEmail {i + 1}:")
- print(f" Subject: {email.get('subject', 'No subject')}")
- print(f" From: {email.get('from', 'Unknown')}")
- print(f" Date: {email.get('date', 'Unknown')}")
-
- client.close()
-
- except Exception as e:
- print(f"Error: {e}")
- finally:
- db.close()
-
-
-if __name__ == "__main__":
- test_fetch_with_database()
diff --git a/test_groq_api.py b/test_groq_api.py
deleted file mode 100644
index 6c2b8bc..0000000
--- a/test_groq_api.py
+++ /dev/null
@@ -1,117 +0,0 @@
-#!/usr/bin/env python3
-"""
-Test script to validate Groq API configuration and diagnose issues.
-"""
-
-import os
-import sys
-
-# Add the src directory to the path
-sys.path.insert(0, os.path.join(os.path.dirname(__file__), "src"))
-
-from ai import analyze_thread
-
-
-def test_groq_api():
- """Test the Groq API with a simple request."""
-
- print("Testing Groq API Configuration")
- print("=" * 40)
-
- # Check API key
- api_key = os.getenv("GROQ_API_KEY")
- if not api_key:
- print("❌ GROQ_API_KEY environment variable not set")
- print(" Please set your Groq API key: export GROQ_API_KEY='your-key-here'")
- return False
-
- print(f"✓ GROQ_API_KEY found (length: {len(api_key)})")
-
- # Check model
- model = os.getenv("GROQ_MODEL", "llama-3.1-70b-versatile")
- print(f"✓ Using model: {model}")
-
- # Test with simple data
- print("\nTesting simple analysis...")
-
- simple_messages = [
- {
- "date_sent": "2025-08-11 10:00:00",
- "is_incoming": True,
- "subject": "Test Question",
- "from_email": "test@example.com",
- "to_email": "user@example.com",
- "body": "Can you help me with this issue? Please let me know.",
- }
- ]
-
- try:
- result = analyze_thread("Test Question", simple_messages)
- print("✓ Analysis successful!")
- print(f" Model used: {result.get('model', 'unknown')}")
- print(f" Actionable: {result.get('actionable', False)}")
- print(f" Confidence: {result.get('confidence', 0)}")
- print(f" Summary: {result.get('summary', 'No summary')[:100]}...")
-
- if result.get("model") == "heuristic":
- print("\n⚠️ Note: Fell back to heuristic analysis")
- print(" This might indicate an API issue")
-
- return True
-
- except Exception as e:
- print(f"❌ Analysis failed: {e}")
- import traceback
-
- traceback.print_exc()
- return False
-
-
-def test_rate_limiting():
- """Test rate limiting by making multiple quick requests."""
-
- print("\nTesting Rate Limiting")
- print("=" * 40)
-
- import time
-
- simple_messages = [
- {
- "date_sent": "2025-08-11 10:00:00",
- "is_incoming": True,
- "subject": "Quick test",
- "from_email": "test@example.com",
- "to_email": "user@example.com",
- "body": "Quick test message.",
- }
- ]
-
- start_time = time.time()
-
- for i in range(3):
- print(f"Request {i + 1}...")
- result = analyze_thread(f"Test {i + 1}", simple_messages)
- print(f" Result: {result.get('model', 'unknown')} analysis")
-
- total_time = time.time() - start_time
- print(f"\nTotal time for 3 requests: {total_time:.2f} seconds")
-
- if total_time < 2.5:
- print("⚠️ Requests completed very quickly - rate limiting may not be working")
- else:
- print("✓ Rate limiting appears to be working")
-
-
-if __name__ == "__main__":
- success = test_groq_api()
-
- if success:
- test_rate_limiting()
-
- print("\nTroubleshooting Tips:")
- print("- If getting 400 errors: Check message content for special characters")
- print("- If getting 401 errors: Verify GROQ_API_KEY is correct")
- print(
- "- If getting 429 errors: Reduce max_concurrent in analyze_and_update_threads()"
- )
- print("- If getting 503 errors: Groq service may be temporarily unavailable")
diff --git a/test_single_analysis.py b/test_single_analysis.py
deleted file mode 100644
index 587adda..0000000
--- a/test_single_analysis.py
+++ /dev/null
@@ -1,94 +0,0 @@
-#!/usr/bin/env python3
-"""
-Simple test to debug the AI analysis function.
-"""
-
-import os
-import sys
-
-# Add the src directory to the path
-sys.path.insert(0, os.path.join(os.path.dirname(__file__), "src"))
-
-from ai import analyze_thread
-from database import SessionLocal, Thread, get_thread_messages
-
-
-def test_single_analysis():
- """Test analyzing a single thread."""
-
- db = SessionLocal()
- try:
- # Get a thread to test with
- thread = (
- db.query(Thread)
- .filter(Thread.account_email == "test-user@company.com")
- .first()
- )
-
- if not thread:
- print("No threads found for test-user@company.com")
- return
-
- print(f"Testing thread {thread.id}: {thread.subject}")
- print(
- f"Before analysis: actionable={thread.actionable}, confidence={thread.ai_confidence}"
- )
-
- # Get messages
- messages = get_thread_messages(db, thread.id)
- print(f"Found {len(messages)} messages")
-
- # Convert to dict format
- message_dicts = []
- for msg in messages:
- message_dicts.append(
- {
- "date_sent": msg.date_sent,
- "is_incoming": msg.is_incoming,
- "subject": msg.subject,
- "from_email": msg.from_email,
- "to_email": msg.to_email,
- "body": msg.body,
- }
- )
-
- # Run analysis
- print("Running AI analysis...")
- analysis_result = analyze_thread(thread.subject, message_dicts)
- print(f"Analysis result: {analysis_result}")
-
- # Update thread
- thread.actionable = analysis_result.get("actionable", False)
- thread.ai_summary = analysis_result.get("summary", "")
- thread.ai_confidence = float(analysis_result.get("confidence", 0.0))
- from datetime import datetime
-
- thread.last_analyzed_at = datetime.now()
-
- print(
- f"Updated thread: actionable={thread.actionable}, confidence={thread.ai_confidence}"
- )
- print(f"Summary: {thread.ai_summary}")
-
- # Commit changes
- db.commit()
- print("Changes committed")
-
- # Verify the changes
- db.refresh(thread)
- print(
- f"After refresh: actionable={thread.actionable}, confidence={thread.ai_confidence}"
- )
-
- except Exception as e:
- print(f"Error: {e}")
- import traceback
-
- traceback.print_exc()
- db.rollback()
- finally:
- db.close()
-
-
-if __name__ == "__main__":
- test_single_analysis()