| 1 | use std::{ |
| 2 | ptr, |
| 3 | rc::Rc, |
| 4 | sync::{Arc, Mutex}, |
| 5 | }; |
| 6 | |
| 7 | use crate::{check_status, sys, Error, JsUnknown, NapiRaw, NapiValue, Result, Status, ValueType}; |
| 8 | |
| 9 | mod array; |
| 10 | mod arraybuffer; |
| 11 | #[cfg (feature = "napi6" )] |
| 12 | mod bigint; |
| 13 | mod boolean; |
| 14 | mod buffer; |
| 15 | mod class; |
| 16 | #[cfg (all(feature = "chrono_date" , feature = "napi5" ))] |
| 17 | mod date; |
| 18 | mod either; |
| 19 | mod external; |
| 20 | mod function; |
| 21 | mod map; |
| 22 | mod nil; |
| 23 | mod number; |
| 24 | mod object; |
| 25 | #[cfg (all(feature = "tokio_rt" , feature = "napi4" ))] |
| 26 | mod promise; |
| 27 | #[cfg (feature = "serde-json" )] |
| 28 | mod serde; |
| 29 | mod string; |
| 30 | mod symbol; |
| 31 | mod task; |
| 32 | mod value_ref; |
| 33 | |
| 34 | pub use crate::js_values::JsUnknown as Unknown; |
| 35 | #[cfg (feature = "napi5" )] |
| 36 | pub use crate::JsDate as Date; |
| 37 | pub use array::*; |
| 38 | pub use arraybuffer::*; |
| 39 | #[cfg (feature = "napi6" )] |
| 40 | pub use bigint::*; |
| 41 | pub use buffer::*; |
| 42 | pub use class::*; |
| 43 | pub use either::*; |
| 44 | pub use external::*; |
| 45 | pub use function::*; |
| 46 | pub use nil::*; |
| 47 | pub use object::*; |
| 48 | #[cfg (all(feature = "tokio_rt" , feature = "napi4" ))] |
| 49 | pub use promise::*; |
| 50 | pub use string::*; |
| 51 | pub use symbol::*; |
| 52 | pub use task::*; |
| 53 | pub use value_ref::*; |
| 54 | |
| 55 | #[cfg (feature = "latin1" )] |
| 56 | pub use string::latin1_string::*; |
| 57 | |
| 58 | pub trait TypeName { |
| 59 | fn type_name() -> &'static str; |
| 60 | |
| 61 | fn value_type() -> ValueType; |
| 62 | } |
| 63 | |
| 64 | pub trait ToNapiValue { |
| 65 | /// # Safety |
| 66 | /// |
| 67 | /// this function called to convert rust values to napi values |
| 68 | unsafe fn to_napi_value(env: sys::napi_env, val: Self) -> Result<sys::napi_value>; |
| 69 | } |
| 70 | |
| 71 | impl TypeName for JsUnknown { |
| 72 | fn type_name() -> &'static str { |
| 73 | "unknown" |
| 74 | } |
| 75 | |
| 76 | fn value_type() -> ValueType { |
| 77 | ValueType::Unknown |
| 78 | } |
| 79 | } |
| 80 | |
| 81 | impl ValidateNapiValue for JsUnknown {} |
| 82 | |
| 83 | impl ToNapiValue for sys::napi_value { |
| 84 | unsafe fn to_napi_value(_env: sys::napi_env, val: Self) -> Result<sys::napi_value> { |
| 85 | Ok(val) |
| 86 | } |
| 87 | } |
| 88 | |
| 89 | impl<T: NapiRaw> ToNapiValue for T { |
| 90 | unsafe fn to_napi_value(_env: sys::napi_env, val: Self) -> Result<sys::napi_value> { |
| 91 | Ok(unsafe { NapiRaw::raw(&val) }) |
| 92 | } |
| 93 | } |
| 94 | |
| 95 | impl<T: NapiValue> FromNapiValue for T { |
| 96 | unsafe fn from_napi_value(env: sys::napi_env, napi_val: sys::napi_value) -> Result<Self> { |
| 97 | Ok(unsafe { T::from_raw_unchecked(env, value:napi_val) }) |
| 98 | } |
| 99 | } |
| 100 | |
| 101 | pub trait FromNapiValue: Sized { |
| 102 | /// # Safety |
| 103 | /// |
| 104 | /// this function called to convert napi values to native rust values |
| 105 | unsafe fn from_napi_value(env: sys::napi_env, napi_val: sys::napi_value) -> Result<Self>; |
| 106 | |
| 107 | fn from_unknown(value: JsUnknown) -> Result<Self> { |
| 108 | unsafe { Self::from_napi_value(value.0.env, napi_val:value.0.value) } |
| 109 | } |
| 110 | } |
| 111 | |
| 112 | pub trait FromNapiRef { |
| 113 | /// # Safety |
| 114 | /// |
| 115 | /// this function called to convert napi values to native rust values |
| 116 | unsafe fn from_napi_ref(env: sys::napi_env, napi_val: sys::napi_value) -> Result<&'static Self>; |
| 117 | } |
| 118 | |
| 119 | pub trait FromNapiMutRef { |
| 120 | /// # Safety |
| 121 | /// |
| 122 | /// this function called to convert napi values to native rust values |
| 123 | unsafe fn from_napi_mut_ref( |
| 124 | env: sys::napi_env, |
| 125 | napi_val: sys::napi_value, |
| 126 | ) -> Result<&'static mut Self>; |
| 127 | } |
| 128 | |
| 129 | pub trait ValidateNapiValue: TypeName { |
| 130 | /// # Safety |
| 131 | /// |
| 132 | /// this function called to validate whether napi value passed to rust is valid type |
| 133 | /// The reason why this function return `napi_value` is that if a `Promise<T>` passed in |
| 134 | /// we need to return `Promise.reject(T)`, not the `T`. |
| 135 | /// So we need to create `Promise.reject(T)` in this function. |
| 136 | unsafe fn validate(env: sys::napi_env, napi_val: sys::napi_value) -> Result<sys::napi_value> { |
| 137 | let value_type = Self::value_type(); |
| 138 | if value_type == ValueType::Unknown { |
| 139 | return Ok(ptr::null_mut()); |
| 140 | } |
| 141 | |
| 142 | let mut result = -1; |
| 143 | check_status!( |
| 144 | unsafe { sys::napi_typeof(env, napi_val, &mut result) }, |
| 145 | "Failed to detect napi value type" , |
| 146 | )?; |
| 147 | |
| 148 | let received_type = ValueType::from(result); |
| 149 | if value_type == received_type { |
| 150 | Ok(ptr::null_mut()) |
| 151 | } else { |
| 152 | Err(Error::new( |
| 153 | Status::InvalidArg, |
| 154 | format!( |
| 155 | "Expect value to be {}, but received {}" , |
| 156 | value_type, received_type |
| 157 | ), |
| 158 | )) |
| 159 | } |
| 160 | } |
| 161 | } |
| 162 | |
| 163 | impl<T: TypeName> TypeName for Option<T> { |
| 164 | fn type_name() -> &'static str { |
| 165 | T::type_name() |
| 166 | } |
| 167 | |
| 168 | fn value_type() -> ValueType { |
| 169 | T::value_type() |
| 170 | } |
| 171 | } |
| 172 | |
| 173 | impl<T: ValidateNapiValue> ValidateNapiValue for Option<T> { |
| 174 | unsafe fn validate(env: sys::napi_env, napi_val: sys::napi_value) -> Result<sys::napi_value> { |
| 175 | let mut result = -1; |
| 176 | check_status!( |
| 177 | unsafe { sys::napi_typeof(env, napi_val, &mut result) }, |
| 178 | "Failed to detect napi value type" , |
| 179 | )?; |
| 180 | |
| 181 | let received_type = ValueType::from(result); |
| 182 | if received_type == ValueType::Null || received_type == ValueType::Undefined { |
| 183 | Ok(ptr::null_mut()) |
| 184 | } else if let Ok(validate_ret) = unsafe { T::validate(env, napi_val) } { |
| 185 | Ok(validate_ret) |
| 186 | } else { |
| 187 | Err(Error::new( |
| 188 | Status::InvalidArg, |
| 189 | format!( |
| 190 | "Expect value to be Option< {}>, but received {}" , |
| 191 | T::value_type(), |
| 192 | received_type |
| 193 | ), |
| 194 | )) |
| 195 | } |
| 196 | } |
| 197 | } |
| 198 | |
| 199 | impl<T> FromNapiValue for Option<T> |
| 200 | where |
| 201 | T: FromNapiValue, |
| 202 | { |
| 203 | unsafe fn from_napi_value(env: sys::napi_env, napi_val: sys::napi_value) -> Result<Self> { |
| 204 | let mut val_type: i32 = 0; |
| 205 | |
| 206 | check_status!( |
| 207 | unsafe { sys::napi_typeof(env, napi_val, &mut val_type) }, |
| 208 | "Failed to convert napi value into rust type `Option<T>`" , |
| 209 | )?; |
| 210 | |
| 211 | match val_type { |
| 212 | sys::ValueType::napi_undefined | sys::ValueType::napi_null => Ok(None), |
| 213 | _ => Ok(Some(unsafe { T::from_napi_value(env, napi_val)? })), |
| 214 | } |
| 215 | } |
| 216 | } |
| 217 | |
| 218 | impl<T> ToNapiValue for Option<T> |
| 219 | where |
| 220 | T: ToNapiValue, |
| 221 | { |
| 222 | unsafe fn to_napi_value(env: sys::napi_env, val: Self) -> Result<sys::napi_value> { |
| 223 | match val { |
| 224 | Some(val: T) => unsafe { T::to_napi_value(env, val) }, |
| 225 | None => { |
| 226 | let mut ptr: *mut napi_value__ = ptr::null_mut(); |
| 227 | check_status!( |
| 228 | unsafe { sys::napi_get_null(env, &mut ptr) }, |
| 229 | "Failed to convert rust type `Option<T>` into napi value" , |
| 230 | )?; |
| 231 | Ok(ptr) |
| 232 | } |
| 233 | } |
| 234 | } |
| 235 | } |
| 236 | |
| 237 | impl<T> ToNapiValue for Result<T> |
| 238 | where |
| 239 | T: ToNapiValue, |
| 240 | { |
| 241 | unsafe fn to_napi_value(env: sys::napi_env, val: Self) -> Result<sys::napi_value> { |
| 242 | match val { |
| 243 | Ok(v: T) => unsafe { T::to_napi_value(env, val:v) }, |
| 244 | Err(e: Error) => { |
| 245 | let error_code: *mut napi_value__ = unsafe { String::to_napi_value(env, val:format!(" {:?}" , e.status))? }; |
| 246 | let reason: *mut napi_value__ = unsafe { String::to_napi_value(env, val:e.reason.clone())? }; |
| 247 | let mut error: *mut napi_value__ = ptr::null_mut(); |
| 248 | check_status!( |
| 249 | unsafe { sys::napi_create_error(env, error_code, reason, &mut error) }, |
| 250 | "Failed to create napi error" |
| 251 | )?; |
| 252 | |
| 253 | Ok(error) |
| 254 | } |
| 255 | } |
| 256 | } |
| 257 | } |
| 258 | |
| 259 | impl<T: TypeName> TypeName for Rc<T> { |
| 260 | fn type_name() -> &'static str { |
| 261 | T::type_name() |
| 262 | } |
| 263 | |
| 264 | fn value_type() -> ValueType { |
| 265 | T::value_type() |
| 266 | } |
| 267 | } |
| 268 | |
| 269 | impl<T: ValidateNapiValue> ValidateNapiValue for Rc<T> { |
| 270 | unsafe fn validate(env: sys::napi_env, napi_val: sys::napi_value) -> Result<sys::napi_value> { |
| 271 | let mut result: i32 = -1; |
| 272 | check_status!( |
| 273 | unsafe { sys::napi_typeof(env, napi_val, &mut result) }, |
| 274 | "Failed to detect napi value type" , |
| 275 | )?; |
| 276 | |
| 277 | let received_type: ValueType = ValueType::from(result); |
| 278 | if let Ok(validate_ret: *mut napi_value__) = unsafe { T::validate(env, napi_val) } { |
| 279 | Ok(validate_ret) |
| 280 | } else { |
| 281 | Err(Error::new( |
| 282 | Status::InvalidArg, |
| 283 | reason:format!( |
| 284 | "Expect value to be Rc< {}>, but received {}" , |
| 285 | T::value_type(), |
| 286 | received_type |
| 287 | ), |
| 288 | )) |
| 289 | } |
| 290 | } |
| 291 | } |
| 292 | |
| 293 | impl<T> FromNapiValue for Rc<T> |
| 294 | where |
| 295 | T: FromNapiValue, |
| 296 | { |
| 297 | unsafe fn from_napi_value(env: sys::napi_env, napi_val: sys::napi_value) -> Result<Self> { |
| 298 | let mut val_type: i32 = 0; |
| 299 | |
| 300 | check_status!( |
| 301 | unsafe { sys::napi_typeof(env, napi_val, &mut val_type) }, |
| 302 | "Failed to convert napi value into rust type `Rc<T>`" , |
| 303 | )?; |
| 304 | |
| 305 | Ok(Rc::new(unsafe { T::from_napi_value(env, napi_val)? })) |
| 306 | } |
| 307 | } |
| 308 | |
| 309 | impl<T> ToNapiValue for Rc<T> |
| 310 | where |
| 311 | T: ToNapiValue + Clone, |
| 312 | { |
| 313 | unsafe fn to_napi_value(env: sys::napi_env, val: Self) -> Result<sys::napi_value> { |
| 314 | unsafe { T::to_napi_value(env, (*val).clone()) } |
| 315 | } |
| 316 | } |
| 317 | |
| 318 | impl<T: TypeName> TypeName for Arc<T> { |
| 319 | fn type_name() -> &'static str { |
| 320 | T::type_name() |
| 321 | } |
| 322 | |
| 323 | fn value_type() -> ValueType { |
| 324 | T::value_type() |
| 325 | } |
| 326 | } |
| 327 | |
| 328 | impl<T: ValidateNapiValue> ValidateNapiValue for Arc<T> { |
| 329 | unsafe fn validate(env: sys::napi_env, napi_val: sys::napi_value) -> Result<sys::napi_value> { |
| 330 | let mut result: i32 = -1; |
| 331 | check_status!( |
| 332 | unsafe { sys::napi_typeof(env, napi_val, &mut result) }, |
| 333 | "Failed to detect napi value type" , |
| 334 | )?; |
| 335 | |
| 336 | let received_type: ValueType = ValueType::from(result); |
| 337 | if let Ok(validate_ret: *mut napi_value__) = unsafe { T::validate(env, napi_val) } { |
| 338 | Ok(validate_ret) |
| 339 | } else { |
| 340 | Err(Error::new( |
| 341 | Status::InvalidArg, |
| 342 | reason:format!( |
| 343 | "Expect value to be Arc< {}>, but received {}" , |
| 344 | T::value_type(), |
| 345 | received_type |
| 346 | ), |
| 347 | )) |
| 348 | } |
| 349 | } |
| 350 | } |
| 351 | |
| 352 | impl<T> FromNapiValue for Arc<T> |
| 353 | where |
| 354 | T: FromNapiValue, |
| 355 | { |
| 356 | unsafe fn from_napi_value(env: sys::napi_env, napi_val: sys::napi_value) -> Result<Self> { |
| 357 | let mut val_type: i32 = 0; |
| 358 | |
| 359 | check_status!( |
| 360 | unsafe { sys::napi_typeof(env, napi_val, &mut val_type) }, |
| 361 | "Failed to convert napi value into rust type `Arc<T>`" , |
| 362 | )?; |
| 363 | |
| 364 | Ok(Arc::new(data:unsafe { T::from_napi_value(env, napi_val)? })) |
| 365 | } |
| 366 | } |
| 367 | |
| 368 | impl<T> ToNapiValue for Arc<T> |
| 369 | where |
| 370 | T: ToNapiValue + Clone, |
| 371 | { |
| 372 | unsafe fn to_napi_value(env: sys::napi_env, val: Self) -> Result<sys::napi_value> { |
| 373 | unsafe { T::to_napi_value(env, (*val).clone()) } |
| 374 | } |
| 375 | } |
| 376 | |
| 377 | impl<T: TypeName> TypeName for Mutex<T> { |
| 378 | fn type_name() -> &'static str { |
| 379 | T::type_name() |
| 380 | } |
| 381 | |
| 382 | fn value_type() -> ValueType { |
| 383 | T::value_type() |
| 384 | } |
| 385 | } |
| 386 | |
| 387 | impl<T: ValidateNapiValue> ValidateNapiValue for Mutex<T> { |
| 388 | unsafe fn validate(env: sys::napi_env, napi_val: sys::napi_value) -> Result<sys::napi_value> { |
| 389 | let mut result: i32 = -1; |
| 390 | check_status!( |
| 391 | unsafe { sys::napi_typeof(env, napi_val, &mut result) }, |
| 392 | "Failed to detect napi value type" , |
| 393 | )?; |
| 394 | |
| 395 | let received_type: ValueType = ValueType::from(result); |
| 396 | if let Ok(validate_ret: *mut napi_value__) = unsafe { T::validate(env, napi_val) } { |
| 397 | Ok(validate_ret) |
| 398 | } else { |
| 399 | Err(Error::new( |
| 400 | Status::InvalidArg, |
| 401 | reason:format!( |
| 402 | "Expect value to be Mutex< {}>, but received {}" , |
| 403 | T::value_type(), |
| 404 | received_type |
| 405 | ), |
| 406 | )) |
| 407 | } |
| 408 | } |
| 409 | } |
| 410 | |
| 411 | impl<T> FromNapiValue for Mutex<T> |
| 412 | where |
| 413 | T: FromNapiValue, |
| 414 | { |
| 415 | unsafe fn from_napi_value(env: sys::napi_env, napi_val: sys::napi_value) -> Result<Self> { |
| 416 | let mut val_type: i32 = 0; |
| 417 | |
| 418 | check_status!( |
| 419 | unsafe { sys::napi_typeof(env, napi_val, &mut val_type) }, |
| 420 | "Failed to convert napi value into rust type `Mutex<T>`" , |
| 421 | )?; |
| 422 | |
| 423 | Ok(Mutex::new(unsafe { T::from_napi_value(env, napi_val)? })) |
| 424 | } |
| 425 | } |
| 426 | |
| 427 | impl<T> ToNapiValue for Mutex<T> |
| 428 | where |
| 429 | T: ToNapiValue + Clone, |
| 430 | { |
| 431 | unsafe fn to_napi_value(env: sys::napi_env, val: Self) -> Result<sys::napi_value> { |
| 432 | unsafe { |
| 433 | match val.lock() { |
| 434 | Ok(inner: MutexGuard<'_, T>) => T::to_napi_value(env, val:inner.clone()), |
| 435 | Err(_) => Err(Error::new( |
| 436 | Status::GenericFailure, |
| 437 | reason:"Failed to acquire a lock" , |
| 438 | )), |
| 439 | } |
| 440 | } |
| 441 | } |
| 442 | } |
| 443 | |