X-Git-Url: https://osm.etsi.org/gitweb/?a=blobdiff_plain;f=osm_policy_module%2Fcommon%2Fcommon_db_client.py;h=2be3693cb53bd7c5ada5b828dfc923d1378c14bf;hb=refs%2Ftags%2Fv5.0.2;hp=41ce97566263ac80f2387c5cad8150b823666c5a;hpb=7ee7c5739c95f39f0010a02de161851bd7c18725;p=osm%2FPOL.git diff --git a/osm_policy_module/common/common_db_client.py b/osm_policy_module/common/common_db_client.py index 41ce975..2be3693 100644 --- a/osm_policy_module/common/common_db_client.py +++ b/osm_policy_module/common/common_db_client.py @@ -24,6 +24,7 @@ from osm_common import dbmongo from osm_policy_module.core.config import Config +from osm_policy_module.core.exceptions import VdurNotFound class CommonDbClient: @@ -56,3 +57,11 @@ class CommonDbClient: nslcmop = self.common_db.get_one("nslcmops", {"_id": nslcmop_id}) return nslcmop + + def get_vdur(self, nsr_id, member_index, vdur_name): + vnfr = self.get_vnfr(nsr_id, member_index) + for vdur in vnfr['vdur']: + if vdur['name'] == vdur_name: + return vdur + raise VdurNotFound('vdur not found for nsr-id %s, member_index %s and vdur_name %s', nsr_id, member_index, + vdur_name)