Activity Delete VNF record
Change-Id: I8c557ebc00833a64041e1c70cc9c6fec4c1a769c
Signed-off-by: Patricia Reinoso <patricia.reinoso@canonical.com>
Signed-off-by: Mark Beierl <mark.beierl@canonical.com>
diff --git a/osm_lcm/tests/test_vnf_activities.py b/osm_lcm/tests/test_vnf_activities.py
index 374a648..64d9caf 100644
--- a/osm_lcm/tests/test_vnf_activities.py
+++ b/osm_lcm/tests/test_vnf_activities.py
@@ -22,6 +22,7 @@
from osm_common.dbbase import DbException
from osm_common.temporal_task_queues.task_queues_mappings import LCM_TASK_QUEUE
from osm_lcm.temporal.vnf_activities import (
+ DeleteVnfRecordImpl,
ChangeVnfInstantiationStateImpl,
ChangeVnfStateImpl,
GetModelNamesImpl,
@@ -269,6 +270,31 @@
)
+class TestDeleteVnfRecord(asynctest.TestCase):
+ async def setUp(self):
+ self.db = Mock()
+ self.delete_vnf_record = DeleteVnfRecordImpl(self.db)
+ self.env = ActivityEnvironment()
+
+ async def test_activity__succeeded__expected_record_is_deleted(self):
+ self.db.del_one.return_value = None
+ await self.env.run(
+ self.delete_vnf_record,
+ DeleteVnfRecordImpl.Input(vnfr_uuid=vnfr_uuid),
+ )
+ self.db.del_one.assert_called_with(
+ "vnfrs", {"_id": vnfr_uuid}, fail_on_empty=False
+ )
+
+ async def test_activity__failed__raise_db_exception(self):
+ self.db.del_one.side_effect = DbException("Can not connect to Database.")
+ with self.assertRaises(DbException):
+ await self.env.run(
+ self.delete_vnf_record,
+ DeleteVnfRecordImpl.Input(vnfr_uuid=vnfr_uuid),
+ )
+
+
class TestGetVimCloud(asynctest.TestCase):
async def setUp(self):
self.db = Mock()