//! ref: composer/src/Composer/Command/RunScriptCommand.php

use anyhow::Result;
use indexmap::IndexMap;
use shirabe_external_packages::symfony::console::command::command::Command;
use shirabe_external_packages::symfony::console::input::InputInterface;
use shirabe_external_packages::symfony::console::output::OutputInterface;
use shirabe_php_shim::PhpMixed;
use shirabe_php_shim::{InvalidArgumentException, RuntimeException};
use std::cell::RefCell;
use std::rc::Rc;

use crate::command::BaseCommand;
use crate::command::BaseCommandData;
use crate::command::base_command::base_command_initialize;
use crate::console::input::InputArgument;
use crate::console::input::InputOption;
use crate::io::IOInterfaceImmutable;
use crate::script::Event as ScriptEvent;
use crate::script::ScriptEvents;
use crate::util::Platform;
use crate::util::ProcessExecutor;

#[derive(Debug)]
pub struct RunScriptCommand {
    base_command_data: BaseCommandData,

    script_events: Vec<&'static str>,
}

impl Default for RunScriptCommand {
    fn default() -> Self {
        Self::new()
    }
}

impl RunScriptCommand {
    pub fn new() -> Self {
        let command = RunScriptCommand {
            base_command_data: BaseCommandData::new(None),
            script_events: vec![
                ScriptEvents::PRE_INSTALL_CMD,
                ScriptEvents::POST_INSTALL_CMD,
                ScriptEvents::PRE_UPDATE_CMD,
                ScriptEvents::POST_UPDATE_CMD,
                ScriptEvents::PRE_STATUS_CMD,
                ScriptEvents::POST_STATUS_CMD,
                ScriptEvents::POST_ROOT_PACKAGE_INSTALL,
                ScriptEvents::POST_CREATE_PROJECT_CMD,
                ScriptEvents::PRE_ARCHIVE_CMD,
                ScriptEvents::POST_ARCHIVE_CMD,
                ScriptEvents::PRE_AUTOLOAD_DUMP,
                ScriptEvents::POST_AUTOLOAD_DUMP,
            ],
        };
        command
            .configure()
            .expect("RunScriptCommand::configure uses static, valid metadata");
        command
    }

    fn list_scripts(&self, output: Rc<RefCell<dyn OutputInterface>>) -> Result<i64> {
        let scripts = self.get_scripts()?;
        if scripts.is_empty() {
            return Ok(0);
        }

        let io = self.get_io();
        io.write_error("<info>scripts:</info>");
        let table: Vec<PhpMixed> = scripts
            .iter()
            .map(|(name, desc)| {
                PhpMixed::List(vec![
                    PhpMixed::String(format!("  {}", name)),
                    PhpMixed::String(desc.clone()),
                ])
            })
            .collect();

        self.render_table(table, output);

        Ok(0)
    }

    fn get_scripts(&self) -> Result<Vec<(String, String)>> {
        let composer = self.require_composer(None, None)?;
        let scripts = crate::composer::composer_full(&composer)
            .get_package()
            .get_scripts();
        drop(composer);
        if scripts.is_empty() {
            return Ok(vec![]);
        }

        let mut result: Vec<(String, String)> = vec![];
        for (name, _script) in scripts {
            // PHP: $cmd = $this->getApplication()->find($name); $description = $cmd->getDescription();
            // TODO(phase-c): Application::find returns PhpMixed (the Symfony command registry is a
            // todo!() stub) and get_application() is itself deferred, so the resolved command's
            // getDescription() cannot be read; the description stays empty until the typed command
            // registry is modelled.
            // get_application() is deferred (returns the Symfony `dyn Application` back-reference,
            // not the shirabe Application with find()); the description stays empty until the
            // shared Application handle and typed command registry are modelled.
            let description = String::new();
            result.push((name, description));
        }

        Ok(result)
    }
}

impl Command for RunScriptCommand {
    fn configure(&self) -> anyhow::Result<()> {
        self.set_name("run-script")?;
        self.set_aliases(vec!["run".to_string()])?;
        self.set_description("Runs the scripts defined in composer.json");
        self.set_definition(&[
            // TODO(cli-completion): script-name completion was provided via a closure suggesting runtime script names
            InputArgument::new(
                "script",
                Some(InputArgument::OPTIONAL),
                "Script name to run.",
                None,
            )
            .unwrap()
            .into(),
            InputArgument::new(
                "args",
                Some(InputArgument::IS_ARRAY | InputArgument::OPTIONAL),
                "",
                None,
            )
            .unwrap()
            .into(),
            InputOption::new(
                "timeout",
                None,
                Some(InputOption::VALUE_REQUIRED),
                "Sets script timeout in seconds, or 0 for never.",
                None,
            )
            .unwrap()
            .into(),
            InputOption::new(
                "dev",
                None,
                Some(InputOption::VALUE_NONE),
                "Sets the dev mode.",
                None,
            )
            .unwrap()
            .into(),
            InputOption::new(
                "no-dev",
                None,
                Some(InputOption::VALUE_NONE),
                "Disables the dev mode.",
                None,
            )
            .unwrap()
            .into(),
            InputOption::new(
                "list",
                Some(PhpMixed::String("l".to_string())),
                Some(InputOption::VALUE_NONE),
                "List scripts.",
                None,
            )
            .unwrap()
            .into(),
        ]);
        self.set_help(
            "The <info>run-script</info> command runs scripts defined in composer.json:\n\n\
            <info>shirabe run-script post-update-cmd</info>\n\n\
            Read more at https://getcomposer.org/doc/03-cli.md#run-script-run",
        );
        Ok(())
    }

