"""CLI enabler for pytrafikverket."""

from __future__ import annotations

import argparse
import asyncio
import json
from datetime import datetime
from typing import Any

import aiohttp

from .const import (
    DATE_TIME_INPUT,
    GET_FERRY_ROUTE,
    GET_NEXT_FERRY_STOP,
    GET_NEXT_TRAIN_STOP,
    GET_TRAIN_STOP,
    GET_WEATHER,
    SEARCH_FOR_FERRY_ROUTE,
    SEARCH_FOR_STATION,
)
from .trafikverket_ferry import TrafikverketFerry
from .trafikverket_train import TrafikverketTrain
from .trafikverket_weather import TrafikverketWeather


async def async_main(loop: Any) -> None:
    """Set up function to handle input and get data to present."""
    async with aiohttp.ClientSession(loop=loop) as session:
        parser = argparse.ArgumentParser(
            description="CLI used to get data from trafikverket"
        )
        parser.add_argument("-key", type=str, required=True)
        parser.add_argument(
            "-method",
            required=True,
            choices=(
                SEARCH_FOR_STATION,
                GET_TRAIN_STOP,
                GET_NEXT_TRAIN_STOP,
                GET_WEATHER,
                GET_FERRY_ROUTE,
                SEARCH_FOR_FERRY_ROUTE,
                GET_NEXT_FERRY_STOP,
            ),
        )
        parser.add_argument("-station", type=str)
        parser.add_argument("-from-station", type=str)
        parser.add_argument("-to-station", type=str)
        parser.add_argument("-date-time", type=str)
        parser.add_argument("-route", type=str)
        parser.add_argument("-from-harbor", type=str)
        parser.add_argument("-to-harbor", type=str)
        parser.add_argument("-train-product", type=str)
        parser.add_argument(
            "-exclude-canceled-trains",
            action=argparse.BooleanOptionalAction,
            default=False,
        )

        async with asyncio.timeout(10):
            args = parser.parse_args()
            train_api = TrafikverketTrain(session, args.key)
            weather_api = TrafikverketWeather(session, args.key)
            ferry_api = TrafikverketFerry(session, args.key)

            if args.method == SEARCH_FOR_STATION:
                if args.station is None:
                    raise ValueError("-station is required")
                stations = await train_api.async_search_train_stations(args.station)
                for station in stations:
                    print_values(station)
            elif args.method == GET_TRAIN_STOP:
                from_station = await train_api.async_search_train_station(
                    args.from_station
                )
                to_station = await train_api.async_search_train_station(args.to_station)
                print(f"from_station_signature: {from_station.signature}")  # noqa: T201
                print(f"to_station_signature:   {to_station.signature}")  # noqa: T201

                time = datetime.strptime(args.date_time, DATE_TIME_INPUT)

                train_stop = await train_api.async_get_train_stop(
                    from_station,
                    to_station,
                    time,
                    product_description=args.train_product,
                    exclude_canceled=args.exclude_canceled_trains,
                )
                print_values(train_stop)

            elif args.method == GET_NEXT_TRAIN_STOP:
                from_station = await train_api.async_search_train_station(
                    args.from_station
                )
                to_station = await train_api.async_search_train_station(args.to_station)
                print(f"from_station_signature: {from_station.signature}")  # noqa: T201
                print(f"to_station_signature:   {to_station.signature}")  # noqa: T201

                if args.date_time is not None:
                    time = datetime.strptime(args.date_time, DATE_TIME_INPUT)
                else:
                    time = datetime.now()
                train_stop = await train_api.async_get_next_train_stop(
                    from_station,
                    to_station,
                    time,
                    product_description=args.train_product,
                    exclude_canceled=args.exclude_canceled_trains,
                )
                print_values(train_stop)

            elif args.method == GET_WEATHER:
                if args.station is None:
                    raise ValueError(
                        '-station is required with name of Weather station\
                         (ex. -station "Nöbbele")'
                    )
                weather = await weather_api.async_get_weather(args.station)
                print_values(weather)

            elif args.method == GET_FERRY_ROUTE:
                if args.route is None:
                    raise ValueError(
                        '-route is required with name of Ferry route\
                         (ex. -route "Ekeröleden")'
                    )
                route = await ferry_api.async_get_ferry_route(args.route)
                print_values(route)

            elif args.method == SEARCH_FOR_FERRY_ROUTE:
                if args.route is None:
                    raise ValueError("-route is required")
                routes = await ferry_api.async_search_ferry_routes(args.route)
                for route in routes:
                    print_values(route)
                    print(f"{route.ferry_route_name} {route.ferry_route_id}")  # noqa: T201

            elif args.method == GET_NEXT_FERRY_STOP:
                if args.from_harbor is None:
                    raise ValueError(
                        '-from-harbor is required with name of Ferry harbor\
                         (ex. -from-harbor "Ekerö")'
                    )
                if args.date_time is not None:
                    time = datetime.strptime(args.date_time, DATE_TIME_INPUT)
                else:
                    time = datetime.now()

                ferry_stop = await ferry_api.async_get_next_ferry_stop(
                    args.from_harbor, args.to_harbor, time
                )
                print_values(ferry_stop)


def print_values(result: Any) -> None:
    """Print out values for all object members."""
    print(json.dumps(result.__dict__, indent=4, ensure_ascii=False))  # noqa: T201


def main() -> None:
    """Initialize the loop."""
    loop = asyncio.get_event_loop()
    loop.run_until_complete(async_main(loop))