updated test_fuseki_triple_store.py

Author: Mihai10Mihai

ted_sws/data_manager/adapters/triple_store.py

@@ -196,9 +196,6 @@ def create_repository(self, repository_name: str):
         if response.status_code == 409:
             raise FusekiException('A repository with this name already exists.')
 
-    # def list_repositories(self) -> List[str]:
-    #     pass
-
     def add_data_to_repository(self, file_content: Union[str, bytes, bytearray], mime_type: str, repository_name: str):
         url = urljoin(self.host, f"{repository_name}/data")
         headers = {

tests/e2e/data_manager/test_fuseki_triple_store.py

@@ -4,8 +4,10 @@
 
 from ted_sws import config
 from ted_sws.data_manager.adapters.triple_store import FusekiAdapter, FusekiException
+from tests.fakes.fake_repository import FakeNoticeRepository
 
 REPOSITORY_NAME = "unknown_repository_123456677"
+SPARQL_QUERY_TRIPLES = "select * {?s ?p ?o} limit 10"
 
 
 def test_fuseki_triple_store_connection():
@@ -28,13 +30,16 @@ def test_fuseki_triple_store_connection():
     assert REPOSITORY_NAME not in triple_store.list_repositories()
 
 
-def test_fuseki_triple_store_connection():
+def test_fuseki_triple_store_add_file_to_repository():
     triple_store = FusekiAdapter()
-    response = triple_store.add_file_to_repository(Path("/home/mihai/work/meaningfy/ted-sws/tests/test_data/example.ttl"),
+    triple_store.add_file_to_repository(Path("/home/mihai/work/meaningfy/ted-sws/tests/test_data/example.ttl"),
                                         repository_name="test1")
-    print(response)
-    # create repo
-    # load sample data
-    # get SAPRQL endpoint
-    # query that the sparql endpoint is not empty (select * {?s ?p ?o} limit 10)
-    # delete repo
+
+
+def test_fuseki_triple_store_get_sparql_endpoint(fuseki_triple_store):
+    sparql_endpoint = fuseki_triple_store.get_sparql_triple_store_endpoint(repository_name="test1")
+    assert sparql_endpoint is not None
+    df_query_result = sparql_endpoint.with_query(sparql_query=SPARQL_QUERY_TRIPLES).fetch_tabular()
+    assert df_query_result is not None
+    if len(df_query_result) > 0:
+        assert True

tests/e2e/notice_publisher_triple_store/test_load_transformed_notice_into_triple_store.py

@@ -14,7 +14,7 @@ def test_load_notice_into_triple_store(transformed_complete_notice, allegro_trip
     load_notice_into_triple_store(notice_id=transformed_complete_notice.ted_id, notice_repository=fake_notice_repo,
                                   triple_store_repository=allegro_triple_store)
 
-    sparql_endpoint = allegro_triple_store.get_sparql_triple_store_endpoint(DEFAULT_NOTICE_REPOSITORY_NAME, )
+    sparql_endpoint = allegro_triple_store.get_sparql_triple_store_endpoint(DEFAULT_NOTICE_REPOSITORY_NAME)
     assert sparql_endpoint is not None
 
     df_query_result = sparql_endpoint.with_query(sparql_query=SPARQL_QUERY_TRIPLES).fetch_tabular()