// SPDX-License-Identifier: GPL-3.0-or-later
// Copyright (c) 2022 Th3-S1lenc3

//! # XRandR-Parser
//!
//! XRandR-Parser is a interface for parsing the output of `xrandr --query` into
//! Rust Stuctures and filter through methods.
//!
//! ## Example
//!
//! Get the available resolutions for `HDMI-1` and the available refresh rates for `HDMI-1 @ 1920 x 1080`.
//!
//! ```edition2021
//! #[allow(non_snake_case)]
//!
//! use xrandr_parser::Parser;
//!
//! fn main() -> Result<(), String> {
//!     let mut XrandrParser = Parser::new();
//!
//!     XrandrParser.parse()?;
//!
//!     let connector = &XrandrParser.get_connector("HDMI-1")?;
//!
//!     let available_resolutions = &connector.available_resolutions_pretty()?;
//!     let available_refresh_rates = &connector.available_refresh_rates("1920x1080")?;
//!
//!     println!(
//!         "Available Resolutions for HDMI-1: {:#?}",
//!         available_resolutions
//!     );
//!     println!(
//!         "Available Refresh Rates for HDMI-1 @ 1920x1080: {:#?}",
//!         available_refresh_rates
//!     );
//!     Ok(())
//! }
//! ```

pub mod connector;

use std::process::Command;
use std::string::String;

use crate::connector::*;

#[derive(Default, Debug, serde::Serialize, serde::Deserialize)]
pub struct Parser {
    /// Every `Connector.name`
    pub outputs: Vec<String>,

    /// Every `Connector.name` where `Connector.status` is `true`
    pub connected_outputs: Vec<String>,

    /// Every Connector Struct
    pub connectors: Vec<Connector>,

    /// The Virtual Screen
    pub screen: Screen,
}

#[derive(Debug, Default, Clone, PartialEq, serde::Serialize, serde::Deserialize)]
pub struct Screen {
    pub minimum: Resolution,
    pub current: Resolution,
    pub maximum: Resolution,
}

impl Parser {
    /// Create a new instance of Parser
    pub fn new() -> Parser {
        Parser::default()
    }

    /// Populate properties of an instance of Parser from the output of `Parser::parse_query()`
    pub fn parse(&mut self) -> Result<(), String> {
        // Instatiate Properties
        self.outputs = Vec::new();
        self.connectors = Vec::new();
        self.connected_outputs = Vec::new();

        self.connectors = match Self::parse_query(self) {
            Ok(r) => r,
            Err(e) => return Err(e),
        };

        self.outputs = self.connectors.iter().map(|c| c.name.to_string()).collect();

        self.connected_outputs = self
            .connectors
            .iter()
            .filter(|c| c.status == "connected")
            .map(|c| c.name.to_string())
            .collect();

        Ok(())
    }

    #[cfg(not(feature = "test"))]
    fn exec_command() -> Result<String, String> {
        let mut cmd = Command::new("sh");
        cmd.arg("-c");

        cmd.arg("xrandr --query | tr -s ' '");

        let output = match cmd.output() {
            Ok(r) => r,
            Err(e) => return Err(e.to_string()),
        };

        if let Some(code) = output.status.code() {
            if code != 0 {
                let err_string = match String::from_utf8(output.stderr) {
                    Ok(r) => r,
                    Err(e) => return Err(e.to_string()),
                };

                return Err(err_string.to_string());
            }
        }

        match String::from_utf8(output.stdout) {
            Ok(r) => Ok(r),
            Err(e) => Err(e.to_string()),
        }
    }

    #[cfg(feature = "test")]
    fn exec_command() -> Result<String, String> {
        use std::env;

        let mut cmd = Command::new("sh");
        cmd.arg("-c");

        let mut example_dir: String = "".to_string();

        for (key, value) in env::vars() {
            if key == "EXAMPLE_DIR" {
                example_dir = value;
            }
        }

        cmd.env("EXAMPLE_DIR", example_dir);
        cmd.arg("cat $EXAMPLE_DIR/example_output");

        let output = match cmd.output() {
            Ok(r) => r,
            Err(e) => return Err(e.to_string()),
        };

        if let Some(code) = output.status.code() {
            if code != 0 {
                let err_string = match String::from_utf8(output.stderr) {
                    Ok(r) => r,
                    Err(e) => return Err(e.to_string()),
                };

                return Err(err_string.to_string());
            }
        }

        match String::from_utf8(output.stdout) {
            Ok(r) => Ok(r),
            Err(e) => return Err(e.to_string()),
        }
    }

