use std::path::PathBuf;

use anyhow::Context;

use clap::Parser;

use clap_verbosity_flag::Verbosity;

use systemd_journal_logger::JournalLog;

use crate::server::{

    config::{ServerConfigArgs, read_config_from_path_with_arg_overrides},

    server_loop::{

        listen_for_incoming_connections_with_socket_path,

        listen_for_incoming_connections_with_systemd_socket,

    },

};

#[derive(Parser, Debug, Clone)]

pub struct ServerArgs {

    #[command(subcommand)]

    subcmd: ServerCommand,

    #[command(flatten)]

    config_overrides: ServerConfigArgs,

    #[arg(long)]

    systemd: bool,

}

#[derive(Parser, Debug, Clone)]

pub enum ServerCommand {

    #[command()]

    Listen,

    #[command()]

    SocketActivate,

}

const LOG_LEVEL_WARNING: &str = r#"

===================================================

== WARNING: LOG LEVEL IS SET TO 'TRACE'!         ==

== THIS WILL CAUSE THE SERVER TO LOG SQL QUERIES ==

== THAT MAY CONTAIN SENSITIVE INFORMATION LIKE   ==

== PASSWORDS AND AUTHENTICATION TOKENS.          ==

== THIS IS INTENDED FOR DEBUGGING PURPOSES ONLY  ==

== AND SHOULD *NEVER* BE USED IN PRODUCTION.     ==

===================================================

"#;

    let mut auto_detected_systemd_mode = false;

    let systemd_mode = args.systemd || {

        if let Ok(true) = sd_notify::booted() {

            auto_detected_systemd_mode = true;

            true

        } else {

            false

        }

    };

    if systemd_mode {

        JournalLog::new()

            .context("Failed to initialize journald logging")?

            .install()

            .context("Failed to install journald logger")?;

        log::set_max_level(verbosity.log_level_filter());

        if verbosity.log_level_filter() >= log::LevelFilter::Trace {

            log::warn!("{}", LOG_LEVEL_WARNING.trim());

        }

        if auto_detected_systemd_mode {

            log::info!("Running in systemd mode, auto-detected");

        } else {

            log::info!("Running in systemd mode");

        }

        start_watchdog_thread_if_enabled();

    } else {

        env_logger::Builder::new()

            .filter_level(verbosity.log_level_filter())

            .init();

        log::info!("Running in standalone mode");

    }

    let config = read_config_from_path_with_arg_overrides(config_path, args.config_overrides)?;

    match args.subcmd {

        ServerCommand::Listen => {

            listen_for_incoming_connections_with_socket_path(socket_path, config).await

        }

        ServerCommand::SocketActivate => {

            if !args.systemd {

                anyhow::bail!(concat!(

                    "The `--systemd` flag must be used with the `socket-activate` command.\n",

                    "This command currently only supports socket activation under systemd."

                ));

            }

            listen_for_incoming_connections_with_systemd_socket(config).await

        }

    }

}

                "Starting systemd watchdog thread with {} millisecond interval",

            );

            loop {

                } else {

                }

            }

        });

    } else {

    }