Commit 9119dd59 authored by Waleed Akbar's avatar Waleed Akbar
Browse files

Changes in Telemetry. 

- tests file name is corrected.
- Telmetry frontend and backend requriements.in is updated
parent cbe6880c

src/telemetry/backend/requirements.in

+0 −4
Original line number Diff line number Diff line
@@ -13,7 +13,3 @@ 
# limitations under the License.



confluent-kafka==2.3.*
 
psycopg2-binary==2.9.*

SQLAlchemy==1.4.*

sqlalchemy-cockroachdb==1.4.*

SQLAlchemy-Utils==0.38.*

src/telemetry/backend/tests/test_TelemetryBackend.py

0 → 100644
+38 −0
Original line number Diff line number Diff line 
# Copyright 2022-2024 ETSI OSG/SDG TeraFlowSDN (TFS) (https://tfs.etsi.org/)

#

# Licensed under the Apache License, Version 2.0 (the "License");

# you may not use this file except in compliance with the License.

# You may obtain a copy of the License at

#

#      http://www.apache.org/licenses/LICENSE-2.0

#

# Unless required by applicable law or agreed to in writing, software

# distributed under the License is distributed on an "AS IS" BASIS,

# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

# See the License for the specific language governing permissions and

# limitations under the License.



import logging

from common.tools.kafka.Variables import KafkaTopic

from src.telemetry.backend.service.TelemetryBackendService import TelemetryBackendService





LOGGER = logging.getLogger(__name__)





###########################

# Tests Implementation of Telemetry Backend

###########################



# --- "test_validate_kafka_topics" should be run before the functionality tests ---

def test_validate_kafka_topics():

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

    response = KafkaTopic.create_all_topics()

    assert isinstance(response, bool)



def test_RunRequestListener():

    LOGGER.info('test_RunRequestListener')

    TelemetryBackendServiceObj = TelemetryBackendService()

    response = TelemetryBackendServiceObj.RunRequestListener()

    LOGGER.debug(str(response))

    assert isinstance(response, bool)

src/telemetry/frontend/requirements.in

+4 −0
Original line number Diff line number Diff line
@@ -13,3 +13,7 @@ 
# limitations under the License.



confluent-kafka==2.3.*

psycopg2-binary==2.9.*

SQLAlchemy==1.4.*

sqlalchemy-cockroachdb==1.4.*

SQLAlchemy-Utils==0.38.*