diff options
author | SagarS <sagar.shetty@est.tech> | 2022-02-24 17:07:01 +0000 |
---|---|---|
committer | SagarS <sagar.shetty@est.tech> | 2022-03-02 13:47:51 +0000 |
commit | 5f69c24ad78121a2840b5299583791e557f8b535 (patch) | |
tree | 22e84dc45427065d7bfa35e2ee0dcc80311a0753 /components/pm-subscription-handler/tests/services/test_measurement_group_service.py | |
parent | 37762006756658532012d9b8e4286e80acb612c4 (diff) |
[PMSH] Update Filter API
Issue-ID: DCAEGEN2-2922
Change-Id: Ibf0ef167642027429b3ba91daea60228cf5fa4c6
Signed-off-by: SagarS <sagar.shetty@est.tech>
Diffstat (limited to 'components/pm-subscription-handler/tests/services/test_measurement_group_service.py')
-rw-r--r-- | components/pm-subscription-handler/tests/services/test_measurement_group_service.py | 45 |
1 files changed, 45 insertions, 0 deletions
diff --git a/components/pm-subscription-handler/tests/services/test_measurement_group_service.py b/components/pm-subscription-handler/tests/services/test_measurement_group_service.py index f656513e..1dbe84a9 100644 --- a/components/pm-subscription-handler/tests/services/test_measurement_group_service.py +++ b/components/pm-subscription-handler/tests/services/test_measurement_group_service.py @@ -358,3 +358,48 @@ class MeasurementGroupServiceTestCase(BaseClassSetup): self.assertEqual(meas_grp.subscription_name, 'sub') self.assertEqual(meas_grp.measurement_group_name, 'MG2') self.assertEqual(meas_grp.administrative_state, 'LOCKING') + + def test_filter_nf_to_meas_grp_for_delete(self): + sub = create_subscription_data('sub') + db.session.add(sub) + nf = NetworkFunction(nf_name='pnf_test2') + nf_service.save_nf(nf) + measurement_group_service.apply_nf_status_to_measurement_group( + "pnf_test2", "MG2", SubNfState.PENDING_DELETE.value) + db.session.commit() + measurement_group_service.filter_nf_to_meas_grp( + "pnf_test2", "MG2", SubNfState.DELETED.value) + measurement_grp_rel = (NfMeasureGroupRelationalModel.query.filter( + NfMeasureGroupRelationalModel.measurement_grp_name == 'MG2', + NfMeasureGroupRelationalModel.nf_name == 'pnf_test2').one_or_none()) + self.assertIsNone(measurement_grp_rel) + network_function = (NetworkFunctionModel.query.filter( + NetworkFunctionModel.nf_name == 'pnf_test2').one_or_none()) + self.assertIsNone(network_function) + meas_grp = measurement_group_service.query_meas_group_by_name('sub', 'MG2') + self.assertEqual(meas_grp.subscription_name, 'sub') + self.assertEqual(meas_grp.measurement_group_name, 'MG2') + self.assertEqual(meas_grp.administrative_state, 'UNLOCKED') + + def test_filter_nf_to_meas_grp_for_create(self): + sub = create_subscription_data('sub') + db.session.add(sub) + nf = NetworkFunction(nf_name='pnf_test2') + nf_service.save_nf(nf) + measurement_group_service.apply_nf_status_to_measurement_group( + "pnf_test2", "MG2", SubNfState.PENDING_CREATE.value) + db.session.commit() + measurement_group_service.filter_nf_to_meas_grp( + "pnf_test2", "MG2", SubNfState.CREATED.value) + measurement_grp_rel = (NfMeasureGroupRelationalModel.query.filter( + NfMeasureGroupRelationalModel.measurement_grp_name == 'MG2', + NfMeasureGroupRelationalModel.nf_name == 'pnf_test2').one_or_none()) + self.assertIsNotNone(measurement_grp_rel) + self.assertEqual(measurement_grp_rel.nf_measure_grp_status, 'CREATED') + network_function = (NetworkFunctionModel.query.filter( + NetworkFunctionModel.nf_name == 'pnf_test2').one_or_none()) + self.assertIsNotNone(network_function) + meas_grp = measurement_group_service.query_meas_group_by_name('sub', 'MG2') + self.assertEqual(meas_grp.subscription_name, 'sub') + self.assertEqual(meas_grp.measurement_group_name, 'MG2') + self.assertEqual(meas_grp.administrative_state, 'UNLOCKED') |