app.py

"""

JanSahayak Flask Web Application

Beautiful UI for Multi-Agent Government Intelligence System

"""

from flask import Flask, render_template, request, jsonify, session, send_file
import json
import os
from datetime import datetime
from graph.workflow import run_workflow
import uuid
import io
import re
from reportlab.lib.pagesizes import letter, A4
from reportlab.lib.styles import getSampleStyleSheet, ParagraphStyle
from reportlab.lib.units import inch
from reportlab.platypus import SimpleDocTemplate, Paragraph, Spacer, Table, TableStyle, PageBreak
from reportlab.lib import colors
from reportlab.lib.enums import TA_CENTER, TA_LEFT, TA_JUSTIFY

app = Flask(__name__)
app.secret_key = os.urandom(24)  # For session management

# Store active sessions
sessions = {}

# Global vectorstores (loaded on first use for faster startup)
SCHEME_VECTORSTORE = None
EXAM_VECTORSTORE = None
VECTORSTORES_INITIALIZED = False

# Check if running on a memory-constrained platform
SKIP_VECTORSTORES = os.environ.get('SKIP_VECTORSTORES', 'false').lower() == 'true'


def initialize_vectorstores():
    """Load vectorstores lazily on first use to avoid blocking port binding"""
    global SCHEME_VECTORSTORE, EXAM_VECTORSTORE, VECTORSTORES_INITIALIZED
    
    if VECTORSTORES_INITIALIZED:
        return  # Already initialized
    
    # Skip vectorstore loading on memory-constrained platforms (use web search only)
    if SKIP_VECTORSTORES:
        print("\n" + "="*70)
        print("⚡ LIGHTWEIGHT MODE: Skipping vectorstore loading")
        print("="*70)
        print("✅ Using Tavily web search only (no embeddings model)")
        print("✅ Low memory usage (<200MB)")
        print("✅ Real-time, up-to-date information")
        print("="*70 + "\n")
        SCHEME_VECTORSTORE = None
        EXAM_VECTORSTORE = None
        VECTORSTORES_INITIALIZED = True
        return
    
    print("\n" + "="*70)
    print("📚 Initializing Vector Stores (lazy loading)")
    print("="*70)
    
    # Load scheme vectorstore
    try:
        from rag.scheme_vectorstore import load_scheme_vectorstore
        SCHEME_VECTORSTORE = load_scheme_vectorstore()
        print("✅ Scheme vectorstore loaded successfully")
    except Exception as e:
        print(f"⚠️  Scheme vectorstore not available: {str(e)}")
        print("   Will use web search only for schemes")
        SCHEME_VECTORSTORE = None
    
    # Load exam vectorstore
    try:
        from rag.exam_vectorstore import load_exam_vectorstore
        EXAM_VECTORSTORE = load_exam_vectorstore()
        print("✅ Exam vectorstore loaded successfully")
    except Exception as e:
        print(f"⚠️  Exam vectorstore not available: {str(e)}")
        print("   Will use web search only for exams")
        EXAM_VECTORSTORE = None
    
    VECTORSTORES_INITIALIZED = True
    print("="*70 + "\n")


def format_markdown(text):
    """Convert markdown-style text to HTML"""
    if not text or not isinstance(text, str):
        return text
    
    import re
    
    # Convert headers (### heading)
    text = re.sub(r'###\s+(.+?)(?=\n|$)', r'<h4>\1</h4>', text)
    text = re.sub(r'##\s+(.+?)(?=\n|$)', r'<h3>\1</h3>', text)
    
    # Convert bold (**text**)
    text = re.sub(r'\*\*(.+?)\*\*', r'<strong>\1</strong>', text)
    
    # Convert italic (*text*)
    text = re.sub(r'\*(.+?)\*', r'<em>\1</em>', text)
    
    # Convert bullet points (- item or * item)
    text = re.sub(r'^[\-\*]\s+(.+)$', r'<li>\1</li>', text, flags=re.MULTILINE)
    text = re.sub(r'(<li>.*?</li>)', r'<ul>\1</ul>', text, flags=re.DOTALL)
    text = text.replace('</ul>\n<ul>', '\n')  # Merge consecutive lists
    
    # Convert line breaks
    text = text.replace('\n\n', '</p><p>')
    text = text.replace('\n', '<br>')
    
    # Wrap in paragraph if not starting with a tag
    if not text.startswith('<'):
        text = f'<p>{text}</p>'
    
    return text


