extern crate fidius_core as fidius;
use fidius_macro::{plugin_impl, plugin_interface};
#[plugin_interface(version = 1, buffer = PluginAllocated)]
#[trait_meta("kind", "integration")]
#[trait_meta("stability", "stable")]
pub trait Tagged: Send + Sync {
#[method_meta("effect", "write")]
#[method_meta("idempotent", "false")]
fn create(&self, name: String) -> String;
#[method_meta("effect", "read")]
fn list(&self) -> String;
fn version(&self) -> String;
}
pub struct MyTagged;
#[plugin_impl(Tagged)]
impl Tagged for MyTagged {
fn create(&self, name: String) -> String {
format!("created:{name}")
}
fn list(&self) -> String {
"listed".into()
}
fn version(&self) -> String {
"v1".into()
}
}
fidius_core::fidius_plugin_registry!();
fn read_cstr(ptr: *const std::ffi::c_char) -> &'static str {
unsafe { std::ffi::CStr::from_ptr(ptr) }
.to_str()
.expect("valid utf-8")
}
#[test]
fn trait_metadata_is_populated() {
let reg = fidius_core::registry::get_registry();
assert_eq!(reg.plugin_count, 1);
let desc = unsafe { &**reg.descriptors };
assert!(!desc.trait_metadata.is_null());
assert_eq!(desc.trait_metadata_count, 2);
let slice = unsafe { std::slice::from_raw_parts(desc.trait_metadata, 2) };
assert_eq!(read_cstr(slice[0].key), "kind");
assert_eq!(read_cstr(slice[0].value), "integration");
assert_eq!(read_cstr(slice[1].key), "stability");
assert_eq!(read_cstr(slice[1].value), "stable");
}
#[test]
fn method_metadata_is_populated_per_method() {
let reg = fidius_core::registry::get_registry();
let desc = unsafe { &**reg.descriptors };
assert!(!desc.method_metadata.is_null());
let table =
unsafe { std::slice::from_raw_parts(desc.method_metadata, desc.method_count as usize) };
assert!(!table[0].kvs.is_null());
assert_eq!(table[0].kv_count, 2);
let kvs_create = unsafe { std::slice::from_raw_parts(table[0].kvs, 2) };
assert_eq!(read_cstr(kvs_create[0].key), "effect");
assert_eq!(read_cstr(kvs_create[0].value), "write");
assert_eq!(read_cstr(kvs_create[1].key), "idempotent");
assert_eq!(read_cstr(kvs_create[1].value), "false");
assert!(!table[1].kvs.is_null());
assert_eq!(table[1].kv_count, 1);
let kvs_list = unsafe { std::slice::from_raw_parts(table[1].kvs, 1) };
assert_eq!(read_cstr(kvs_list[0].key), "effect");
assert_eq!(read_cstr(kvs_list[0].value), "read");
assert!(table[2].kvs.is_null());
assert_eq!(table[2].kv_count, 0);
}
#[test]
fn interface_hash_unaffected_by_metadata() {
use fidius_core::hash::interface_hash;
let expected = interface_hash(&["create:String->String", "list:->String", "version:->String"]);
assert_eq!(__fidius_Tagged::Tagged_INTERFACE_HASH, expected);
}