Commit 1836983f authored by Waleed Akbar's avatar Waleed Akbar
Browse files

Changes in Analytics and KpiValueApi test files.

parent ced97fbb

src/analytics/backend/tests/test_backend.py

+26 −4
Original line number Diff line number Diff line
@@ -15,7 +15,7 @@ 
import time, json

from typing import Dict

import logging

import threading

from threading import Event, Thread

from common.tools.kafka.Variables import KafkaTopic

from analytics.backend.service.AnalyticsBackendService import AnalyticsBackendService

from analytics.backend.tests.messages import get_kpi_id_list, get_operation_list, get_threshold_dict
@@ -69,9 +69,31 @@ def test_StopRequestListener(): 
    time.sleep(10)

    LOGGER.info('Initiating StopRequestListener...')

    AnalyticsBackendServiceObj = AnalyticsBackendService()

    response = AnalyticsBackendServiceObj.StopRequestListener(response_thread)

    LOGGER.debug(str(response)) 

    assert isinstance(response, bool)

    AnalyticsBackendServiceObj.stop_event = Event()

    listener_thread = Thread(target=AnalyticsBackendServiceObj.RequestListener, args=())

    listener_thread.start()



    time.sleep(2000)



    # AnalyticsBackendServiceObj.stop_event.set()

    # LOGGER.info('Backend termination initiated. waiting for termination... 10 seconds')

    # listener_thread.join(timeout=10)

    # assert not listener_thread.is_alive(), "RequestListener thread did not terminate as expected."

    LOGGER.info('Completed test_RunRequestListener')



# To test START and STOP communication together

# def test_StopRequestListener():

#     LOGGER.info('test_RunRequestListener')

#     LOGGER.info('Initiating StartRequestListener...')

#     AnalyticsBackendServiceObj = AnalyticsBackendService()

#     response_thread = AnalyticsBackendServiceObj.StartRequestListener() # response is Tuple (thread, stop_event)

#     # LOGGER.debug(str(response_thread))

#     time.sleep(10)

#     LOGGER.info('Initiating StopRequestListener...')

#     AnalyticsBackendServiceObj = AnalyticsBackendService()

#     response = AnalyticsBackendServiceObj.StopRequestListener(response_thread)

#     LOGGER.debug(str(response)) 

#     assert isinstance(response, bool)



# To independently tests the SparkListener functionality

# def test_SparkListener():

src/kpi_value_api/tests/test_kpi_value_api.py

+11 −4
Original line number Diff line number Diff line
@@ -78,7 +78,14 @@ def test_validate_kafka_topics(): 
    response = KafkaTopic.create_all_topics()

    assert isinstance(response, bool)



def test_store_kpi_values(kpi_value_api_client):

    LOGGER.debug(" >>> test_set_list_of_KPIs: START <<< ")

    response = kpi_value_api_client.StoreKpiValues(create_kpi_value_list())

    assert isinstance(response, Empty)
 
def test_GetKpiAlarms(kpi_value_api_client):

    LOGGER.debug(" >>> test_GetKpiAlarms")

    stream = kpi_value_api_client.GetKpiAlarms(create_kpi_id_request())

    for response in stream:

        LOGGER.debug(str(response))

    assert isinstance(response, KpiAlarms)



# def test_store_kpi_values(kpi_value_api_client):

#     LOGGER.debug(" >>> test_set_list_of_KPIs: START <<< ")

#     response = kpi_value_api_client.StoreKpiValues(create_kpi_value_list())

#     assert isinstance(response, Empty)