    fn interact(
        &self,
        input: Rc<RefCell<dyn InputInterface>>,
        _output: Rc<RefCell<dyn OutputInterface>>,
    ) {
        let _ = (|| -> anyhow::Result<()> {
            let scripts = self.get_scripts()?;
            if scripts.is_empty() {
                return Ok(());
            }

            if input.borrow().get_argument("script")?.as_string().is_some()
                || input
                    .borrow()
                    .get_option("list")?
                    .as_bool()
                    .unwrap_or(false)
            {
                return Ok(());
            }

            let mut options = indexmap::IndexMap::new();
            for script in &scripts {
                options.insert(script.0.clone(), script.1.clone());
            }

            let io = self.get_io();
            let script = io.select(
                "Script to run: ".to_string(),
                options.keys().cloned().collect(),
                PhpMixed::String(String::new()),
                PhpMixed::Int(1),
                "Invalid script name \"%s\"".to_string(),
                false,
            );

            input.borrow_mut().set_argument("script", script)?;

            Ok(())
        })();
    }

    fn execute(
        &self,
        input: Rc<RefCell<dyn InputInterface>>,
        output: Rc<RefCell<dyn OutputInterface>>,
    ) -> anyhow::Result<i64> {
        if input
            .borrow()
            .get_option("list")?
            .as_bool()
            .unwrap_or(false)
        {
            return self.list_scripts(output);
        }

        let script = match input.borrow().get_argument("script")?.as_string() {
            None => {
                return Err(RuntimeException {
                    message: "Missing required argument \"script\"".to_string(),
                    code: 0,
                }
                .into());
            }
            Some(s) => s.to_string(),
        };

        if !self.script_events.contains(&script.as_str()) {
            let const_name = script.to_uppercase().replace('-', "_");
            if ScriptEvents::is_defined(&const_name) {
                return Err(InvalidArgumentException {
                    message: format!("Script \"{}\" cannot be run with this command", script),
                    code: 0,
                }
                .into());
            }
        }

        let composer = self.require_composer(None, None)?;
        let dispatcher = crate::composer::composer_full(&composer)
            .get_event_dispatcher()
            .clone();
        let dev_mode = input.borrow().get_option("dev")?.as_bool().unwrap_or(false)
            || !input
                .borrow()
                .get_option("no-dev")?
                .as_bool()
                .unwrap_or(false);
        let io = self.get_io();
        let event = ScriptEvent::new(
            script.clone(),
            composer
                .as_full()
                .expect("require_composer returns a full Composer")
                .downgrade(),
            io,
            dev_mode,
            vec![],
            IndexMap::new(),
        );
        let has_listeners = dispatcher.borrow_mut().has_event_listeners(&event);
        if !has_listeners {
            return Err(InvalidArgumentException {
                message: format!("Script \"{}\" is not defined in this package", script),
                code: 0,
            }
            .into());
        }

        let args: Vec<String> = input
            .borrow()
            .get_argument("args")?
            .as_list()
            .map(|l| {
                l.iter()
                    .filter_map(|v| v.as_string().map(|s| s.to_string()))
                    .collect()
            })
            .unwrap_or_default();

        if let Some(timeout_val) = input.borrow().get_option("timeout")?.as_string() {
            let timeout_str = timeout_val.to_string();
            if !timeout_str.chars().all(|c| c.is_ascii_digit()) {
                return Err(RuntimeException {
                    message:
                        "Timeout value must be numeric and positive if defined, or 0 for forever"
                            .to_string(),
                    code: 0,
                }
                .into());
            }
            let timeout: i64 = timeout_str.parse().unwrap_or(0);
            ProcessExecutor::set_timeout(timeout);
        }

        Platform::put_env("COMPOSER_DEV_MODE", if dev_mode { "1" } else { "0" });

        dispatcher
            .borrow_mut()
            .dispatch_script(&script, dev_mode, args, IndexMap::new())
    }

    fn initialize(
        &self,
        input: Rc<RefCell<dyn InputInterface>>,
        output: Rc<RefCell<dyn OutputInterface>>,
    ) -> anyhow::Result<()> {
        base_command_initialize(self, input, output)
    }

    shirabe_external_packages::delegate_command_trait_impls_to_inner!(base_command_data);
}

impl BaseCommand for RunScriptCommand {
    fn command_data(
        &self,
    ) -> &shirabe_external_packages::symfony::console::command::command::CommandData {
        self.base_command_data.command_data()
    }

    crate::delegate_base_command_trait_impls_to_inner!(base_command_data);
}