Update o2dms lcm api

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

diff --git a/o2dms/domain/dms_repo.py b/o2dms/domain/dms_repo.py
index 2564a81..c53d90f 100644 (file)
--- a/o2dms/domain/dms_repo.py
+++ b/o2dms/domain/dms_repo.py
@@ -17,6 +17,46 @@ from typing import List, Set
 from o2dms.domain import dms\r
 \r
 \r
+class NfDeploymentRepository(abc.ABC):\r
+    def __init__(self):\r
+        self.seen = set()  # type: Set[dms.NfDeployment]\r
+\r
+    def add(self, nfdeployment: dms.NfDeployment):\r
+        self._add(nfdeployment)\r
+        self.seen.add(nfdeployment)\r
+\r
+    def get(self, nfdeployment_id) -> dms.NfDeployment:\r
+        nfdeployment = self._get(nfdeployment_id)\r
+        if nfdeployment:\r
+            self.seen.add(nfdeployment)\r
+        return nfdeployment\r
+\r
+    def list(self) -> List[dms.NfDeployment]:\r
+        return self._list()\r
+\r
+    def update(self, id, **kwargs):\r
+        self._update(id, **kwargs)\r
+\r
+    def delete(self, nfdeployment_id):\r
+        self._delete(nfdeployment_id)\r
+\r
+    @abc.abstractmethod\r
+    def _add(self, nfdeployment: dms.NfDeployment):\r
+        raise NotImplementedError\r
+\r
+    @abc.abstractmethod\r
+    def _get(self, nfdeployment_id) -> dms.NfDeployment:\r
+        raise NotImplementedError\r
+\r
+    @abc.abstractmethod\r
+    def _update(self,  id, **kwargs):\r
+        raise NotImplementedError\r
+\r
+    @abc.abstractmethod\r
+    def _delete(self, nfdeployment_id):\r
+        raise NotImplementedError\r
+\r
+\r
 class NfDeploymentDescRepository(abc.ABC):\r
     def __init__(self):\r
         self.seen = set()  # type: Set[dms.NfDeploymentDesc]\r
@@ -49,9 +89,49 @@ class NfDeploymentDescRepository(abc.ABC):
         raise NotImplementedError\r
 \r
     @abc.abstractmethod\r
-    def _update(self, nfdeployment_descriptor: dms.NfDeploymentDesc):\r
+    def _update(self,  id, **kwargs):\r
         raise NotImplementedError\r
 \r
     @abc.abstractmethod\r
     def _delete(self, nfdeployment_descriptor_id):\r
         raise NotImplementedError\r
+\r
+\r
+class NfOCloudVResourceRepository(abc.ABC):\r
+    def __init__(self):\r
+        self.seen = set()  # type: Set[dms.NfOCloudVResource]\r
+\r
+    def add(self, nfocloudvres: dms.NfOCloudVResource):\r
+        self._add(nfocloudvres)\r
+        self.seen.add(nfocloudvres)\r
+\r
+    def get(self, nfocloudvres_id) -> dms.NfOCloudVResource:\r
+        nfocloudvres = self._get(nfocloudvres_id)\r
+        if nfocloudvres:\r
+            self.seen.add(nfocloudvres)\r
+        return nfocloudvres\r
+\r
+    def list(self) -> List[dms.NfOCloudVResource]:\r
+        return self._list()\r
+\r
+    def update(self, nfocloudvres_id, **kwargs):\r
+        self._update(nfocloudvres_id, **kwargs)\r
+\r
+    def delete(self, nfocloudvres_id):\r
+        self._delete(nfocloudvres_id)\r
+\r
+    @abc.abstractmethod\r
+    def _add(self, nfocloudvres: dms.NfOCloudVResource):\r
+        raise NotImplementedError\r
+\r
+    @abc.abstractmethod\r
+    def _get(self, nfocloudvres_id) -> dms.NfOCloudVResource:\r
+        raise NotImplementedError\r
+\r
+    @abc.abstractmethod\r
+    def _update(self,  nfocloudvres_id, **kwargs):\r
+        raise NotImplementedError\r
+\r
+    @abc.abstractmethod\r
+    def _delete(self, nfocloudvres_id):\r
+        raise NotImplementedError\r