#!/usr/bin/python
# -*- coding: utf-8 -*-
"""
dremel3dpy by Gustavo Stor - A Dremel 3D Printer Python library.

https://github.com/godely/dremel3dpy

Published under the MIT license - See LICENSE file for more details.

This library supports the three Dremel models: 3D20, 3D40 and 3D45.

"Dremel" is a trademark owned by Bosch, see www.dremel.com for
more information. I am in no way affiliated with Dremel.
"""

import asyncio
import json
import logging
import os
import random
import re
import string
from typing import Any, Dict

import requests
import validators
from numpy import ndarray
from urllib3.exceptions import InsecureRequestWarning
from yarl import URL

from .helpers.constants import (
    _LOGGER,
    AVAILABLE_STORAGE,
    CAMERA_PORT,
    CANCEL_COMMAND,
    CHAMBER_TEMPERATURE,
    COMMAND_PATH,
    COMMAND_PORT,
    CONF_API_VERSION,
    CONF_CONNECTION_TYPE,
    CONF_ETHERNET_CONNECTED,
    CONF_ETHERNET_IP,
    CONF_FIRMWARE_VERSION,
    CONF_HOST,
    CONF_MACHINE_TYPE,
    CONF_MODEL,
    CONF_SERIAL_NUMBER,
    CONF_TITLE,
    CONF_WIFI_CONNECTED,
    CONF_WIFI_IP,
    DOOR_OPEN,
    DREMEL_MANUFACTURER,
    ELAPSED_TIME,
    ERROR_CODE,
    ESTIMATED_TOTAL_TIME,
    EXTRA_STATUS_PORT,
    EXTRUDER_TARGET_TEMPERATURE,
    EXTRUDER_TEMPERATURE,
    EXTRUDER_TEMPERATURE_RANGE,
    FAN_SPEED,
    FILAMENT,
    HOME_MESSAGE_PATH,
    JOB_NAME,
    JOB_STATUS,
    NETWORK_BUILD,
    PAUSE_COMMAND,
    PLATFORM_TARGET_TEMPERATURE,
    PLATFORM_TEMPERATURE,
    PLATFORM_TEMPERATURE_RANGE,
    PRINT_COMMAND,
    PRINT_FILE_UPLOADS,
    PRINTER_INFO_COMMAND,
    PRINTER_STATUS_COMMAND,
    PROGRESS,
    REMAINING_TIME,
    REQUEST_TIMEOUT,
    RESUME_COMMAND,
    STATS_FILAMENT_USED,
    STATS_FILE_NAME,
    STATS_LAYER_HEIGHT,
    STATS_SOFTWARE,
    STATUS,
    USAGE_COUNTER,
)


