"""Entrypoint orchestrator script running as a Cloud Run Job.

Loads the environment config, configures centralized logging, and executes the
iterative bug-fixing orchestrator asynchronously.
"""

import asyncio
import logging
import sys

from config import Config
from orchestrator import Orchestrator, OrchestrationError


class IgnoreRawWsMsgFilter(logging.Filter):
    """Filter to ignore raw websocket messages in the log output."""

    def filter(self, record: logging.LogRecord) -> bool:
        return "RAW WS MSG" not in record.getMessage()


def setup_logging() -> None:
    """Sets up the root logger with a standardized format."""
    handler = logging.StreamHandler(sys.stdout)
    handler.addFilter(IgnoreRawWsMsgFilter())
    logging.basicConfig(
        level=logging.INFO,
        format="%(asctime)s [%(levelname)s] %(name)s: %(message)s",
        handlers=[handler],
    )


async def main() -> None:
    """Asynchronous process execution entrypoint."""
    setup_logging()
    logging.info("Starting SSR Agent Orchestration Worker...")

    try:
        config = Config()
        orchestrator = Orchestrator(config)
        await orchestrator.run()
    except OrchestrationError as e:
        logging.critical("Orchestrator encountered a fatal error: %s", e)
        sys.exit(1)
    except Exception as e:
        logging.exception("An unhandled error occurred in the orchestrator.")
        sys.exit(4)


if __name__ == "__main__":
    try:
        asyncio.run(main())
    except Exception as err:
        print(f"Fatal crash during startup initialization: {err}", file=sys.stderr)
        sys.exit(4)