Commit e2504b5b authored by Lluis Gifre Renom's avatar Lluis Gifre Renom
Browse files

Monitoring component: 

- Fixed unitary tests
parent e19b834b

src/monitoring/tests/test_unitary.py

+13 −2
Original line number Diff line number Diff line
@@ -22,16 +22,18 @@ from apscheduler.executors.pool import ProcessPoolExecutor 
from apscheduler.schedulers.background import BackgroundScheduler

from apscheduler.schedulers.base import STATE_STOPPED

from grpc._channel import _MultiThreadedRendezvous

from common.Constants import ServiceNameEnum

from common.Constants import DEFAULT_CONTEXT_NAME, DEFAULT_TOPOLOGY_NAME, ServiceNameEnum

from common.Settings import (

    ENVVAR_SUFIX_SERVICE_HOST, ENVVAR_SUFIX_SERVICE_PORT_GRPC, get_env_var_name, get_service_port_grpc)

from common.proto.context_pb2 import ConfigActionEnum, DeviceOperationalStatusEnum, EventTypeEnum, DeviceEvent, Device, Empty

from common.proto.context_pb2 import ConfigActionEnum, Context, ContextId, DeviceOperationalStatusEnum, EventTypeEnum, DeviceEvent, Device, Empty, Topology, TopologyId

from common.proto.context_pb2_grpc import add_ContextServiceServicer_to_server

from common.proto.kpi_sample_types_pb2 import KpiSampleType

from common.proto.monitoring_pb2 import KpiId, KpiDescriptor, SubsDescriptor, SubsList, AlarmID, \

    AlarmDescriptor, AlarmList, KpiDescriptorList, SubsResponse, AlarmResponse, RawKpiTable #, Kpi, KpiList

from common.tests.MockServicerImpl_Context import MockServicerImpl_Context

from common.tools.object_factory.ConfigRule import json_config_rule_set

from common.tools.object_factory.Context import json_context, json_context_id

from common.tools.object_factory.Topology import json_topology, json_topology_id

from common.tools.service.GenericGrpcService import GenericGrpcService

from common.tools.timestamp.Converters import timestamp_utcnow_to_float #, timestamp_string_to_float

from context.client.ContextClient import ContextClient
@@ -599,6 +601,10 @@ def test_listen_events( 
    events_collector = EventsDeviceCollector(metrics_db.name_mapping)

    events_collector.start()



    context_id = json_context_id(DEFAULT_CONTEXT_NAME)

    context_client.SetContext(Context(**json_context(DEFAULT_CONTEXT_NAME)))

    context_client.SetTopology(Topology(**json_topology(DEFAULT_TOPOLOGY_NAME, context_id=context_id)))



    LOGGER.info('Adding Device {:s}'.format(DEVICE_DEV1_UUID))

    device_with_connect_rules = copy.deepcopy(DEVICE_DEV1)

    device_with_connect_rules['device_config']['config_rules'].extend(DEVICE_DEV1_CONNECT_RULES)
@@ -623,6 +629,11 @@ def test_listen_events( 
    assert len(kpi_id_list) > 0



    device_client.DeleteDevice(response)



    context_id = json_context_id(DEFAULT_CONTEXT_NAME)

    context_client.RemoveTopology(TopologyId(**json_topology_id(DEFAULT_TOPOLOGY_NAME, context_id=context_id)))

    context_client.RemoveContext(ContextId(**context_id))



    events_collector.stop()



    LOGGER.warning('test_listen_events end')