Adding the integration tests

Author: angelosantos4

tests/e2e/project/node-ttls.yaml

@@ -0,0 +1,17 @@
+- implementation: nodestream.pipeline.extractors:TimeToLiveConfigurationExtractor
+  arguments:
+    graph_object_type: NODE
+    configurations: 
+    - object_type: Airport
+      expiry_in_hours: 0
+    - object_type: Country
+      expiry_in_hours: 0
+    - object_type: Region
+      expiry_in_hours: 0
+    - object_type: Player
+      expiry_in_hours: 0
+    - object_type: PlaceOfOrigin
+      expiry_in_hours: 0
+    - object_type: Position
+      expiry_in_hours: 0
+    - object_type: Team

tests/e2e/project/nodestream.yaml

@@ -5,6 +5,10 @@ scopes:
         name: airports
       - path: tests/e2e/project/fifa_2021_player_data.yaml
         name: fifa
+      - path: tests/e2e/project/node-ttls.yaml
+        name: node-ttls
+      - path: tests/e2e/project/node-ttls.yaml
+        name: relationship-ttls
 
 targets:
   my-neo4j-db:

tests/e2e/project/relationship-ttls.yaml

@@ -0,0 +1,12 @@
+- implementation: nodestream.pipeline.extractors:TimeToLiveConfigurationExtractor
+  arguments:
+    graph_object_type: RELATIONSHIP
+    configurations: 
+    - object_type: WITHIN
+      expiry_in_hours: 0
+    - object_type: ORIGINATES_FROM
+      expiry_in_hours: 0
+    - object_type: LINES_UP_AT
+      expiry_in_hours: 0
+    - object_type: PLAYS_FOR
+      expiry_in_hours: 0

tests/e2e/test_neo4j_pipelines.py

@@ -59,6 +59,33 @@ def validate_fifa_mo_club(session):
     assert result.single()["club"] == "Liverpool"
 
 
+def validate_relationship_ttls(session):
+    result = session.run(
+        """
+        MATCH ()-[r]-()
+        RETURN count(r) as relationship_count
+        """
+    )
+    assert result.single()["relationship_count"] == 0
+    result = session.run(
+        """
+            MATCH (n)
+            RETURN count(n) as node_count
+        """
+    )
+    assert result.single()["relationship_count"] != 0
+
+
+def validate_node_ttls(session):
+    result = session.run(
+        """
+        MATCH (n)
+        RETURN count(n) as node_count
+        """
+    )
+    assert result.single()["node_count"] == 0
+
+
 @pytest.mark.asyncio
 @pytest.mark.e2e
 @pytest.mark.parametrize("neo4j_version", TESTED_NEO4J_VERSIONS)
@@ -67,6 +94,8 @@ def validate_fifa_mo_club(session):
     [
         ("airports", [validate_airports, valiudate_airport_country]),
         ("fifa", [validate_fifa_player_count, validate_fifa_mo_club]),
+        ("relatiobship-ttls", [validate_relationship_ttls]),
+        ("node-ttls", [validate_node_ttls]),
     ],
 )
 async def test_neo4j_pipeline(