assay-lua 0.11.2

use data_encoding::BASE64;
use mlua::{Lua, Value};
use std::os::unix::fs::PermissionsExt;
use std::time::{SystemTime, UNIX_EPOCH};
use tracing::{error, info, warn};

static TEMPDIR_COUNTER: std::sync::atomic::AtomicU64 = std::sync::atomic::AtomicU64::new(0);

pub fn register_log(lua: &Lua) -> mlua::Result<()> {
    let log_table = lua.create_table()?;

    let info_fn = lua.create_function(|_, msg: String| {
        info!(target: "lua", "{}", msg);
        Ok(())
    })?;
    log_table.set("info", info_fn)?;

    let warn_fn = lua.create_function(|_, msg: String| {
        warn!(target: "lua", "{}", msg);
        Ok(())
    })?;
    log_table.set("warn", warn_fn)?;

    let error_fn = lua.create_function(|_, msg: String| {
        error!(target: "lua", "{}", msg);
        Ok(())
    })?;
    log_table.set("error", error_fn)?;

    lua.globals().set("log", log_table)?;
    Ok(())
}

pub fn register_env(lua: &Lua) -> mlua::Result<()> {
    let env_table = lua.create_table()?;

    let process_get_fn = lua.create_function(|_, name: String| match std::env::var(&name) {
        Ok(val) => Ok(Some(val)),
        Err(_) => Ok(None),
    })?;
    env_table.set("_process_get", process_get_fn)?;
    env_table.set("_check_env", lua.create_table()?)?;

    lua.globals().set("env", env_table)?;

    lua.load(
        r#"
        function env.get(name)
            local val = env._check_env[name]
            if val ~= nil then return val end
            return env._process_get(name)
        end
        "#,
    )
    .exec()?;

    // env.set(key, val) — set env var (nil val = unset)
    let set_fn = lua.create_function(|_, (key, val): (String, Option<String>)| {
        match val {
            Some(v) => unsafe { std::env::set_var(&key, &v) },
            None => unsafe { std::env::remove_var(&key) },
        }
        Ok(())
    })?;
    lua.globals()
        .get::<mlua::Table>("env")?
        .set("set", set_fn)?;

    // env.list() — returns table of {key, value} for all env vars
    let list_fn = lua.create_function(|lua, ()| {
        let results = lua.create_table()?;
        for (i, (key, val)) in (1..).zip(std::env::vars()) {
            let entry = lua.create_table()?;
            entry.set("key", key)?;
            entry.set("value", val)?;
            results.set(i, entry)?;
        }
        Ok(results)
    })?;
    lua.globals()
        .get::<mlua::Table>("env")?
        .set("list", list_fn)?;

    Ok(())
}

pub fn register_sleep(lua: &Lua) -> mlua::Result<()> {
    let sleep_fn = lua.create_async_function(|_, seconds: f64| async move {
        let duration = std::time::Duration::from_secs_f64(seconds);
        tokio::time::sleep(duration).await;
        Ok(())
    })?;
    lua.globals().set("sleep", sleep_fn)?;
    Ok(())
}

pub fn register_time(lua: &Lua) -> mlua::Result<()> {
    let time_fn = lua.create_function(|_, ()| {
        let secs = SystemTime::now()
            .duration_since(UNIX_EPOCH)
            .map_err(|e| mlua::Error::runtime(format!("time(): {e}")))?
            .as_secs_f64();
        Ok(secs)
    })?;
    lua.globals().set("time", time_fn)?;
    Ok(())
}