# Register Jinja filter
app.jinja_env.filters['format_markdown'] = format_markdown


@app.route('/')
def index():
    """Landing page with input form"""
    return render_template('index.html')


@app.route('/about')
def about():
    """About page"""
    return render_template('about.html')


@app.route('/health')
def health():
    """Health check endpoint for monitoring"""
    from config import GROQ_API_KEY, TAVILY_API_KEY, HF_TOKEN
    
    return jsonify({
        'status': 'ok',
        'service': 'JanSahayak',
        'api_keys_configured': {
            'groq': bool(GROQ_API_KEY),
            'tavily': bool(TAVILY_API_KEY),
            'hf_token': bool(HF_TOKEN)
        }
    })


@app.route('/analyze', methods=['POST'])
def analyze():
    """Process user input and run workflow"""
    try:
        # First check if API keys are configured
        from config import GROQ_API_KEY, TAVILY_API_KEY
        
        if not GROQ_API_KEY or GROQ_API_KEY == "":
            return jsonify({
                'success': False,
                'error': 'GROQ_API_KEY is not configured. Please set environment variables on Render.'
            }), 500
        
        if not TAVILY_API_KEY or TAVILY_API_KEY == "":
            return jsonify({
                'success': False,
                'error': 'TAVILY_API_KEY is not configured. Please set environment variables on Render.'
            }), 500
        
        # Initialize vectorstores lazily on first request
        initialize_vectorstores()
        
        # Get user input
        user_input = request.json.get('user_input', '')
        structured_data = request.json.get('structured_data', None)
        
        if not user_input.strip():
            return jsonify({
                'success': False,
                'error': 'Please provide your details'
            }), 400
        
        # Generate session ID
        session_id = str(uuid.uuid4())
        
        # Store in session (including structured data if available)
        sessions[session_id] = {
            'status': 'processing',
            'input': user_input,
            'structured_data': structured_data,
            'started_at': datetime.now().isoformat()
        }
        
        # Extract user interests from structured data
        user_interests = structured_data.get('interests', ['schemes', 'exams']) if structured_data else ['schemes', 'exams']
        
        # Prepare structured profile if available
        structured_profile = None
        if structured_data:
            structured_profile = {
                'name': structured_data.get('name', 'Not Provided'),
                'age': structured_data.get('age', 'Not Provided'),
                'gender': structured_data.get('gender', 'Not Provided'),
                'state': structured_data.get('state', 'Not Provided'),
                'education': structured_data.get('education', 'Not Provided'),
                'employment_status': structured_data.get('employment', 'Not Provided'),
                'income': structured_data.get('income', 'Not Provided'),
                'caste': structured_data.get('category', 'Not Provided'),
                'specialization': structured_data.get('specialization', 'Not Provided'),
                'career_interest': structured_data.get('career_interest', 'Not Provided'),
                'interests': structured_data.get('interests', [])
            }
        
        # Run workflow with interests, structured profile, and pre-loaded vectorstores
        result = run_workflow(
            user_input, 
            user_interests, 
            structured_profile,
            scheme_vectorstore=SCHEME_VECTORSTORE,
            exam_vectorstore=EXAM_VECTORSTORE
        )
        
        # Ensure user_profile key exists in result
        if 'user_profile' not in result and 'profile' in result:
            result['user_profile'] = result['profile']
        
        # Update session
        sessions[session_id]['status'] = 'completed'
        sessions[session_id]['result'] = result
        sessions[session_id]['completed_at'] = datetime.now().isoformat()
        
        # Save to file
        timestamp = datetime.now().strftime("%Y%m%d_%H%M%S")
        filename = f"outputs/results_{timestamp}.json"
        os.makedirs('outputs', exist_ok=True)
        
        with open(filename, 'w', encoding='utf-8') as f:
            json.dump(result, f, indent=2, ensure_ascii=False)
        
        return jsonify({
            'success': True,
            'session_id': session_id,
            'result': result,
            'filename': filename
        })
        
    except ImportError as e:
        print(f"Import Error in /analyze: {str(e)}")
        return jsonify({
            'success': False,
            'error': f'Configuration error: {str(e)}. Please ensure all dependencies are installed.'
        }), 500
    except TimeoutError as e:
        print(f"Timeout Error in /analyze: {str(e)}")
        return jsonify({
            'success': False,
            'error': 'Request timed out. The analysis is taking longer than expected. Please try again.'
        }), 504
    except Exception as e:
        print(f"Error in /analyze: {str(e)}")
        import traceback
        traceback.print_exc()
        return jsonify({
            'success': False,
            'error': f'An error occurred during analysis: {str(e)}'
        }), 500


