X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2app%2Fservice%2Fhandlers.py;h=9b4f49dd2ed17ddce8bbdcabdb6cae3d1df4b1fa;hb=8d6c2f135ee103b9a94ea6c29986a608069b6982;hp=cc69fc56c7e62fca8d9c2d07337cf764e28f4500;hpb=9ee90ffa2414326c26fd10edc59bf315204254e2;p=pti%2Fo2.git diff --git a/o2app/service/handlers.py b/o2app/service/handlers.py index cc69fc5..9b4f49d 100644 --- a/o2app/service/handlers.py +++ b/o2app/service/handlers.py @@ -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, alarm_event + resource_pool_event, alarm_event, dms_event, resource_type_event # if TYPE_CHECKING: # from . import unit_of_work @@ -53,6 +55,9 @@ 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], @@ -66,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: