// Copyright (c) Microsoft Corporation.
// Licensed under the MIT License.

#![allow(unknown_lints, clippy::empty_docs)]
#![allow(non_snake_case)]

use diagnostic::interpret_errors_into_qsharp_errors;
use katas::check_solution;
use language_service::IOperationInfo;
use num_bigint::BigUint;
use num_complex::Complex64;
use project_system::{ProgramConfig, into_openqasm_arg, into_qsc_args, is_openqasm_program};
use qsc::{
    LanguageFeatures, PackageStore, PackageType, PauliNoise, SourceContents, SourceMap, SourceName,
    SparseSim, TargetCapabilityFlags,
    compile::{self, Dependencies, package_store_with_stdlib},
    format_state_id, get_matrix_latex, get_state_latex,
    hir::PackageId,
    interpret::{
        self, CircuitEntryPoint,
        output::{self, Receiver},
    },
    openqasm::{CompileRawQasmResult, io::InMemorySourceResolver},
    target::Profile,
};
use resource_estimator::{self as re, estimate_entry};
use serde::{Deserialize, Serialize};
use serde_json::json;
use std::{fmt::Write, sync::Arc};
use wasm_bindgen::prelude::*;

use crate::diagnostic::interpret_errors_to_run_result;

mod debug_service;
mod diagnostic;
mod language_service;
mod line_column;
mod logging;
mod project_system;
mod serializable_type;
mod test_discovery;

#[cfg(test)]
mod tests;

thread_local! {
    static STORE_CORE_STD: (PackageStore, PackageId) = {
        let (std_id, store) = package_store_with_stdlib(Profile::Unrestricted.into());
        (store, std_id)
    };
}

#[wasm_bindgen]
#[must_use]
pub fn git_hash() -> String {
    let git_hash = env!("QSHARP_GIT_HASH");
    git_hash.into()
}

#[wasm_bindgen]
pub fn get_qir(program: ProgramConfig) -> Result<String, String> {
    if is_openqasm_program(&program) {
        let (sources, capabilities) = into_openqasm_arg(program);
        get_qir_from_openqasm(&sources, capabilities)
    } else {
        let (source_map, capabilities, language_features, store, deps) =
            into_qsc_args(program, None, false).map_err(compile_errors_into_qsharp_errors_json)?;

        get_qir_from_qsharp(
            source_map,
            language_features,
            capabilities,
            store,
            &deps[..],
        )
    }
}

pub(crate) fn get_qir_from_qsharp(
    sources: SourceMap,
    language_features: LanguageFeatures,
    capabilities: TargetCapabilityFlags,
    store: PackageStore,
    deps: &qsc::compile::Dependencies,
) -> Result<String, String> {
    qsc::codegen::qir::get_qir(sources, language_features, capabilities, store, deps)
        .map_err(interpret_errors_into_qsharp_errors_json)
}

pub(crate) fn get_qir_from_openqasm(
    sources: &[(Arc<str>, Arc<str>)],
    capabilities: TargetCapabilityFlags,
) -> Result<String, String> {
    let (entry_expr, mut interpreter) = get_interpreter_from_openqasm(sources, capabilities)
        .map_err(interpret_errors_into_qsharp_errors_json)?;
    interpreter
        .qirgen(&entry_expr)
        .map_err(interpret_errors_into_qsharp_errors_json)
}

#[wasm_bindgen]
pub fn get_estimates(program: ProgramConfig, expr: &str, params: &str) -> Result<String, String> {
    if is_openqasm_program(&program) {
        let (sources, capabilities) = into_openqasm_arg(program);
        get_estimates_from_openqasm(&sources, capabilities, params)
    } else {
        let (source_map, capabilities, language_features, store, deps) =
            into_qsc_args(program, Some(expr.into()), false).map_err(|mut e| {
                // Wrap in `interpret::Error` to match the error type from `Interpreter::new` below
                qsc::interpret::Error::from(e.pop().expect("expected at least one error"))
                    .to_string()
            })?;

        let mut interpreter = interpret::Interpreter::new(
            source_map,
            PackageType::Exe,
            capabilities,
            language_features,
            store,
            &deps[..],
        )
        .map_err(|e| e[0].to_string())?;

        estimate_entry(&mut interpreter, params).map_err(|e| match &e[0] {
            re::Error::Interpreter(interpret::Error::Eval(e)) => e.to_string(),
            re::Error::Interpreter(_) => unreachable!("interpreter errors should be eval errors"),
            re::Error::Estimation(e) => e.to_string(),
        })
    }
}

