//! Symbolic-name resolution for runtime probes (M4).
//!
//! Lets `--pc-probe` / `--branch-probe` / `--ctor-probe` accept names like
//! `xe::apu::AudioSystem::Setup` or `MyClass::*` instead of bare PC literals.
//! Resolution joins the M3-produced `classes` × `methods` × `functions` tables
//! and the M2 `demangled_names` table.
//!
//! Numeric tokens (`0x824D6640`, `2186674160`) are returned unchanged; symbolic
//! tokens require a path to an existing `sylpheed.db` (passed by the caller).
//!
//! All DB access is read-only and happens before guest execution, so the
//! lockstep digest is unaffected.

use std::path::Path;

use anyhow::{anyhow, Result};
use duckdb::params;

/// Parse one probe token into one or more PCs.
///
/// Recognized forms:
/// - `0xADDR` / `ADDR` (decimal) → returns one PC unchanged.
/// - `Class::method` → all `methods.function_address` matching that
///   `class_name` + `method_name` pair.
/// - `Class::*` → all `methods.function_address` for that class.
/// - `func::Name` (free function) → falls back to `functions.name` lookup.
///
/// `db_path` is consulted ONLY if the token is non-numeric. When `db_path` is
/// `None` and the token is symbolic, returns an error suggesting the user
/// either pass `--db` or use a numeric address.
pub fn resolve_probe_token(db_path: Option<&Path>, token: &str) -> Result<Vec<u32>> {
    let token = token.trim();
    if token.is_empty() {
        return Ok(vec![]);
    }

    if let Some(pc) = parse_numeric(token) {
        return Ok(vec![pc]);
    }

    let db = db_path.ok_or_else(|| {
        anyhow!(
            "symbolic probe token {token:?} requires a sylpheed.db; \
             pass --probe-db=PATH or use a numeric 0x… address",
        )
    })?;

    if !db.exists() {
        return Err(anyhow!("--probe-db not found: {}", db.display()));
    }

    let conn = duckdb::Connection::open_with_flags(
        db,
        duckdb::Config::default().access_mode(duckdb::AccessMode::ReadOnly)?,
    )?;

    // Class::method or Class::*
    if let Some((class, method)) = token.split_once("::") {
        if method == "*" {
            return resolve_class_star(&conn, class);
        }
        // Try Class::method first, then fall back to functions.name lookup.
        let pcs = resolve_class_method(&conn, class, method)?;
        if !pcs.is_empty() {
            return Ok(pcs);
        }
    }

    // Last-resort: functions.name match (e.g. for `entry_point` or
    // `__savegprlr_22`). Substring-free; user gets a clear error if missing.
    resolve_function_name(&conn, token)
}

fn parse_numeric(token: &str) -> Option<u32> {
    if let Some(hex) = token.strip_prefix("0x").or_else(|| token.strip_prefix("0X")) {
        return u32::from_str_radix(hex, 16).ok();
    }
    token.parse::<u32>().ok()
}

fn resolve_class_method(conn: &duckdb::Connection, class: &str, method: &str) -> Result<Vec<u32>> {
    // Two-step lookup so we can give better errors:
    //   1. find matching methods rows joined to classes;
    //   2. surface the function_address column.
    let mut stmt = conn.prepare(
        "SELECT DISTINCT m.function_address FROM methods m
         JOIN classes c ON c.vtable_address = m.vtable_address
         JOIN demangled_names dn ON dn.address = m.function_address
         WHERE c.name = ? AND dn.method_name = ?",
    )?;
    let pcs: Vec<u32> = stmt
        .query_map(params![class, method], |r| r.get::<_, i64>(0).map(|x| x as u32))?
        .filter_map(|r| r.ok())
        .collect();
    Ok(pcs)
}

fn resolve_class_star(conn: &duckdb::Connection, class: &str) -> Result<Vec<u32>> {
    let mut stmt = conn.prepare(
        "SELECT DISTINCT m.function_address FROM methods m
         JOIN classes c ON c.vtable_address = m.vtable_address
         WHERE c.name = ?",
    )?;
    let pcs: Vec<u32> = stmt
        .query_map(params![class], |r| r.get::<_, i64>(0).map(|x| x as u32))?
        .filter_map(|r| r.ok())
        .collect();
    if pcs.is_empty() {
        return Err(anyhow!(
            "no class named {class:?} found in classes table — has --dis populated this DB?",
        ));
    }
    Ok(pcs)
}

