main.py

from app.gmail_service import get_messages
from app.processor import process_email
import logging

logging.basicConfig(
    level=logging.INFO,
    format="%(asctime)s - %(levelname)s - %(message)s"
)

def main():
    service, messages = get_messages()

    if not messages:
        logging.info("No new emails.")
        return

    total_emails = 0
    total_tasks = 0

    for msg in messages:
        try:
            created_tasks = process_email(service, msg)
            total_emails += 1
            total_tasks += created_tasks

            # mark as read
            service.users().messages().modify(
                userId='me',
                id=msg['id'],
                body={'removeLabelIds': ['UNREAD']}
            ).execute()

        except Exception as e:
            logging.error(f"Error processing email: {e}")

    logging.info(
        "Run complete. Processed %s email(s) and created %s task(s).",
        total_emails,
        total_tasks,
    )


if __name__ == "__main__":
    main()