pub fn register_fs(lua: &Lua) -> mlua::Result<()> {
    let fs_table = lua.create_table()?;

    let read_fn = lua.create_function(|_, path: String| {
        std::fs::read_to_string(&path)
            .map_err(|e| mlua::Error::runtime(format!("fs.read: failed to read {path:?}: {e}")))
    })?;
    fs_table.set("read", read_fn)?;

    // fs.read_bytes(path) → string (binary-safe, Lua strings can hold any bytes)
    let read_bytes_fn = lua.create_function(|lua, path: String| {
        let bytes = std::fs::read(&path)
            .map_err(|e| mlua::Error::runtime(format!("fs.read_bytes: failed to read {path:?}: {e}")))?;
        lua.create_string(&bytes)
    })?;
    fs_table.set("read_bytes", read_bytes_fn)?;

    let write_fn = lua.create_function(|_, (path, content): (String, String)| {
        let p = std::path::Path::new(&path);
        if let Some(parent) = p.parent() {
            std::fs::create_dir_all(parent).map_err(|e| {
                mlua::Error::runtime(format!(
                    "fs.write: failed to create directories for {path:?}: {e}"
                ))
            })?;
        }
        std::fs::write(&path, &content)
            .map_err(|e| mlua::Error::runtime(format!("fs.write: failed to write {path:?}: {e}")))
    })?;
    fs_table.set("write", write_fn)?;

    // fs.write_bytes(path, data) → write binary data (Lua string with arbitrary bytes)
    let write_bytes_fn = lua.create_function(|_, (path, data): (String, mlua::String)| {
        let p = std::path::Path::new(&path);
        if let Some(parent) = p.parent() {
            std::fs::create_dir_all(parent).map_err(|e| {
                mlua::Error::runtime(format!(
                    "fs.write_bytes: failed to create directories for {path:?}: {e}"
                ))
            })?;
        }
        std::fs::write(&path, data.as_bytes())
            .map_err(|e| mlua::Error::runtime(format!("fs.write_bytes: failed to write {path:?}: {e}")))
    })?;
    fs_table.set("write_bytes", write_bytes_fn)?;

    let remove_fn = lua.create_function(|_, path: String| {
        let p = std::path::Path::new(&path);
        // Use symlink_metadata to detect symlinks without following them.
        // A symlink to a directory should be removed as a file (unlink),
        // not recursively delete the target directory.
        let is_dir = match std::fs::symlink_metadata(&path) {
            Ok(m) => m.file_type().is_dir(),
            Err(_) => p.is_dir(),
        };
        if is_dir {
            std::fs::remove_dir_all(&path).map_err(|e| {
                mlua::Error::runtime(format!(
                    "fs.remove: failed to remove directory {path:?}: {e}"
                ))
            })
        } else {
            std::fs::remove_file(&path).map_err(|e| {
                mlua::Error::runtime(format!("fs.remove: failed to remove {path:?}: {e}"))
            })
        }
    })?;
    fs_table.set("remove", remove_fn)?;

    let list_fn =
        lua.create_function(|lua, path: String| {
            let entries = lua.create_table()?;
            for (i, entry) in (1..).zip(std::fs::read_dir(&path).map_err(|e| {
                mlua::Error::runtime(format!("fs.list: failed to list {path:?}: {e}"))
            })?) {
                let entry = entry.map_err(|e| {
                    mlua::Error::runtime(format!("fs.list: error reading entry in {path:?}: {e}"))
                })?;
                let info = lua.create_table()?;
                let name = entry.file_name().to_string_lossy().to_string();
                info.set("name", name)?;
                let file_type = entry.file_type().map_err(|e| {
                    mlua::Error::runtime(format!("fs.list: failed to get file type: {e}"))
                })?;
                if file_type.is_dir() {
                    info.set("type", "directory")?;
                } else if file_type.is_symlink() {
                    info.set("type", "symlink")?;
                } else {
                    info.set("type", "file")?;
                }
                entries.set(i, info)?;
            }
            Ok(entries)
        })?;
    fs_table.set("list", list_fn)?;

    let stat_fn = lua.create_function(|lua, path: String| {
        let metadata = std::fs::metadata(&path)
            .map_err(|e| mlua::Error::runtime(format!("fs.stat: failed to stat {path:?}: {e}")))?;
        // Use symlink_metadata separately to correctly detect symlinks,
        // since std::fs::metadata follows symlinks (is_symlink always false).
        let is_symlink = std::fs::symlink_metadata(&path)
            .map(|m| m.file_type().is_symlink())
            .unwrap_or(false);
        let info = lua.create_table()?;
        info.set("size", metadata.len())?;
        info.set("is_file", metadata.is_file())?;
        info.set("is_dir", metadata.is_dir())?;
        info.set("is_symlink", is_symlink)?;
        if let Ok(modified) = metadata.modified()
            && let Ok(duration) = modified.duration_since(std::time::UNIX_EPOCH)
        {
            info.set("modified", duration.as_secs_f64())?;
        }
        if let Ok(created) = metadata.created()
            && let Ok(duration) = created.duration_since(std::time::UNIX_EPOCH)
        {
            info.set("created", duration.as_secs_f64())?;
        }
        Ok(info)
    })?;
    fs_table.set("stat", stat_fn)?;

    let mkdir_fn = lua.create_function(|_, path: String| {
        std::fs::create_dir_all(&path)
            .map_err(|e| mlua::Error::runtime(format!("fs.mkdir: failed to create {path:?}: {e}")))
    })?;
    fs_table.set("mkdir", mkdir_fn)?;

    let exists_fn =
        lua.create_function(|_, path: String| Ok(std::path::Path::new(&path).exists()))?;
    fs_table.set("exists", exists_fn)?;

    // fs.copy(src, dst) — copy file, returns bytes copied
    let copy_fn = lua.create_function(|_, (src, dst): (String, String)| {
        let bytes = std::fs::copy(&src, &dst).map_err(|e| {
            mlua::Error::runtime(format!("fs.copy: failed to copy {src:?} to {dst:?}: {e}"))
        })?;
        Ok(bytes)
    })?;
    fs_table.set("copy", copy_fn)?;

    // fs.rename(src, dst) — atomic rename
    let rename_fn = lua.create_function(|_, (src, dst): (String, String)| {
        std::fs::rename(&src, &dst).map_err(|e| {
            mlua::Error::runtime(format!(
                "fs.rename: failed to rename {src:?} to {dst:?}: {e}"
            ))
        })
    })?;
    fs_table.set("rename", rename_fn)?;

    // fs.glob(pattern) — glob pattern matching, returns array of path strings
    let glob_fn = lua.create_function(|lua, pattern: String| {
        let paths = glob::glob(&pattern).map_err(|e| {
            mlua::Error::runtime(format!("fs.glob: invalid pattern {pattern:?}: {e}"))
        })?;
        let results = lua.create_table()?;
        for (i, entry) in (1..).zip(paths) {
            let path = entry
                .map_err(|e| mlua::Error::runtime(format!("fs.glob: error reading entry: {e}")))?;
            results.set(i, path.to_string_lossy().to_string())?;
        }
        Ok(results)
    })?;
    fs_table.set("glob", glob_fn)?;

    // fs.tempdir() — create a temporary directory, returns path string
    let tempdir_fn = lua.create_function(|_, ()| {
        let base = std::env::temp_dir();
        let nanos: u64 = std::time::SystemTime::now()
            .duration_since(std::time::UNIX_EPOCH)
            .unwrap_or_default()
            .as_nanos() as u64;
        let seq = TEMPDIR_COUNTER.fetch_add(1, std::sync::atomic::Ordering::Relaxed);
        let dir = base.join(format!("assay-{nanos:x}-{seq}"));
        std::fs::create_dir_all(&dir).map_err(|e| {
            mlua::Error::runtime(format!("fs.tempdir: failed to create {dir:?}: {e}"))
        })?;
        Ok(dir.to_string_lossy().to_string())
    })?;
    fs_table.set("tempdir", tempdir_fn)?;

    // fs.chmod(path, mode) — set file permissions (octal integer, e.g. 493 = 0o755)
    let chmod_fn = lua.create_function(|_, (path, mode): (String, u32)| {
        let perms = std::fs::Permissions::from_mode(mode);
        std::fs::set_permissions(&path, perms)
            .map_err(|e| mlua::Error::runtime(format!("fs.chmod: failed to chmod {path:?}: {e}")))
    })?;
    fs_table.set("chmod", chmod_fn)?;

    // fs.readdir(path, opts?) — recursive directory listing
    // opts: { depth = N } — max recursion depth (nil = unlimited)
    let readdir_fn = lua.create_function(|lua, args: mlua::MultiValue| {
        let mut args_iter = args.into_iter();
        let path: String = args_iter
            .next()
            .ok_or_else(|| mlua::Error::runtime("fs.readdir: path required"))
            .and_then(|v| lua.unpack(v))?;

        let max_depth: Option<usize> = if let Some(Value::Table(opts)) = args_iter.next() {
            opts.get::<Option<usize>>("depth")?
        } else {
            None
        };

        let results = lua.create_table()?;
        let mut i = 1u64;
        let base = std::path::PathBuf::from(&path);

        fn walk(
            base: &std::path::Path,
            dir: &std::path::Path,
            results: &mlua::Table,
            lua: &Lua,
            i: &mut u64,
            depth: usize,
            max_depth: Option<usize>,
        ) -> mlua::Result<()> {
            let entries = std::fs::read_dir(dir).map_err(|e| {
                mlua::Error::runtime(format!("fs.readdir: failed to read {dir:?}: {e}"))
            })?;
            for entry in entries {
                let entry = entry.map_err(|e| {
                    mlua::Error::runtime(format!("fs.readdir: error reading entry: {e}"))
                })?;
                let file_type = entry.file_type().map_err(|e| {
                    mlua::Error::runtime(format!("fs.readdir: failed to get file type: {e}"))
                })?;
                let rel_path = entry
                    .path()
                    .strip_prefix(base)
                    .unwrap_or(&entry.path())
                    .to_string_lossy()
                    .to_string();
                let info = lua.create_table()?;
                info.set("path", rel_path)?;
                if file_type.is_dir() {
                    info.set("type", "directory")?;
                } else if file_type.is_symlink() {
                    info.set("type", "symlink")?;
                } else {
                    info.set("type", "file")?;
                }
                results.set(*i, info)?;
                *i += 1;
                if file_type.is_dir() && (max_depth.is_none() || depth < max_depth.unwrap()) {
                    walk(base, &entry.path(), results, lua, i, depth + 1, max_depth)?;
                }
            }
            Ok(())
        }

        walk(&base, &base, &results, lua, &mut i, 1, max_depth)?;
        Ok(results)
    })?;
    fs_table.set("readdir", readdir_fn)?;

    lua.globals().set("fs", fs_table)?;
    Ok(())
}

