X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=o2app%2Fservice%2Fhandlers.py;h=d68b295d1bc9044b13ba39c16774df9f7451de2a;hb=refs%2Fchanges%2F82%2F7282%2F1;hp=f3b3d6db1cd52dbb9d39eff72d764a3975c03e90;hpb=f73c8e3b01b8f5b7438ba544870e06d8f30cdea0;p=pti%2Fo2.git diff --git a/o2app/service/handlers.py b/o2app/service/handlers.py index f3b3d6d..d68b295 100644 --- a/o2app/service/handlers.py +++ b/o2app/service/handlers.py @@ -14,13 +14,19 @@ # pylint: disable=unused-argument from __future__ import annotations +from o2dms.service.nfdeployment_handler import install_nfdeployment +from o2dms.service.nfdeployment_handler import publish_nfdeployment_created # from dataclasses import asdict from typing import List, Dict, Callable, Type # TYPE_CHECKING from o2ims.domain import commands, events + +from o2dms.domain import commands as o2dms_cmmands +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_mem_handler, pserver_port_handler, pserver_if_handler,\ + pserver_eth_handler # if TYPE_CHECKING: # from . import unit_of_work @@ -31,7 +37,8 @@ class InvalidResourceType(Exception): EVENT_HANDLERS = { -} # type: Dict[Type[events.Event], List[Callable]] + o2dms_events.NfDeploymentCreated: [publish_nfdeployment_created] +} COMMAND_HANDLERS = { @@ -42,5 +49,7 @@ COMMAND_HANDLERS = { 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.UpdatePserverPort: pserver_port_handler.update_pserver_port, + commands.UpdatePserverIfPort: pserver_port_handler.update_pserver_port, + commands.UpdatePserverEth: pserver_eth_handler.update_pserver_eth, + o2dms_cmmands.InstallNfDeployment: install_nfdeployment } # type: Dict[Type[commands.Command], Callable]