use oxide_kernel::shape_forge::EMPTY_SHAPE_ID; use oxide_types::object::JsObject; use oxide_types::value::JsValue; use crate::set::SetKey; use oxide_runtime_api::{NativeResult, VmHost}; macro_rules! native_try { ($expr:expr) => { match $expr { Ok(value) => value, Err(err) => return NativeResult::Err(err), } }; } pub(crate) type MapInner = indexmap::IndexMap; /// Retrieve the `IndexMap` pointer stored in a Map object's native-data slot. /// /// # Safety contract maintained by callers /// /// The pointer is valid as long as the Map `JsObject` itself is alive, which is guaranteed /// because the `JsObject` lives in the current `Epoch` arena and `Epoch::reset()` is never /// called while a native builtin is executing. The `Box` that owns the allocation /// is created in `new_map_inner()` and is never freed until the process exits (intentional /// leak — lifetime is tied to the epoch). Only one live `*mut` alias exists at a time /// per Map object because native calls are single-threaded. fn get_map_inner(vm: &mut H, this_val: JsValue) -> Result<*mut MapInner, JsValue> { if !this_val.is_object() { return Err(crate::error::create_type_error(vm, "called on non-Map object")); } let map_ptr = this_val.as_js_object_ptr(); if map_ptr.is_null() { return Err(crate::error::create_type_error(vm, "Map internal state invalid")); } // SAFETY: map_ptr is a non-null, aligned pointer to a JsObject bump-allocated in the // current Epoch. It remains valid for the duration of this call (epoch is not reset // during native execution). let map_obj = unsafe { &*map_ptr }; if !map_obj.is_map() { return Err(crate::error::create_type_error( vm, "Map.prototype method called on incompatible receiver", )); } // SAFETY: native_data holds the raw pointer written by `alloc_map`. // The pointer is a valid, heap-allocated `Box>`. // Alignment: IndexMap requires at most 8-byte alignment; the global allocator satisfies this. let inner_ptr = map_obj.native_data() as *mut MapInner; if inner_ptr.is_null() { return Err(crate::error::create_type_error(vm, "Map internal state invalid")); } Ok(inner_ptr) } fn new_map_inner() -> *mut MapInner { Box::into_raw(Box::new(MapInner::new())) } fn alloc_map(vm: &mut H) -> *mut JsObject { let map_proto = vm.session().builtin_world().map_proto.as_ptr() as *mut JsObject; let mut obj = JsObject::new_empty(EMPTY_SHAPE_ID, JsValue::from_js_object(map_proto)); obj.set_map(true); let inner = new_map_inner(); obj.set_native_data(inner as *mut u8); vm.alloc_object(obj) } /// 收集 Map 中作为对象引用的键和值(GC 根边),供跨 epoch 遍历/重写时追踪。 pub fn map_native_edges(obj: &JsObject) -> Vec { if !obj.is_map() { return Vec::new(); } let inner = obj.native_data() as *const MapInner; if inner.is_null() { return Vec::new(); } unsafe { (*inner) .iter() .flat_map(|(key, value)| [key.0, *value]) .filter(|value: &JsValue| value.is_object()) .collect() } } /// 克隆 Map 的 native 数据到新对象,用 `rewrite` 改写其中的对象引用 /// (供跨 epoch 的对象重写/克隆流程使用)。 pub fn clone_map_native_with_rewrite(src: &JsObject, dst: &mut JsObject, mut rewrite: F) where F: FnMut(JsValue) -> JsValue, { if !src.is_map() { return; } let inner = src.native_data() as *const MapInner; if inner.is_null() { dst.set_native_data(std::ptr::null_mut()); return; } let mut cloned = MapInner::new(); unsafe { for (key, value) in (*inner).iter() { let new_key = if key.0.is_object() { SetKey(rewrite(key.0)) } else { *key }; let new_value = if value.is_object() { rewrite(*value) } else { *value }; cloned.insert(new_key, new_value); } } dst.set_native_data(Box::into_raw(Box::new(cloned)) as *mut u8); } /// 原地重写 Map 的 native 数据,用 `rewrite` 改写其中的对象引用。 pub fn rewrite_map_native(obj: &mut JsObject, mut rewrite: F) where F: FnMut(JsValue) -> JsValue, { if !obj.is_map() { return; } let inner = obj.native_data() as *mut MapInner; if inner.is_null() { return; } unsafe { let mut rewritten = MapInner::with_capacity((*inner).len()); for (key, value) in (*inner).iter() { let new_key = if key.0.is_object() { SetKey(rewrite(key.0)) } else { *key }; let new_value = if value.is_object() { rewrite(*value) } else { *value }; rewritten.insert(new_key, new_value); } *inner = rewritten; } } /// 释放 Map 的 native 数据(IndexMap),返回释放的字节数供泄漏统计。 pub fn drop_map_native(obj: &mut JsObject) -> u64 { if !obj.is_map() { return 0; } let inner = obj.native_data() as *mut MapInner; if inner.is_null() { return 0; } unsafe { let boxed: Box = Box::from_raw(inner); let bytes = std::mem::size_of::() + boxed.capacity() * std::mem::size_of::<(SetKey, JsValue)>(); drop(boxed); obj.set_native_data(std::ptr::null_mut()); bytes as u64 } } /// `Map` 构造函数:创建带空 IndexMap native 数据的 Map 对象。 pub fn map_constructor(vm: &mut H, _args: &[u8]) -> NativeResult { let map_obj = alloc_map(vm); NativeResult::Ok(JsValue::from_js_object(map_obj)) } /// `Map.prototype.set(key, value)`:插入/更新键值对,返回 this。 pub fn map_set(vm: &mut H, args: &[u8]) -> NativeResult { let this_val = vm.reg(if args.is_empty() { 0 } else { args[0] }); let inner = native_try!(get_map_inner(vm, this_val)); let key = vm.reg(if args.len() > 1 { args[1] } else { 0 }); let val = vm.reg(if args.len() > 2 { args[2] } else { 0 }); unsafe { (*inner).insert(SetKey(key), val); } NativeResult::Ok(this_val) } /// `Map.prototype.get(key)`:返回 key 对应的值;不存在返回 undefined。 pub fn map_get(vm: &mut H, args: &[u8]) -> NativeResult { let this_val = vm.reg(if args.is_empty() { 0 } else { args[0] }); let inner = native_try!(get_map_inner(vm, this_val)); let key = vm.reg(if args.len() > 1 { args[1] } else { 0 }); let found = unsafe { (*inner).get(&SetKey(key)).copied() }; NativeResult::Ok(found.unwrap_or(JsValue::undefined())) } /// `Map.prototype.has(key)`:key 是否存在。 pub fn map_has(vm: &mut H, args: &[u8]) -> NativeResult { let this_val = vm.reg(if args.is_empty() { 0 } else { args[0] }); let inner = native_try!(get_map_inner(vm, this_val)); let key = vm.reg(if args.len() > 1 { args[1] } else { 0 }); let found = unsafe { (*inner).contains_key(&SetKey(key)) }; NativeResult::Ok(JsValue::bool(found)) } /// `Map.prototype.delete(key)`:删除键并返回是否删除成功。 pub fn map_delete(vm: &mut H, args: &[u8]) -> NativeResult { let this_val = vm.reg(if args.is_empty() { 0 } else { args[0] }); let inner = native_try!(get_map_inner(vm, this_val)); let key = vm.reg(if args.len() > 1 { args[1] } else { 0 }); let removed = unsafe { (*inner).shift_remove(&SetKey(key)) }; NativeResult::Ok(JsValue::bool(removed.is_some())) } /// `Map.prototype.clear()`:清空全部键值对,返回 undefined。 pub fn map_clear(vm: &mut H, args: &[u8]) -> NativeResult { let this_val = vm.reg(if args.is_empty() { 0 } else { args[0] }); let inner = native_try!(get_map_inner(vm, this_val)); unsafe { (*inner).clear(); } NativeResult::Ok(JsValue::undefined()) } /// `Map.prototype.size` getter:返回键值对数量。 pub fn map_size(vm: &mut H, args: &[u8]) -> NativeResult { let this_val = vm.reg(if args.is_empty() { 0 } else { args[0] }); let inner = native_try!(get_map_inner(vm, this_val)); NativeResult::Ok(JsValue::float(unsafe { (*inner).len() } as f64)) } /// `Map.prototype.entries()`:返回按插入序迭代 `[key, value]` 对的迭代器。 pub fn map_entries(vm: &mut H, args: &[u8]) -> NativeResult { let this_val = vm.reg(if args.is_empty() { 0 } else { args[0] }); let _inner = native_try!(get_map_inner(vm, this_val)); NativeResult::Ok(crate::iterator::make_mode_iterator( vm, this_val, crate::iterator::map_entries_iter_next:: as *const (), )) } /// `Map.prototype.values()`:返回按插入序迭代值的迭代器。 pub fn map_values(vm: &mut H, args: &[u8]) -> NativeResult { let this_val = vm.reg(if args.is_empty() { 0 } else { args[0] }); let _inner = native_try!(get_map_inner(vm, this_val)); NativeResult::Ok(crate::iterator::make_mode_iterator( vm, this_val, crate::iterator::map_values_iter_next:: as *const (), )) } /// `Map.prototype.keys()`:返回按插入序迭代键的迭代器。 pub fn map_keys(vm: &mut H, args: &[u8]) -> NativeResult { let this_val = vm.reg(if args.is_empty() { 0 } else { args[0] }); let _inner = native_try!(get_map_inner(vm, this_val)); NativeResult::Ok(crate::iterator::make_mode_iterator( vm, this_val, crate::iterator::map_keys_iter_next:: as *const (), )) }