@app.route('/result/<session_id>')
def result(session_id):
    """Display results page"""
    if session_id not in sessions:
        return render_template('error.html', 
                             error='Session not found'), 404
    
    session_data = sessions[session_id]
    
    if session_data['status'] != 'completed':
        return render_template('error.html', 
                             error='Analysis still in progress'), 400
    
    return render_template('results.html', 
                         session_id=session_id,
                         session_data=session_data,
                         result=session_data['result'])


@app.route('/api/status/<session_id>')
def status(session_id):
    """Check analysis status"""
    if session_id not in sessions:
        return jsonify({'error': 'Session not found'}), 404
    
    return jsonify(sessions[session_id])


@app.route('/history')
def history():
    """View analysis history"""
    output_files = []
    
    if os.path.exists('outputs'):
        files = [f for f in os.listdir('outputs') if f.endswith('.json')]
        files.sort(reverse=True)
        
        for filename in files[:10]:  # Show last 10
            filepath = os.path.join('outputs', filename)
            with open(filepath, 'r', encoding='utf-8') as f:
                data = json.load(f)
                output_files.append({
                    'filename': filename,
                    'timestamp': filename.replace('results_', '').replace('.json', ''),
                    'profile': data.get('user_profile', {}),
                    'errors': data.get('errors', [])
                })
    
    return render_template('history.html', files=output_files)


@app.route('/api/file/<filename>')
def get_file(filename):
    """Download result file"""
    try:
        filepath = os.path.join('outputs', filename)
        with open(filepath, 'r', encoding='utf-8') as f:
            data = json.load(f)
        return jsonify(data)
    except Exception as e:
        return jsonify({'error': str(e)}), 404