    /// Parse the output of `xrandr --query` and return it
    fn parse_query(&mut self) -> Result<Vec<Connector>, String> {
        let out_string = Self::exec_command()?;

        let mut output: Vec<String> = out_string.split("\n").map(|s| s.to_string()).collect();
        output.retain(|d| d != "");

        let mut connectors: Vec<Connector> = Vec::new();
        let mut active: Connector = Connector::default();

        for o in &output {
            let mut o_vec: Vec<&str> = o.split(" ").collect();
            o_vec.retain(|s| s != &"");

            if o_vec.contains(&"Screen") {
                self.screen = Screen {
                    minimum: Resolution {
                        horizontal: o_vec[3].to_string(),
                        vertical: o_vec[5].replace(",", ""),
                    },
                    current: Resolution {
                        horizontal: o_vec[7].to_string(),
                        vertical: o_vec[9].replace(",", ""),
                    },
                    maximum: Resolution {
                        horizontal: o_vec[11].to_string(),
                        vertical: o_vec[13].replace(",", ""),
                    },
                };

                continue;
            }

            if o_vec.contains(&"connected") {
                if active != Connector::default() {
                    connectors.push(active);
                }
                active = Connector::new();

                active.set_name(o_vec[0].to_string());
                active.set_status(o_vec[1].to_string());

                let mut index = 2;

                if o_vec[index] == "primary" {
                    active.set_primary(true);
                } else {
                    active.set_primary(false);
                    index -= 1; // Shift 1 place left
                }

                index += 1;

                let respos: Vec<&str> = o_vec[index].split(&['x', '+'][..]).collect();

                active.set_current_resolution(Resolution {
                    horizontal: respos[0].to_string(),
                    vertical: respos[1].to_string(),
                });

                active.set_position(Position {
                    x: respos[2].to_string(),
                    y: respos[3].to_string(),
                });

                index += 1;

                if o_vec[index].contains("(") {
                    active.set_orientation("normal".to_string());
                } else {
                    active.set_orientation(o_vec[index].to_string());

                    index += 1;
                }

                let i7 = index + 7;

                let filtered: Vec<String> =
                    o_vec[index..=i7].iter().map(|s| s.to_string()).collect();

                let mut available_orientations: Vec<String> = Vec::new();

                for ao in filtered {
                    available_orientations.push(ao.replace(&['(', ')'][..], ""));
                }

                active.set_available_orientations(available_orientations);

                index += 8;

                active.set_physical_dimensions(Dimensions {
                    x: o_vec[index].replace("mm", ""),
                    y: o_vec[index + 2].replace("mm", ""),
                });

                if o_vec.contains(&"disconnected") {
                    connectors.push(active);
                    active = Connector::default();
                }

                continue;
            }

            if o_vec.contains(&"disconnected") {
                if active != Connector::default() {
                    connectors.push(active);
                }
                active = Connector::new();

                active.set_name(o_vec[0].to_string());
                active.set_status(o_vec[1].to_string());

                let filtered: Vec<String> = o_vec[2..].iter().map(|s| s.to_string()).collect();

                let mut available_orientations: Vec<String> = Vec::new();

                for ao in filtered {
                    available_orientations.push(ao.replace(&['(', ')'][..], ""));
                }

                active.set_available_orientations(available_orientations);

                continue;
            }

            if active != Connector::default() {
                let mut outputs: Vec<Output> = active.output_info();

                let mut rates: Vec<String> =
                    o_vec[1..].to_vec().iter().map(|s| s.to_string()).collect();

                rates.retain(|r| r != "");

                let resolution: Vec<&str> = o_vec[0].split('x').collect();

                for r in &rates {
                    if r.contains('+') {
                        active.set_prefered_resolution(Resolution {
                            horizontal: resolution[0].to_string(),
                            vertical: resolution[1].to_string(),
                        });
                        active.set_prefered_refresh_rate(r.replace(&['+', '*'][..], ""));
                    }

                    if r.contains('*') {
                        active.set_current_refresh_rate(r.replace(&['+', '*'][..], ""));
                    }
                }

                rates = rates
                    .iter()
                    .map(|r| r.replace(&['+', '*'][..], ""))
                    .collect();

                outputs.push(Output {
                    resolution: Resolution {
                        horizontal: resolution[0].to_string(),
                        vertical: resolution[1].to_string(),
                    },
                    rates,
                });

                active.set_output_info(outputs.to_vec());
            }
        }

        if active != Connector::default() {
            connectors.push(active);
        }

        Ok(connectors)
    }

