/*
 * Copyright (C) 2023 Huawei Device Co., Ltd.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
use std::io::Write;
use std::path::Path;
use std::sync::{Arc, Mutex};
use std::time::SystemTime;

use hdc::config;

// #[derive(Default)]

pub struct LoggerMeta {
    stdout_require: bool,
    run_in_server: bool, // scrolling dump only by server
    current_size: usize,
    log_file: std::path::PathBuf,
    log_level: log::LevelFilter,
}

impl Default for LoggerMeta {
    fn default() -> Self {
        Self {
            stdout_require: Default::default(),
            run_in_server: Default::default(),
            current_size: Default::default(),
            log_file: Default::default(),
            log_level: log::LevelFilter::Debug,
        }
    }
}

type LoggerMeta_ = Arc<Mutex<LoggerMeta>>;

struct HostLoggerMeta {}
impl HostLoggerMeta {
    fn get_instance() -> LoggerMeta_ {
        static mut LOGGER_META: Option<LoggerMeta_> = None;
        unsafe {
            LOGGER_META
                .get_or_insert_with(|| Arc::new(Mutex::new(LoggerMeta::default())))
                .clone()
        }
    }

    fn init(run_in_server: bool, spawned_server: bool, log_level: log::LevelFilter) {
        let instance = Self::get_instance();
        let Ok(mut meta) = instance.lock() else {
            println!("init lock error");
            return;
        };
        meta.log_level = log_level;
        if run_in_server && !spawned_server {
            meta.stdout_require = true;
        }
        meta.run_in_server = run_in_server;
        meta.log_file = Path::new(&std::env::temp_dir())
            .join(config::LOG_FILE_NAME.to_string() + config::LOG_TAIL_NAME);
        if run_in_server {
            Self::dump_log_file(config::LOG_BAK_NAME, meta.log_level);
            if let Err(err) = std::fs::File::create(&meta.log_file) {
                println!("File::create failed, {}, {err}", meta.log_file.display());
            }
        }
    }

    fn write_log(content: String) {
        let instance = Self::get_instance();
        let mut meta = instance.lock().unwrap();
        if meta.run_in_server && meta.current_size > config::LOG_FILE_SIZE {
            meta.current_size = 0;
            Self::dump_log_file(config::LOG_CACHE_NAME, meta.log_level);
            std::fs::File::create(&meta.log_file).unwrap();
        }
        meta.current_size += content.len();
        if let Ok(mut f) = std::fs::File::options().append(true).open(&meta.log_file) {
            writeln!(&mut f, "{}", content).unwrap();
        }
        if meta.stdout_require {
            println!("{}", content);
        }
    }

    fn dump_log_file(file_type: &str, log_level: log::LevelFilter) {
        let file_path = Path::new(&std::env::temp_dir())
            .join(config::LOG_FILE_NAME.to_string() + config::LOG_TAIL_NAME);
        let ts = humantime::format_rfc3339_millis(SystemTime::now())
            .to_string()
            .replace(':', "");
        let file_cache_path = if log_level == log::LevelFilter::Trace {
            Path::new(&std::env::temp_dir())
                .join(file_type.to_string() + &ts[..19] + config::LOG_TAIL_NAME)
        } else {
            Path::new(&std::env::temp_dir()).join(file_type.to_string() + config::LOG_TAIL_NAME)
        };
        if file_path.exists() {
            if let Err(err) = std::fs::rename(&file_path, file_cache_path) {
                hdc::error!("rename failed, {err}");
            }
        }
    }

    fn get_running_mode() -> String {
        let instance = Self::get_instance();
        let Ok(meta) = instance.lock() else {
            return "".to_string();
        };
        if meta.run_in_server {
            "server".to_string()
        } else {
            "client".to_string()
        }
    }
}

struct SimpleHostLogger;
impl log::Log for SimpleHostLogger {
    fn enabled(&self, metadata: &log::Metadata) -> bool {
        metadata.level() <= log::max_level()
    }
    fn log(&self, record: &log::Record) {
        if self.enabled(record.metadata()) {
            let ts = humantime::format_rfc3339_millis(SystemTime::now()).to_string();
            let level = &record.level().to_string()[..1];
            let Some(file) = record.file() else {
                println!("Get record file failed");
                return;
            };
            // cargo编译下的文件目录可能存在\\的目录，需要通过编译宏隔离
            #[cfg(target_os = "windows")]
            let file = file.replace('\\', "/");
            let running_mode = HostLoggerMeta::get_running_mode();
            let content = format!(
                "{} {} {} [{}] {}:{} - {}",
                &ts[..10],
                &ts[11..23],
                level,
                running_mode,
                file.split_once('/').unwrap_or(("", "")).1,
                record.line().unwrap_or_default(),
                record.args()
            );
            HostLoggerMeta::write_log(content);
        }
    }
    fn flush(&self) {}
}

static LOGGER: SimpleHostLogger = SimpleHostLogger;

pub fn logger_init(log_level: log::LevelFilter, run_in_server: bool, spawned_server: bool) {
    HostLoggerMeta::init(run_in_server, spawned_server, log_level);
    if let Err(err) = log::set_logger(&LOGGER) {
        println!("log::set_logger failed, {err}");
        return;
    }
    log::set_max_level(log_level);
}