Author: alexdma
Date: Tue May 10 08:20:22 2011
New Revision: 1101359
URL: http://svn.apache.org/viewvc?rev=1101359&view=rev
Log:
STANBOL-171 :
- RefactorEnhancementEngine now uses standard Ontology input sources from the
ontonet API.
Modified:
incubator/stanbol/trunk/enhancer/engines/refactor/src/main/java/org/apache/stanbol/enhancer/engines/refactor/RefactorEnhancementEngine.java
Modified:
incubator/stanbol/trunk/enhancer/engines/refactor/src/main/java/org/apache/stanbol/enhancer/engines/refactor/RefactorEnhancementEngine.java
URL:
http://svn.apache.org/viewvc/incubator/stanbol/trunk/enhancer/engines/refactor/src/main/java/org/apache/stanbol/enhancer/engines/refactor/RefactorEnhancementEngine.java?rev=1101359&r1=1101358&r2=1101359&view=diff
==============================================================================
---
incubator/stanbol/trunk/enhancer/engines/refactor/src/main/java/org/apache/stanbol/enhancer/engines/refactor/RefactorEnhancementEngine.java
(original)
+++
incubator/stanbol/trunk/enhancer/engines/refactor/src/main/java/org/apache/stanbol/enhancer/engines/refactor/RefactorEnhancementEngine.java
Tue May 10 08:20:22 2011
@@ -34,7 +34,9 @@ import org.apache.stanbol.entityhub.serv
import org.apache.stanbol.entityhub.servicesapi.site.ReferencedSiteManager;
import org.apache.stanbol.ontologymanager.ontonet.api.DuplicateIDException;
import org.apache.stanbol.ontologymanager.ontonet.api.ONManager;
+import org.apache.stanbol.ontologymanager.ontonet.api.io.BlankOntologySource;
import org.apache.stanbol.ontologymanager.ontonet.api.io.OntologyInputSource;
+import org.apache.stanbol.ontologymanager.ontonet.api.io.RootOntologyIRISource;
import org.apache.stanbol.ontologymanager.ontonet.api.ontology.OntologyScope;
import
org.apache.stanbol.ontologymanager.ontonet.api.ontology.OntologyScopeFactory;
import org.apache.stanbol.ontologymanager.ontonet.api.ontology.OntologySpace;
@@ -65,15 +67,13 @@ import org.slf4j.LoggerFactory;
/**
*
- * This an engine to post-process the enhancements. Its main goal is to
- * refactor the RDF produced by the enhancement applying some vocabulary
related
- * to a specific task.
+ * This an engine to post-process the enhancements. Its main goal is to
refactor the RDF produced by the
+ * enhancement applying some vocabulary related to a specific task.
*
* To do that, exploit a Refactor recipe and an ontology scope of OntoNet.
*
- * The first implementation is targeted to SEO use case. * It retrieves data by
- * dereferencing the entities, * includes the DBpedia ontology * refactor the
- * data using the google rich snippets vocabulary.
+ * The first implementation is targeted to SEO use case. * It retrieves data
by dereferencing the entities, *
+ * includes the DBpedia ontology * refactor the data using the google rich
snippets vocabulary.
*
* @author andrea.nuzzolese
*
@@ -83,634 +83,536 @@ import org.slf4j.LoggerFactory;
@Service(EnhancementEngine.class)
public class RefactorEnhancementEngine implements EnhancementEngine,
ServiceProperties {
- /*
- * TODO This are the scope and recipe IDs to be used by this
implementation
- * In future implementation this will be configurable
- */
-
- @Property(value =
"http://incubator.apache.org/stanbol/enhancer/engines/refactor/scope";)
- public static final String SCOPE = "engine.refactor.scope";
+ /*
+ * TODO This are the scope and recipe IDs to be used by this
implementation In future implementation this
+ * will be configurable
+ */
+
+ @Property(value =
"http://incubator.apache.org/stanbol/enhancer/engines/refactor/scope";)
+ public static final String SCOPE = "engine.refactor.scope";
- @Property(value = "")
- public static final String RECIPE_URI = "engine.refactor.recipe";
+ @Property(value = "")
+ public static final String RECIPE_URI = "engine.refactor.recipe";
-
@Property(value={"http://ontologydesignpatterns.org/ont/iks/kres/dbpedia_demo.owl",""},
cardinality=1000, description="To fix a set of resolvable ontology URIs for
the scope's ontologies.")
- public static final String SCOPE_CORE_ONTOLOGY
="engine.refactor.scope.core.ontology";
+ @Property(value =
{"http://ontologydesignpatterns.org/ont/iks/kres/dbpedia_demo.owl";, ""},
cardinality = 1000, description = "To fix a set of resolvable ontology URIs for
the scope's ontologies.")
+ public static final String SCOPE_CORE_ONTOLOGY =
"engine.refactor.scope.core.ontology";
- @Property(boolValue=true, description="If true: the previously generated
RDF is deleted and substituted with the new one. If false: the new one is
appended to the old RDF. Possible value: true or false.")
+ @Property(boolValue = true, description = "If true: the previously
generated RDF is deleted and substituted with the new one. If false: the new
one is appended to the old RDF. Possible value: true or false.")
public static final String APPEND_OTHER_ENHANCEMENT_GRAPHS =
"engine.refactor.append.graphs";
-
- @Property(boolValue=true, description="If true: entities are fetched via
the EntityHub. If false: entities are fetched on-line. Possible value: true or
false.")
+
+ @Property(boolValue = true, description = "If true: entities are fetched
via the EntityHub. If false: entities are fetched on-line. Possible value: true
or false.")
public static final String USAGE_OF_ENTITY_HUB =
"engine.refactor.entityhub";
- @Reference
- ONManager onManager;
+ @Reference
+ ONManager onManager;
- @Reference
- ReferencedSiteManager referencedSiteManager;
+ @Reference
+ ReferencedSiteManager referencedSiteManager;
- @Reference
- RuleStore ruleStore;
+ @Reference
+ RuleStore ruleStore;
- @Reference
- Reasoner reasoner;
+ @Reference
+ Reasoner reasoner;
- @Reference
- Refactorer refactorer;
+ @Reference
+ Refactorer refactorer;
- private OntologyScope scope;
- private IRI recipeIRI;
+ private OntologyScope scope;
+ private IRI recipeIRI;
private boolean graph_append;
private boolean useEntityHub;
- private final Logger log = LoggerFactory.getLogger(getClass());
+ private final Logger log = LoggerFactory.getLogger(getClass());
+
+ @Override
+ public int canEnhance(ContentItem ci) throws EngineException {
+ /*
+ * Dulcifier can enhance only content items that are previously
enhanced by other enhancement engines,
+ * as it must be the last engine in the chain.
+ *
+ * Works only if some enhancement has been produced.
+ */
+ MGraph mGraph = ci.getMetadata();
+ if (mGraph != null) {
+ return ENHANCE_SYNCHRONOUS;
+ } else {
+ return CANNOT_ENHANCE;
+ }
+ }
+
+ @Override
+ public void computeEnhancements(ContentItem ci) throws EngineException {
+ /*
+ * Retrieve the graph
+ */
+ final MGraph mGraph = ci.getMetadata();
+
+ /*
+ * We filter the entities recognized by the engines
+ */
+ UriRef fiseEntityReference = new
UriRef("http://fise.iks-project.eu/ontology/entity-reference";);
+ Iterator<Triple> tripleIt = mGraph.filter(null, fiseEntityReference,
null);
+
+ /*
+ * Now we prepare the OntoNet environment. First we create the OntoNet
session in which run the whole
+ */
+ final IRI sessionIRI = createAndAddSessionSpaceToScope();
+
+ /*
+ * We retrieve the session space
+ */
+ OntologySpace sessionSpace = scope.getSessionSpace(sessionIRI);
+
+ while (tripleIt.hasNext()) {
+ Triple triple = tripleIt.next();
+ Resource entityReference = triple.getObject();
+ /*
+ * the entity uri
+ */
+ final String entityReferenceString =
entityReference.toString().replace("<", "").replace(">", "");
+ log.debug("Trying to resolve entity " + entityReferenceString);
+ /**
+ * We fetch the entity in the OntologyInputSource object
+ */
+ try {
+
+ final IRI fetchedIri = IRI.create(entityReferenceString);
+
+ /*
+ * The RDF graph of an entity is fetched via the EntityHub.
The getEntityOntology is a method
+ * the do the job of asking the entity to the EntityHub and
wrap the RDF graph into an
+ * OWLOntology.
+ */
+ OWLOntology fetched = null;
+
+ if (useEntityHub) {
+ fetched = getEntityOntology(entityReferenceString);
+ } else {
+ Dereferencer dereferencer = new Dereferencer();
+ try {
+ fetched =
OWLManager.createOWLOntologyManager().loadOntologyFromOntologyDocument(
+ dereferencer.resolve(entityReferenceString));
+ } catch (OWLOntologyCreationException e) {
+ log.error("An error occurred while trying to create
the ontology related to the entity "
+ + entityReferenceString);
+ } catch (FileNotFoundException e) {
+ log.error("The entity " + entityReferenceString + "
does not exist or is unreachable");
+ }
+ }
+
+ if (fetched != null) {
+ final OWLOntology fetchedFinal = fetched;
+ OntologyInputSource ontologySource = new
OntologyInputSource() {
+
+ @Override
+ public boolean hasRootOntology() {
+ return (fetchedFinal != null);
+ }
+
+ @Override
+ public boolean hasPhysicalIRI() {
+ return true;
+ }
+
+ @Override
+ public OWLOntology getRootOntology() {
+ return fetchedFinal;
+ }
+
+ @Override
+ public IRI getPhysicalIRI() {
+ return fetchedIri;
+ }
+
+ @Override
+ public Set<OWLOntology> getClosure() {
+ return
fetchedFinal.getOWLOntologyManager().getImportsClosure(fetchedFinal);
+ }
+ };
+ sessionSpace.addOntology(ontologySource);
+ }
+
+ log.debug("Added " + entityReferenceString + " to the session
space of scope "
+ + scope.getID().toString(), this);
+
+ } catch (UnmodifiableOntologySpaceException e) {
+ log.error("Cannot load the entity", e);
+ }
+
+ }
+
+ /*
+ * Now we merge the RDF from the T-box - the ontologies - and the
A-box - the RDF data fetched
+ */
+
+ final OWLOntologyManager man = OWLManager.createOWLOntologyManager();
+
+ OWLOntologySetProvider provider = new OWLOntologySetProvider() {
- @Override
- public int canEnhance(ContentItem ci) throws EngineException {
- /*
- * Dulcifier can enhance only content items that are previously
enhanced
- * by other enhancement engines, as it must be the last engine
in the chain.
- *
- * Works only if some enhancement has been produced.
- */
- MGraph mGraph = ci.getMetadata();
- if (mGraph != null) {
- return ENHANCE_SYNCHRONOUS;
- } else {
- return CANNOT_ENHANCE;
- }
- }
-
- @Override
- public void computeEnhancements(ContentItem ci) throws EngineException {
- /*
- * Retrieve the graph
- */
- final MGraph mGraph = ci.getMetadata();
-
- /*
- * We filter the entities recognized by the engines
- */
- UriRef fiseEntityReference = new
UriRef("http://fise.iks-project.eu/ontology/entity-reference";);
- Iterator<Triple> tripleIt = mGraph.filter(null,
fiseEntityReference,null);
-
- /*
- * Now we prepare the OntoNet environment. First we create the
OntoNet session
- * in which run the whole
- */
- final IRI sessionIRI = createAndAddSessionSpaceToScope();
-
-
- /*
- * We retrieve the session space
- */
- OntologySpace sessionSpace = scope.getSessionSpace(sessionIRI);
-
- while (tripleIt.hasNext()) {
- Triple triple = tripleIt.next();
- Resource entityReference = triple.getObject();
- /*
- * the entity uri
- */
- final String entityReferenceString =
entityReference.toString()
- .replace("<", "").replace(">", "");
- log.debug("Trying to resolve entity " +
entityReferenceString);
- /**
- * We fetch the entity in the OntologyInputSource object
- */
- try {
-
-
- final IRI fetchedIri =
IRI.create(entityReferenceString);
-
- /*
- * The RDF graph of an entity is fetched via
the EntityHub.
- * The getEntityOntology is a method the do the
job of asking
- * the entity to the EntityHub and wrap the RDF
graph into
- * an OWLOntology.
- */
- OWLOntology fetched = null;
-
- if(useEntityHub){
- fetched =
getEntityOntology(entityReferenceString);
- }
- else{
- Dereferencer dereferencer = new
Dereferencer();
- try {
- fetched =
OWLManager.createOWLOntologyManager().loadOntologyFromOntologyDocument(dereferencer.resolve(entityReferenceString));
- } catch (OWLOntologyCreationException
e) {
- log.error("An error occurred
while trying to create the ontology related to the entity " +
entityReferenceString);
- } catch (FileNotFoundException e) {
- log.error("The entity " +
entityReferenceString + " does not exist or is unreachable");
- }
- }
-
- if(fetched != null){
- final OWLOntology fetchedFinal =
fetched;
- OntologyInputSource ontologySource =
new OntologyInputSource() {
-
- @Override
- public boolean
hasRootOntology() {
- return (fetchedFinal !=
null);
- }
-
- @Override
- public boolean hasPhysicalIRI()
{
- return true;
- }
-
- @Override
- public OWLOntology
getRootOntology() {
- return fetchedFinal;
- }
-
- @Override
- public IRI getPhysicalIRI() {
- return fetchedIri;
- }
- };
-
sessionSpace.addOntology(ontologySource);
- }
-
- log.debug("Added " + entityReferenceString
- + " to the session space of
scope "
- + scope.getID().toString(),
this);
-
-
- } catch (UnmodifiableOntologySpaceException e) {
- log.error("Cannot load the entity",e);
- }
-
- }
-
- /*
- * Now we merge the RDF from the T-box - the ontologies - and
the A-box
- * - the RDF data fetched
- *
- */
-
- final OWLOntologyManager man =
OWLManager.createOWLOntologyManager();
-
- OWLOntologySetProvider provider = new OWLOntologySetProvider() {
-
- @Override
- public Set<OWLOntology> getOntologies() {
-
- Set<OWLOntology> ontologies = new
HashSet<OWLOntology>();
- OntologySpace sessionSpace =
scope.getSessionSpace(sessionIRI);
- ontologies.addAll(sessionSpace.getOntologies());
-
- /*
- * We add to the set the graph containing the
metadata generated by previous
- * enhancement engines. It is important becaus
we want to menage during the refactoring
- * also some information fron that graph.
- * As the graph is provided as a Clerezza
MGraph, we first need to convert it to an OWLAPI
- * OWLOntology.
- * There is no chance that the mGraph could be
null as it was previously controlled by the JobManager
- * through the canEnhance method and the
computeEnhancement is always called iff the former returns true.
- */
- OWLOntology fiseMetadataOntology =
OWLAPIToClerezzaConverter.clerezzaMGraphToOWLOntology(mGraph);
- ontologies.add(fiseMetadataOntology);
- return ontologies;
- }
- };
-
- /*
- * We merge all the ontologies from the session space of the
scope into
- * a single ontology that will be used for the refactoring.
- */
- OWLOntologyMerger merger = new OWLOntologyMerger(provider);
-
- OWLOntology ontology;
- try {
- ontology =
merger.createMergedOntology(man,IRI.create("http://fise.iks-project.eu/dulcifier/integrity-check";));
-
- /*
- * To perform the refactoring of the ontology to a given
- * vocabulary we use the Stanbol Refactor.
- */
-
- log.debug("Refactoring recipe IRI is : " + recipeIRI);
-
- /*
- * We pass the ontology and the recipe IRI to the
Refactor that
- * returns the refactored graph expressed by using the
given
- * vocabulary.
- */
- try {
-
- Recipe recipe = ruleStore.getRecipe(recipeIRI);
-
- log.debug("Rules in the recipe are : "+
recipe.getkReSRuleList().size(), this);
-
- log.debug("The ontology to be refactor is : " +
ontology, this);
-
- ontology =
refactorer.ontologyRefactoring(ontology, recipeIRI);
-
- } catch (RefactoringException e) {
- log.error("The refactoring engine failed the
execution.", e);
- } catch (NoSuchRecipeException e) {
- log.error("The recipe with ID " + recipeIRI
- + " does not exists", e);
- }
-
- log.debug("Merged ontologies in " + ontology);
-
- /*
- * The new generated ontology is converted to Clarezza format
and than added os substitued to the old mGraph.
- */
- if(graph_append){
-
mGraph.addAll(OWLAPIToClerezzaConverter.owlOntologyToClerezzaTriples(ontology));
- log.debug("Metadata of the content passd have
been substituted",this);
- }
- else{
- mGraph.removeAll(mGraph);
-
mGraph.addAll(OWLAPIToClerezzaConverter.owlOntologyToClerezzaTriples(ontology));
- log.debug("Metadata of the content is appended
to the existent one",this);
- }
-
- /*
- * The session needs to be destroyed, as it is no more
useful.
- */
-
onManager.getSessionManager().destroySession(sessionIRI);
-
- } catch (OWLOntologyCreationException e) {
- log.error("Cannot create the ontology for the
refactoring", e);
- }
- }
-
- /**
- * Setup the KReS session
- *
- * @return
- */
- private IRI createAndAddSessionSpaceToScope() {
- /*
- * Retrieve the session manager
- */
- SessionManager sessionManager = onManager.getSessionManager();
- log.debug("Starting create session for the dulcifier");
-
- /*
- * Create and setup the session. TODO FIXME This is an
operation that
- * should be made easier for developers to do through the API
- */
- Session session = sessionManager.createSession();
- OntologySpaceFactory ontologySpaceFactory =
onManager.getOntologySpaceFactory();
- OntologySpace sessionSpace =
ontologySpaceFactory.createSessionOntologySpace(scope.getID());
- scope.addSessionSpace(sessionSpace, session.getID());
-
- /*
- * Finally, we return the session ID to be used by the caller
- */
- log.debug("Session " + session.getID() + " created", this);
- return session.getID();
- }
+ @Override
+ public Set<OWLOntology> getOntologies() {
+
+ Set<OWLOntology> ontologies = new HashSet<OWLOntology>();
+ OntologySpace sessionSpace = scope.getSessionSpace(sessionIRI);
+ ontologies.addAll(sessionSpace.getOntologies());
+
+ /*
+ * We add to the set the graph containing the metadata
generated by previous enhancement
+ * engines. It is important becaus we want to menage during
the refactoring also some
+ * information fron that graph. As the graph is provided as a
Clerezza MGraph, we first need
+ * to convert it to an OWLAPI OWLOntology. There is no chance
that the mGraph could be null as
+ * it was previously controlled by the JobManager through the
canEnhance method and the
+ * computeEnhancement is always called iff the former returns
true.
+ */
+ OWLOntology fiseMetadataOntology = OWLAPIToClerezzaConverter
+ .clerezzaMGraphToOWLOntology(mGraph);
+ ontologies.add(fiseMetadataOntology);
+ return ontologies;
+ }
+ };
+
+ /*
+ * We merge all the ontologies from the session space of the scope
into a single ontology that will be
+ * used for the refactoring.
+ */
+ OWLOntologyMerger merger = new OWLOntologyMerger(provider);
+
+ OWLOntology ontology;
+ try {
+ ontology = merger.createMergedOntology(man,
+
IRI.create("http://fise.iks-project.eu/dulcifier/integrity-check";));
+
+ /*
+ * To perform the refactoring of the ontology to a given
vocabulary we use the Stanbol Refactor.
+ */
+
+ log.debug("Refactoring recipe IRI is : " + recipeIRI);
+
+ /*
+ * We pass the ontology and the recipe IRI to the Refactor that
returns the refactored graph
+ * expressed by using the given vocabulary.
+ */
+ try {
+
+ Recipe recipe = ruleStore.getRecipe(recipeIRI);
+
+ log.debug("Rules in the recipe are : " +
recipe.getkReSRuleList().size(), this);
+
+ log.debug("The ontology to be refactor is : " + ontology,
this);
+
+ ontology = refactorer.ontologyRefactoring(ontology, recipeIRI);
+
+ } catch (RefactoringException e) {
+ log.error("The refactoring engine failed the execution.", e);
+ } catch (NoSuchRecipeException e) {
+ log.error("The recipe with ID " + recipeIRI + " does not
exists", e);
+ }
+
+ log.debug("Merged ontologies in " + ontology);
+
+ /*
+ * The new generated ontology is converted to Clarezza format and
than added os substitued to the
+ * old mGraph.
+ */
+ if (graph_append) {
+
mGraph.addAll(OWLAPIToClerezzaConverter.owlOntologyToClerezzaTriples(ontology));
+ log.debug("Metadata of the content passd have been
substituted", this);
+ } else {
+ mGraph.removeAll(mGraph);
+
mGraph.addAll(OWLAPIToClerezzaConverter.owlOntologyToClerezzaTriples(ontology));
+ log.debug("Metadata of the content is appended to the existent
one", this);
+ }
+
+ /*
+ * The session needs to be destroyed, as it is no more useful.
+ */
+ onManager.getSessionManager().destroySession(sessionIRI);
+
+ } catch (OWLOntologyCreationException e) {
+ log.error("Cannot create the ontology for the refactoring", e);
+ }
+ }
/**
- * To create the input source necesary to load the ontology inside the
scope.
- * @param uri -- A resolvable string uri.
- * @return An OntologyInputSource
+ * Setup the KReS session
+ *
+ * @return
*/
- private OntologyInputSource oisForScope(final String uri){
+ private IRI createAndAddSessionSpaceToScope() {
/*
- * The scope factory needs an OntologyInputSource as input for
the core
- * ontology space. We want to use the dbpedia ontology as core
ontology
- * of our scope.
- */
- OntologyInputSource ois = new OntologyInputSource() {
-
- @Override
- public boolean hasRootOntology() {
- return true;
- }
-
- @Override
- public boolean hasPhysicalIRI() {
- return false;
- }
-
- @Override
- public OWLOntology getRootOntology() {
-
- InputStream inputStream;
- try {
- /*
- * The input stream for the dbpedia
ontology is obtained
- * through the dereferencer component.
- */
-
-
- //inputStream =
dereferencer.resolve(uri);
- OWLOntologyManager manager =
OWLManager.createOWLOntologyManager();
- return
manager.loadOntologyFromOntologyDocument(IRI.create(uri));
-
-
- //return getEntityOntology(uri);
- } catch (Exception e) {
- log.error("Cannot load the ontology
"+uri, e);
- }
- /** If some errors occur **/
- return null;
- }
-
- @Override
- public IRI getPhysicalIRI() {
- return null;
- }
- };
+ * Retrieve the session manager
+ */
+ SessionManager sessionManager = onManager.getSessionManager();
+ log.debug("Starting create session for the dulcifier");
- return ois;
- }
+ /*
+ * Create and setup the session. TODO FIXME This is an operation that
should be made easier for
+ * developers to do through the API
+ */
+ Session session = sessionManager.createSession();
+ OntologySpaceFactory ontologySpaceFactory =
onManager.getOntologySpaceFactory();
+ OntologySpace sessionSpace =
ontologySpaceFactory.createSessionOntologySpace(scope.getID());
+ scope.addSessionSpace(sessionSpace, session.getID());
+ /*
+ * Finally, we return the session ID to be used by the caller
+ */
+ log.debug("Session " + session.getID() + " created", this);
+ return session.getID();
+ }
+
+ /**
+ * To create the input source necesary to load the ontology inside the
scope.
+ *
+ * @param uri
+ * -- A resolvable string uri.
+ * @return An OntologyInputSource
+ */
+ private OntologyInputSource oisForScope(final String uri) {
+ try {
+ return new RootOntologyIRISource(IRI.create(uri));
+ } catch (OWLOntologyCreationException e) {
+ log.error("Failed to load scope ontology {}", uri, e);
+ return null;
+ }
+ }
/**
* Activating the component
+ *
* @param context
*/
- protected void activate(ComponentContext context) {
-
- /*
- * Read property to indicate if the the new eanchment metada must be
append to the existing mGraph
- */
- graph_append =
((Boolean)context.getProperties().get(APPEND_OTHER_ENHANCEMENT_GRAPHS)).booleanValue();
-
- useEntityHub =
((Boolean)context.getProperties().get(USAGE_OF_ENTITY_HUB)).booleanValue();
-
- /*
- * Get the Scope Factory from the ONM of KReS that allows to
create new
- * scopes
- */
- OntologyScopeFactory scopeFactory =
onManager.getOntologyScopeFactory();
-
-
- /*
- * Adding ontologies to the scope core ontology.
- * 1) Get all the ontologies from the property.
- * 2) Create a base scope with an empity ontology.
- * 3) Retrieve the ontology space from the scope.
- * 4) Add the ontologies to the scope via ontology space.
- */
- //Step 1
- Object obj = context.getProperties().get(SCOPE_CORE_ONTOLOGY);
- String[] coreScopeOntologySet;
- if(obj instanceof String[]){
- coreScopeOntologySet = (String[]) obj;
- }
- else{
- String[] aux = new String[1];
- aux[0] = (String) obj;
- coreScopeOntologySet =aux;
- }
-
- //Step 2
- OntologyInputSource oisbase = new OntologyInputSource() {
-
- @Override
- public boolean hasRootOntology() {
- return true;
- }
-
- @Override
- public boolean hasPhysicalIRI() {
- return false;
- }
-
- @Override
- public OWLOntology getRootOntology() {
-
- try {
- /*
- * The input stream for the dbpedia
ontology is obtained
- * through the dereferencer component.
- */
- OWLOntologyManager manager =
OWLManager.createOWLOntologyManager();
- return manager.createOntology();
- } catch (OWLOntologyCreationException e) {
- log.error("Cannot create the scope with
empity ontology.", e);
- } catch (Exception e) {
- log.error("Cannot create the scope with
empity ontology.", e);
- }
- /** If some errors occur **/
- return null;
- }
-
- @Override
- public IRI getPhysicalIRI() {
- return null;
- }
- };
-
- IRI dulcifierScopeIRI = IRI.create((String)
context.getProperties().get(SCOPE));
-
- /*
- * The scope is created by the ScopeFactory or loaded from the
scope
- * registry of KReS
- */
- try {
- scope =
scopeFactory.createOntologyScope(dulcifierScopeIRI, oisbase);
- } catch (DuplicateIDException e) {
- ScopeRegistry scopeRegistry =
onManager.getScopeRegistry();
- scope = scopeRegistry.getScope(dulcifierScopeIRI);
- }
+ protected void activate(ComponentContext context) {
+
+ /*
+ * Read property to indicate if the the new eanchment metada must be
append to the existing mGraph
+ */
+ graph_append = ((Boolean)
context.getProperties().get(APPEND_OTHER_ENHANCEMENT_GRAPHS))
+ .booleanValue();
+
+ useEntityHub = ((Boolean)
context.getProperties().get(USAGE_OF_ENTITY_HUB)).booleanValue();
/*
- * Step 3
+ * Get the Scope Factory from the ONM of KReS that allows to create
new scopes
*/
- OntologySpace ontologySpace = scope.getCoreSpace();
-
+ OntologyScopeFactory scopeFactory =
onManager.getOntologyScopeFactory();
+
/*
- * Step 4
+ * Adding ontologies to the scope core ontology. 1) Get all the
ontologies from the property. 2)
+ * Create a base scope with an empity ontology. 3) Retrieve the
ontology space from the scope. 4) Add
+ * the ontologies to the scope via ontology space.
*/
+ // Step 1
+ Object obj = context.getProperties().get(SCOPE_CORE_ONTOLOGY);
+ String[] coreScopeOntologySet;
+ if (obj instanceof String[]) {
+ coreScopeOntologySet = (String[]) obj;
+ } else {
+ String[] aux = new String[1];
+ aux[0] = (String) obj;
+ coreScopeOntologySet = aux;
+ }
+
+ // Step 2
+ OntologyInputSource oisbase = new BlankOntologySource();
+
+ IRI dulcifierScopeIRI = IRI.create((String)
context.getProperties().get(SCOPE));
+
+ /*
+ * The scope is created by the ScopeFactory or loaded from the scope
registry of KReS
+ */
+ try {
+ scope = scopeFactory.createOntologyScope(dulcifierScopeIRI,
oisbase);
+ } catch (DuplicateIDException e) {
+ ScopeRegistry scopeRegistry = onManager.getScopeRegistry();
+ scope = scopeRegistry.getScope(dulcifierScopeIRI);
+ }
+
+ // Step 3
+ OntologySpace ontologySpace = scope.getCoreSpace();
+
+ // Step 4
ontologySpace.tearDown();
- for(int o = 0; o<coreScopeOntologySet.length; o++){
+ for (int o = 0; o < coreScopeOntologySet.length; o++) {
OntologyInputSource ois = oisForScope(coreScopeOntologySet[o]);
try {
ontologySpace.addOntology(ois);
} catch (UnmodifiableOntologySpaceException ex) {
- log.error("Unmodifiable Ontology SpaceException.",ex);
+ log.error("Unmodifiable Ontology SpaceException.", ex);
}
}
ontologySpace.setUp();
- log.debug("The set of ontologies loaded in the core scope space is:
"+ontologySpace.getOntologies()+
- "\nN.B. The root.owl ontology is the first (on the list)
ontology added when the scope is created.");
-
- /*
- * The first thing to do is to create a recipe in the rule store that
can be used
- * by the engine to refactor the enhancement graphs.
- */
- recipeIRI = IRI.create((String)
context.getProperties().get(RECIPE_URI));
-
- log.debug("Start create the Recipe", this);
-
- ruleStore.addRecipe(recipeIRI, null);
-
- log.debug("The recipe has been created", this);
-
-
- /*
- * The set of rule to put in the recipe can be provided by the
user.
- * A default set of rules is provided in
/META-INF/default/seo_rules.sem.
- * Use the property engine.refactor in the felix console to
pass to the engine
- * your set of rules.
- *
+ log.debug("The set of ontologies loaded in the core scope space is: "
+ + ontologySpace.getOntologies()
+ + "\nN.B. The root.owl ontology is the first (on the list)
ontology added when the scope is created.");
+
+ /*
+ * The first thing to do is to create a recipe in the rule store that
can be used by the engine to
+ * refactor the enhancement graphs.
*/
-
- String recipeURI = (String)
context.getProperties().get(RECIPE_URI);
-
- InputStream recipeStream = null;
- String recipeString = null;
-
- if(recipeURI != null && !recipeURI.isEmpty()){
- IDereferencer dereferencer = new Dereferencer();
- try {
- recipeStream = dereferencer.resolve(recipeURI);
- } catch (FileNotFoundException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- }
- else{
- recipeStream =
RefactorEnhancementEngine.class.getResourceAsStream("/META-INF/default/seo_rules.sem");
- }
-
- System.out.println("Refactorer engine recipe stream
"+recipeStream);
-
- if(recipeStream != null){
-
- recipeString = "";
-
- BufferedReader reader = new BufferedReader(new
InputStreamReader(recipeStream));
-
- String line = null;
- try {
- while((line=reader.readLine()) != null){
- recipeString += line;
- }
- } catch (IOException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- }
-
+ recipeIRI = IRI.create((String)
context.getProperties().get(RECIPE_URI));
+
+ log.debug("Start creating the Recipe", this);
+
+ ruleStore.addRecipe(recipeIRI, null);
+
+ log.debug("The recipe has been created", this);
+
+ /*
+ * The set of rule to put in the recipe can be provided by the user. A
default set of rules is
+ * provided in /META-INF/default/seo_rules.sem. Use the property
engine.refactor in the felix console
+ * to pass to the engine your set of rules.
+ */
+
+ String recipeURI = (String) context.getProperties().get(RECIPE_URI);
+
+ InputStream recipeStream = null;
+ String recipeString = null;
+
+ if (recipeURI != null && !recipeURI.isEmpty()) {
+ IDereferencer dereferencer = new Dereferencer();
+ try {
+ recipeStream = dereferencer.resolve(recipeURI);
+ } catch (FileNotFoundException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ } else {
+ recipeStream = RefactorEnhancementEngine.class
+ .getResourceAsStream("/META-INF/default/seo_rules.sem");
+ }
+
+ System.out.println("Refactorer engine recipe stream " + recipeStream);
+
+ if (recipeStream != null) {
+
+ recipeString = "";
+
+ BufferedReader reader = new BufferedReader(new
InputStreamReader(recipeStream));
+
+ String line = null;
+ try {
+ while ((line = reader.readLine()) != null) {
+ recipeString += line;
+ }
+ } catch (IOException e) {
+ // TODO Auto-generated catch block
+ e.printStackTrace();
+ }
+ }
/*
* step 3
*/
try {
- //ruleStore.addRuleToRecipe(recipeIRI.toString(),
kReSRuleSyntax);
- ruleStore.addRuleToRecipe(recipeIRI.toString(), recipeString);
- log.debug("Added rules to recipe " + recipeIRI.toString());
- } catch (NoSuchRecipeException e) {
- log.error("The recipe does not exists: ", e);
- }
- log.info("Activated Dulcifier engine");
-
- }
-
- protected void deactivate(ComponentContext context) {
-
- /* Deactivating the dulcifier. The procedure require:
- * 1) get all the rules from the recipe
- * 2) remove the recipe.
- * 3) remove the single rule.
- * 4) tear down the scope ontologySpace and the scope itself.
- */
-
- try {
- /*
- * step 1: get all the rule
- */
- RuleList recipeRuleList =
ruleStore.getRecipe(recipeIRI).getkReSRuleList();
-
- /*
- * step 2: remove the recipe
- */
- if(ruleStore.removeRecipe(recipeIRI)){
- log.info("The recipe "+recipeIRI+" has been
removed correctly");
- }
- else{
- log.error("The recipe "+recipeIRI+" can not be
removed");
- }
-
- /*
- * step 3: remove the rules
- */
- for(Rule rule : recipeRuleList){
- if(ruleStore.removeRule(rule)){
- log.info("The rule "+rule.getRuleName()+" has
been removed correctly");
- }
- else{
- log.error("The rule "+rule.getRuleName()+" can not be
removed");
- }
- }
+ // ruleStore.addRuleToRecipe(recipeIRI.toString(), kReSRuleSyntax);
+ ruleStore.addRuleToRecipe(recipeIRI.toString(), recipeString);
+ log.debug("Added rules to recipe " + recipeIRI.toString());
+ } catch (NoSuchRecipeException e) {
+ log.error("The recipe does not exists: ", e);
+ }
+ log.info("Activated Dulcifier engine");
+
+ }
+
+ protected void deactivate(ComponentContext context) {
- /*
- * step 4:
- */
- scope.getCoreSpace().tearDown();
- scope.tearDown();
-
-
- } catch (NoSuchRecipeException ex) {
- log.error("The recipe "+recipeIRI+" doesn't exist",ex);
+ /*
+ * Deactivating the dulcifier. The procedure require: 1) get all the
rules from the recipe 2) remove
+ * the recipe. 3) remove the single rule. 4) tear down the scope
ontologySpace and the scope itself.
+ */
+
+ try {
+ /*
+ * step 1: get all the rule
+ */
+ RuleList recipeRuleList =
ruleStore.getRecipe(recipeIRI).getkReSRuleList();
+
+ /*
+ * step 2: remove the recipe
+ */
+ if (ruleStore.removeRecipe(recipeIRI)) {
+ log.info("The recipe " + recipeIRI + " has been removed
correctly");
+ } else {
+ log.error("The recipe " + recipeIRI + " can not be removed");
}
- log.info("Deactivated Dulcifier engine");
+ /*
+ * step 3: remove the rules
+ */
+ for (Rule rule : recipeRuleList) {
+ if (ruleStore.removeRule(rule)) {
+ log.info("The rule " + rule.getRuleName() + " has been
removed correctly");
+ } else {
+ log.error("The rule " + rule.getRuleName() + " can not be
removed");
+ }
+ }
+
+ /*
+ * step 4:
+ */
+ scope.getCoreSpace().tearDown();
+ scope.tearDown();
+
+ } catch (NoSuchRecipeException ex) {
+ log.error("The recipe " + recipeIRI + " doesn't exist", ex);
+ }
+
+ log.info("Deactivated Dulcifier engine");
+
+ }
+
+ @Override
+ public Map<String,Object> getServiceProperties() {
+ return Collections.unmodifiableMap(Collections.singletonMap(
+ ServiceProperties.ENHANCEMENT_ENGINE_ORDERING,
+ (Object) ServiceProperties.ORDERING_POST_PROCESSING));
+ }
+
+ /**
+ * Fetch the OWLOntology containing the graph associated to an entity from
Linked Data. It uses the Entity
+ * Hub for accessing LOD and fetching entities.
+ *
+ * @param entityURI
+ * {@link String}
+ * @return the {@link OWLOntology} of the entity
+ */
+ private OWLOntology getEntityOntology(String entityURI) {
+
+ OWLOntology fetchedOntology = null;
+
+ log.debug("Asking entity: " + entityURI);
+ /*
+ * Ask to the entityhub the fetch the entity.
+ */
+ Sign entitySign = referencedSiteManager.getSign(entityURI);
+
+ /*
+ * Wrap the entity graph into an owl ontology.
+ */
+ MGraph entityMGraph = null;
+
+ if (entitySign != null) {
+ Representation entityRepresentation =
entitySign.getRepresentation();
+ RdfRepresentation entityRdfRepresentation =
RdfValueFactory.getInstance().toRdfRepresentation(
+ entityRepresentation);
+ TripleCollection tripleCollection =
entityRdfRepresentation.getRdfGraph();
+ entityMGraph = new SimpleMGraph();
+ entityMGraph.addAll(tripleCollection);
+ }
+
+ if (entityMGraph != null) {
+ /*
+ * OWLOntologyManager manager =
OWLManager.createOWLOntologyManager(); final OWLOntology fetched =
+ *
manager.loadOntologyFromOntologyDocument(dereferencer.resolve(entityReferenceString));
+ */
+
+ fetchedOntology =
OWLAPIToClerezzaConverter.clerezzaMGraphToOWLOntology(entityMGraph);
+ }
- }
+ return fetchedOntology;
- @Override
- public Map<String, Object> getServiceProperties() {
- return Collections.unmodifiableMap(Collections.singletonMap(
- ServiceProperties.ENHANCEMENT_ENGINE_ORDERING,
- (Object)
ServiceProperties.ORDERING_POST_PROCESSING));
- }
-
- /**
- * Fetch the OWLOntology containing the graph associated to an entity
from Linked Data.
- * It uses the Entity Hub for accessing LOD and fetching entities.
- *
- * @param entityURI {@link String}
- * @return the {@link OWLOntology} of the entity
- */
- private OWLOntology getEntityOntology(String entityURI){
-
- OWLOntology fetchedOntology = null;
-
-
-
- log.debug("Asking entity: "+entityURI);
- /*
- * Ask to the entityhub the fetch the entity.
- */
- Sign entitySign = referencedSiteManager.getSign(entityURI);
-
- /*
- * Wrap the entity graph into an owl ontology.
- *
- */
- MGraph entityMGraph = null;
-
- if(entitySign != null){
- Representation entityRepresentation =
entitySign.getRepresentation();
- RdfRepresentation entityRdfRepresentation =
RdfValueFactory.getInstance().toRdfRepresentation(entityRepresentation);
- TripleCollection tripleCollection =
entityRdfRepresentation.getRdfGraph();
- entityMGraph = new SimpleMGraph();
- entityMGraph.addAll(tripleCollection);
- }
-
- if(entityMGraph != null){
- /*
- * OWLOntologyManager manager =
OWLManager.createOWLOntologyManager();
- * final OWLOntology fetched =
manager.loadOntologyFromOntologyDocument(dereferencer.resolve(entityReferenceString));
- */
-
- fetchedOntology =
OWLAPIToClerezzaConverter.clerezzaMGraphToOWLOntology(entityMGraph);
- }
-
- return fetchedOntology;
-
- }
+ }
}
