use crate::{Error, Options, compact_iri, iri::keyword_alias};
use jsonld_context_processing::{Options as ProcessingOptions, Process};
use jsonld_core::{Container, ContainerKind, Context, ContextRef, Id, Loader, Term, Type, Value, object};
use jsonld_syntax::Keyword;
use rdfx::vocabulary::VocabularyMut;
use std::hash::Hash;
pub async fn compact_indexed_value_with<N, L>(
vocabulary: &mut N,
value: &Value<N::Iri>,
index: Option<&str>,
active_context: &Context<N::Iri, N::BlankId>,
active_property: Option<&str>,
loader: &L,
options: Options,
) -> Result<jstrict::Value, Error<L::Error>>
where
N: VocabularyMut,
N::Iri: Clone + Hash + Eq,
N::BlankId: Clone + Hash + Eq,
L: Loader,
{
let mut active_context = ContextRef::Borrowed(active_context);
if let Some(active_property) = active_property
&& let Some(active_property_definition) = active_context.get(active_property)
&& let Some(local_context) = active_property_definition.context()
{
active_context = ContextRef::owned(
local_context
.process_with(
vocabulary,
active_context.as_ref(),
loader,
active_property_definition.base_url().cloned(),
ProcessingOptions::from(options).with_override(),
)
.await?
.into_processed(),
);
}
let mut result = jstrict::Object::default();
let active_property_definition = match active_property {
Some(active_property) => active_context.get(active_property),
None => None,
};
let language = match active_property_definition {
Some(def) => match def.language() {
Some(lang) => lang.as_ref().map(|l| l.as_lenient_lang_tag_ref()).option(),
None => active_context.default_language(),
},
None => active_context.default_language(),
};
let direction = match active_property_definition {
Some(def) => match def.direction() {
Some(dir) => dir.option(),
None => active_context.default_base_direction(),
},
None => active_context.default_base_direction(),
};
let type_mapping: Option<Type<N::Iri>> = match active_property_definition {
Some(def) => def.typ().cloned(),
None => None,
};
let container_mapping = match active_property_definition {
Some(def) => def.container(),
None => Container::None,
};
let remove_index = (index.is_some() && container_mapping.contains(ContainerKind::Index)) || index.is_none();
match value {
Value::Literal(lit, ty) => {
use object::value::Literal;
if ty.clone().map(Type::Iri) == type_mapping && remove_index {
match lit {
Literal::Null => return Ok(jstrict::Value::Null),
Literal::Boolean(b) => return Ok(jstrict::Value::Boolean(*b)),
Literal::Number(n) => return Ok(jstrict::Value::Number(n.clone())),
Literal::String(s) => {
if ty.is_some() || (language.is_none() && direction.is_none()) {
return Ok(jstrict::Value::String(s.as_str().into()));
}
let compact_key = keyword_alias(vocabulary, active_context.as_ref(), options, Keyword::Value);
result.insert(compact_key.into(), jstrict::Value::String(s.as_str().into()));
}
}
} else {
let value_key = keyword_alias(vocabulary, active_context.as_ref(), options, Keyword::Value);
match lit {
Literal::Null => {
result.insert(value_key.into(), jstrict::Value::Null);
}
Literal::Boolean(b) => {
result.insert(value_key.into(), jstrict::Value::Boolean(*b));
}
Literal::Number(n) => {
result.insert(value_key.into(), jstrict::Value::Number(n.clone()));
}
Literal::String(s) => {
result.insert(value_key.into(), jstrict::Value::String(s.as_str().into()));
}
}
if let Some(ty) = ty {
let type_key = keyword_alias(vocabulary, active_context.as_ref(), options, Keyword::Type);
let compact_ty = compact_iri(vocabulary, active_context.as_ref(), &Term::Id(Id::iri(ty.clone())), true, false, options)?;
result.insert(
type_key.into(),
match compact_ty {
Some(s) => jstrict::Value::String((&*s).into()),
None => jstrict::Value::Null,
},
);
}
}
}
Value::LangString(ls) => {
let ls_language = ls.language();
let ls_direction = ls.direction();
if remove_index && (ls_language.is_none() || language == ls_language) && (ls_direction.is_none() || direction == ls_direction) {
return Ok(jstrict::Value::String(ls.as_str().into()));
}
let value_key = keyword_alias(vocabulary, active_context.as_ref(), options, Keyword::Value);
result.insert(value_key.into(), jstrict::Value::String(ls.as_str().into()));
if let Some(language) = ls.language() {
let lang_key = keyword_alias(vocabulary, active_context.as_ref(), options, Keyword::Language);
result.insert(lang_key.into(), jstrict::Value::String(language.as_str().into()));
}
if let Some(direction) = ls.direction() {
let dir_key = keyword_alias(vocabulary, active_context.as_ref(), options, Keyword::Direction);
result.insert(dir_key.into(), jstrict::Value::String(direction.as_str().into()));
}
}
Value::Json(value) => {
if type_mapping == Some(Type::Json) && remove_index {
return Ok(value.clone());
}
let value_key = keyword_alias(vocabulary, active_context.as_ref(), options, Keyword::Value);
result.insert(value_key.into(), value.clone());
let type_key = keyword_alias(vocabulary, active_context.as_ref(), options, Keyword::Type);
let json_alias = keyword_alias(vocabulary, active_context.as_ref(), options, Keyword::Json);
result.insert(type_key.into(), jstrict::Value::String(json_alias.into()));
}
}
if !remove_index && let Some(index) = index {
let index_key = keyword_alias(vocabulary, active_context.as_ref(), options, Keyword::Index);
result.insert(index_key.into(), jstrict::Value::String(index.into()));
}
Ok(jstrict::Value::Object(result))
}