#!/usr/bin/env python3
"""
Run Collection — Brand Monitoring V1
Wrapper script that runs collect_rss.py, pipeline.py, and alert_dispatcher.py.
"""

import subprocess
import os
import sys

def main():
    script_dir = os.path.dirname(os.path.abspath(__file__))
    
    print("Step 1: Running RSS collection...")
    res = subprocess.run(["python3", f"{script_dir}/collect_rss.py"], capture_output=True, text=True)
    print(res.stdout)
    if res.returncode != 0:
        print("RSS collection failed", file=sys.stderr)
        print(res.stderr, file=sys.stderr)
        sys.exit(1)
        
    print("Step 2: Running pipeline...")
    res = subprocess.run(["python3", f"{script_dir}/pipeline.py"], capture_output=True, text=True)
    print(res.stdout)
    if res.returncode != 0:
        print("Pipeline execution failed", file=sys.stderr)
        print(res.stderr, file=sys.stderr)
        sys.exit(1)
        
    print("Step 3: Running alert dispatcher...")
    res = subprocess.run(["python3", f"{script_dir}/alert_dispatcher.py"], capture_output=True, text=True)
    print(res.stdout)
    if res.returncode != 0:
        print("Alert dispatch failed", file=sys.stderr)
        print(res.stderr, file=sys.stderr)
        sys.exit(1)
        
    print("Collection run finished successfully.")

if __name__ == "__main__":
    main()