feat: use new method

Author: FlorentLvr

src/core/modules/opendata/triggers.py

@@ -1,3 +1,24 @@
+# This file defines triggers for the opendata module
+# Triggers allow the module to react automatically to changes in the ontology store
+# Each trigger consists of:
+#   1. A triple pattern (subject, predicate, object) where None acts as a wildcard
+#   2. An event type (OntologyEvent.INSERT or OntologyEvent.DELETE)
+#   3. A callback function to execute when the event occurs
+#
+# Example:
+# from abi.services.ontology_store.OntologyStorePorts import OntologyEvent
+# from rdflib import URIRef, Namespace
+#
+# ex = Namespace("http://example.org/")
+#
+# def handle_new_dataset(event_type, ontology_name, triple):
+#     subject, predicate, obj = triple
+#     # Process the new dataset here
+#
+# triggers = [
+#     ((None, URIRef(ex + "hasOpenData"), None), OntologyEvent.INSERT, handle_new_dataset),
+# ]
+
 from src import services
 from lib.abi.services.ontology_store.OntologyStorePorts import OntologyEvent
 from rdflib import URIRef, Literal
@@ -38,7 +59,7 @@ def register_organization_logo_update_trigger():
     ))
 
     # Subscribe to the trigger
-    services.ontology_store_service.subscribe((None, None, URIRef("https://www.commoncoreontologies.org/ont00000443")), OntologyEvent.INSERT, pipeline.trigger)
+    return ((None, None, URIRef("https://www.commoncoreontologies.org/ont00000443")), OntologyEvent.INSERT, pipeline.trigger)
 
 # Register organization size trigger
 def register_organization_size_trigger():
@@ -53,27 +74,9 @@ def register_organization_size_trigger():
     ))
 
     # Subscribe to the trigger
-    services.ontology_store_service.subscribe((None, URIRef("http://ontology.naas.ai/abi/number_of_employees"), None), OntologyEvent.INSERT, pipeline.trigger)
-    
-# This file defines triggers for the opendata module
-# Triggers allow the module to react automatically to changes in the ontology store
-# Each trigger consists of:
-#   1. A triple pattern (subject, predicate, object) where None acts as a wildcard
-#   2. An event type (OntologyEvent.INSERT or OntologyEvent.DELETE)
-#   3. A callback function to execute when the event occurs
-#
-# Example:
-# from abi.services.ontology_store.OntologyStorePorts import OntologyEvent
-# from rdflib import URIRef, Namespace
-#
-# ex = Namespace("http://example.org/")
-#
-# def handle_new_dataset(event_type, ontology_name, triple):
-#     subject, predicate, obj = triple
-#     # Process the new dataset here
-#
-# triggers = [
-#     ((None, URIRef(ex + "hasOpenData"), None), OntologyEvent.INSERT, handle_new_dataset),
-# ]
+    return ((None, URIRef("http://ontology.naas.ai/abi/number_of_employees"), None), OntologyEvent.INSERT, pipeline.trigger)
 
-triggers = []
+triggers = [
+    register_organization_logo_update_trigger(),
+    register_organization_size_trigger(),
+]