use super::Pyo3Backend;
use super::config::cfg_present_for_pyo3;
use super::mutex::{rewrite_to_tokio_mutex_impl, rewrite_to_tokio_mutex_struct};
use crate::backends::pyo3::type_map::Pyo3Mapper;
use crate::codegen::generators::gen_pyo3_data_enum_with_mapper;
use crate::core::backend::Backend;
use crate::core::config::Language;
use crate::core::ir::{EnumDef, EnumVariant, FieldDef, PrimitiveType, TypeRef};
#[test]
fn data_enum_emits_variant_constructors_through_pyo3_mapper() {
let str_field = |name: &str| FieldDef {
name: name.to_string(),
ty: TypeRef::String,
..Default::default()
};
let def = EnumDef {
name: "EmbeddingModelType".to_string(),
rust_path: "crate::EmbeddingModelType".to_string(),
serde_tag: Some("type".to_string()),
has_serde: true,
variants: vec![
EnumVariant {
name: "Preset".to_string(),
fields: vec![str_field("name")],
..Default::default()
},
EnumVariant {
name: "Custom".to_string(),
fields: vec![
str_field("model_id"),
FieldDef {
name: "dimensions".to_string(),
ty: TypeRef::Primitive(PrimitiveType::U32),
..Default::default()
},
],
..Default::default()
},
],
..Default::default()
};
let generated = gen_pyo3_data_enum_with_mapper(&def, "core", Some(&Pyo3Mapper::new()));
assert!(generated.contains("#[staticmethod]"), "{generated}");
assert!(generated.contains(r#"#[pyo3(name = "preset")]"#), "{generated}");
assert!(
generated.contains("pub fn _factory_preset(name: String) -> Self"),
"{generated}"
);
assert!(
generated.contains("Self { inner: crate::EmbeddingModelType::Preset { name } }"),
"{generated}"
);
assert!(generated.contains(r#"#[pyo3(name = "custom")]"#), "{generated}");
assert!(
generated.contains("pub fn _factory_custom(model_id: String, dimensions: u32) -> Self"),
"{generated}"
);
assert!(
generated.contains("Self { inner: crate::EmbeddingModelType::Custom { model_id, dimensions } }"),
"{generated}"
);
}
#[test]
fn pyo3_backend_name_is_pyo3() {
let b = Pyo3Backend;
assert_eq!(b.name(), "pyo3");
}
#[test]
fn pyo3_backend_language_is_python() {
let b = Pyo3Backend;
assert_eq!(b.language(), Language::Python);
}
#[test]
fn rewrite_tokio_mutex_struct_replaces_std_mutex() {
let input = "pub inner: Arc<std::sync::Mutex<MyType>>";
let result = rewrite_to_tokio_mutex_struct(input);
assert_eq!(result, "pub inner: Arc<tokio::sync::Mutex<MyType>>");
}
#[test]
fn rewrite_tokio_mutex_struct_noop_when_no_std_mutex() {
let input = "pub inner: Arc<tokio::sync::Mutex<MyType>>";
let result = rewrite_to_tokio_mutex_struct(input);
assert_eq!(result, input);
}
#[test]
fn rewrite_tokio_mutex_impl_replaces_all_patterns() {
let input = concat!(
"pub inner: Arc<std::sync::Mutex<MyType>>,\n",
"Self { inner: Arc::new(std::sync::Mutex::new(val)) }\n",
"let guard = self.inner.lock().unwrap();\n",
);
let result = rewrite_to_tokio_mutex_impl(input);
assert!(result.contains("Arc<tokio::sync::Mutex<MyType>>"));
assert!(result.contains("Arc::new(tokio::sync::Mutex::new(val))"));
assert!(result.contains("self.inner.lock().await"));
}
#[test]
fn rewrite_tokio_mutex_impl_noop_when_already_tokio() {
let input = concat!(
"pub inner: Arc<tokio::sync::Mutex<MyType>>,\n",
"Self { inner: Arc::new(tokio::sync::Mutex::new(val)) }\n",
"let guard = self.inner.lock().await;\n",
);
let result = rewrite_to_tokio_mutex_impl(input);
assert_eq!(result, input);
}
#[test]
fn cfg_present_for_pyo3_accepts_non_wasm_gate() {
assert!(cfg_present_for_pyo3("not(target_arch = \"wasm32\")"));
assert!(cfg_present_for_pyo3("not (target_arch = \"wasm32\")"));
}
#[test]
fn cfg_present_for_pyo3_accepts_feature_gates() {
assert!(cfg_present_for_pyo3("feature = \"pdf\""));
assert!(cfg_present_for_pyo3("feature = \"html\""));
assert!(cfg_present_for_pyo3("feature=\"tree-sitter\""));
assert!(cfg_present_for_pyo3(
"any(feature=\"keywords-yake\", feature=\"keywords-rake\")"
));
}
#[test]
fn cfg_present_for_pyo3_rejects_unsupported_gates() {
assert!(!cfg_present_for_pyo3("target_arch = \"wasm32\""));
assert!(!cfg_present_for_pyo3("any(unix, windows)"));
assert!(!cfg_present_for_pyo3("any(unix, feature=\"pdf\")"));
}
fn python_config() -> crate::core::config::ResolvedCrateConfig {
let cfg: crate::core::config::new_config::NewAlefConfig = toml::from_str(
r#"
[workspace]
languages = ["python"]
[[crates]]
name = "test-lib"
sources = ["src/lib.rs"]
[crates.python]
module_name = "test_lib"
"#,
)
.unwrap();
cfg.resolve().unwrap().remove(0)
}
#[test]
fn struct_impl_block_skips_method_colliding_with_a_field_getter() {
use crate::core::ir::{ApiSurface, MethodDef, ReceiverKind, TypeDef};
let api = ApiSurface {
crate_name: "test-lib".to_string(),
version: "0.1.0".to_string(),
types: vec![TypeDef {
name: "LlmConfig".to_string(),
rust_path: "test_lib::LlmConfig".to_string(),
has_serde: true,
fields: vec![FieldDef {
name: "providers".to_string(),
ty: TypeRef::String,
optional: true,
..Default::default()
}],
methods: vec![MethodDef {
name: "providers".to_string(),
return_type: TypeRef::String,
receiver: Some(ReceiverKind::Ref),
..Default::default()
}],
..Default::default()
}],
..Default::default()
};
let files = Pyo3Backend.generate_bindings(&api, &python_config()).unwrap();
let content = &files[0].content;
assert!(
content.contains("pub providers:"),
"the struct field must still be emitted:\n{content}"
);
let wrappers = content.matches("fn providers(&self)").count();
assert_eq!(
wrappers, 0,
"the same-named #[pymethods] wrapper must be skipped, found {wrappers}:\n{content}"
);
}