|
|
@ -10,7 +10,8 @@ |
|
|
|
use crate::local_broker::{doc_create, doc_sparql_construct, doc_sparql_update}; |
|
|
|
use crate::local_broker::{doc_create, doc_sparql_construct, doc_sparql_update}; |
|
|
|
use crate::tests::create_or_open_wallet::create_or_open_wallet; |
|
|
|
use crate::tests::create_or_open_wallet::create_or_open_wallet; |
|
|
|
use ng_net::orm::{ |
|
|
|
use ng_net::orm::{ |
|
|
|
BasicType, OrmSchemaDataType, OrmSchemaLiteralType, OrmSchemaPredicate, OrmSchemaShape, OrmShapeType |
|
|
|
BasicType, OrmSchemaDataType, OrmSchemaLiteralType, OrmSchemaPredicate, OrmSchemaShape, |
|
|
|
|
|
|
|
OrmShapeType, |
|
|
|
}; |
|
|
|
}; |
|
|
|
use ng_repo::log_info; |
|
|
|
use ng_repo::log_info; |
|
|
|
use ng_verifier::orm::shape_type_to_sparql; |
|
|
|
use ng_verifier::orm::shape_type_to_sparql; |
|
|
@ -109,9 +110,9 @@ INSERT DATA { |
|
|
|
Arc::new(OrmSchemaPredicate { |
|
|
|
Arc::new(OrmSchemaPredicate { |
|
|
|
dataTypes: vec![OrmSchemaDataType { |
|
|
|
dataTypes: vec![OrmSchemaDataType { |
|
|
|
valType: OrmSchemaLiteralType::literal, |
|
|
|
valType: OrmSchemaLiteralType::literal, |
|
|
|
literals: Some(vec![ |
|
|
|
literals: Some(vec![BasicType::Str( |
|
|
|
BasicType::Str("http://example.org/TestObject".to_string()), |
|
|
|
"http://example.org/TestObject".to_string(), |
|
|
|
]), |
|
|
|
)]), |
|
|
|
shape: None, |
|
|
|
shape: None, |
|
|
|
}], |
|
|
|
}], |
|
|
|
iri: "http://www.w3.org/1999/02/22-rdf-syntax-ns#type".to_string(), |
|
|
|
iri: "http://www.w3.org/1999/02/22-rdf-syntax-ns#type".to_string(), |
|
|
@ -287,7 +288,7 @@ INSERT DATA { |
|
|
|
}; |
|
|
|
}; |
|
|
|
|
|
|
|
|
|
|
|
// Generate and execute the CONSTRUCT query
|
|
|
|
// Generate and execute the CONSTRUCT query
|
|
|
|
let query = shape_type_to_sparql(&shape_type, Some(1)).unwrap(); |
|
|
|
let query = shape_type_to_sparql(&shape_type.schema, &shape_type.shape, None).unwrap(); |
|
|
|
|
|
|
|
|
|
|
|
let triples = doc_sparql_construct(session_id, query, Some(doc_nuri.clone())) |
|
|
|
let triples = doc_sparql_construct(session_id, query, Some(doc_nuri.clone())) |
|
|
|
.await |
|
|
|
.await |
|
|
@ -390,7 +391,7 @@ INSERT DATA { |
|
|
|
}; |
|
|
|
}; |
|
|
|
|
|
|
|
|
|
|
|
// Generate and run query
|
|
|
|
// Generate and run query
|
|
|
|
let query = shape_type_to_sparql(&shape_type, Some(1)).unwrap(); |
|
|
|
let query = shape_type_to_sparql(&shape_type.schema, &shape_type.shape, None).unwrap(); |
|
|
|
let triples = doc_sparql_construct(session_id, query, Some(doc_nuri.clone())) |
|
|
|
let triples = doc_sparql_construct(session_id, query, Some(doc_nuri.clone())) |
|
|
|
.await |
|
|
|
.await |
|
|
|
.unwrap(); |
|
|
|
.unwrap(); |
|
|
@ -453,7 +454,7 @@ INSERT DATA { |
|
|
|
}; |
|
|
|
}; |
|
|
|
|
|
|
|
|
|
|
|
// Generate and run query
|
|
|
|
// Generate and run query
|
|
|
|
let query = shape_type_to_sparql(&shape_type, Some(1)).unwrap(); |
|
|
|
let query = shape_type_to_sparql(&shape_type.schema, &shape_type.shape, None).unwrap(); |
|
|
|
let triples = doc_sparql_construct(session_id, query, Some(doc_nuri.clone())) |
|
|
|
let triples = doc_sparql_construct(session_id, query, Some(doc_nuri.clone())) |
|
|
|
.await |
|
|
|
.await |
|
|
|
.unwrap(); |
|
|
|
.unwrap(); |
|
|
@ -528,7 +529,7 @@ INSERT DATA { |
|
|
|
}; |
|
|
|
}; |
|
|
|
|
|
|
|
|
|
|
|
// Generate and run query. This must not infinite loop.
|
|
|
|
// Generate and run query. This must not infinite loop.
|
|
|
|
let query = shape_type_to_sparql(&shape_type, Some(1)).unwrap(); |
|
|
|
let query = shape_type_to_sparql(&shape_type.schema, &shape_type.shape, None).unwrap(); |
|
|
|
log_info!("cyclic query result:\n{}", query); |
|
|
|
log_info!("cyclic query result:\n{}", query); |
|
|
|
let triples = doc_sparql_construct(session_id, query, Some(doc_nuri.clone())) |
|
|
|
let triples = doc_sparql_construct(session_id, query, Some(doc_nuri.clone())) |
|
|
|
.await |
|
|
|
.await |
|
|
|