diff options
Diffstat (limited to 'tests/test_binding.py')
| -rw-r--r-- | tests/test_binding.py | 86 |
1 files changed, 75 insertions, 11 deletions
diff --git a/tests/test_binding.py b/tests/test_binding.py index 24c7b61..bfa13ba 100644 --- a/tests/test_binding.py +++ b/tests/test_binding.py @@ -20,9 +20,14 @@ import os import io import requests import httpretty +import sys #import miss_htbt_service from miss_htbt_service import htbtworker +from miss_htbt_service import misshtbtd +from miss_htbt_service import db_monitoring +from miss_htbt_service import config_notif #from miss_htbt_service.htbtworker import get_collector_uri,get_policy_uri +from trapd_vnf_table import hb_properties import subprocess import pytest import json @@ -30,7 +35,9 @@ import base64 import errno import imp import time +from pip._internal import main as _main from onap_dcae_cbs_docker_client.client import get_config +import unittest MODULE_EXTENSIONS = ('.py', '.pyc', '.pyo') @@ -54,7 +61,7 @@ intopic = 'VESCOLL-VNFNJ-SECHEARTBEAT-OUTPUT' outopic = 'POLICY-HILOTCA-EVENT-OUTPUT' @httpretty.activate -def test_resolve_all(monkeypatch): +def test_resolve_all(): #htbtmsg = "Find the best daily deals" htbtmsg = '{"event":{"commonEventHeader":{"startEpochMicrosec":1518616063564475,"sourceId":"587c14b3-72c0-4581-b5cb-6567310b9bb7","eventId":"10048640","reportingEntityId":"587c14b3-72c0-4581-b5cb-6567310b9bb7","priority":"Normal","version":3,"reportingEntityName":"TESTVM","sequence":10048640,"domain":"heartbeat","lastEpochMicrosec":1518616063564476,"eventName":"Heartbeat_vVnf","sourceName":"TESTVM","nfNamingCode":"vVNF"}}}' send_url = mr_url+'/events/'+intopic+'/DefaultGroup/1?timeout=15000' @@ -73,17 +80,74 @@ def test_resolve_all(monkeypatch): pol_body = json.dumps({"event":{"commonEventHeader":{"startEpochMicrosec":1518616063564475,"sourceId":"587c14b3-72c0-4581-b5cb-6567310b9bb7","eventId":"10048640","reportingEntityId":"587c14b3-72c0-4581-b5cb-6567310b9bb7","priority":"Normal","version":3,"reportingEntityName":"TESTVM","sequence":10048640,"domain":"heartbeat","lastEpochMicrosec":1518616063564476,"eventName":"Heartbeat_vVnf","sourceName":"TESTVM","nfNamingCode":"vVNF"}}}) print("Policy URL : "+pol_url) httpretty.register_uri(httpretty.POST, pol_url, body=pol_body, status=200, content_type='text/json') - htbtworker.main([send_url,intopic,send_url,outopic,"vVNF",3,60,"internal_test"]) - ret = htbtworker.periodic_event() - print("Returned",ret) - assert(ret == 1) + #misshtbtd.main() + #ret = htbtworker.periodic_event() + #print("Returned",ret) + #assert(ret == 1) def test_full(): - p = subprocess.Popen(['./miss_htbt_service/misshtbtd.py'],stdout=subprocess.PIPE) - time.sleep(30) - r = requests.get('http://127.0.0.1:10001') - print(r.status_code) - assert(r.status_code == 200) - #r = requests.post('http://127.0.0.1:10001',data={'number': 12524, 'health': 'good', 'action': 'show'}) + p = subprocess.Popen(['./miss_htbt_service/misshtbtd.py'], stdout=subprocess.PIPE,shell=True) + #time.sleep(30) + #r = requests.get('http://127.0.0.1:10002') + #r = requests.get('http://localhost:10001') #print(r.status_code) #assert(r.status_code == 200) + #r = requests.post('http://127.0.0.1:10001',data={'number': '12524', 'health': 'good', 'action': 'show'}) + #print(r.status_code) + #assert(r.status_code == 200) + +def test_fetch_json_file(): + os.environ['pytest']='test' + os.environ['SERVICE_NAME']='mvp-dcaegen2-heartbeat-static' + #os.environ['CONSUL_HOST']='10.12.6.50' # Used this IP during testing + os.environ['CONSUL_HOST']='localhost' + os.environ['HOSTNAME']='mvp-dcaegen2-heartbeat-static' + try: + misshtbtd.fetch_json_file() + result = True + except Exception as e: + result = False + print(result) + os.unsetenv('pytest') + os.unsetenv('SERVICE_NAME') + os.unsetenv('CONSUL_HOST') + os.unsetenv('HOSTNAME') + + assert(result == True) + +def test_misshtbtdmain(): + os.environ['pytest']='test' + os.environ['SERVICE_NAME']='mvp-dcaegen2-heartbeat-static' + os.environ['CONSUL_HOST']='localhost' + os.environ['HOSTNAME']='mvp-dcaegen2-heartbeat-static' + + try: + misshtbtd.main() + result = True + except Exception as e: + result = False + print(result) + os.unsetenv('pytest') + os.unsetenv('SERVICE_NAME') + os.unsetenv('CONSUL_HOST') + os.unsetenv('HOSTNAME') + assert(result == True) + +def test_dbmonitoring(): + ip_address, port_num, user_name, password, db_name, cbs_polling_required, cbs_polling_interval = hb_properties() + jsfile = misshtbtd.fetch_json_file() + hbc_pid, hbc_state, hbc_srcName, hbc_time = misshtbtd.read_hb_common(user_name,password,ip_address,port_num,db_name) + db_monitoring.db_monitoring(hbc_pid,jsfile,user_name,password,ip_address,port_num,db_name) + +def test_htbtworker(): + if os.environ['pytest'] == 'test': + print ('environ is set') + else: + print ('environ is not set') + ip_address, port_num, user_name, password, db_name, cbs_polling_required, cbs_polling_interval = hb_properties() + jsfile = "/home/ubuntu/HB_Nov5/etc/config.json" + hbc_pid, hbc_state, hbc_srcName, hbc_time = config_notif.read_hb_common(user_name,password,ip_address,port_num,db_name) + #htbtworker.process_msg(jsfile,user_name, password, ip_address, port_num, db_name) + +def test_conifg_notif(): + config_notif.config_notif_run() |