X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2app%2Fservice%2Fhandlers.py;h=9b4f49dd2ed17ddce8bbdcabdb6cae3d1df4b1fa;hb=8d6c2f135ee103b9a94ea6c29986a608069b6982;hp=d630720a75d3b289ab27989adcc4e7b2ffc8b57b;hpb=d2f6cc674bf3623caf114a8d7709e70d55ec9340;p=pti%2Fo2.git diff --git a/o2app/service/handlers.py b/o2app/service/handlers.py index d630720..9b4f49d 100644 --- a/o2app/service/handlers.py +++ b/o2app/service/handlers.py @@ -17,7 +17,7 @@ from __future__ import annotations from o2dms.service import nfdeployment_handler # from dataclasses import asdict -from typing import List, Dict, Callable, Type +from typing import Dict, Callable, Type # TYPE_CHECKING from o2ims.domain import commands, events @@ -26,11 +26,13 @@ from o2dms.domain import events as o2dms_events from o2ims.service.auditor import ocloud_handler, dms_handler, \ resourcepool_handler, pserver_handler, pserver_cpu_handler, \ pserver_mem_handler, pserver_port_handler, pserver_if_handler,\ - pserver_eth_handler, alarm_handler + pserver_eth_handler, pserver_acc_handler, alarm_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 from o2ims.service.event import ocloud_event, resource_event, \ - resource_pool_event, configuration_event, alarm_event + resource_pool_event, alarm_event, dms_event, resource_type_event # if TYPE_CHECKING: # from . import unit_of_work @@ -53,11 +55,12 @@ 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.ConfigurationChanged: [configuration_event.\ - notify_configuration_change], events.AlarmEventChanged: [alarm_event.\ notify_alarm_event_change], } # type: Dict[Type[events.Event], Callable] @@ -68,12 +71,19 @@ COMMAND_HANDLERS = { commands.UpdateDms: dms_handler.update_dms, commands.UpdateAlarm: alarm_handler.update_alarm, commands.UpdateResourcePool: resourcepool_handler.update_resourcepool, + commands.UpdateComputeAgg: agg_compute_handler.update_compute_aggregate, + commands.UpdateNetworkAgg: agg_network_handler.update_network_aggregate, + commands.UpdateStorageAgg: agg_storage_handler.update_storage_aggregate, + commands.UpdateUndefinedAgg: + agg_undefined_handler.update_undefined_aggregate, commands.UpdatePserver: pserver_handler.update_pserver, commands.UpdatePserverCpu: pserver_cpu_handler.update_pserver_cpu, commands.UpdatePserverMem: pserver_mem_handler.update_pserver_mem, commands.UpdatePserverIf: pserver_if_handler.update_pserver_if, commands.UpdatePserverIfPort: pserver_port_handler.update_pserver_port, commands.UpdatePserverEth: pserver_eth_handler.update_pserver_eth, + commands.UpdatePserverDev: pserver_dev_handler.update_pserver_dev, + commands.UpdatePserverAcc: pserver_acc_handler.update_pserver_acc, o2dms_cmmands.HandleNfDeploymentStateChanged: nfdeployment_handler.handle_nfdeployment_statechanged, o2dms_cmmands.InstallNfDeployment: