feature: added fhirservice concrete class

personal_graph/database/externalservice.py

@@ -20,7 +20,11 @@ def disconnect(self):
 
     @abstractmethod
     def execute_request(
-        self, method: str, endpoint: str, data: Optional[Dict] = None
+        self,
+        method: str,
+        endpoint: str,
+        data: Optional[Dict] = None,
+        params: Optional[Dict] = None,
     ) -> Any:
         """Execute a REST API request to the external service"""
         pass

personal_graph/database/fhirservice/fhirservice.py

@@ -0,0 +1,62 @@
+import requests
+from fastapi import HTTPException
+from typing import List, Any, Dict, Optional
+
+from personal_graph.database.externalservice import ExternalService
+
+
+class FhirService(ExternalService):
+    def __init__(self, ontologies: Optional[List[Any]] = None):
+        if not ontologies:
+            raise ValueError("Ontology not provided")
+
+        self.ontologies = ontologies
+        self.base_url = ""
+        self.session = requests.Session()
+
+    def connect(self, url: str):
+        self.base_url = url
+
+    def disconnect(self):
+        self.session.close()
+
+    def execute_request(
+        self,
+        method: str,
+        endpoint: str,
+        data: Optional[Dict] = None,
+        params: Optional[Dict] = None,
+    ) -> Any:
+        url = f"{self.base_url}/{endpoint}"
+        try:
+            response = self.session.request(method, url, json=data, params=params)
+            response.raise_for_status()
+            return response.json()
+        except requests.HTTPError as e:
+            if e.response.status_code == 422:
+                raise HTTPException(
+                    status_code=422,
+                    detail="Validation error: " + str(e.response.json()),
+                )
+            else:
+                raise
+
+    def add_node(self, db_url: str, label: str, attribute: Dict):
+        try:
+            params = {
+                "db_url": db_url,
+                "resource_type": label,
+            }
+
+            response = self.execute_request(
+                method="POST", endpoint=label, data=attribute, params=params
+            )
+            return response
+        except requests.HTTPError as e:
+            if e.response.status_code == 422:
+                error_detail = e.response.json()
+                raise HTTPException(
+                    status_code=422, detail="Validation error: " + str(error_detail)
+                )
+            else:
+                raise