    /// Getter function for `Parser.outputs`
    ///
    /// ## Example
    ///
    /// ```edition2021
    ///  #[allow(non_snake_case)]
    ///
    ///  use xrandr_parser::Parser;
    ///
    ///  fn main() -> Result<(), String> {
    ///      let mut XrandrParser = Parser::new();
    ///
    ///      XrandrParser.parse()?;
    ///
    ///      let outputs = &XrandrParser.outputs();
    ///
    /// #    assert_eq!(outputs, &vec![
    /// #        "HDMI-1".to_string(),
    /// #        "HDMI-2".to_string(),
    /// #    ]);
    ///      Ok(())
    ///  }
    /// ```
    pub fn outputs(&self) -> Vec<String> {
        self.outputs.to_vec()
    }

    /// Getter function for `Parser.connected_outputs`
    ///
    /// ## Example
    ///
    /// ```edition2021
    /// #[allow(non_snake_case)]
    ///
    /// use xrandr_parser::Parser;
    ///
    /// fn main() -> Result<(), String> {
    ///     let mut XrandrParser = Parser::new();
    ///
    ///     XrandrParser.parse()?;
    ///
    ///     let connected_outputs = &XrandrParser.connected_outputs();
    ///
    ///     println!("Connected Outputs: {:?}", connected_outputs);
    ///
    /// #    assert_eq!(connected_outputs, &vec![
    /// #        "HDMI-1".to_string(),
    /// #    ]);
    ///     Ok(())
    /// }
    /// ```
    pub fn connected_outputs(&self) -> Vec<String> {
        self.connected_outputs.to_vec()
    }

    /// Getter function for `Parser.connectors`
    ///
    /// ## Example
    ///
    /// ```edition2021
    ///  #[allow(non_snake_case)]
    ///
    ///  use xrandr_parser::Parser;
    /// # use xrandr_parser::connector::*;
    ///
    ///  fn main() -> Result<(), String> {
    ///      let mut XrandrParser = Parser::new();
    ///
    ///      XrandrParser.parse()?;
    ///
    ///      let connectors = &XrandrParser.connectors();
    ///
    ///      println!("Connectors: {:#?}", connectors);
    ///
    /// #     assert_eq!(connectors, &vec![
    /// #         Connector {
    /// #            name: "HDMI-1".to_string(),
    /// #            status: "connected".to_string(),
    /// #            primary: true,
    /// #            current_resolution: Resolution {
    /// #                horizontal: "1920".to_string(),
    /// #                vertical: "1080".to_string(),
    /// #            },
    /// #            current_refresh_rate: "60.00".to_string(),
    /// #            prefered_resolution: Resolution {
    /// #                horizontal: "1920".to_string(),
    /// #                vertical: "1080".to_string(),
    /// #            },
    /// #            prefered_refresh_rate: "60.00".to_string(),
    /// #            position: Position {
    /// #                x: "0".to_string(),
    /// #                y: "0".to_string(),
    /// #            },
    /// #            orientation: "normal".to_string(),
    /// #            available_orientations: [
    /// #                "normal".to_string(),
    /// #                "left".to_string(),
    /// #                "inverted".to_string(),
    /// #                "right".to_string(),
    /// #                "x".to_string(),
    /// #                "axis".to_string(),
    /// #                "y".to_string(),
    /// #                "axis".to_string(),
    /// #            ].to_vec(),
    /// #            physical_dimensions: Dimensions {
    /// #                x: "1210".to_string(),
    /// #                y: "680".to_string(),
    /// #            },
    /// #            output_info: [
    /// #                Output {
    /// #                    resolution: Resolution {
    /// #                        horizontal: "1920".to_string(),
    /// #                        vertical: "1080".to_string(),
    /// #                    },
    /// #                    rates: [
    /// #                        "60.00".to_string(),
    /// #                    ].to_vec(),
    /// #                },
    /// #            ].to_vec(),
    /// #        },
    /// #         Connector {
    /// #            name: "HDMI-2".to_string(),
    /// #            status: "disconnected".to_string(),
    /// #            primary: false,
    /// #            current_resolution: Resolution {
    /// #                horizontal: "".to_string(),
    /// #                vertical: "".to_string(),
    /// #            },
    /// #            current_refresh_rate: "".to_string(),
    /// #            prefered_resolution: Resolution {
    /// #                horizontal: "".to_string(),
    /// #                vertical: "".to_string(),
    /// #            },
    /// #            prefered_refresh_rate: "".to_string(),
    /// #            position: Position {
    /// #                x: "".to_string(),
    /// #                y: "".to_string(),
    /// #            },
    /// #            orientation: "".to_string(),
    /// #            available_orientations: [
    /// #                "normal".to_string(),
    /// #                "left".to_string(),
    /// #                "inverted".to_string(),
    /// #                "right".to_string(),
    /// #                "x".to_string(),
    /// #                "axis".to_string(),
    /// #                "y".to_string(),
    /// #                "axis".to_string(),
    /// #            ].to_vec(),
    /// #            physical_dimensions: Dimensions {
    /// #                x: "".to_string(),
    /// #                y: "".to_string(),
    /// #            },
    /// #            output_info: [].to_vec(),
    /// #        },
    /// #     ]);
    ///      Ok(())
    /// }
    /// ```
    pub fn connectors(&self) -> Vec<Connector> {
        self.connectors.to_vec()
    }

