diff options
Diffstat (limited to 'tests/test_binding.py')
| -rw-r--r-- | tests/test_binding.py | 45 |
1 files changed, 21 insertions, 24 deletions
diff --git a/tests/test_binding.py b/tests/test_binding.py index f0faac0..24c7b61 100644 --- a/tests/test_binding.py +++ b/tests/test_binding.py @@ -23,11 +23,16 @@ import httpretty #import miss_htbt_service from miss_htbt_service import htbtworker #from miss_htbt_service.htbtworker import get_collector_uri,get_policy_uri +import subprocess import pytest import json import base64 import errno import imp +import time +from onap_dcae_cbs_docker_client.client import get_config + + MODULE_EXTENSIONS = ('.py', '.pyc', '.pyo') def package_contents(package_name): @@ -44,14 +49,14 @@ def package_contents(package_name): ##### #mr_url = 'http://127.0.0.1:3904' -mr_url = 'http://mrrouter.att.com:3904' +mr_url = 'http://mrrouter.onap.org:3904' intopic = 'VESCOLL-VNFNJ-SECHEARTBEAT-OUTPUT' outopic = 'POLICY-HILOTCA-EVENT-OUTPUT' @httpretty.activate def test_resolve_all(monkeypatch): #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":"SWMSVM","sequence":10048640,"domain":"heartbeat","lastEpochMicrosec":1518616063564476,"eventName":"Heartbeat_vMrf","sourceName":"SWMSVM","nfNamingCode":"vMRF"}}}' + 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' print(send_url) httpretty.register_uri(httpretty.GET, send_url, body=htbtmsg) @@ -60,33 +65,25 @@ def test_resolve_all(monkeypatch): print(response) print(response.text) assert(response.text == htbtmsg) - try: - os.makedirs('/tmp/config') - except OSError as e: - if e.errno != errno.EEXIST: - raise - with open("/tmp/config/coll_ip.txt", "w") as file: - #file.write('127.0.0.1') - file.write('mytest.onap.org') - file.close() - with open("/tmp/config/coll_port.txt", "w") as file2: - file2.write('3904') - file2.close() - #print(package_contents('miss_htbt_service')) - #response = requests.get(send_url) - #print(response) - #print(response.text) - #assert(response.text == htbtmsg) - htbtmsg = 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":"SWMSVM","sequence":10048640,"domain":"heartbeat","lastEpochMicrosec":1518616063564476,"eventName":"Heartbeat_vMrf","sourceName":"SWMSVM","nfNamingCode":"vMRF"}}}) - send_url = htbtworker.get_collector_uri()+'/events/'+intopic+'/DefaultGroup/1?timeout=15000' + htbtmsg = 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"}}}) + send_url = mr_url+'/events/'+intopic+'/DefaultGroup/1?timeout=15000' print("Send URL : "+send_url) httpretty.register_uri(httpretty.GET, send_url, body=htbtmsg, content_type="application/json") - pol_url = htbtworker.get_policy_uri()+'/events/'+outopic+'/DefaultGroup/1?timeout=15000' - 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":"SWMSVM","sequence":10048640,"domain":"heartbeat","lastEpochMicrosec":1518616063564476,"eventName":"Heartbeat_vMrf","sourceName":"SWMSVM","nfNamingCode":"vMRF"}}}) + pol_url = mr_url+'/events/'+outopic+'/DefaultGroup/1?timeout=15000' + 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.test_setup([send_url,send_url,3,60,intopic,outopic]) + htbtworker.main([send_url,intopic,send_url,outopic,"vVNF",3,60,"internal_test"]) 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'}) + #print(r.status_code) + #assert(r.status_code == 200) |