pub(crate) fn get_estimates_from_openqasm(
    sources: &[(Arc<str>, Arc<str>)],
    capabilities: TargetCapabilityFlags,
    params: &str,
) -> Result<String, String> {
    let (_, mut interpreter) = get_interpreter_from_openqasm(sources, capabilities)
        .map_err(interpret_errors_into_qsharp_errors_json)?;
    estimate_entry(&mut interpreter, params).map_err(|e| match &e[0] {
        re::Error::Interpreter(interpret::Error::Eval(e)) => e.to_string(),
        re::Error::Interpreter(_) => {
            unreachable!("interpreter errors should be eval errors")
        }
        re::Error::Estimation(e) => e.to_string(),
    })
}

serializable_type! {
    CircuitConfig,
    {
        generation_method: String,
        max_operations: usize,
        source_locations: bool,
        group_by_scope: bool,
    },
    r#"export interface ICircuitConfig {
        generationMethod: "simulate" | "classicalEval" | "static";
        maxOperations: number;
        sourceLocations: boolean;
        groupByScope: boolean;
    }"#,
    ICircuitConfig
}

#[wasm_bindgen]
pub fn get_circuit(
    program: ProgramConfig,
    operation: Option<IOperationInfo>,
    config: ICircuitConfig,
) -> Result<JsValue, String> {
    let config: CircuitConfig = config.into();
    let method = match config.generation_method.as_str() {
        "simulate" => qsc::interpret::CircuitGenerationMethod::Simulate,
        "classicalEval" => qsc::interpret::CircuitGenerationMethod::ClassicalEval,
        "static" => qsc::interpret::CircuitGenerationMethod::Static,
        _ => {
            panic!(
                "Invalid generation method option: {}",
                config.generation_method
            )
        }
    };
    let tracer_config = qsc::circuit::TracerConfig {
        source_locations: config.source_locations,
        max_operations: config.max_operations,
        group_by_scope: config.group_by_scope,
        prune_classical_qubits: false,
    };

    if is_openqasm_program(&program) {
        let (sources, capabilities) = into_openqasm_arg(program);
        let (_, mut interpreter) = get_interpreter_from_openqasm(&sources, capabilities)
            .map_err(interpret_errors_into_qsharp_errors_json)?;

        let circuit = interpreter
            .circuit(CircuitEntryPoint::EntryPoint, method, tracer_config)
            .map_err(interpret_errors_into_qsharp_errors_json)?;
        serde_wasm_bindgen::to_value(&circuit).map_err(|e| e.to_string())
    } else {
        let (source_map, capabilities, language_features, store, deps) =
            into_qsc_args(program, None, false).map_err(compile_errors_into_qsharp_errors_json)?;

        let (package_type, entry_point) = match operation {
            Some(p) => {
                let o: language_service::OperationInfo = p.into();
                // lib package - no need to enforce an entry point since the operation is provided.
                (PackageType::Lib, CircuitEntryPoint::Operation(o.operation))
            }
            None => {
                // exe package - the @EntryPoint attribute will be used.
                (PackageType::Exe, CircuitEntryPoint::EntryPoint)
            }
        };

        let mut interpreter = interpret::Interpreter::new(
            source_map,
            package_type,
            capabilities,
            LanguageFeatures::from_iter(language_features),
            store,
            &deps[..],
        )
        .map_err(interpret_errors_into_qsharp_errors_json)?;

        let circuit = interpreter
            .circuit(entry_point, method, tracer_config)
            .map_err(interpret_errors_into_qsharp_errors_json)?;

        serde_wasm_bindgen::to_value(&circuit).map_err(|e| e.to_string())
    }
}

#[allow(clippy::needless_pass_by_value)]
fn interpret_errors_into_qsharp_errors_json(errs: Vec<qsc::interpret::Error>) -> String {
    serde_json::to_string(&interpret_errors_into_qsharp_errors(&errs))
        .expect("serializing errors to json should succeed")
}

