Cluster name update check unique name and replace in both collection
Change-Id: I9ddc891591ec58e8d3cb51118966fb1ebe6ff0f9
Signed-off-by: yshah <shahithya.y@tataelxsi.co.in>
diff --git a/osm_nbi/acm_topic.py b/osm_nbi/acm_topic.py
index 87087b7..27273f9 100644
--- a/osm_nbi/acm_topic.py
+++ b/osm_nbi/acm_topic.py
@@ -262,22 +262,6 @@
self.db.set_one("k8sclusters", {"_id": item_1["_id"]}, item_1)
return
- def edit_extra_before(self, session, _id, indata=None, kwargs=None, content=None):
- check = self.db.get_one(self.topic, {"_id": _id})
- if self.topic != "clusters":
- if check["default"] is True:
- raise EngineException(
- "Cannot edit default profiles",
- HTTPStatus.UNPROCESSABLE_ENTITY,
- )
- if "name" in indata:
- if check["name"] == indata["name"]:
- pass
- else:
- self.check_unique_name(session, indata["name"])
-
- return True
-
def cluster_unique_name_check(self, session, name):
self.check_unique_name(session, name)
_filter = {"name": name}
@@ -323,6 +307,17 @@
def __init__(self, db, fs, msg, auth):
super().__init__(db, fs, msg, auth)
+ def edit_extra_before(self, session, _id, indata=None, kwargs=None, content=None):
+ check = self.db.get_one(self.topic, {"_id": _id})
+ if check["default"] is True:
+ raise EngineException(
+ "Cannot edit default profiles",
+ HTTPStatus.UNPROCESSABLE_ENTITY,
+ )
+ if "name" in indata and check["name"] != indata["name"]:
+ self.check_unique_name(session, indata["name"])
+ return True
+
def delete_extra_before(self, session, _id, db_content, not_send_msg=None):
op_id = self.common_delete(_id, db_content)
return {"profile_id": _id, "operation_id": op_id}