Something went wrong. Try again.
A lexicon-driven AppView for ATProto. happyview.dev
backfill firehose jetstream atproto appview oauth lexicon
Something went wrong. Try again.
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338use mlua::{Lua, LuaSerdeExt, Result as LuaResult};use serde_json::Value;use std::collections::HashMap;
/// Optional space context passed to Lua scripts when the request is space-scoped.#[derive(Debug, Clone)]pub struct SpaceContext { pub space: String, pub space_id: String, pub did: String, pub authority_did: String, pub type_nsid: String, pub skey: String,}
fn set_space_context(lua: &Lua, space: Option<&SpaceContext>) -> LuaResult<()> { let globals = lua.globals(); match space { Some(ctx) => { let table = lua.create_table()?; table.set("space", ctx.space.as_str())?; table.set("space_id", ctx.space_id.as_str())?; table.set("did", ctx.did.as_str())?; table.set("authority_did", ctx.authority_did.as_str())?; table.set("type_nsid", ctx.type_nsid.as_str())?; table.set("skey", ctx.skey.as_str())?; globals.set("space", table)?; } None => { globals.set("space", mlua::Value::Nil)?; } } Ok(())}
/// Set global context variables for a procedure script.#[allow(clippy::too_many_arguments)]pub fn set_procedure_context( lua: &Lua, method: &str, input: &Value, params: &HashMap<String, Value>, caller_did: &str, collection: &str, space: Option<&SpaceContext>, delegate_did: Option<&str>,) -> LuaResult<()> { let globals = lua.globals(); globals.set("method", method.to_string())?; globals.set("input", lua.to_value(input)?)?; globals.set("params", lua.to_value(params)?)?; globals.set("caller_did", caller_did.to_string())?; globals.set("collection", collection.to_string())?; match delegate_did { Some(did) => globals.set("delegate_did", did.to_string())?, None => globals.set("delegate_did", mlua::Value::Nil)?, } set_space_context(lua, space)?; Ok(())}
/// Set global context variables for a query script.pub fn set_query_context( lua: &Lua, method: &str, params: &HashMap<String, Value>, collection: &str, caller_did: Option<&str>, space: Option<&SpaceContext>,) -> LuaResult<()> { let globals = lua.globals(); globals.set("method", method.to_string())?; globals.set("params", lua.to_value(params)?)?; globals.set("collection", collection.to_string())?; match caller_did { Some(did) => globals.set("caller_did", did.to_string())?, None => globals.set("caller_did", mlua::Value::Nil)?, } set_space_context(lua, space)?; Ok(())}
/// Set the `env` global table from script variables.pub fn set_env_context(lua: &Lua, vars: &HashMap<String, String>) -> LuaResult<()> { let globals = lua.globals(); globals.set("env", lua.to_value(vars)?)?; Ok(())}
/// Set global context variables for an index hook script.pub fn set_hook_context( lua: &Lua, action: &str, uri: &str, did: &str, collection: &str, rkey: &str, record: Option<&Value>,) -> LuaResult<()> { let globals = lua.globals(); globals.set("action", action.to_string())?; globals.set("uri", uri.to_string())?; globals.set("did", did.to_string())?; globals.set("collection", collection.to_string())?; globals.set("rkey", rkey.to_string())?; match record { Some(r) => globals.set("record", lua.to_value(r)?)?, None => globals.set("record", mlua::Value::Nil)?, } Ok(())}
#[cfg(test)]mod tests { use super::*; use crate::lua::sandbox::create_sandbox; use serde_json::json;
#[test] fn hook_context_sets_all_globals() { let lua = create_sandbox().unwrap(); let record = json!({"name": "Test Game"}); set_hook_context( &lua, "create", "at://did:plc:abc/col/rkey", "did:plc:abc", "col", "rkey", Some(&record), ) .unwrap();
let globals = lua.globals(); assert_eq!(globals.get::<String>("action").unwrap(), "create"); assert_eq!( globals.get::<String>("uri").unwrap(), "at://did:plc:abc/col/rkey" ); assert_eq!(globals.get::<String>("did").unwrap(), "did:plc:abc"); assert_eq!(globals.get::<String>("collection").unwrap(), "col"); assert_eq!(globals.get::<String>("rkey").unwrap(), "rkey");
let rec: mlua::Table = globals.get("record").unwrap(); assert_eq!(rec.get::<String>("name").unwrap(), "Test Game"); }
#[test] fn procedure_context_sets_all_globals() { let lua = create_sandbox().unwrap(); let input = json!({"key": "val"}); let mut params = HashMap::new(); params.insert("limit".to_string(), json!(10)); set_procedure_context( &lua, "com.example.doThing", &input, ¶ms, "did:plc:test", "com.example.thing", None, None, ) .unwrap();
let globals = lua.globals(); assert_eq!( globals.get::<String>("method").unwrap(), "com.example.doThing" ); assert_eq!(globals.get::<String>("caller_did").unwrap(), "did:plc:test"); assert_eq!( globals.get::<String>("collection").unwrap(), "com.example.thing" ); assert!(globals.get::<mlua::Value>("delegate_did").unwrap().is_nil());
let input_table: mlua::Table = globals.get("input").unwrap(); assert_eq!(input_table.get::<String>("key").unwrap(), "val");
let params_table: mlua::Table = globals.get("params").unwrap(); assert_eq!(params_table.get::<i64>("limit").unwrap(), 10); }
#[test] fn query_context_sets_all_globals() { let lua = create_sandbox().unwrap(); let mut params = HashMap::new(); params.insert("limit".to_string(), json!("10")); params.insert("cursor".to_string(), json!("abc")); set_query_context( &lua, "com.example.listThings", ¶ms, "com.example.thing", Some("did:plc:test"), None, ) .unwrap();
let globals = lua.globals(); assert_eq!( globals.get::<String>("method").unwrap(), "com.example.listThings" ); assert_eq!( globals.get::<String>("collection").unwrap(), "com.example.thing" );
let params_table: mlua::Table = globals.get("params").unwrap(); assert_eq!(params_table.get::<String>("limit").unwrap(), "10"); assert_eq!(params_table.get::<String>("cursor").unwrap(), "abc"); }
#[test] fn procedure_context_with_delegate_did() { let lua = create_sandbox().unwrap(); let input = json!({"key": "val"}); let params = HashMap::new(); set_procedure_context( &lua, "com.example.doThing", &input, ¶ms, "did:plc:caller", "com.example.thing", None, Some("did:plc:delegate"), ) .unwrap();
let globals = lua.globals(); assert_eq!( globals.get::<String>("delegate_did").unwrap(), "did:plc:delegate" ); assert_eq!( globals.get::<String>("caller_did").unwrap(), "did:plc:caller" ); }
#[test] fn env_context_sets_table() { let lua = create_sandbox().unwrap(); let mut vars = HashMap::new(); vars.insert("API_KEY".to_string(), "secret123".to_string()); vars.insert("OTHER".to_string(), "value".to_string()); set_env_context(&lua, &vars).unwrap();
let globals = lua.globals(); let env: mlua::Table = globals.get("env").unwrap(); assert_eq!(env.get::<String>("API_KEY").unwrap(), "secret123"); assert_eq!(env.get::<String>("OTHER").unwrap(), "value"); }
#[test] fn env_context_empty_map() { let lua = create_sandbox().unwrap(); let vars = HashMap::new(); set_env_context(&lua, &vars).unwrap();
let globals = lua.globals(); let env: mlua::Table = globals.get("env").unwrap(); assert!(env.get::<mlua::Value>("anything").unwrap().is_nil()); }
#[test] fn query_context_with_space() { let lua = create_sandbox().unwrap(); let params = HashMap::new(); let space = SpaceContext { space: "at://did:plc:owner/space/com.example.forum/main".into(), space_id: "space-123".into(), did: "did:plc:owner".into(), authority_did: "did:plc:owner".into(), type_nsid: "com.example.forum".into(), skey: "main".into(), }; set_query_context( &lua, "com.example.listPosts", ¶ms, "com.example.forum.post", Some("did:plc:test"), Some(&space), ) .unwrap();
let globals = lua.globals(); let space_table: mlua::Table = globals.get("space").unwrap(); assert_eq!( space_table.get::<String>("space").unwrap(), "at://did:plc:owner/space/com.example.forum/main" ); assert_eq!(space_table.get::<String>("space_id").unwrap(), "space-123"); assert_eq!(space_table.get::<String>("did").unwrap(), "did:plc:owner"); }
#[test] fn query_context_without_space() { let lua = create_sandbox().unwrap(); let params = HashMap::new(); set_query_context( &lua, "com.example.listThings", ¶ms, "com.example.thing", None, None, ) .unwrap();
let globals = lua.globals(); assert!(globals.get::<mlua::Value>("space").unwrap().is_nil()); }
#[test] fn hook_context_record_nil_on_delete() { let lua = create_sandbox().unwrap(); set_hook_context( &lua, "delete", "at://did:plc:abc/col/rkey", "did:plc:abc", "col", "rkey", None, ) .unwrap();
let globals = lua.globals(); assert_eq!(globals.get::<String>("action").unwrap(), "delete"); assert!(globals.get::<mlua::Value>("record").unwrap().is_nil()); }}