@app.route('/download/pdf/<session_id>')
def download_pdf(session_id):
    """Generate and download PDF report"""
    try:
        if session_id not in sessions:
            return jsonify({'error': 'Session not found'}), 404
        
        session_data = sessions[session_id]
        result = session_data.get('result', {})
        
        # Create PDF in memory
        buffer = io.BytesIO()
        doc = SimpleDocTemplate(buffer, pagesize=letter,
                              rightMargin=72, leftMargin=72,
                              topMargin=72, bottomMargin=18)
        
        # Container for PDF elements
        elements = []
        
        # Define styles
        styles = getSampleStyleSheet()
        title_style = ParagraphStyle(
            'CustomTitle',
            parent=styles['Heading1'],
            fontSize=24,
            textColor=colors.HexColor('#5B21B6'),
            spaceAfter=30,
            alignment=TA_CENTER
        )
        heading_style = ParagraphStyle(
            'CustomHeading',
            parent=styles['Heading2'],
            fontSize=16,
            textColor=colors.HexColor('#7C3AED'),
            spaceAfter=12,
            spaceBefore=12
        )
        normal_style = styles['BodyText']
        normal_style.alignment = TA_JUSTIFY
        
        # Get user name for personalization
        profile = result.get('user_profile', {})
        user_name = profile.get('name', 'Citizen')
        if user_name and user_name != 'Not Provided':
            user_name = user_name.strip()
        else:
            user_name = 'Citizen'
        
        # Title with logo-like header
        elements.append(Paragraph("🇮🇳 JanSahayak", title_style))
        elements.append(Paragraph("Government Benefits Analysis Report", styles['Heading3']))
        elements.append(Spacer(1, 0.2*inch))
        
        # Personalized greeting
        greeting = ParagraphStyle('Greeting', parent=styles['Normal'], fontSize=14, 
                                 textColor=colors.HexColor('#374151'), spaceBefore=6, spaceAfter=12)
        elements.append(Paragraph(f"<b>Prepared for: {user_name}</b>", greeting))
        
        # Timestamp
        timestamp = datetime.now().strftime("%B %d, %Y at %I:%M %p")
        elements.append(Paragraph(f"<i>Generated: {timestamp}</i>", styles['Normal']))
        
        # Separator line
        elements.append(Spacer(1, 0.2*inch))
        elements.append(Table([['_'*100]], colWidths=[6.5*inch]))
        elements.append(Spacer(1, 0.4*inch))
        
        # User Profile Section
        elements.append(Paragraph("Your Profile", heading_style))
        profile = result.get('user_profile', {})
        
        if profile:
            profile_data = []
            for key, value in profile.items():
                if key not in ['raw_profile', 'user_input', 'error', 'note'] and value != 'Not Provided':
                    label = key.replace('_', ' ').title()
                    # Format interests list properly
                    if key == 'interests' and isinstance(value, list):
                        value = ', '.join([v.title() for v in value])
                    profile_data.append([Paragraph(f"<b>{label}:</b>", normal_style), 
                                       Paragraph(str(value), normal_style)])
            
            if profile_data:
                profile_table = Table(profile_data, colWidths=[2.2*inch, 4.3*inch])
                profile_table.setStyle(TableStyle([
                    ('BACKGROUND', (0, 0), (0, -1), colors.HexColor('#EEF2FF')),  # Label column
                    ('BACKGROUND', (1, 0), (1, -1), colors.white),  # Value column
                    ('TEXTCOLOR', (0, 0), (-1, -1), colors.HexColor('#1F2937')),
                    ('ALIGN', (0, 0), (-1, -1), 'LEFT'),
                    ('VALIGN', (0, 0), (-1, -1), 'TOP'),
                    ('FONTNAME', (0, 0), (0, -1), 'Helvetica-Bold'),  # Bold labels
                    ('FONTNAME', (1, 0), (1, -1), 'Helvetica'),
                    ('FONTSIZE', (0, 0), (-1, -1), 10),
                    ('BOTTOMPADDING', (0, 0), (-1, -1), 10),
                    ('TOPPADDING', (0, 0), (-1, -1), 10),
                    ('LEFTPADDING', (0, 0), (-1, -1), 12),
                    ('RIGHTPADDING', (0, 0), (-1, -1), 12),
                    ('GRID', (0, 0), (-1, -1), 1, colors.HexColor('#D1D5DB')),
                    ('ROWBACKGROUNDS', (0, 0), (-1, -1), [colors.white, colors.HexColor('#F9FAFB')]),
                ]))
                elements.append(profile_table)
        
        elements.append(Spacer(1, 0.4*inch))
        
        # Helper function to clean and format text
        def clean_text(text):
            if not text or not isinstance(text, str):
                return "No information available"
            # Skip if "Not requested by user"
            if "Not requested by user" in text:
                return None
            # Remove HTML tags
            text = re.sub(r'<[^>]+>', '', text)
            # Convert markdown headers to regular text with proper spacing
            text = re.sub(r'###\s+(.+)', r'\n\1\n', text)
            text = re.sub(r'##\s+(.+)', r'\n\1\n', text)
            # Clean up bold markers
            text = re.sub(r'\*\*(.+?)\*\*', r'\1', text)
            # Clean up bullet points
            text = re.sub(r'^\*\s+', '\u2022 ', text, flags=re.MULTILINE)
            text = re.sub(r'^-\s+', '\u2022 ', text, flags=re.MULTILINE)
            return text.strip()
        
        # Section style for better visual separation
        section_box_style = ParagraphStyle(
            'SectionBox',
            parent=normal_style,
            leftIndent=20,
            rightIndent=20,
            spaceBefore=6,
            spaceAfter=6,
            borderColor=colors.HexColor('#E5E7EB'),
            borderWidth=1,
            borderPadding=10,
            backColor=colors.HexColor('#F9FAFB')
        )
        
        # Government Schemes Section
        schemes_text = clean_text(result.get('scheme_recommendations', 'No recommendations available'))
        if schemes_text:
            elements.append(Paragraph("\ud83c\udfdb\ufe0f Government Schemes for You", heading_style))
            elements.append(Spacer(1, 0.1*inch))
            
            # Split into paragraphs and add with better formatting
            paragraphs = [p.strip() for p in schemes_text.split('\n\n') if p.strip()]
            for para in paragraphs:
                if para:
                    elements.append(Paragraph(para, normal_style))
                    elements.append(Spacer(1, 0.15*inch))
            
            elements.append(Spacer(1, 0.2*inch))
        
        # Competitive Exams Section
        exams_text = clean_text(result.get('exam_recommendations', 'No recommendations available'))
        if exams_text:
            elements.append(Paragraph("\ud83c\udf93 Competitive Exams for You", heading_style))
            elements.append(Spacer(1, 0.1*inch))
            
            paragraphs = [p.strip() for p in exams_text.split('\n\n') if p.strip()]
            for para in paragraphs:
                if para:
                    elements.append(Paragraph(para, normal_style))
                    elements.append(Spacer(1, 0.15*inch))
            
            elements.append(Spacer(1, 0.2*inch))
        
        # Missed Benefits Section
        benefits_text = clean_text(result.get('missed_benefits_analysis', 'No analysis available'))
        if benefits_text:
            elements.append(Paragraph("\ud83d\udcca Missed Benefits Analysis", heading_style))
            elements.append(Spacer(1, 0.1*inch))
            
            paragraphs = [p.strip() for p in benefits_text.split('\n\n') if p.strip()]
            for para in paragraphs:
                if para:
                    elements.append(Paragraph(para, normal_style))
                    elements.append(Spacer(1, 0.15*inch))
        
        # Errors (if any)
        errors = result.get('errors', [])
        if errors:
            elements.append(Spacer(1, 0.3*inch))
            elements.append(Paragraph("Notices", heading_style))
            for error in errors:
                elements.append(Paragraph(f"• {error}", normal_style))
        
        # Footer with disclaimer
        elements.append(Spacer(1, 0.5*inch))
        
        # Add separator before footer
        elements.append(Table([['_'*100]], colWidths=[6.5*inch]))
        elements.append(Spacer(1, 0.2*inch))
        
        footer_style = ParagraphStyle('Footer', parent=styles['Normal'], 
                                     fontSize=9, textColor=colors.HexColor('#6B7280'),
                                     alignment=TA_CENTER)
        elements.append(Paragraph(
            "<i>This report is generated by JanSahayak AI system. "
            "For official information and application procedures, "
            "please visit the respective government ministry websites or contact local government offices.</i>",
            footer_style
        ))
        elements.append(Spacer(1, 0.1*inch))
        elements.append(Paragraph(
            "<i>Generated by JanSahayak - Your Government Benefits Assistant</i>",
            footer_style
        ))
        
        # Build PDF
        doc.build(elements)
        
        # Prepare response
        buffer.seek(0)
        
        # Create filename with user's name
        safe_name = re.sub(r'[^a-zA-Z0-9\s]', '', user_name).replace(' ', '_')
        timestamp_str = datetime.now().strftime("%Y%m%d")
        filename = f'JanSahayak_{safe_name}_{timestamp_str}.pdf'
        
        return send_file(
            buffer,
            as_attachment=True,
            download_name=filename,
            mimetype='application/pdf'
        )
        
    except Exception as e:
        print(f"PDF Generation Error: {str(e)}")
        return jsonify({'error': str(e)}), 500


