Add o2dms api endpoint

[pti/o2.git] / o2dms / domain / dms_repo.py

diff --git a/o2dms/domain/dms_repo.py b/o2dms/domain/dms_repo.py
new file mode 100644 (file)
index 0000000..f199a3c
--- /dev/null
+++ b/o2dms/domain/dms_repo.py
@@ -0,0 +1,50 @@
+# Copyright (C) 2021 Wind River Systems, Inc.\r
+#\r
+#  Licensed under the Apache License, Version 2.0 (the "License");\r
+#  you may not use this file except in compliance with the License.\r
+#  You may obtain a copy of the License at\r
+#\r
+#      http://www.apache.org/licenses/LICENSE-2.0\r
+#\r
+#  Unless required by applicable law or agreed to in writing, software\r
+#  distributed under the License is distributed on an "AS IS" BASIS,\r
+#  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
+#  See the License for the specific language governing permissions and\r
+#  limitations under the License.\r
+\r
+import abc\r
+from typing import List, Set\r
+from o2dms.domain import dms\r
+\r
+\r
+class NfDeploymentDescRepository(abc.ABC):\r
+    def __init__(self):\r
+        self.seen = set()  # type: Set[dms.NfDeploymentDesc]\r
+\r
+    def add(self, nfdeployment_descriptor: dms.NfDeploymentDesc):\r
+        self._add(nfdeployment_descriptor)\r
+        self.seen.add(nfdeployment_descriptor)\r
+\r
+    def get(self, nfdeployment_descriptor_id) -> dms.NfDeploymentDesc:\r
+        nfdeployment_descriptor = self._get(nfdeployment_descriptor_id)\r
+        if nfdeployment_descriptor:\r
+            self.seen.add(nfdeployment_descriptor)\r
+        return nfdeployment_descriptor\r
+\r
+    def list(self) -> List[dms.NfDeploymentDesc]:\r
+        return self._list()\r
+\r
+    def update(self, nfdeployment_descriptor: dms.NfDeploymentDesc):\r
+        self._update(nfdeployment_descriptor)\r
+\r
+    @abc.abstractmethod\r
+    def _add(self, nfdeployment_descriptor: dms.NfDeploymentDesc):\r
+        raise NotImplementedError\r
+\r
+    @abc.abstractmethod\r
+    def _get(self, nfdeployment_descriptor_id) -> dms.NfDeploymentDesc:\r
+        raise NotImplementedError\r
+\r
+    @abc.abstractmethod\r
+    def _update(self, nfdeployment_descriptor: dms.NfDeploymentDesc):\r
+        raise NotImplementedError\r