use std::path::Path;
use std::sync::Arc;
use algocline_core::CustomMetricsHandle;
use mlua::prelude::*;
use mlua::LuaSerdeExt;
use crate::card::{self, FileCardStore};
use crate::state::{JsonFileStore, StateStore};
pub(super) fn register_json(lua: &Lua, alc_table: &LuaTable) -> LuaResult<()> {
let encode = lua.create_function(|lua, value: LuaValue| {
let json: serde_json::Value = lua.from_value(value)?;
serde_json::to_string(&json).map_err(LuaError::external)
})?;
let decode = lua.create_function(|lua, s: String| {
let value: serde_json::Value = serde_json::from_str(&s).map_err(LuaError::external)?;
lua.to_value(&value)
})?;
alc_table.set("json_encode", encode)?;
alc_table.set("json_decode", decode)?;
Ok(())
}
pub(super) fn register_log(_lua: &Lua, alc_table: &LuaTable) -> LuaResult<()> {
let log = _lua.create_function(|_, (level, msg): (String, String)| {
match level.as_str() {
"error" => tracing::error!("{}", msg),
"warn" => tracing::warn!("{}", msg),
"info" => tracing::info!("{}", msg),
"debug" => tracing::debug!("{}", msg),
_ => tracing::info!("{}", msg),
}
Ok(())
})?;
alc_table.set("log", log)?;
Ok(())
}
pub(super) fn register_state(
lua: &Lua,
alc_table: &LuaTable,
ns: String,
state_store: Arc<JsonFileStore>,
) -> LuaResult<()> {
let state_table = lua.create_table()?;
let ns_get = ns.clone();
let store_get = Arc::clone(&state_store);
let get =
lua.create_function(
move |lua, (key, default): (String, Option<LuaValue>)| match store_get
.get(&ns_get, &key)
{
Ok(Some(v)) => lua.to_value(&v),
Ok(None) => Ok(default.unwrap_or(LuaValue::Nil)),
Err(e) => Err(LuaError::external(e)),
},
)?;
let ns_set = ns.clone();
let store_set = Arc::clone(&state_store);
let set = lua.create_function(move |lua, (key, value): (String, LuaValue)| {
let json: serde_json::Value = lua.from_value(value)?;
store_set
.set(&ns_set, &key, json)
.map_err(LuaError::external)
})?;
let ns_keys = ns.clone();
let store_keys = Arc::clone(&state_store);
let keys = lua.create_function(move |lua, ()| {
let k = store_keys.keys(&ns_keys).map_err(LuaError::external)?;
lua.to_value(&k)
})?;
let ns_del = ns.clone();
let store_del = Arc::clone(&state_store);
let delete = lua.create_function(move |_, key: String| {
store_del.delete(&ns_del, &key).map_err(LuaError::external)
})?;
let ns_has = ns.clone();
let store_has = Arc::clone(&state_store);
let has = lua.create_function(move |_, key: String| {
store_has.has(&ns_has, &key).map_err(LuaError::external)
})?;
let ns_snx = ns.clone();
let store_snx = Arc::clone(&state_store);
let set_nx = lua.create_function(move |lua, (key, value): (String, LuaValue)| {
let json: serde_json::Value = lua.from_value(value)?;
store_snx
.set_nx(&ns_snx, &key, json)
.map_err(LuaError::external)
})?;
let ns_incr = ns;
let store_incr = Arc::clone(&state_store);
let incr = lua.create_function(
move |_, (key, delta, default): (String, Option<f64>, Option<f64>)| {
store_incr
.incr(&ns_incr, &key, delta.unwrap_or(1.0), default.unwrap_or(0.0))
.map_err(LuaError::external)
},
)?;
state_table.set("get", get)?;
state_table.set("set", set)?;
state_table.set("keys", keys)?;
state_table.set("delete", delete)?;
state_table.set("has", has)?;
state_table.set("set_nx", set_nx)?;
state_table.set("incr", incr)?;
alc_table.set("state", state_table)?;
Ok(())
}
pub(super) fn register_dirs(
lua: &Lua,
alc_table: &LuaTable,
state_dir: &Path,
cards_dir: &Path,
scenarios_dir: &Path,
) -> LuaResult<()> {
let dirs = lua.create_table()?;
dirs.set("state", state_dir.to_string_lossy().into_owned())?;
dirs.set("cards", cards_dir.to_string_lossy().into_owned())?;
dirs.set("scenarios", scenarios_dir.to_string_lossy().into_owned())?;
alc_table.set("_dirs", dirs)?;
Ok(())
}
pub(super) fn register_card(
lua: &Lua,
alc_table: &LuaTable,
card_store: Arc<FileCardStore>,
) -> LuaResult<()> {
let card_table = lua.create_table()?;
let store_create = Arc::clone(&card_store);
let create = lua.create_function(move |lua, input: LuaValue| {
let json: serde_json::Value = lua.from_value(input)?;
let (card_id, path) = store_create.create(json).map_err(LuaError::external)?;
let ret = lua.create_table()?;
ret.set("card_id", card_id)?;
ret.set("path", path.to_string_lossy().to_string())?;
Ok(ret)
})?;
let store_get = Arc::clone(&card_store);
let get = lua.create_function(move |lua, card_id: String| match store_get.get(&card_id) {
Ok(Some(v)) => lua.to_value(&v),
Ok(None) => Ok(LuaValue::Nil),
Err(e) => Err(LuaError::external(e)),
})?;
let store_list = Arc::clone(&card_store);
let list = lua.create_function(move |lua, filter: Option<LuaTable>| {
let pkg = match filter {
Some(t) => t.get::<Option<String>>("pkg")?,
None => None,
};
let rows = store_list
.list(pkg.as_deref())
.map_err(LuaError::external)?;
lua.to_value(&card::summaries_to_json(&rows))
})?;
let store_append = Arc::clone(&card_store);
let append = lua.create_function(move |lua, (card_id, fields): (String, LuaValue)| {
let json: serde_json::Value = lua.from_value(fields)?;
let merged = store_append
.append(&card_id, json)
.map_err(LuaError::external)?;
lua.to_value(&merged)
})?;
let store_gba = Arc::clone(&card_store);
let get_by_alias = lua.create_function(move |lua, name: String| {
match store_gba.get_by_alias(&name).map_err(LuaError::external)? {
Some(v) => lua.to_value(&v),
None => Ok(LuaValue::Nil),
}
})?;
let store_aset = Arc::clone(&card_store);
let alias_set = lua.create_function(
move |lua, (name, card_id, opts): (String, String, Option<LuaTable>)| {
let (pkg, note) = match opts {
Some(t) => (
t.get::<Option<String>>("pkg")?,
t.get::<Option<String>>("note")?,
),
None => (None, None),
};
let a = store_aset
.alias_set(&name, &card_id, pkg.as_deref(), note.as_deref())
.map_err(LuaError::external)?;
let arr = card::aliases_to_json(&[a]);
let first = match arr {
serde_json::Value::Array(mut v) if !v.is_empty() => v.remove(0),
other => other,
};
lua.to_value(&first)
},
)?;
let store_alist = Arc::clone(&card_store);
let alias_list = lua.create_function(move |lua, filter: Option<LuaTable>| {
let pkg = match filter {
Some(t) => t.get::<Option<String>>("pkg")?,
None => None,
};
let rows = store_alist
.alias_list(pkg.as_deref())
.map_err(LuaError::external)?;
lua.to_value(&card::aliases_to_json(&rows))
})?;
let store_find = Arc::clone(&card_store);
let find = lua.create_function(move |lua, query: Option<LuaTable>| {
let q = match query {
Some(t) => {
let pkg = t.get::<Option<String>>("pkg")?;
let limit = t.get::<Option<usize>>("limit")?;
let offset = t.get::<Option<usize>>("offset")?;
let where_parsed = match t.get::<LuaValue>("where")? {
LuaValue::Nil => None,
v => {
let json: serde_json::Value = lua.from_value(v)?;
Some(card::parse_where(&json).map_err(LuaError::external)?)
}
};
let order_parsed = match t.get::<LuaValue>("order_by")? {
LuaValue::Nil => Vec::new(),
v => {
let json: serde_json::Value = lua.from_value(v)?;
card::parse_order_by(&json).map_err(LuaError::external)?
}
};
card::FindQuery {
pkg,
where_: where_parsed,
order_by: order_parsed,
limit,
offset,
}
}
None => card::FindQuery::default(),
};
let rows = store_find.find(q).map_err(LuaError::external)?;
lua.to_value(&card::summaries_to_json(&rows))
})?;
let store_ws = Arc::clone(&card_store);
let write_samples =
lua.create_function(move |lua, (card_id, samples): (String, LuaValue)| {
let json: serde_json::Value = lua.from_value(samples)?;
let arr = match json {
serde_json::Value::Array(a) => a,
_ => {
return Err(LuaError::external(
"alc.card.write_samples: samples must be an array",
))
}
};
let count = arr.len();
let path = store_ws
.write_samples(&card_id, arr)
.map_err(LuaError::external)?;
let ret = lua.create_table()?;
ret.set("path", path.to_string_lossy().to_string())?;
ret.set("count", count)?;
Ok(ret)
})?;
let store_rs = Arc::clone(&card_store);
let read_samples =
lua.create_function(move |lua, (card_id, opts): (String, Option<LuaTable>)| {
let (offset, limit, where_parsed) = match opts {
Some(t) => {
let offset = t.get::<Option<usize>>("offset")?.unwrap_or(0);
let limit = t.get::<Option<usize>>("limit")?;
let where_parsed = match t.get::<LuaValue>("where")? {
LuaValue::Nil => None,
v => {
let json: serde_json::Value = lua.from_value(v)?;
Some(card::parse_where(&json).map_err(LuaError::external)?)
}
};
(offset, limit, where_parsed)
}
None => (0, None, None),
};
let q = card::SamplesQuery {
offset,
limit,
where_: where_parsed,
};
let rows = store_rs
.read_samples(&card_id, q)
.map_err(LuaError::external)?;
lua.to_value(&serde_json::Value::Array(rows))
})?;
let store_sb = Arc::clone(&card_store);
let sink_backfill = lua.create_function(move |lua, params: LuaTable| {
let sink: String = params.get("sink")?;
let dry_run: Option<bool> = params.get("dry_run")?;
let report = store_sb
.card_sink_backfill(&sink, dry_run.unwrap_or(false))
.map_err(LuaError::external)?;
lua.to_value(&report)
})?;
let store_lin = Arc::clone(&card_store);
let lineage = lua.create_function(move |lua, query: LuaTable| {
let card_id: String = query.get("card_id")?;
let direction_str: Option<String> = query.get("direction")?;
let direction = match direction_str.as_deref() {
Some(s) => card::LineageDirection::parse(s).map_err(LuaError::external)?,
None => card::LineageDirection::Up,
};
let depth: Option<usize> = query.get("depth")?;
let include_stats: Option<bool> = query.get("include_stats")?;
let relation_filter: Option<Vec<String>> = match query.get::<LuaValue>("relation_filter")? {
LuaValue::Nil => None,
v => Some(lua.from_value(v)?),
};
let q = card::LineageQuery {
card_id,
direction,
depth,
include_stats: include_stats.unwrap_or(true),
relation_filter,
};
match store_lin.lineage(q).map_err(LuaError::external)? {
Some(res) => lua.to_value(&card::lineage_to_json(&res)),
None => Ok(LuaValue::Nil),
}
})?;
card_table.set("create", create)?;
card_table.set("get", get)?;
card_table.set("list", list)?;
card_table.set("append", append)?;
card_table.set("get_by_alias", get_by_alias)?;
card_table.set("alias_set", alias_set)?;
card_table.set("alias_list", alias_list)?;
card_table.set("find", find)?;
card_table.set("write_samples", write_samples)?;
card_table.set("read_samples", read_samples)?;
card_table.set("lineage", lineage)?;
card_table.set("sink_backfill", sink_backfill)?;
alc_table.set("card", card_table)?;
Ok(())
}
pub(super) fn register_stats(
lua: &Lua,
alc_table: &LuaTable,
custom_metrics: CustomMetricsHandle,
) -> LuaResult<()> {
let stats_table = lua.create_table()?;
let cm_record = custom_metrics.clone();
let record = lua.create_function(move |lua, (key, value): (String, LuaValue)| {
let json: serde_json::Value = lua.from_value(value)?;
cm_record.record(key, json);
Ok(())
})?;
let cm_get = custom_metrics;
let get = lua.create_function(move |lua, key: String| match cm_get.get(&key) {
Some(v) => lua.to_value(&v),
None => Ok(LuaValue::Nil),
})?;
stats_table.set("record", record)?;
stats_table.set("get", get)?;
alc_table.set("stats", stats_table)?;
Ok(())
}
#[cfg(test)]
mod tests {
use super::*;
use algocline_core::ExecutionMetrics;
fn test_config_with(ns: &str) -> crate::bridge::BridgeConfig {
let metrics = ExecutionMetrics::new();
let tmp = tempfile::tempdir().expect("test tempdir");
let root = tmp.path().to_path_buf();
std::mem::forget(tmp);
crate::bridge::BridgeConfig {
llm_tx: None,
ns: ns.into(),
custom_metrics: metrics.custom_metrics_handle(),
budget: metrics.budget_handle(),
progress: metrics.progress_handle(),
lib_paths: vec![],
variant_pkgs: vec![],
state_store: Arc::new(JsonFileStore::new(root.join("state"))),
card_store: Arc::new(FileCardStore::new(root.join("cards"))),
scenarios_dir: root.join("scenarios"),
}
}
fn test_config() -> crate::bridge::BridgeConfig {
test_config_with("default")
}
fn test_config_with_ns(ns: &str) -> crate::bridge::BridgeConfig {
test_config_with(ns)
}
#[test]
fn json_roundtrip() {
let lua = Lua::new();
let t = lua.create_table().unwrap();
crate::bridge::register(&lua, &t, test_config()).unwrap();
lua.globals().set("alc", t).unwrap();
let result: String = lua
.load(r#"return alc.json_encode({hello = "world", n = 42})"#)
.eval()
.unwrap();
let parsed: serde_json::Value = serde_json::from_str(&result).unwrap();
assert_eq!(parsed["hello"], "world");
assert_eq!(parsed["n"], 42);
}
#[test]
fn json_decode_encode() {
let lua = Lua::new();
let t = lua.create_table().unwrap();
crate::bridge::register(&lua, &t, test_config()).unwrap();
lua.globals().set("alc", t).unwrap();
let result: String = lua
.load(
r#"
local val = alc.json_decode('{"a":1,"b":"two"}')
val.c = true
return alc.json_encode(val)
"#,
)
.eval()
.unwrap();
let parsed: serde_json::Value = serde_json::from_str(&result).unwrap();
assert_eq!(parsed["a"], 1);
assert_eq!(parsed["b"], "two");
assert_eq!(parsed["c"], true);
}
#[test]
fn state_get_set() {
let ns = "_test_bridge_state";
let lua = Lua::new();
let t = lua.create_table().unwrap();
crate::bridge::register(&lua, &t, test_config_with_ns(ns)).unwrap();
lua.globals().set("alc", t).unwrap();
lua.load(r#"alc.state.set("x", 99)"#).exec().unwrap();
let result: i64 = lua.load(r#"return alc.state.get("x")"#).eval().unwrap();
assert_eq!(result, 99);
let result: i64 = lua
.load(r#"return alc.state.get("missing", 0)"#)
.eval()
.unwrap();
assert_eq!(result, 0);
let result: LuaValue = lua
.load(r#"return alc.state.get("missing")"#)
.eval()
.unwrap();
assert!(result.is_nil());
}
#[test]
fn state_has_set_nx_incr() {
let ns = "_test_bridge_state_t1";
let lua = Lua::new();
let t = lua.create_table().unwrap();
crate::bridge::register(&lua, &t, test_config_with_ns(ns)).unwrap();
lua.globals().set("alc", t).unwrap();
let h: bool = lua.load(r#"return alc.state.has("k")"#).eval().unwrap();
assert!(!h);
let ok: bool = lua
.load(r#"return alc.state.set_nx("k", "first")"#)
.eval()
.unwrap();
assert!(ok);
let h: bool = lua.load(r#"return alc.state.has("k")"#).eval().unwrap();
assert!(h);
let ok: bool = lua
.load(r#"return alc.state.set_nx("k", "second")"#)
.eval()
.unwrap();
assert!(!ok);
let v: f64 = lua
.load(r#"return alc.state.incr("counter")"#)
.eval()
.unwrap();
assert!((v - 1.0).abs() < f64::EPSILON);
let v: f64 = lua
.load(r#"return alc.state.incr("counter", 5)"#)
.eval()
.unwrap();
assert!((v - 6.0).abs() < f64::EPSILON);
let v: f64 = lua
.load(r#"return alc.state.incr("counter", 10, 100)"#)
.eval()
.unwrap();
assert!((v - 16.0).abs() < f64::EPSILON);
}
#[test]
fn card_create_get_list_from_lua() {
let ns = std::time::SystemTime::now()
.duration_since(std::time::UNIX_EPOCH)
.unwrap()
.as_nanos();
let pkg = format!("_test_bridge_card_{ns}");
let lua = Lua::new();
let t = lua.create_table().unwrap();
crate::bridge::register(&lua, &t, test_config()).unwrap();
lua.globals().set("alc", t).unwrap();
let create_script = format!(
r#"
local r = alc.card.create({{
pkg = {{ name = "{pkg}" }},
model = {{ id = "claude-opus-4-6" }},
stats = {{ pass_rate = 0.9 }},
}})
return r.card_id
"#
);
let card_id: String = lua.load(&create_script).eval().unwrap();
assert!(card_id.starts_with(&pkg));
let get_script = format!(r#"return alc.card.get("{card_id}").stats.pass_rate"#);
let rate: f64 = lua.load(&get_script).eval().unwrap();
assert!((rate - 0.9).abs() < 1e-9);
let list_script = format!(
r#"
local rows = alc.card.list({{ pkg = "{pkg}" }})
return #rows
"#
);
let count: i64 = lua.load(&list_script).eval().unwrap();
assert_eq!(count, 1);
}
#[test]
fn stats_record_get() {
let metrics = ExecutionMetrics::new();
let custom_handle = metrics.custom_metrics_handle();
let lua = Lua::new();
let t = lua.create_table().unwrap();
let tmp = tempfile::tempdir().expect("test tempdir");
let root = tmp.path().to_path_buf();
std::mem::forget(tmp);
crate::bridge::register(
&lua,
&t,
crate::bridge::BridgeConfig {
llm_tx: None,
ns: "default".into(),
custom_metrics: custom_handle.clone(),
budget: metrics.budget_handle(),
progress: metrics.progress_handle(),
lib_paths: vec![],
variant_pkgs: vec![],
state_store: Arc::new(JsonFileStore::new(root.join("state"))),
card_store: Arc::new(FileCardStore::new(root.join("cards"))),
scenarios_dir: root.join("scenarios"),
},
)
.unwrap();
lua.globals().set("alc", t).unwrap();
lua.load(r#"alc.stats.record("score", 42)"#).exec().unwrap();
let result: i64 = lua.load(r#"return alc.stats.get("score")"#).eval().unwrap();
assert_eq!(result, 42);
assert_eq!(custom_handle.get("score"), Some(serde_json::json!(42)));
let result: LuaValue = lua
.load(r#"return alc.stats.get("missing")"#)
.eval()
.unwrap();
assert!(result.is_nil());
}
}