if __name__ == '__main__':
    # Get port from environment variable (for deployment platforms)
    port = int(os.environ.get('PORT', 5000))
    
    # Check if running in production
    is_production = os.environ.get('FLASK_ENV') != 'development'
    
    print("\n" + "="*70)
    print("🙏 JANSAHAYAK - Starting Web Server")
    print("="*70)
    
    # Check API keys on startup
    from config import GROQ_API_KEY, TAVILY_API_KEY, HF_TOKEN
    
    if not GROQ_API_KEY or GROQ_API_KEY == "":
        print("⚠️  WARNING: GROQ_API_KEY is not set!")
        print("   The application will not work without this API key.")
    else:
        print("✅ GROQ_API_KEY is configured")
    
    if not TAVILY_API_KEY or TAVILY_API_KEY == "":
        print("⚠️  WARNING: TAVILY_API_KEY is not set!")
        print("   The application will not work without this API key.")
    else:
        print("✅ TAVILY_API_KEY is configured")
    
    if not HF_TOKEN or HF_TOKEN == "":
        print("⚠️  WARNING: HF_TOKEN is not set (optional but recommended)")
    else:
        print("✅ HF_TOKEN is configured")
    
    print(f"\n📱 Starting Flask server on port {port}...")
    print(f"🌍 Environment: {'Production' if is_production else 'Development'}")
    print("🔄 Vectorstores will be loaded on first request")
    print("🛑 Press CTRL+C to stop the server\n")
    
    # Start Flask FIRST to bind to port, then load vectorstores in background
    app.run(debug=not is_production, host='0.0.0.0', port=port, threaded=True)