Utilities

def setup_logging(level: int = logging.INFO) -> None:
    """Configure the root ``pluginlake`` logger.

    Call once at application startup. All child loggers
    (e.g., ``pluginlake.storage``) inherit this configuration.

    Args:
        level: The log level to set.
    """
    root_logger = logging.getLogger("pluginlake")
    root_logger.handlers.clear()
    root_logger.setLevel(level)

    handler = logging.StreamHandler(sys.stderr)
    handler.setFormatter(logging.Formatter(fmt=_TEXT_FORMAT, datefmt=_TEXT_DATE_FORMAT))

    root_logger.addHandler(handler)
    root_logger.propagate = False

def get_logger(name: str) -> logging.Logger:
    """Get a namespaced logger for a pluginlake module.

    Usage::

        from pluginlake.utils.logger import get_logger

        logger = get_logger(__name__)
        logger.info("Processing started")

    Args:
        name: The module name, typically ``__name__``.

    Returns:
        A logger under the ``pluginlake`` namespace.
    """
    if not name.startswith("pluginlake"):
        name = f"pluginlake.{name}"
    return logging.getLogger(name)

def check_dev_services() -> list[ServiceStatus]:
    """Check PostgreSQL, Dagster, and FastAPI connectivity for the local dev stack."""
    return [
        _check_postgres(),
        _check_http("Dagster", "http://localhost:3000/server_info"),
        _check_http("FastAPI", "http://localhost:8000/health"),
    ]

def find_repo_root() -> Path:
    """Walk up from this file to find the directory containing pyproject.toml."""
    current = Path(__file__).resolve().parent
    for parent in [current, *current.parents]:
        if (parent / "pyproject.toml").exists():
            return parent
    msg = "Could not find repo root (no pyproject.toml found)"
    raise FileNotFoundError(msg)

def ensure_synthea1k(project_root: Path | None = None) -> Path:
    """Ensure Synthea 1K test data is available locally."""
    root = project_root or find_repo_root()
    return download_and_extract(_SYNTHEA1K_URL, root / _SYNTHEA1K_DEST)

def ensure_synthea_fhir_ndjson(project_root: Path | None = None) -> Path:
    """Ensure Synthea FHIR NDJSON files are available locally."""
    root = project_root or find_repo_root()
    return download_and_extract(_SYNTHEA_FHIR_NDJSON_URL, root / _SYNTHEA_FHIR_NDJSON_DEST)