use libR_sys::*;
use std::os::raw;
use crate::*;
use std::collections::HashMap;
use std::iter::IntoIterator;
use std::ops::{Range, RangeInclusive};
mod from_robj;
mod into_robj;
mod operators;
mod rinternals;
mod try_from_robj;
#[cfg(test)]
mod tests;
pub use from_robj::*;
pub use into_robj::*;
pub use iter::*;
pub use operators::*;
pub use rinternals::*;
pub enum Robj {
#[doc(hidden)]
Owned(SEXP),
#[doc(hidden)]
Sys(SEXP),
}
impl Clone for Robj {
fn clone(&self) -> Self {
unsafe {
match *self {
Robj::Owned(sexp) => new_owned(sexp),
Robj::Sys(sexp) => new_sys(sexp),
}
}
}
}
impl Default for Robj {
fn default() -> Self {
Robj::from(())
}
}
impl Robj {
#[doc(hidden)]
pub unsafe fn get(&self) -> SEXP {
match self {
Robj::Owned(sexp) => *sexp,
Robj::Sys(sexp) => *sexp,
}
}
#[doc(hidden)]
pub unsafe fn get_mut(&mut self) -> Option<SEXP> {
match self {
Robj::Owned(sexp) => Some(*sexp),
Robj::Sys(_) => None,
}
}
#[doc(hidden)]
pub fn sexptype(&self) -> u32 {
unsafe { TYPEOF(self.get()) as u32 }
}
pub fn rtype(&self) -> RType {
match self.sexptype() {
NILSXP => RType::Null,
SYMSXP => RType::Symbol,
LISTSXP => RType::Pairlist,
CLOSXP => RType::Function,
ENVSXP => RType::Environment,
PROMSXP => RType::Promise,
LANGSXP => RType::Language,
SPECIALSXP => RType::Special,
BUILTINSXP => RType::Builtin,
CHARSXP => RType::Character,
LGLSXP => RType::Logical,
INTSXP => RType::Integer,
REALSXP => RType::Real,
CPLXSXP => RType::Complex,
STRSXP => RType::String,
DOTSXP => RType::Dot,
ANYSXP => RType::Any,
VECSXP => RType::List,
EXPRSXP => RType::Expression,
BCODESXP => RType::Bytecode,
EXTPTRSXP => RType::ExternalPtr,
WEAKREFSXP => RType::WeakRef,
RAWSXP => RType::Raw,
S4SXP => RType::S4,
_ => RType::Unknown,
}
}
pub fn len(&self) -> usize {
unsafe { Rf_xlength(self.get()) as usize }
}
pub fn is_empty(&self) -> bool {
self.len() == 0
}
pub fn is_na(&self) -> bool {
if self.len() != 1 {
false
} else {
unsafe {
let sexp = self.get();
match self.sexptype() {
STRSXP => STRING_ELT(sexp, 0) == libR_sys::R_NaString,
INTSXP => *(INTEGER(sexp)) == libR_sys::R_NaInt,
LGLSXP => *(LOGICAL(sexp)) == libR_sys::R_NaInt,
REALSXP => R_IsNA(*(REAL(sexp))) != 0,
_ => false,
}
}
}
}
pub fn as_integer_slice<'a>(&self) -> Option<&'a [i32]> {
self.as_typed_slice()
}
pub fn as_integer_iter(&self) -> Option<Int> {
self.as_integer_slice()
.map(|slice| Int::from_slice(self.to_owned(), slice))
}
pub fn as_integer_vector(&self) -> Option<Vec<i32>> {
self.as_integer_slice().map(|value| value.to_vec())
}
pub fn as_logical_slice(&self) -> Option<&[Bool]> {
self.as_typed_slice()
}
pub fn as_logical_vector(&self) -> Option<Vec<Bool>> {
self.as_logical_slice().map(|value| value.to_vec())
}
pub fn as_logical_iter(&self) -> Option<Logical> {
self.as_logical_slice()
.map(|slice| Logical::from_slice(self.to_owned(), slice))
}
pub fn as_real_slice(&self) -> Option<&[f64]> {
self.as_typed_slice()
}
pub fn as_real_iter(&self) -> Option<Real> {
self.as_real_slice()
.map(|slice| Real::from_slice(self.to_owned(), slice))
}
pub fn as_real_vector(&self) -> Option<Vec<f64>> {
self.as_real_slice().map(|value| value.to_vec())
}
pub fn as_raw_slice(&self) -> Option<&[u8]> {
self.as_typed_slice()
}
pub fn as_integer_slice_mut(&mut self) -> Option<&mut [i32]> {
self.as_typed_slice_mut()
}
pub fn as_real_slice_mut(&mut self) -> Option<&mut [f64]> {
self.as_typed_slice_mut()
}
pub fn as_raw_slice_mut(&mut self) -> Option<&mut [u8]> {
self.as_typed_slice_mut()
}
pub fn as_string_vector(&self) -> Option<Vec<String>> {
self.as_str_iter()
.map(|iter| iter.map(str::to_string).collect())
}
pub fn as_str_vector(&self) -> Option<Vec<&str>> {
self.as_str_iter().map(|iter| iter.collect())
}
pub fn as_str<'a>(&self) -> Option<&'a str> {
unsafe {
match self.sexptype() {
STRSXP => {
if self.len() != 1 {
None
} else {
Some(to_str(R_CHAR(STRING_ELT(self.get(), 0)) as *const u8))
}
}
_ => None,
}
}
}
pub fn as_integer(&self) -> Option<i32> {
match self.as_integer_slice() {
Some(slice) if slice.len() == 1 && !slice[0].is_na() => Some(slice[0]),
_ => None,
}
}
pub fn as_real(&self) -> Option<f64> {
match self.as_real_slice() {
Some(slice) if slice.len() == 1 && !slice[0].is_na() => Some(slice[0]),
_ => None,
}
}
pub fn as_bool(&self) -> Option<bool> {
match self.as_logical_slice() {
Some(slice) if slice.len() == 1 && !slice[0].is_na() => Some(slice[0].into()),
_ => None,
}
}
pub fn as_logical(&self) -> Option<Bool> {
match self.as_logical_slice() {
Some(slice) if slice.len() == 1 => Some(slice[0]),
_ => None,
}
}
pub fn eval(&self) -> Result<Robj> {
self.eval_with_env(&global_env())
}
pub fn eval_with_env(&self, env: &Environment) -> Result<Robj> {
single_threaded(|| unsafe {
let mut error: raw::c_int = 0;
let res = R_tryEval(self.get(), env.get(), &mut error as *mut raw::c_int);
if error != 0 {
Err(Error::EvalError(self.clone()))
} else {
Ok(new_owned(res))
}
})
}
pub fn eval_blind(&self) -> Robj {
let res = self.eval();
if let Ok(robj) = res {
robj
} else {
Robj::from(())
}
}
}
pub trait AsTypedSlice<'a, T>
where
Self: 'a,
{
fn as_typed_slice(&self) -> Option<&'a [T]>
where
Self: 'a,
{
None
}
fn as_typed_slice_mut(&mut self) -> Option<&'a mut [T]>
where
Self: 'a,
{
None
}
}
macro_rules! make_typed_slice {
($type: ty, $fn: tt, $($sexp: tt),* ) => {
impl<'a> AsTypedSlice<'a, $type> for Robj
where
Self : 'a,
{
fn as_typed_slice(&self) -> Option<&'a [$type]> {
match self.sexptype() {
$( $sexp )|* => {
unsafe {
let ptr = $fn(self.get()) as *const $type;
Some(std::slice::from_raw_parts(ptr, self.len()))
}
}
_ => None
}
}
fn as_typed_slice_mut(&mut self) -> Option<&'a mut [$type]> {
match self.sexptype() {
$( $sexp )|* => {
unsafe {
let ptr = $fn(self.get()) as *mut $type;
Some(std::slice::from_raw_parts_mut(ptr, self.len()))
}
}
_ => None
}
}
}
}
}
make_typed_slice!(Bool, INTEGER, LGLSXP);
make_typed_slice!(i32, INTEGER, INTSXP);
make_typed_slice!(f64, REAL, REALSXP);
make_typed_slice!(u8, RAW, RAWSXP);
#[allow(non_snake_case)]
impl Robj {
pub fn get_attrib<'a, N>(&self, name: N) -> Option<Robj>
where
Self: 'a,
Robj: From<N> + 'a,
{
let name = Robj::from(name);
if self.sexptype() == CHARSXP {
None
} else {
let res = unsafe { new_owned(Rf_getAttrib(self.get(), name.get())) };
if res.is_null() {
None
} else {
Some(res)
}
}
}
pub fn set_attrib<N, V>(&self, name: N, value: V) -> Result<Robj>
where
N: Into<Robj>,
V: Into<Robj>,
{
let name = name.into();
let value = value.into();
unsafe {
single_threaded(|| {
catch_r_error(|| Rf_setAttrib(self.get(), name.get(), value.get()))
.map(|_| self.clone())
})
}
}
pub fn names(&self) -> Option<StrIter> {
if let Some(names) = self.get_attrib(wrapper::symbol::names_symbol()) {
names.as_str_iter()
} else {
None
}
}
pub fn set_names<T>(&self, names: T) -> Result<Robj>
where
T: IntoIterator,
T::IntoIter: ExactSizeIterator,
T::Item: ToVectorValue + AsRef<str>,
{
let iter = names.into_iter();
let robj = iter.collect_robj();
if robj.len() == self.len() {
self.set_attrib(wrapper::symbol::names_symbol(), robj)
} else {
Err(Error::NamesLengthMismatch(robj))
}
}
pub fn dim(&self) -> Option<Int> {
if let Some(dim) = self.get_attrib(wrapper::symbol::dim_symbol()) {
dim.as_integer_iter()
} else {
None
}
}
pub fn dimnames(&self) -> Option<ListIter> {
if let Some(names) = self.get_attrib(wrapper::symbol::dimnames_symbol()) {
names.as_list().map(|v| v.values())
} else {
None
}
}
pub fn class(&self) -> Option<StrIter> {
if let Some(class) = self.get_attrib(wrapper::symbol::class_symbol()) {
class.as_str_iter()
} else {
None
}
}
pub fn set_class<T>(&self, class: T) -> Result<Robj>
where
T: IntoIterator,
T::IntoIter: ExactSizeIterator,
T::Item: ToVectorValue + AsRef<str>,
{
let iter = class.into_iter();
self.set_attrib(wrapper::symbol::class_symbol(), iter.collect_robj())
}
pub fn inherits(&self, classname: &str) -> bool {
if let Some(mut iter) = self.class() {
iter.any(|n| n == classname)
} else {
false
}
}
pub fn levels(&self) -> Option<StrIter> {
if let Some(levels) = self.get_attrib(wrapper::symbol::levels_symbol()) {
levels.as_str_iter()
} else {
None
}
}
}
#[doc(hidden)]
pub unsafe fn new_owned(sexp: SEXP) -> Robj {
single_threaded(|| ownership::protect(sexp));
Robj::Owned(sexp)
}
#[doc(hidden)]
pub unsafe fn new_sys(sexp: SEXP) -> Robj {
Robj::Sys(sexp)
}
impl<'a> PartialEq<[i32]> for Robj {
fn eq(&self, rhs: &[i32]) -> bool {
self.as_integer_slice() == Some(rhs)
}
}
impl<'a> PartialEq<[f64]> for Robj {
fn eq(&self, rhs: &[f64]) -> bool {
self.as_real_slice() == Some(rhs)
}
}
impl PartialEq<str> for Robj {
fn eq(&self, rhs: &str) -> bool {
self.as_str() == Some(rhs)
}
}
impl PartialEq<Robj> for Robj {
fn eq(&self, rhs: &Robj) -> bool {
unsafe {
if self.get() == rhs.get() {
return true;
}
R_compute_identical(self.get(), rhs.get(), 16) != 0
}
}
}
impl std::fmt::Debug for Robj {
fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
match self.sexptype() {
NILSXP => write!(f, "r!(NULL)"),
SYMSXP => {
if self.is_missing_arg() {
write!(f, "missing_arg()")
} else if self.is_unbound_value() {
write!(f, "unbound_value()")
} else {
write!(f, "sym!({})", self.as_symbol().unwrap().as_str())
}
}
LISTSXP => {
let pairlist = self.as_pairlist().unwrap().iter();
write!(f, "r!({:?})", pairlist)
}
CLOSXP => {
let func = self.as_function().unwrap();
let formals = func.formals();
let body = func.body();
let environment = func.environment();
write!(
f,
"r!(Function::from_parts({:?}, {:?}, {:?}))",
formals, body, environment
)
}
ENVSXP => unsafe {
let sexp = self.get();
if sexp == R_GlobalEnv {
write!(f, "global_env()")
} else if sexp == R_BaseEnv {
write!(f, "base_env()")
} else if sexp == R_EmptyEnv {
write!(f, "empty_env()")
} else {
write!(f, "r!(Environment::from_pairs(...))")
}
},
PROMSXP => {
let p = self.as_promise().unwrap();
write!(
f,
"r!(Promise::from_parts({:?}, {:?}))",
p.code(),
p.environment()
)
}
LANGSXP => write!(
f,
"r!(Language::from_values({:?}))",
self.as_language().unwrap().values().collect::<Vec<_>>()
),
SPECIALSXP => write!(f, "r!(Special())"),
BUILTINSXP => write!(f, "r!(Builtin())"),
CHARSXP => {
let c = Character::try_from(self.clone()).unwrap();
write!(f, "r!(Character::from_string({:?}))", c.as_str())
}
LGLSXP => {
let slice = self.as_logical_slice().unwrap();
if slice.len() == 1 {
write!(f, "r!({:?})", slice[0])
} else {
write!(f, "r!({:?})", slice)
}
}
INTSXP => {
let slice = self.as_integer_slice().unwrap();
if slice.len() == 1 {
write!(f, "r!({:?})", slice[0])
} else {
write!(f, "r!({:?})", self.as_integer_slice().unwrap())
}
}
REALSXP => {
let slice = self.as_real_slice().unwrap();
if slice.len() == 1 {
write!(f, "r!({:?})", slice[0])
} else {
write!(f, "r!({:?})", slice)
}
}
VECSXP => {
let list = self.as_list().unwrap();
if self.names().is_some() {
write!(f, "r!(List::from_pairs({:?}))", list.iter())
} else {
write!(f, "r!(List::from_values({:?}))", list.values())
}
}
EXPRSXP => write!(
f,
"r!(Expression::from_values({:?}))",
self.as_expression().unwrap().values()
),
WEAKREFSXP => write!(f, "r!(Weakref())"),
STRSXP => {
write!(f, "r!([")?;
let mut sep = "";
for s in self.as_str_iter().unwrap() {
write!(f, "{}{:?}", sep, s)?;
sep = ", ";
}
write!(f, "])")
}
DOTSXP => write!(f, "r!(Dot())"),
ANYSXP => write!(f, "r!(Any())"),
BCODESXP => write!(f, "r!(Bcode())"),
EXTPTRSXP => write!(f, "r!(Extptr())"),
RAWSXP => {
write!(
f,
"r!(Raw::from_bytes({:?}))",
self.as_raw().unwrap().as_slice()
)
}
S4SXP => write!(f, "r!(S4())"),
NEWSXP => write!(f, "r!(New())"),
FREESXP => write!(f, "r!(Free())"),
_ => write!(f, "??"),
}?;
if let Some(c) = self.class() {
write!(f, ".set_class({:?}", c)?;
}
Ok(())
}
}
pub(crate) unsafe fn to_str<'a>(ptr: *const u8) -> &'a str {
let mut len = 0;
loop {
if *ptr.offset(len) == 0 {
break;
}
len += 1;
}
let slice = std::slice::from_raw_parts(ptr, len as usize);
std::str::from_utf8_unchecked(slice)
}
impl Drop for Robj {
fn drop(&mut self) {
unsafe {
match self {
Robj::Owned(sexp) => ownership::unprotect(*sexp),
Robj::Sys(_) => (),
}
}
}
}