X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2app%2Fservice%2Fhandlers.py;h=4ef0ef8ece94a2d96245d9a47ab352f784c8dd66;hb=e00040ca7c6149995c5883bcd9dd81e02b25d0da;hp=1754f7922cfb9741a7e06eeae81d9924b8de5512;hpb=4aabbc42db31fb781f16eecf59223776cff3b034;p=pti%2Fo2.git diff --git a/o2app/service/handlers.py b/o2app/service/handlers.py index 1754f79..4ef0ef8 100644 --- a/o2app/service/handlers.py +++ b/o2app/service/handlers.py @@ -1,4 +1,4 @@ -# Copyright (C) 2021 Wind River Systems, Inc. +# Copyright (C) 2021-2024 Wind River Systems, Inc. # # Licensed under the Apache License, Version 2.0 (the "License"); # you may not use this file except in compliance with the License. @@ -30,9 +30,9 @@ from o2ims.service.auditor import ocloud_handler, dms_handler, \ pserver_dev_handler, agg_compute_handler, agg_network_handler,\ agg_storage_handler, agg_undefined_handler from o2ims.service.command import notify_handler, registration_handler,\ - notify_alarm_handler + notify_alarm_handler, purge_alarm_handler from o2ims.service.event import ocloud_event, resource_event, \ - resource_pool_event, alarm_event + resource_pool_event, alarm_event, dms_event, resource_type_event # if TYPE_CHECKING: # from . import unit_of_work @@ -55,11 +55,16 @@ EVENT_HANDLERS = { # o2dms_events.NfDeploymentUninstalled: [ # nfdeployment_handler.publish_nfdeployment_uninstalled] events.OcloudChanged: [ocloud_event.notify_ocloud_update], + events.ResourceTypeChanged: [resource_type_event.\ + notify_resourcetype_change], + events.DmsChanged: [dms_event.notify_dms_change], events.ResourceChanged: [resource_event.notify_resource_change], events.ResourcePoolChanged: [resource_pool_event.\ notify_resourcepool_change], events.AlarmEventChanged: [alarm_event.\ notify_alarm_event_change], + events.AlarmEventPurged: [alarm_event.\ + notify_alarm_event_purge], } # type: Dict[Type[events.Event], Callable] @@ -92,4 +97,5 @@ COMMAND_HANDLERS = { commands.PubMessage2SMO: notify_handler.notify_change_to_smo, commands.PubAlarm2SMO: notify_alarm_handler.notify_alarm_to_smo, commands.Register2SMO: registration_handler.registry_to_smo, + commands.PurgeAlarmEvent: purge_alarm_handler.purge_alarm_event, } # type: Dict[Type[commands.Command], Callable]