class Dremel3DPrinter:
    """Main Dremel 3D Printer class."""

    def __init__(self, host: str) -> None:
        """Init a Dremel 3D Printer instance"""
        self._host = host
        self._printer_info = None
        self._job_status = None
        self._printer_extra_stats = None
        self._total_time = 0
        self._is_printing = False
        self._is_building = False
        self._is_calibrating = False
        self._is_starting = False
        self._is_heating = False
        self._is_finished = False
        self.refresh()

    def set_printer_info(self, refresh=False):
        """Return attributes related to the printer."""
        if refresh or self._printer_info is None:
            try:
                printer_info = default_request(self._host, PRINTER_INFO_COMMAND)
            except RuntimeError as exc:
                self._printer_info = None
                raise exc
            else:
                title = None
                model = None
                try:
                    title = re.search(
                        r"DREMEL [^\s+]+", printer_info[CONF_MACHINE_TYPE]
                    ).group(0)
                    model = re.search(
                        r"DREMEL ([^\s+]+)", printer_info[CONF_MACHINE_TYPE]
                    ).group(1)
                except Exception:  # pylint: disable=try-except-raise
                    raise
                self._printer_info = {
                    CONF_HOST: self._host,
                    CONF_API_VERSION: printer_info[CONF_API_VERSION],
                    CONF_CONNECTION_TYPE: "eth0"
                    if printer_info[CONF_ETHERNET_CONNECTED] == 1
                    else "wlan",
                    CONF_ETHERNET_IP: printer_info[CONF_ETHERNET_IP]
                    if printer_info[CONF_ETHERNET_CONNECTED] == 1
                    else "n-a",
                    CONF_FIRMWARE_VERSION: printer_info[CONF_FIRMWARE_VERSION],
                    CONF_MACHINE_TYPE: printer_info[CONF_MACHINE_TYPE],
                    CONF_MODEL: model,
                    CONF_SERIAL_NUMBER: printer_info[CONF_SERIAL_NUMBER],
                    CONF_TITLE: title,
                    CONF_WIFI_IP: printer_info[CONF_WIFI_IP]
                    if printer_info[CONF_WIFI_CONNECTED] == 1
                    else "n-a",
                }

    def set_job_status(self, refresh=False):
        """Return stats related to the printer and the printing job."""
        if refresh or self._job_status is None:
            try:
                last_printing_status = (
                    self.get_printing_status()
                    if self.get_job_status() is not None
                    else "idle"
                )
                job_status = default_request(self._host, PRINTER_STATUS_COMMAND)
                job_name = re.search(
                    r"(.*?)(\.[^\.]*)?$", job_status[JOB_NAME[0]]
                ).group(1)
            except RuntimeError as exc:
                self._job_status = None
                raise exc
            else:
                mapped_status = {
                    "": "idle",
                    "abort": "abort",
                    "building": "building",
                    "completed": "completed",
                    "pausing": "pausing",
                    "preparing": "preparing",
                    "!pausing": "paused",
                    "!resuming": "resuming",
                }
                self._job_status = {
                    DOOR_OPEN[1]: job_status[DOOR_OPEN[0]],
                    CHAMBER_TEMPERATURE[1]: job_status[CHAMBER_TEMPERATURE[0]],
                    ELAPSED_TIME[1]: job_status[ELAPSED_TIME[0]],
                    REMAINING_TIME[1]: job_status[REMAINING_TIME[0]],
                    ESTIMATED_TOTAL_TIME[1]: job_status[ESTIMATED_TOTAL_TIME[0]],
                    EXTRUDER_TEMPERATURE[1]: job_status[EXTRUDER_TEMPERATURE[0]],
                    EXTRUDER_TARGET_TEMPERATURE[1]: job_status[
                        EXTRUDER_TARGET_TEMPERATURE[0]
                    ],
                    FAN_SPEED[1]: job_status[FAN_SPEED[0]],
                    FILAMENT[1]: job_status[FILAMENT[0]],
                    JOB_STATUS[1]: mapped_status[job_status[JOB_STATUS[0]]]
                    if job_status[JOB_STATUS[0]] in mapped_status
                    else "unknown",
                    JOB_NAME[1]: job_name,
                    NETWORK_BUILD[1]: job_status[NETWORK_BUILD[0]],
                    PLATFORM_TARGET_TEMPERATURE[1]: job_status[
                        PLATFORM_TARGET_TEMPERATURE[0]
                    ],
                    PLATFORM_TEMPERATURE[1]: job_status[PLATFORM_TEMPERATURE[0]],
                    PROGRESS[1]: job_status[PROGRESS[0]],
                    STATUS[1]: job_status[STATUS[0]],
                }
                current_printing_status = self.get_printing_status()
                if last_printing_status != current_printing_status:
                    self._is_printing = False
                    self._is_building = False
                    self._is_calibrating = False
                    self._is_starting = False
                    self._is_heating = False
                    self._is_finished = False
                    if current_printing_status == "building":
                        self._is_printing = True
                        self._is_building = True
                    elif (
                        current_printing_status == "resuming"
                        or current_printing_status == "paused"
                        or current_printing_status == "pausing"
                    ):
                        self._is_printing = True
                    elif current_printing_status == "preparing":
                        self._is_printing = True
                        if last_printing_status == "completed":
                            self._is_heating = True
                        else:
                            self._is_calibrating = True
                    elif (
                        last_printing_status == "completed"
                        and current_printing_status == "idle"
                    ):
                        self._is_printing = True
                        self._is_starting = True
                    elif (
                        last_printing_status == "preparing"
                        and current_printing_status == "idle"
                    ):
                        self._is_printing = True
                        self._is_heating = True
                    elif (
                        last_printing_status == "building"
                        and current_printing_status == "completed"
                    ):
                        self._is_finished = True
                    info_msg = "Printer changed its phase from {last_printing_status} to {current_printing_status}."
                    _LOGGER.info(info_msg)
                    last_printing_status = current_printing_status
            # Patch fix the total time. Sometimes when in a printing job this API can
            # keep returning a total time of 0 but an actual estimated remaining time.
            # Every time we call this API, if total_time is still not set, we check to
            # see if the API returned a correct value for the estimated total time and
            # use that as source of truth. Otherwise, we check to see if we the API
            # returned at least a non-zero value for remaining time. The first time this
            # happens we get the value of remaining time and use it as total_time and
            # do not change it again.
            if self._total_time == 0:
                total_times = [0]
                if (total_time := self._job_status[ESTIMATED_TOTAL_TIME[1]]) > 0:
                    total_times += [total_time]
                if (total_time := self._job_status[REMAINING_TIME[1]]) > 0:
                    total_times += [self._job_status[REMAINING_TIME[1]]]
                    if (elapsed_time := self._job_status[ELAPSED_TIME[1]]) > 0:
                        total_times += [total_time + elapsed_time]
                if (total_time := max(total_times)) > self._total_time:
                    self._total_time = total_time

    def set_extra_status(self, refresh=False):
        """Return extra status that we grab from the Dremel webpage API."""
        if refresh or self._printer_extra_stats is None:
            try:
                extra_status = default_request(
                    self._host,
                    scheme="https",
                    port=EXTRA_STATUS_PORT,
                    path=HOME_MESSAGE_PATH,
                )
            except RuntimeError as exc:
                self._printer_extra_stats = None
                raise exc
            else:
                max_platform_temperature = re.search(
                    r"0-(\d+)", extra_status[PLATFORM_TEMPERATURE_RANGE[0]]
                ).group(1)
                max_extruder_temperature = re.search(
                    r"0-(\d+)", extra_status[EXTRUDER_TEMPERATURE_RANGE[0]]
                ).group(1)
                self._printer_extra_stats = {
                    AVAILABLE_STORAGE[1]: extra_status[AVAILABLE_STORAGE[0]],
                    EXTRUDER_TEMPERATURE_RANGE[1]: max_extruder_temperature,
                    PLATFORM_TEMPERATURE_RANGE[1]: max_platform_temperature,
                    USAGE_COUNTER[1]: extra_status[USAGE_COUNTER[0]],
                }

    def refresh(self) -> None:
        """Do a full refresh of all API calls."""
        try:
            self.set_printer_info(refresh=True)
            self.set_job_status(refresh=True)
            self.set_extra_status(refresh=True)
        except RuntimeError as exc:
            _LOGGER.exception(str(exc))

    def get_printer_info(self) -> Dict[str, Any]:
        return (self._printer_info or {}) | (self._printer_extra_stats or {})

    def get_job_status(self) -> Dict[str, Any]:
        return self._job_status

    def get_manufacturer(self) -> str:
        return DREMEL_MANUFACTURER

    def get_model(self) -> str:
        return self.get_printer_info().get(CONF_MODEL)

    def get_title(self) -> str:
        return self.get_printer_info().get(CONF_TITLE)

    def get_firmware_version(self) -> str:
        return self.get_printer_info().get(CONF_FIRMWARE_VERSION)

    def get_job_name(self) -> str:
        return self.get_job_status().get(JOB_NAME[1])

    def get_remaining_time(self) -> int:
        return self.get_job_status().get(REMAINING_TIME[1])

    def get_elapsed_time(self) -> int:
        return self.get_job_status().get(ELAPSED_TIME[1])

    def get_total_time(self) -> int:
        return self.get_elapsed_time() + self.get_remaining_time()

    def get_filament(self) -> str:
        return self.get_job_status().get(FILAMENT[1])

    def is_busy(self) -> bool:
        return self.get_job_status().get(STATUS[1]) == "busy"

    def is_ready(self) -> bool:
        return self.get_job_status().get(STATUS[1]) == "ready"

    def is_printing(self) -> bool:
        return self._is_printing

    def is_finished(self) -> bool:
        return self._is_finished

    def is_heating(self) -> bool:
        return self._is_heating

    def is_calibrating(self) -> bool:
        return self._is_calibrating

    def is_starting(self) -> bool:
        return self._is_starting

    def is_not_printing(self) -> bool:
        return not self.is_printing()

    def is_completed(self) -> bool:
        return self._is_finished

    def is_paused(self) -> bool:
        return self.get_printing_status() == "paused"

    def is_pausing(self) -> bool:
        return self.get_printing_status() == "pausing"

    def is_aborted(self) -> bool:
        return self.get_printing_status() == "aborted"

    def is_running(self) -> bool:
        return self.is_printing() and not self.is_paused() and not self.is_pausing()

    def is_building(self) -> bool:
        return (
            self._is_building
            and self.get_total_time() > 0
            # This function is a maybe because there were times the initial calls to the API failed
            # and the target temperature was always zero. A better solution in the future is use code
            # that we already created to check if the platform/extruder temperatures are not moving.
            and self.are_temperatures_maybe_within_target_range()
            # Maybe change it to: self._is_building or (self._is_idle and self.get_total_temp() > 0 and self.are_temp...)
        )

    def is_door_open(self) -> bool:
        return self.get_job_status().get(DOOR_OPEN[1]) == 1

    def get_stream_url(self) -> str:
        return f"http://{self._host}:{CAMERA_PORT}/?action=stream"

    def get_snapshot_url(self) -> str:
        return f"http://{self._host}:{CAMERA_PORT}/?action=snapshot"

    def get_serial_number(self) -> str:
        return self.get_printer_info().get(CONF_SERIAL_NUMBER)

    def get_printing_status(self) -> str:
        return self.get_job_status().get(JOB_STATUS[1])

    def get_printing_progress(self) -> float:
        return self.get_job_status().get(PROGRESS[1])

    def get_temperature_type(self, temp_type: str) -> int:
        return self.get_job_status().get(f"{temp_type}_temperature")

    def get_temperature_attributes(self, temp_type: str) -> Dict[str, int]:
        return {
            "target_temp": self.get_job_status().get(f"{temp_type}_target_temperature"),
            "max_temp": int(
                self.get_printer_info().get(f"{temp_type}_max_temperature")
            ),
        }

    def is_maybe_temperature_within_target_range(self, temp_type) -> bool:
        temperature = self.get_temperature_type(temp_type)
        target_temperature = self.get_temperature_attributes(temp_type)["target_temp"]
        if target_temperature == 0:
            return True
        return temperature in range(target_temperature - 2, target_temperature + 3)

    def are_temperatures_maybe_within_target_range(self) -> bool:
        return all(
            [
                self.is_maybe_temperature_within_target_range(temp_type)
                for temp_type in ["platform", "extruder"]
            ]
        )

    def _upload_print(self: str, file: str) -> str:
        try:
            filename = (
                "".join(random.choice(string.ascii_letters) for i in range(10))
                + ".gcode"
            )
            response = requests.post(
                f"http://{self._host}{PRINT_FILE_UPLOADS}",
                files={"print_file": (filename, file)},
                timeout=REQUEST_TIMEOUT,
            )
        except Exception as exc:  # pylint: disable=broad-except
            raise exc
        if error_code := response.status_code != 200:
            raise RuntimeError(f"Upload failed with status code {error_code}")

        return filename

    def _get_print_stats(self, filename: str, data: str) -> Dict[str, str]:
        filament_used = (
            f"{match.group(1)}m"
            if (match := re.search("Filament used: ([0-9.]+)", data)) is not None
            else ""
        )
        layer_height = (
            f"{match.group(1)}mm"
            if (match := re.search("Layer height: ([0-9.]+)", data)) is not None
            else ""
        )
        software = (
            match.group(1)
            if (match := re.search("Generated with (.+)", data)) is not None
            else ""
        )
        return {
            STATS_FILAMENT_USED: filament_used,
            STATS_FILE_NAME: filename,
            STATS_LAYER_HEIGHT: layer_height,
            STATS_SOFTWARE: software,
        }

    def start_print_from_file(self, filepath: str) -> Dict[str, str]:
        """
        Uploads a file to the printer, so it can start a print job. This file is local.
        """
        if (
            filepath is not None
            and os.path.isfile(filepath)
            and filepath.lower().endswith(".gcode")
        ):
            file = open(filepath, "rb")
            data = file.read().decode("utf-8")
        else:
            raise RuntimeError(
                "File path must be defined and point to a valid .gcode file."
            )
        filename = self._upload_print(data)
        try:
            default_request(self._host, {PRINT_COMMAND: filename})
            return self._get_print_stats(filename, data)
        except RuntimeError as exc:
            _LOGGER.exception(str(exc))

    def start_print_from_url(self, url: str) -> Dict[str, str]:
        """
        Uploads a file to the printer, so it can start a print job. This file is fetched from an URL.
        """
        if url is not None:
            try:
                if validators.url(url) is True:
                    request = requests.get(url, timeout=REQUEST_TIMEOUT)
                elif validators.url(f"https://{url}") is True:
                    try:
                        request = requests.get(
                            f"https://{url}", timeout=REQUEST_TIMEOUT
                        )
                    except requests.exceptions.SSLError:
                        request = requests.get(f"http://{url}", timeout=REQUEST_TIMEOUT)
                else:
                    raise RuntimeError("Invalid URL format")
                if request.status_code != 200:
                    raise RuntimeError(
                        f"URL returned status code {request.status_code}"
                    )
                file = request.content
                data = file.decode("utf-8")
            except requests.exceptions.ConnectionError as exc:
                raise exc
            except Exception as exc:  # pylint: disable=broad-except
                raise exc
        else:
            raise RuntimeError("URL must be defined and be a valid gcode file")
        filename = self._upload_print(data)
        try:
            default_request(self._host, {PRINT_COMMAND: filename})
            return self._get_print_stats(filename, data)
        except RuntimeError as exc:
            _LOGGER.exception(str(exc))

    def resume_print(self) -> Dict[str, Any]:
        """Resumes a print job."""
        return default_request(self._host, RESUME_COMMAND)[ERROR_CODE] == 200

    def pause_print(self) -> Dict[str, Any]:
        """Pauses a print job."""
        return default_request(self._host, PAUSE_COMMAND)[ERROR_CODE] == 200

    def stop_print(self) -> Dict[str, Any]:
        """Stops a print job."""
        return default_request(self._host, CANCEL_COMMAND)[ERROR_CODE] == 200


def default_request(
    host, command="", scheme="http", port=COMMAND_PORT, path=COMMAND_PATH
) -> Dict[str, Any]:
    """Performs a default request to the Dremel 3D Printer APIs."""
    url = URL.build(scheme=scheme, host=host, port=port, path=path)

    requests.packages.urllib3.disable_warnings(category=InsecureRequestWarning)
    response = requests.post(url, data=command, timeout=REQUEST_TIMEOUT, verify=False)

    response_json = json.loads(response.content.decode("utf-8"))
    if response.status_code != 200:
        raise RuntimeError(
            {
                f"HTTP {response.status_code}",
                {
                    "content-type": response.headers.get("Content-Type"),
                    "message": response_json["message"],
                    "status-code": response.status_code,
                },
            }
        )
    return response_json