pub fn register_base64(lua: &Lua) -> mlua::Result<()> {
    let b64_table = lua.create_table()?;

    let encode_fn = lua.create_function(|_, input: String| Ok(BASE64.encode(input.as_bytes())))?;
    b64_table.set("encode", encode_fn)?;

    let decode_fn = lua.create_function(|_, input: String| {
        let bytes = BASE64
            .decode(input.as_bytes())
            .map_err(|e| mlua::Error::runtime(format!("base64.decode: {e}")))?;
        String::from_utf8(bytes)
            .map_err(|e| mlua::Error::runtime(format!("base64.decode: invalid UTF-8: {e}")))
    })?;
    b64_table.set("decode", decode_fn)?;

    lua.globals().set("base64", b64_table)?;
    Ok(())
}

pub fn register_regex(lua: &Lua) -> mlua::Result<()> {
    let regex_table = lua.create_table()?;

    let match_fn = lua.create_function(|_, (text, pattern): (String, String)| {
        let re = regex_lite::Regex::new(&pattern)
            .map_err(|e| mlua::Error::runtime(format!("regex.match: invalid pattern: {e}")))?;
        Ok(re.is_match(&text))
    })?;
    regex_table.set("match", match_fn)?;

    let find_fn = lua.create_function(|lua, (text, pattern): (String, String)| {
        let re = regex_lite::Regex::new(&pattern)
            .map_err(|e| mlua::Error::runtime(format!("regex.find: invalid pattern: {e}")))?;
        match re.captures(&text) {
            Some(caps) => {
                let result = lua.create_table()?;
                let full_match = caps.get(0).map(|m| m.as_str()).unwrap_or("");
                result.set("match", full_match.to_string())?;
                let groups = lua.create_table()?;
                for i in 1..caps.len() {
                    if let Some(m) = caps.get(i) {
                        groups.set(i, m.as_str().to_string())?;
                    }
                }
                result.set("groups", groups)?;
                Ok(Value::Table(result))
            }
            None => Ok(Value::Nil),
        }
    })?;
    regex_table.set("find", find_fn)?;

    let find_all_fn = lua.create_function(|lua, (text, pattern): (String, String)| {
        let re = regex_lite::Regex::new(&pattern)
            .map_err(|e| mlua::Error::runtime(format!("regex.find_all: invalid pattern: {e}")))?;
        let results = lua.create_table()?;
        for (i, m) in re.find_iter(&text).enumerate() {
            results.set(i + 1, m.as_str().to_string())?;
        }
        Ok(results)
    })?;
    regex_table.set("find_all", find_all_fn)?;

    let replace_fn = lua.create_function(
        |_, (text, pattern, replacement): (String, String, String)| {
            let re = regex_lite::Regex::new(&pattern).map_err(|e| {
                mlua::Error::runtime(format!("regex.replace: invalid pattern: {e}"))
            })?;
            Ok(re.replace_all(&text, replacement.as_str()).into_owned())
        },
    )?;
    regex_table.set("replace", replace_fn)?;

    lua.globals().set("regex", regex_table)?;
    Ok(())
}

