main.py

import asyncio
import argparse
import os
from investment_army.core.orchestrator import Orchestrator
from dotenv import load_dotenv

async def main():
    load_dotenv()
    
    parser = argparse.ArgumentParser(description="Investment Army CIA - Capital Investment Agency")
    parser.add_argument("--context", type=str, required=True, help="Path to business context directory or file")
    parser.add_argument("--investors", type=str, required=True, help="Path to investors website list file")
    
    args = parser.parse_args()
    
    orchestrator = Orchestrator()
    await orchestrator.initialize(args.context, args.investors)
    
    print("\n--- Investment Army Operation Started ---")
    
    user_input = None
    while True:
        try:
            await orchestrator.run_cycle(user_input)
            user_input = input("\n[NEXT STEP / FEEDBACK] (or 'exit' to quit): ")
            if user_input.lower() == 'exit':
                break
        except KeyboardInterrupt:
            break
        except Exception as e:
            print(f"Error in cycle: {e}")
            break

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