cache_manager.py

"""Cache management for processed emails"""
import json
import os

from config import EMAIL_CACHE_FILE


def load_email_cache():
    """Load previously processed email IDs from cache"""
    if os.path.exists(EMAIL_CACHE_FILE):
        try:
            with open(EMAIL_CACHE_FILE, 'r', encoding='utf-8') as f:
                cache = json.load(f)
                print(f"Loaded cache with {len(cache.get('processed_ids', []))} previously processed emails")
                return cache
        except Exception as e:
            print(f"Warning: Could not load cache file: {e}")
            return {'processed_ids': [], 'applications': []}
    return {'processed_ids': [], 'applications': []}


def save_email_cache(cache):
    """Save processed email IDs and applications to cache"""
    try:
        with open(EMAIL_CACHE_FILE, 'w', encoding='utf-8') as f:
            json.dump(cache, f, indent=2, default=str)
        print(f"Saved cache with {len(cache['processed_ids'])} processed emails")
    except Exception as e:
        print(f"Warning: Could not save cache file: {e}")