pub fn register_async(lua: &Lua) -> mlua::Result<()> {
    let async_table = lua.create_table()?;

    let spawn_fn = lua.create_async_function(|lua, func: mlua::Function| async move {
        let thread = lua.create_thread(func)?;
        let async_thread = thread.into_async::<mlua::MultiValue>(())?;
        let join_handle: tokio::task::JoinHandle<Result<Vec<Value>, String>> =
            tokio::task::spawn_local(async move {
                let values = async_thread.await.map_err(|e| e.to_string())?;
                Ok(values.into_vec())
            });

        let handle = lua.create_table()?;
        let cell = std::rc::Rc::new(std::cell::RefCell::new(Some(join_handle)));
        let cell_clone = cell.clone();

        let await_fn = lua.create_async_function(move |lua, ()| {
            let cell = cell_clone.clone();
            async move {
                let join_handle = cell
                    .borrow_mut()
                    .take()
                    .ok_or_else(|| mlua::Error::runtime("async handle already awaited"))?;
                let result = join_handle.await.map_err(|e| {
                    mlua::Error::runtime(format!("async.spawn: task panicked: {e}"))
                })?;
                match result {
                    Ok(values) => {
                        let tbl = lua.create_table()?;
                        for (i, v) in values.into_iter().enumerate() {
                            tbl.set(i + 1, v)?;
                        }
                        Ok(Value::Table(tbl))
                    }
                    Err(msg) => Err(mlua::Error::runtime(msg)),
                }
            }
        })?;
        handle.set("await", await_fn)?;

        Ok(handle)
    })?;
    async_table.set("spawn", spawn_fn)?;

    let spawn_interval_fn =
        lua.create_async_function(|lua, (seconds, func): (f64, mlua::Function)| async move {
            if seconds <= 0.0 {
                return Err(mlua::Error::runtime(
                    "async.spawn_interval: interval must be positive",
                ));
            }

            let cancel = std::sync::Arc::new(std::sync::atomic::AtomicBool::new(false));
            let cancel_clone = cancel.clone();

            tokio::task::spawn_local({
                let cancel = cancel_clone.clone();
                async move {
                    let mut interval =
                        tokio::time::interval(std::time::Duration::from_secs_f64(seconds));
                    interval.tick().await;
                    loop {
                        interval.tick().await;
                        if cancel.load(std::sync::atomic::Ordering::Relaxed) {
                            break;
                        }
                        if let Err(e) = func.call_async::<()>(()).await {
                            error!("async.spawn_interval: callback error: {e}");
                            break;
                        }
                    }
                }
            });

            let handle = lua.create_table()?;
            let cancel_fn = lua.create_function(move |_, ()| {
                cancel.store(true, std::sync::atomic::Ordering::Relaxed);
                Ok(())
            })?;
            handle.set("cancel", cancel_fn)?;

            Ok(handle)
        })?;
    async_table.set("spawn_interval", spawn_interval_fn)?;

    lua.globals().set("async", async_table)?;
    Ok(())
}

#[cfg(test)]
mod tests {
    use data_encoding::BASE64;

    #[test]
    fn test_base64_roundtrip() {
        let input = "hello world";
        let encoded = BASE64.encode(input.as_bytes());
        assert_eq!(encoded, "aGVsbG8gd29ybGQ=");
        let decoded = BASE64.decode(encoded.as_bytes()).unwrap();
        assert_eq!(String::from_utf8(decoded).unwrap(), input);
    }

    #[test]
    fn test_base64_empty() {
        let encoded = BASE64.encode(b"");
        assert_eq!(encoded, "");
        let decoded = BASE64.decode(b"").unwrap();
        assert!(decoded.is_empty());
    }
}