final_campaign.py

#!/usr/bin/env python3
"""Final working email campaign with Bedrock Nova."""

import asyncio
from ai_email_generator import AIEmailGenerator


async def run_final_campaign():
    """Run production-ready email campaign."""

    print("🚀 Production Email Campaign - Bedrock Nova")
    print("=" * 50)

    # Add your real contacts here (manually or from CSV)
    contacts = [
        {
            "name": "Andreas Garcia",
            "email": "andreas@allcode.com",
            "company": "AllCode",
            "title": "Account Executive",
            "industry": "Cloud Services",
        },
        {
            "name": "Joel Garcia",
            "email": "joel@allcode.com",
            "company": "AllCode",
            "title": "CEO",
            "industry": "Technology",
        },
    ]

    ai_generator = AIEmailGenerator()

    for i, contact in enumerate(contacts, 1):
        print(f"\n📤 Contact {i}: {contact['name']} ({contact['email']})")

        try:
            # Create profile data
            profile_data = {
                "name": contact["name"],
                "company": contact["company"],
                "job_title": contact["title"],
                "about": f"Professional in {contact['industry']} at {contact['company']}",
            }

            # Format for AI
            profile_info = ai_generator.format_profile_for_ai(profile_data)
            first_name = contact["name"].split()[0]

            # Generate email with Bedrock Nova
            print("🤖 Generating Bedrock Nova email...")
            ai_email = await ai_generator.generate_ai_email(profile_info, first_name)

            print("✅ Generated Email:")
            print("-" * 50)
            print(ai_email)
            print("-" * 50)

            # Here you can add CCAI email sending
            # await send_via_ccai(contact, ai_email)

        except Exception as e:
            print(f"❌ Error: {e}")

    print("\n🎉 Campaign completed!")
    print("💡 Add more contacts to the 'contacts' list above")
    print("💡 Integrate with CCAI for actual sending")


if __name__ == "__main__":
    asyncio.run(run_final_campaign())