fn resolve_function_name(conn: &duckdb::Connection, name: &str) -> Result<Vec<u32>> {
    let mut stmt = conn.prepare("SELECT address FROM functions WHERE name = ?")?;
    let pcs: Vec<u32> = stmt
        .query_map(params![name], |r| r.get::<_, i64>(0).map(|x| x as u32))?
        .filter_map(|r| r.ok())
        .collect();
    if pcs.is_empty() {
        return Err(anyhow!(
            "probe token {name:?} did not match any classes::methods or functions row",
        ));
    }
    Ok(pcs)
}

#[cfg(test)]
mod tests {
    use super::*;
    use duckdb::Connection;

    fn build_synthetic_db(path: &Path) {
        let conn = Connection::open(path).expect("open");
        conn.execute_batch(
            "
            CREATE TABLE functions (
                address BIGINT PRIMARY KEY,
                name VARCHAR
            );
            CREATE TABLE classes (
                name VARCHAR PRIMARY KEY,
                vtable_address BIGINT,
                rtti_present BOOLEAN,
                base_classes_json VARCHAR
            );
            CREATE TABLE methods (
                vtable_address BIGINT,
                slot BIGINT,
                function_address BIGINT,
                mangled_name VARCHAR,
                demangled_name VARCHAR,
                PRIMARY KEY (vtable_address, slot)
            );
            CREATE TABLE demangled_names (
                address BIGINT,
                mangled VARCHAR,
                raw_demangled VARCHAR,
                namespace_path VARCHAR,
                class_name VARCHAR,
                method_name VARCHAR,
                params_signature VARCHAR
            );
            INSERT INTO classes VALUES ('Foo', 11000, true, NULL);
            INSERT INTO functions VALUES (12000, 'sub_2EE0'), (12100, 'sub_2F44');
            INSERT INTO methods VALUES (11000, 0, 12000, NULL, NULL),
                                       (11000, 1, 12100, NULL, NULL);
            INSERT INTO demangled_names (address, mangled, raw_demangled, class_name, method_name)
            VALUES (12000, '?bar@Foo@@QEAAXXZ', 'void Foo::bar(void)', 'Foo', 'bar'),
                   (12100, '?baz@Foo@@QEAAXXZ', 'void Foo::baz(void)', 'Foo', 'baz');
            ",
        )
        .expect("seed");
    }

    #[test]
    fn numeric_passthrough_no_db_needed() {
        let pcs = resolve_probe_token(None, "0x824D6640").unwrap();
        assert_eq!(pcs, vec![0x824D6640]);
        let pcs = resolve_probe_token(None, "2186095088").unwrap();
        assert_eq!(pcs, vec![0x824D29F0]);
    }

    #[test]
    fn symbolic_token_without_db_errors() {
        let err = resolve_probe_token(None, "Foo::bar").unwrap_err();
        assert!(format!("{err}").contains("requires a sylpheed.db"));
    }

    #[test]
    fn class_method_resolves() {
        let tmp = std::env::temp_dir().join("xenia_lookup_test.duckdb");
        let _ = std::fs::remove_file(&tmp);
        build_synthetic_db(&tmp);
        let pcs = resolve_probe_token(Some(&tmp), "Foo::bar").unwrap();
        assert_eq!(pcs, vec![12000]);
        let _ = std::fs::remove_file(&tmp);
    }

    #[test]
    fn class_star_returns_all_methods() {
        let tmp = std::env::temp_dir().join("xenia_lookup_star.duckdb");
        let _ = std::fs::remove_file(&tmp);
        build_synthetic_db(&tmp);
        let mut pcs = resolve_probe_token(Some(&tmp), "Foo::*").unwrap();
        pcs.sort();
        assert_eq!(pcs, vec![12000, 12100]);
        let _ = std::fs::remove_file(&tmp);
    }

    #[test]
    fn function_name_fallback() {
        let tmp = std::env::temp_dir().join("xenia_lookup_fn.duckdb");
        let _ = std::fs::remove_file(&tmp);
        build_synthetic_db(&tmp);
        let pcs = resolve_probe_token(Some(&tmp), "sub_2EE0").unwrap();
        assert_eq!(pcs, vec![12000]);
        let _ = std::fs::remove_file(&tmp);
    }
}