From 5d51d5e91a5f41057ac81e1a9bc0b7a21a9dc3be Mon Sep 17 00:00:00 2001
From: zrgt <garmaev@gmx.de>
Date: Tue, 27 Aug 2024 18:01:02 +0200
Subject: [PATCH] adapter.http: add CD-Repo routes

---
 basyx/aas/adapter/http.py | 57 ++++++++++++++++++++++++++++++++++++---
 1 file changed, 54 insertions(+), 3 deletions(-)

diff --git a/basyx/aas/adapter/http.py b/basyx/aas/adapter/http.py
index 3b244499..359f621c 100644
--- a/basyx/aas/adapter/http.py
+++ b/basyx/aas/adapter/http.py
@@ -550,7 +550,14 @@ def __init__(self, object_store: model.AbstractObjectStore, file_store: aasx.Abs
                                  endpoint=self.delete_submodel_submodel_element_qualifiers)
                         ])
                     ])
-                ])
+                ]),
+                Rule("/concept-descriptions", methods=["GET"], endpoint=self.get_concept_description_all),
+                Rule("/concept-descriptions", methods=["POST"], endpoint=self.post_concept_description),
+                Submount("/concept-descriptions", [
+                    Rule("/<base64url:concept_id>", methods=["GET"], endpoint=self.get_concept_description),
+                    Rule("/<base64url:concept_id>", methods=["PUT"], endpoint=self.put_concept_description),
+                    Rule("/<base64url:concept_id>", methods=["DELETE"], endpoint=self.delete_concept_description),
+                ]),
             ])
         ], converters={
             "base64url": Base64URLConverter,
@@ -730,8 +737,8 @@ def not_implemented(self, request: Request, url_args: Dict, **_kwargs) -> Respon
     # ------ AAS REPO ROUTES -------
     def get_aas_all(self, request: Request, url_args: Dict, **_kwargs) -> Response:
         response_t = get_response_type(request)
-        aashels, cursor = self._get_shells(request)
-        return response_t(list(aashels), cursor=cursor)
+        aashells, cursor = self._get_shells(request)
+        return response_t(list(aashells), cursor=cursor)
 
     def post_aas(self, request: Request, url_args: Dict, map_adapter: MapAdapter) -> Response:
         response_t = get_response_type(request)
@@ -1143,9 +1150,53 @@ def delete_submodel_submodel_element_qualifiers(self, request: Request, url_args
         sm_or_se.commit()
         return response_t()
 
+    # --------- CONCEPT DESCRIPTION ROUTES ---------
+    def get_concept_description_all(self, request: Request, url_args: Dict, **_kwargs) -> Response:
+        response_t = get_response_type(request)
+        concept_descriptions: Iterator[model.ConceptDescription] = self._get_all_obj_of_type(model.ConceptDescription)
+        concept_descriptions, cursor = self._get_slice(request, concept_descriptions)
+        return response_t(list(concept_descriptions), cursor=cursor, stripped=is_stripped_request(request))
+
+    def post_concept_description(self, request: Request, url_args: Dict, map_adapter: MapAdapter) -> Response:
+        response_t = get_response_type(request)
+        concept_description = HTTPApiDecoder.request_body(request, model.ConceptDescription, is_stripped_request(request))
+        try:
+            self.object_store.add(concept_description)
+        except KeyError as e:
+            raise Conflict(f"ConceptDescription with Identifier {concept_description.id} already exists!") from e
+        concept_description.commit()
+        created_resource_url = map_adapter.build(self.get_concept_description, {
+            "concept_id": concept_description.id
+        }, force_external=True)
+        return response_t(concept_description, status=201, headers={"Location": created_resource_url})
+
+    def get_concept_description(self, request: Request, url_args: Dict, **_kwargs) -> Response:
+        response_t = get_response_type(request)
+        concept_description = self._get_concept_description(url_args)
+        return response_t(concept_description, stripped=is_stripped_request(request))
+
+    def _get_concept_description(self, url_args):
+        return self._get_obj_ts(url_args["concept_id"], model.ConceptDescription)
+
+    def put_concept_description(self, request: Request, url_args: Dict, **_kwargs) -> Response:
+        response_t = get_response_type(request)
+        concept_description = self._get_concept_description(url_args)
+        concept_description.update_from(HTTPApiDecoder.request_body(request, model.ConceptDescription,
+                                                                    is_stripped_request(request)))
+        concept_description.commit()
+        return response_t()
+
+    def delete_concept_description(self, request: Request, url_args: Dict, **_kwargs) -> Response:
+        response_t = get_response_type(request)
+        self.object_store.remove(self._get_concept_description(url_args))
+        return response_t()
+
 
 if __name__ == "__main__":
     from werkzeug.serving import run_simple
     from basyx.aas.examples.data.example_aas import create_full_example
     run_simple("localhost", 8080, WSGIApp(create_full_example(), aasx.DictSupplementaryFileContainer()),
                use_debugger=True, use_reloader=True)
+
+
+# Commit msg: Add CD-Repo routes to the server
\ No newline at end of file