from __future__ import annotations

import argparse
import asyncio
import importlib.metadata
import typing

from loguru import logger

from aphrodite.endpoints.cli.types import CLISubcommand
from aphrodite.endpoints.utils import (
    APHRODITE_SUBCMD_PARSER_EPILOG, show_filtered_argument_or_group_from_help)

if typing.TYPE_CHECKING:
    from aphrodite.utils import FlexibleArgumentParser


class RunBatchSubcommand(CLISubcommand):
    """The `run-batch` subcommand for Aphrodite CLI."""
    name = "run-batch"

    @staticmethod
    def cmd(args: argparse.Namespace) -> None:
        from aphrodite.endpoints.openai.run_batch import main as run_batch_main

        logger.info("Aphrodite batch processing API version {}",
                    importlib.metadata.version("aphrodite-engine"))
        logger.info("args: {}", args)

        # Start the Prometheus metrics server.
        # LLMEngine uses the Prometheus client
        # to publish metrics at the /metrics endpoint.
        if args.enable_metrics:
            from prometheus_client import start_http_server

            logger.info("Prometheus metrics enabled")
            start_http_server(port=args.port, addr=args.url)
        else:
            logger.info("Prometheus metrics disabled")

        asyncio.run(run_batch_main(args))

    def subparser_init(
            self,
            subparsers: argparse._SubParsersAction) -> FlexibleArgumentParser:
        from aphrodite.endpoints.openai.run_batch import make_arg_parser

        run_batch_parser = subparsers.add_parser(
            "run-batch",
            help="Run batch prompts and write results to file.",
            description=(
                "Run batch prompts using Aphrodite's OpenAI-compatible API.\n"
                "Supports local or HTTP input/output files."),
            usage=
            "aphrodite run-batch -i INPUT.jsonl -o OUTPUT.jsonl --model <model>",
        )
        run_batch_parser = make_arg_parser(run_batch_parser)
        show_filtered_argument_or_group_from_help(run_batch_parser,
                                                  ["run-batch"])
        run_batch_parser.epilog = APHRODITE_SUBCMD_PARSER_EPILOG
        return run_batch_parser


def cmd_init() -> list[CLISubcommand]:
    return [RunBatchSubcommand()]