fn compile_errors_into_qsharp_errors_json(errs: Vec<qsc::compile::Error>) -> String {
    interpret_errors_into_qsharp_errors_json(errs.into_iter().map(Into::into).collect())
}

#[wasm_bindgen]
#[must_use]
pub fn get_library_source_content(name: &str) -> Option<String> {
    STORE_CORE_STD.with(|(store, std)| {
        for id in [PackageId::CORE, *std] {
            if let Some(source) = store
                .get(id)
                .expect("package should be in store")
                .sources
                .find_by_name(name)
            {
                return Some(source.contents.to_string());
            }
        }

        None
    })
}

#[wasm_bindgen]
pub fn get_ast(code: &str, language_features: Vec<String>) -> Result<String, String> {
    let language_features = LanguageFeatures::from_iter(language_features);
    let sources = SourceMap::new([("code".into(), code.into())], None);
    let profile = Profile::Unrestricted;
    let package = STORE_CORE_STD.with(|(store, std)| {
        let (unit, _) = compile::compile(
            store,
            &[(*std, None)],
            sources,
            PackageType::Exe,
            profile.into(),
            language_features,
        );
        unit.ast.package
    });
    Ok(format!("{package}"))
}

#[wasm_bindgen]
pub fn get_hir(code: &str, language_features: Vec<String>) -> Result<String, String> {
    let language_features = LanguageFeatures::from_iter(language_features);
    let sources = SourceMap::new([("code".into(), code.into())], None);
    let profile = Profile::Unrestricted;
    let package = STORE_CORE_STD.with(|(store, std)| {
        let (unit, _) = compile::compile(
            store,
            &[(*std, None)],
            sources,
            PackageType::Exe,
            profile.into(),
            language_features,
        );
        unit.package
    });
    Ok(package.to_string())
}

#[wasm_bindgen]
pub fn get_rir(program: ProgramConfig) -> Result<Vec<String>, String> {
    let (source_map, capabilities, language_features, store, deps) =
        into_qsc_args(program, None, false).map_err(compile_errors_into_qsharp_errors_json)?;

    qsc::codegen::qir::get_rir(
        source_map,
        language_features,
        capabilities,
        store,
        &deps[..],
    )
    .map_err(interpret_errors_into_qsharp_errors_json)
}

#[wasm_bindgen]
#[must_use]
pub fn get_target_profile_from_entry_point(file_name: String, source: String) -> Option<String> {
    qsc_frontend::compile::get_target_profile_from_entry_point(&[(
        Arc::<str>::from(file_name),
        Arc::<str>::from(source),
    )])
    .map(|(p, _)| p.to_str().to_string().to_lowercase())
}

struct CallbackReceiver<F>
where
    F: FnMut(&str),
{
    event_cb: F,
}

