diff --git a/src/monitoring/tests/test_unitary.py b/src/monitoring/tests/test_unitary.py index 0701c5ce8bc56ee34d0a90760b0d6e88fdbbee42..cd20e38de6bf9d451af0bac48945fdbe442540e7 100644 --- a/src/monitoring/tests/test_unitary.py +++ b/src/monitoring/tests/test_unitary.py @@ -400,34 +400,34 @@ def test_get_device_events(context_client_grpc: ContextClient, # pylint: disabl events_collector.stop() -def test_listen_events(monitoring_client: MonitoringClient, - context_client_grpc: ContextClient, # pylint: disable=redefined-outer-name - context_db_mb: Tuple[Database, MessageBroker]): - - LOGGER.warning('test_listen_events begin') - - context_database = context_db_mb[0] - - # ----- Clean the database ----------------------------------------------------------------------------------------- - context_database.clear_all() - - # ----- Initialize the EventsCollector ----------------------------------------------------------------------------- - events_collector = EventsDeviceCollector(context_client_grpc,monitoring_client) - events_collector.start() - - # # ----- Dump state of database before create the object ------------------------------------------------------------ - db_entries = context_database.dump() - LOGGER.info('----- Database Dump [{:3d} entries] -------------------------'.format(len(db_entries))) - for db_entry in db_entries: - LOGGER.info(' [{:>4s}] {:40s} :: {:s}'.format(*db_entry)) # pragma: no cover - LOGGER.info('-----------------------------------------------------------') - assert len(db_entries) == 0 - - populate('localhost', GRPC_PORT_CONTEXT) # place this call in the appropriate line, according to your tests - - kpi_id_list = events_collector.listen_events() - - assert bool(kpi_id_list) == True +# def test_listen_events(monitoring_client: MonitoringClient, +# context_client_grpc: ContextClient, # pylint: disable=redefined-outer-name +# context_db_mb: Tuple[Database, MessageBroker]): +# +# LOGGER.warning('test_listen_events begin') +# +# context_database = context_db_mb[0] +# +# # ----- Clean the database ----------------------------------------------------------------------------------------- +# context_database.clear_all() +# +# # ----- Initialize the EventsCollector ----------------------------------------------------------------------------- +# events_collector = EventsDeviceCollector(context_client_grpc,monitoring_client) +# events_collector.start() +# +# # # ----- Dump state of database before create the object ------------------------------------------------------------ +# db_entries = context_database.dump() +# LOGGER.info('----- Database Dump [{:3d} entries] -------------------------'.format(len(db_entries))) +# for db_entry in db_entries: +# LOGGER.info(' [{:>4s}] {:40s} :: {:s}'.format(*db_entry)) # pragma: no cover +# LOGGER.info('-----------------------------------------------------------') +# assert len(db_entries) == 0 +# +# populate('localhost', GRPC_PORT_CONTEXT) # place this call in the appropriate line, according to your tests +# +# kpi_id_list = events_collector.listen_events() +# +# assert bool(kpi_id_list) == True def test_socket_ports(address, port): s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)