    /// Getter function for `Parser.screen`
    ///
    /// ## Example
    ///
    /// ```edition2021
    /// #[allow(non_snake_case)]
    ///
    /// use xrandr_parser::Parser;
    /// # use xrandr_parser::connector::*;
    /// # use xrandr_parser::Screen;
    ///
    /// fn main() -> Result<(), String> {
    ///     let mut XrandrParser = Parser::new();
    ///
    ///     XrandrParser.parse()?;
    ///
    ///     let screen = &XrandrParser.screen();
    ///
    ///     println!("Screen Information: {:#?}", screen);
    ///
    /// #   assert_eq!(screen, &Screen {
    /// #       minimum: Resolution {
    /// #           horizontal: "320".to_string(),
    /// #           vertical: "200".to_string(),
    /// #       },
    /// #       current: Resolution {
    /// #           horizontal: "1920".to_string(),
    /// #           vertical: "1080".to_string(),
    /// #       },
    /// #       maximum: Resolution {
    /// #           horizontal: "16384".to_string(),
    /// #           vertical: "16384".to_string(),
    /// #       },
    /// #   });
    ///     Ok(())
    /// }
    /// ```
    pub fn screen(&self) -> Screen {
        self.screen.clone()
    }

    /// Get the connector struct for a with the name provided. Returns `"Not found"` if the connector
    /// is not found in `self.connectors`.
    ///
    /// ## Example
    ///
    /// ```edition2021
    /// #[allow(non_snake_case)]
    ///
    /// use xrandr_parser::Parser;
    /// # use xrandr_parser::connector::*;
    ///
    /// fn main() -> Result<(), String> {
    ///     let mut XrandrParser = Parser::new();
    ///
    ///     XrandrParser.parse()?;
    ///
    ///     let connector = &XrandrParser.get_connector("HDMI-1")?;
    ///
    ///     println!("Connector - HDMI-1: {:#?}", connector);
    ///
    /// # assert_eq!(connector, &Connector {
    /// #     name: "HDMI-1".to_string(),
    /// #     status: "connected".to_string(),
    /// #     primary: true,
    /// #     current_resolution: Resolution {
    /// #         horizontal: "1920".to_string(),
    /// #         vertical: "1080".to_string(),
    /// #     },
    /// #     current_refresh_rate: "60.00".to_string(),
    /// #     prefered_resolution: Resolution {
    /// #         horizontal: "1920".to_string(),
    /// #         vertical: "1080".to_string(),
    /// #     },
    /// #     prefered_refresh_rate: "60.00".to_string(),
    /// #     position: Position {
    /// #         x: "0".to_string(),
    /// #         y: "0".to_string(),
    /// #     },
    /// #     orientation: "normal".to_string(),
    /// #     available_orientations: [
    /// #         "normal".to_string(),
    /// #         "left".to_string(),
    /// #         "inverted".to_string(),
    /// #         "right".to_string(),
    /// #         "x".to_string(),
    /// #         "axis".to_string(),
    /// #         "y".to_string(),
    /// #         "axis".to_string(),
    /// #     ]
    /// #     .to_vec(),
    /// #     physical_dimensions: Dimensions {
    /// #         x: "1210".to_string(),
    /// #         y: "680".to_string(),
    /// #     },
    /// #     output_info: [Output {
    /// #         resolution: Resolution {
    /// #             horizontal: "1920".to_string(),
    /// #             vertical: "1080".to_string(),
    /// #         },
    /// #         rates: ["60.00".to_string()].to_vec(),
    /// #     }]
    /// #     .to_vec(),
    /// # });
    ///     Ok(())
    /// }
    /// ```
    pub fn get_connector(&self, connector: &str) -> Result<Connector, String> {
        for c in &self.connectors {
            if c.name == connector {
                return Ok(c.clone());
            }
        }

        Err("Not Found".to_string())
    }
}