impl<F> Receiver for CallbackReceiver<F>
where
    F: FnMut(&str),
{
    fn state(
        &mut self,
        state: Vec<(BigUint, Complex64)>,
        qubit_count: usize,
    ) -> Result<(), output::Error> {
        let mut dump_json = String::new();
        write!(dump_json, r#"{{"type": "DumpMachine","state": {{"#)
            .expect("writing to string should succeed");
        let (last, most) = state
            .split_last()
            .expect("state should always have at least one entry");
        for state in most {
            write!(
                dump_json,
                r#""{}": [{}, {}],"#,
                format_state_id(&state.0, qubit_count),
                state.1.re,
                state.1.im
            )
            .expect("writing to string should succeed");
        }
        write!(
            dump_json,
            r#""{}": [{}, {}]}}, "#,
            format_state_id(&last.0, qubit_count),
            last.1.re,
            last.1.im
        )
        .expect("writing to string should succeed");

        let json_latex = serde_json::to_string(&get_state_latex(&state, qubit_count))
            .expect("serialization should succeed");
        write!(
            dump_json,
            r#" "stateLatex": {json_latex}, "qubitCount": {qubit_count} }} "#
        )
        .expect("writing to string should succeed");
        (self.event_cb)(&dump_json);
        Ok(())
    }

    fn matrix(&mut self, matrix: Vec<Vec<Complex64>>) -> Result<(), output::Error> {
        let mut dump_json = String::new();

        // Write the type and open the array or rows.
        write!(dump_json, r#"{{"type": "Matrix","matrix": ["#)
            .expect("writing to string should succeed");

        // Map each row to a string representation of the row, and join them with commas.
        // The row is an array, and each element is a tuple formatted as "[re, im]".
        // e.g. {"type": "Matrix", "matrix": [
        //   [[1, 2], [3, 4], [5, 6]],
        //   [[7, 8], [9, 10], [11, 12]]
        // ]}
        let row_strings = matrix
            .iter()
            .map(|row| {
                let row_str = row
                    .iter()
                    .map(|elem| format!("[{}, {}]", elem.re, elem.im))
                    .collect::<Vec<_>>()
                    .join(", ");
                format!("[{row_str}]")
            })
            .collect::<Vec<_>>()
            .join(", ");

        // Close the array of rows and the JSON object.
        let latex_string = serde_json::to_string(&get_matrix_latex(&matrix))
            .expect("serialization should succeed");
        write!(
            dump_json,
            r#"{row_strings}], "matrixLatex": {latex_string} }}"#
        )
        .expect("writing to string should succeed");

        (self.event_cb)(&dump_json);
        Ok(())
    }

    fn message(&mut self, msg: &str) -> Result<(), output::Error> {
        let msg_json = json!({"type": "Message", "message": msg});
        (self.event_cb)(&msg_json.to_string());
        Ok(())
    }
}

fn run_interpreter<F>(
    interpreter: &mut interpret::Interpreter,
    out: &mut CallbackReceiver<F>,
    shots: u32,
    pauliNoise: &PauliNoise,
    qubitLoss: f64,
) where
    F: FnMut(&str),
{
    for _ in 0..shots {
        let result = {
            let mut sim = SparseSim::new_with_noise(pauliNoise);
            sim.set_loss(qubitLoss);
            interpreter.eval_entry_with_sim(&mut sim, out)
        };
        let mut success = true;
        let msg: serde_json::Value = match result {
            Ok(value) => serde_json::Value::String(value.to_string()),
            Err(errors) => {
                success = false;
                interpret_errors_to_run_result(&errors)
            }
        };

        let msg_string = json!({"type": "Result", "success": success, "result": msg}).to_string();
        (out.event_cb)(&msg_string);
    }
}

#[allow(clippy::too_many_arguments)]
fn run_internal_with_features<F>(
    sources: SourceMap,
    event_cb: F,
    shots: u32,
    language_features: LanguageFeatures,
    capabilities: TargetCapabilityFlags,
    store: PackageStore,
    dependencies: &Dependencies,
    pauliNoise: &PauliNoise,
    qubitLoss: f64,
) -> Result<(), Box<interpret::Error>>
where
    F: FnMut(&str),
{
    let mut out = CallbackReceiver { event_cb };
    let mut interpreter = match interpret::Interpreter::new(
        sources,
        PackageType::Exe,
        capabilities,
        language_features,
        store,
        dependencies,
    ) {
        Ok(interpreter) => interpreter,
        Err(err) => {
            let diag = interpret_errors_to_run_result(&err);
            let msg = json!(
                {"type": "Result", "success": false, "result": diag});
            (out.event_cb)(&msg.to_string());
            return Err(Box::new(err[0].clone()));
        }
    };

    run_interpreter(&mut interpreter, &mut out, shots, pauliNoise, qubitLoss);
    Ok(())
}

#[wasm_bindgen]
pub fn run(
    program: ProgramConfig,
    expr: &str,
    event_cb: &js_sys::Function,
    shots: u32,
) -> Result<bool, JsValue> {
    runWithNoise(
        program,
        expr,
        event_cb,
        shots,
        &JsValue::null(),
        &JsValue::null(),
    )
}

/// Emits a failed `Result` event via the callback before returning the error,
/// ensuring the caller always receives at least one `Result` event.
fn emit_run_error(event_cb: &impl Fn(&str), errors: Vec<interpret::Error>) -> JsValue {
    let diag = interpret_errors_to_run_result(&errors);
    let msg = json!({"type": "Result", "success": false, "result": diag}).to_string();
    event_cb(&msg);
    JsError::from(
        errors
            .into_iter()
            .next()
            .expect("expected at least one error"),
    )
    .into()
}

#[wasm_bindgen]
pub fn runWithNoise(
    program: ProgramConfig,
    expr: &str,
    event_cb: &js_sys::Function,
    shots: u32,
    pauliNoise: &JsValue,
    qubitLoss: &JsValue,
) -> Result<bool, JsValue> {
    if !event_cb.is_function() {
        return Err(JsError::new("Events callback function must be provided").into());
    }

    let event_cb = |msg: &str| {
        // See example at https://rustwasm.github.io/wasm-bindgen/reference/receiving-js-closures-in-rust.html
        let _ = event_cb.call1(&JsValue::null(), &JsValue::from(msg));
    };

    // See if the pauliNoise JsValue is an array
    let noise = if pauliNoise.is_array() {
        let pauliArray = js_sys::Array::from(pauliNoise);
        if pauliArray.length() != 3 {
            return Err(JsError::new("Pauli noise must have 3 probabilities").into());
        }
        PauliNoise::from_probabilities(
            pauliArray
                .get(0)
                .as_f64()
                .expect("Probabilities should be floats"),
            pauliArray
                .get(1)
                .as_f64()
                .expect("Probabilities should be floats"),
            pauliArray
                .get(2)
                .as_f64()
                .expect("Probabilities should be floats"),
        )
        .expect("Unable to create Pauli noise from the array provided")
    } else {
        PauliNoise::default()
    };

    // See if the qubitLoss JsValue is a number
    let qubitLoss = qubitLoss.as_f64().unwrap_or(0.0);

    if is_openqasm_program(&program) {
        let (sources, capabilities) = into_openqasm_arg(program);
        let (entry_expr, mut interpreter) =
            match get_interpreter_from_openqasm(&sources, capabilities) {
                Ok(result) => result,
                Err(errors) => return Err(emit_run_error(&event_cb, errors)),
            };
        if let Err(errors) = interpreter.set_entry_expr(&entry_expr) {
            return Err(emit_run_error(&event_cb, errors));
        }
        let mut out = CallbackReceiver { event_cb };
        run_interpreter(&mut interpreter, &mut out, shots, &noise, qubitLoss);
        Ok(true)
    } else {
        let (source_map, capabilities, language_features, store, deps) =
            match into_qsc_args(program, Some(expr.into()), false) {
                Ok(args) => args,
                Err(errors) => {
                    let errors = errors.into_iter().map(Into::into).collect();
                    return Err(emit_run_error(&event_cb, errors));
                }
            };

        match run_internal_with_features(
            source_map,
            event_cb,
            shots,
            language_features,
            capabilities,
            store,
            &deps[..],
            &noise,
            qubitLoss,
        ) {
            Ok(()) => Ok(true),
            Err(e) => Err(JsError::from(e).into()),
        }
    }
}

fn check_exercise_solution_internal(
    solution_code: &str,
    exercise_sources: Vec<(SourceName, SourceContents)>,
    event_cb: impl Fn(&str),
) -> bool {
    let source_name = "solution";
    let mut sources = vec![(source_name.into(), solution_code.into())];
    for exercise_source in exercise_sources {
        sources.push(exercise_source);
    }
    let mut out = CallbackReceiver { event_cb };
    let result = check_solution(sources, &mut out);
    let mut runtime_success = true;
    let (exercise_success, msg) = match result {
        Ok(value) => (value, serde_json::Value::String(value.to_string())),
        Err(errors) => {
            runtime_success = false;
            (false, interpret_errors_to_run_result(&errors))
        }
    };
    let msg_string =
        json!({"type": "Result", "success": runtime_success, "result": msg}).to_string();
    (out.event_cb)(&msg_string);
    exercise_success
}

#[wasm_bindgen]
#[must_use]
pub fn check_exercise_solution(
    solution_code: &str,
    exercise_sources_js: JsValue,
    event_cb: &js_sys::Function,
) -> bool {
    let exercise_soruces_strs: Vec<String> = serde_wasm_bindgen::from_value(exercise_sources_js)
        .expect("Deserializing code dependencies should succeed");
    let mut exercise_sources: Vec<(SourceName, SourceContents)> = vec![];
    for (index, code) in exercise_soruces_strs.into_iter().enumerate() {
        exercise_sources.push((index.to_string().into(), code.into()));
    }
    check_exercise_solution_internal(solution_code, exercise_sources, |msg: &str| {
        let _ = event_cb.call1(&JsValue::null(), &JsValue::from_str(msg));
    })
}

serializable_type! {
    DocFile,
    {
        filename: String,
        metadata: String,
        contents: String,
    },
    r#"export interface IDocFile {
        filename: string;
        metadata: string;
        contents: string;
    }"#,
    IDocFile
}

#[wasm_bindgen]
#[must_use]
pub fn generate_docs(additional_program: Option<ProgramConfig>) -> Vec<IDocFile> {
    let docs = if let Some(additional_program) = additional_program {
        let Ok((source_map, capabilities, language_features, package_store, dependencies)) =
            into_qsc_args(additional_program, None, true)
        else {
            // Can't generate docs if building dependencies failed
            return Vec::new();
        };

        qsc_doc_gen::generate_docs::generate_docs(
            Some((package_store, &dependencies, source_map)),
            Some(capabilities),
            Some(language_features),
        )
    } else {
        qsc_doc_gen::generate_docs::generate_docs(None, None, None)
    };

    let mut result: Vec<IDocFile> = vec![];

    for (name, metadata, contents) in docs {
        result.push(
            DocFile {
                filename: name.to_string(),
                metadata: metadata.to_string(),
                contents: contents.to_string(),
            }
            .into(),
        );
    }

    result
}

#[wasm_bindgen]
#[must_use]
pub fn get_library_summaries() -> String {
    qsc_doc_gen::generate_docs::generate_summaries()
}

fn get_debugger_from_openqasm(
    sources: &[(Arc<str>, Arc<str>)],
    capabilities: TargetCapabilityFlags,
) -> Result<(String, interpret::Interpreter), Vec<interpret::Error>> {
    get_configured_interpreter_from_openqasm(sources, capabilities, true)
}

fn get_interpreter_from_openqasm(
    sources: &[(Arc<str>, Arc<str>)],
    capabilities: TargetCapabilityFlags,
) -> Result<(String, interpret::Interpreter), Vec<interpret::Error>> {
    get_configured_interpreter_from_openqasm(sources, capabilities, false)
}

fn get_configured_interpreter_from_openqasm(
    sources: &[(Arc<str>, Arc<str>)],
    capabilities: TargetCapabilityFlags,
    dbg: bool,
) -> Result<(String, interpret::Interpreter), Vec<interpret::Error>> {
    let (file, source) = sources
        .iter()
        .next()
        .expect("There should be at least one source");
    let mut resolver = sources.iter().cloned().collect::<InMemorySourceResolver>();

    let CompileRawQasmResult(store, source_package_id, dependencies, sig, errors) =
        qsc::openqasm::parse_and_compile_raw_qasm(
            source.clone(),
            file.clone(),
            Some(&mut resolver),
            PackageType::Exe,
        );

    if !errors.is_empty() {
        return Err(errors
            .iter()
            .map(|e| qsc::interpret::Error::Compile(e.clone()))
            .collect());
    }

    let sig = sig.expect("msg: there should be a signature");
    let language_features = LanguageFeatures::default();
    let entry_expr = sig.create_entry_expr_from_params(String::new());
    let interpreter = interpret::Interpreter::with_package_store(
        dbg,
        store,
        source_package_id,
        capabilities,
        language_features,
        &dependencies,
    )?;

    Ok((entry_expr, interpreter))
}

#[wasm_bindgen(typescript_custom_section)]
const TARGET_PROFILE: &'static str = r#"
export type TargetProfile = "base" | "adaptive_ri" | "adaptive_rif" | "unrestricted";
"#;

#[wasm_bindgen(typescript_custom_section)]
const LANGUAGE_FEATURES: &'static str = r#"
export type LanguageFeatures = "v2-preview-syntax";
"#;

#[wasm_bindgen(typescript_custom_section)]
const PROJECT_TYPE: &'static str = r#"
export type ProjectType = "qsharp" | "openqasm";
"#;
