diff options
| author |   Moshe <moshehoa@amdocs.com> | 2018-03-25 17:00:40 +0300 |
|---|---|---|
| committer | Moshe <moshehoa@amdocs.com> | 2018-03-25 18:07:32 +0300 |
| commit | ea90f9ba9d0e317dfc5521dda9946844b7336abd (patch) | |
| tree | 24b8d699b7d8166f9b8597d1f72c4557db3906bf | |
| parent | 583448a180e36b5b406fa9542392ea0400914700 (diff) | |
Add unit tests and handle coverage
Issue-ID: VNFSDK-183
Change-Id: I228576f5c06b371164bcd653d23cf169098436a8
Signed-off-by: Moshe <moshehoa@amdocs.com>
handle coverage
Issue-ID: VNFSDK-183
Change-Id: I3d78293fdf5cb8bc57caa4078ab8fa5baa429a0d
Signed-off-by: Moshe <moshehoa@amdocs.com>
28 files changed, 810 insertions, 298 deletions
diff --git a/.coveragerc b/.coveragerc new file mode 100644 index 0000000..ce33f41 --- /dev/null +++ b/.coveragerc @@ -0,0 +1,7 @@ +[run] +branch = True +source = vnftest + +[report] +ignore_errors = True +precision = 3
\ No newline at end of file diff --git a/dist/vnftest-0.1.dev0-py2.7.egg b/dist/vnftest-0.1.dev0-py2.7.egg Binary files differindex 7df66f0..be0bc0e 100644 --- a/dist/vnftest-0.1.dev0-py2.7.egg +++ b/dist/vnftest-0.1.dev0-py2.7.egg @@ -20,7 +20,6 @@ under the License. <groupId>org.onap.oparent</groupId> <artifactId>oparent</artifactId> <version>1.1.0</version> - <relativePath>../oparent</relativePath> </parent> <groupId>org.onap.vnfsdk.dovetail-integration</groupId> @@ -30,10 +29,13 @@ under the License. <name>vnfsdk-dovetail-integration</name> <description>Integration with OPNFV Dovetail project</description> <properties> + <sonar.sources>.</sonar.sources> + <sonar.python.coverage.reportPath>coverage.xml</sonar.python.coverage.reportPath> <sonar.language>py</sonar.language> <sonar.pluginName>Python</sonar.pluginName> <sonar.inclusions>**/*.py</sonar.inclusions> <sonar.skip>false</sonar.skip> + <sonar.exclusions>version.py,setup.py</sonar.exclusions> </properties> </project> @@ -24,12 +24,13 @@ setup( include_package_data=True, package_data={ 'vnftest': [ - 'onap/steps/onboard/*.yaml', - 'onap/steps/create_service/*.yaml' + 'onap/onboard/*.yaml', + 'onap/lifecycle/*.yaml' ], 'etc': [ 'vnftest/*.yaml', - 'vnftest/*.conf' + 'vnftest/*.conf', + 'vnftest/vnf_descriptors/*.yaml' ], 'tests': [ 'onap/*/*.yaml' diff --git a/tools/cover.sh b/tools/cover.sh index 8acfb56..d8170ba 100644 --- a/tools/cover.sh +++ b/tools/cover.sh @@ -44,11 +44,12 @@ run_coverage_test() { # Temporarily run tests from two directories, until all tests have moved coverage run -p -m unittest discover ./tests/unit - coverage run -p -m unittest discover ./vnftest/tests/unit + coverage run -p -m unittest discover ./vnftest/tests/unit/core + coverage run -p -m unittest discover ./vnftest/tests/unit/onap coverage combine # Temporarily omit vnftest/tests from the report - coverage report --omit=vnftest/tests/*/* > ${baseline_report} + coverage report > ${baseline_report} coverage erase # debug awk @@ -71,7 +72,8 @@ run_coverage_test() { # Temporarily run tests from two directories, until all tests have moved coverage run -p -m unittest discover ./tests/unit - coverage run -p -m unittest discover ./vnftest/tests/unit + coverage run -p -m unittest discover ./vnftest/tests/unit/core + coverage run -p -m unittest discover ./vnftest/tests/unit/onap coverage combine # Temporarily omit vnftest/tests from the report @@ -6,6 +6,9 @@ usedevelop=True deps = -r{toxinidir}/requirements.txt -r{toxinidir}/test-requirements.txt -commands = /bin/bash {toxinidir}/tools/run_tests.sh --unit whitelist_externals = /bin/bash +[testenv:py27] +commands = + /bin/bash {toxinidir}/tools/run_tests.sh --unit + /bin/bash {toxinidir}/tools/run_tests.sh --coverage diff --git a/vnftest.egg-info/PKG-INFO b/vnftest.egg-info/PKG-INFO index 14cf284..74ef199 100644 --- a/vnftest.egg-info/PKG-INFO +++ b/vnftest.egg-info/PKG-INFO @@ -6,6 +6,5 @@ Home-page: https://www.onap.org Author: UNKNOWN Author-email: UNKNOWN License: UNKNOWN -Description-Content-Type: UNKNOWN Description: UNKNOWN Platform: UNKNOWN diff --git a/vnftest.egg-info/SOURCES.txt b/vnftest.egg-info/SOURCES.txt index 611c563..b91c982 100644 --- a/vnftest.egg-info/SOURCES.txt +++ b/vnftest.egg-info/SOURCES.txt @@ -14,7 +14,6 @@ vnftest.egg-info/SOURCES.txt vnftest.egg-info/dependency_links.txt vnftest.egg-info/entry_points.txt vnftest.egg-info/top_level.txt -vnftest/cmd/NSBperf.py vnftest/cmd/__init__.py vnftest/cmd/cli.py vnftest/cmd/commands/__init__.py @@ -62,6 +61,7 @@ vnftest/onap/package_upload.py vnftest/onap/common/__init__.py vnftest/onap/common/vnf_type_crawler.py vnftest/onap/onboard/__init__.py +vnftest/resources/__init__.py vnftest/runners/__init__.py vnftest/runners/base.py vnftest/runners/duration.py @@ -72,4 +72,6 @@ vnftest/runners/sequence.py vnftest/steps/__init__.py vnftest/steps/base.py vnftest/steps/dummy/__init__.py -vnftest/steps/dummy/dummy.py
\ No newline at end of file +vnftest/steps/dummy/dummy.py +vnftest/tests/__init__.py +vnftest/tests/fixture.py
\ No newline at end of file diff --git a/vnftest/cmd/NSBperf.py b/vnftest/cmd/NSBperf.py deleted file mode 100755 index 40a157b..0000000 --- a/vnftest/cmd/NSBperf.py +++ /dev/null @@ -1,228 +0,0 @@ -#!/usr/bin/env python -############################################################################## -# Copyright 2018 EuropeanSoftwareMarketingLtd. -# =================================================================== -# Licensed under the ApacheLicense, Version2.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 -# -# 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 -############################################################################## -# vnftest comment: this is a modified copy of -# yardstick/cmd/NSBperf.py - -"""NSBPERF main script. -""" - -from __future__ import absolute_import -from __future__ import print_function -import os -import argparse -import json -import subprocess -import signal -from oslo_serialization import jsonutils - -from six.moves import input - -CLI_PATH = os.path.dirname(os.path.realpath(__file__)) -REPO_PATH = os.path.abspath(os.path.join(CLI_PATH, os.pardir)) - - -def sigint_handler(*args, **kwargs): - """ Capture ctrl+c and exit cli """ - subprocess.call(["pkill", "-9", "vnftest"]) - raise SystemExit(1) - - -class VnftestNSCli(object): - """ This class handles vnftest network serivce testing """ - - def __init__(self): - super(VnftestNSCli, self).__init__() - - @classmethod - def validate_input(cls, choice, choice_len): - """ Validate user inputs """ - if not str(choice): - return 1 - - choice = int(choice) - if not 1 <= choice <= choice_len: - print("\nInvalid wrong choice...") - input("Press Enter to continue...") - return 1 - subprocess.call(['clear']) - return 0 - - @classmethod - def parse_arguments(cls): - """ - Parse command line arguments. - """ - parser = \ - argparse.ArgumentParser( - prog=__file__, - formatter_class=argparse.ArgumentDefaultsHelpFormatter) - parser.add_argument('--version', action='version', - version='%(prog)s 0.1') - parser.add_argument('--list', '--list-tests', action='store_true', - help='list all tests and exit') - parser.add_argument('--list-vnfs', action='store_true', - help='list all system vnfs and exit') - - group = parser.add_argument_group('test selection options') - group.add_argument('--vnf', help='vnf to use') - group.add_argument('--test', help='test in use') - - args = vars(parser.parse_args()) - - return args - - @classmethod - def generate_kpi_results(cls, tkey, tgen): - """ Generate report for vnf & traffic generator kpis """ - if tgen: - print("\n%s stats" % tkey) - print("----------------------------") - for key, value in tgen.items(): - if key != "collect_stats": - print(json.dumps({key: value}, indent=2)) - - @classmethod - def generate_nfvi_results(cls, nfvi): - """ Generate report for vnf & traffic generator kpis """ - if nfvi: - nfvi_kpi = {k: v for k, v in nfvi.items() if k == 'collect_stats'} - if nfvi_kpi: - print("\nNFVi stats") - print("----------------------------") - for key, value in nfvi_kpi.items(): - print(json.dumps({key: value}, indent=2)) - - def generate_final_report(self, test_case): - """ Function will check if partial test results are available - and generates final report in rst format. - """ - - tc_name = os.path.splitext(test_case)[0] - report_caption = '{}\n{} ({})\n{}\n\n'.format( - '================================================================', - 'Performance report for', tc_name.upper(), - '================================================================') - print(report_caption) - if os.path.isfile("/tmp/vnftest.out"): - lines = [] - with open("/tmp/vnftest.out") as infile: - lines = jsonutils.load(infile) - - if lines: - lines = \ - lines['result']["testcases"][tc_name]["tc_data"] - tc_res = lines.pop(len(lines) - 1) - for key, value in tc_res["data"].items(): - self.generate_kpi_results(key, value) - self.generate_nfvi_results(value) - - @classmethod - def handle_list_options(cls, args, test_path): - """ Process --list cli arguments if needed - - :param args: A dictionary with all CLI arguments - """ - if args['list_vnfs']: - vnfs = os.listdir(test_path) - print("VNF :") - print("================") - for index, vnf in enumerate(vnfs, 1): - print((' %-2s %s' % ('%s:' % str(index), vnf))) - raise SystemExit(0) - - if args['list']: - vnfs = os.listdir(test_path) - - print("Available Tests:") - print("*****************") - for vnf in vnfs: - testcases = os.listdir(test_path + vnf) - print(("VNF :(%s)" % vnf)) - print("================") - test_cases = [tc for tc in testcases if "tc_" in tc and "template" not in tc] - - print("\tBareMetal Testcase:") - print("\t===================") - for testcase in [tc for tc in test_cases if "baremetal" in tc]: - print("\t%s" % testcase) - - print(os.linesep) - print("\tStandalone Virtualization Testcase:") - print("\t===================================") - for testcase in [tc for tc in test_cases if "ovs" in tc or "sriov" in tc]: - print("\t%s" % testcase) - - print(os.linesep) - print("\tOpenstack Testcase:") - print("\t===================") - for testcase in [tc for tc in test_cases if "heat" in tc]: - print("\t%s" % testcase) - print(os.linesep) - raise SystemExit(0) - - @classmethod - def terminate_if_less_options(cls, args): - """ terminate cli if cmdline options is invalid """ - if not (args["vnf"] and args["test"]): - print("CLI needs option, make sure to pass vnf, test") - print("eg: NSBperf.py --vnf <vnf untertest> --test <test yaml>") - raise SystemExit(1) - - def run_test(self, args, test_path): - """ run requested test """ - try: - vnf = args.get("vnf", "") - test = args.get("test", "") - - vnf_dir = test_path + os.sep + vnf - if not os.path.exists(vnf_dir): - raise ValueError("'%s', vnf not supported." % vnf) - - testcases = [tc for tc in os.listdir(vnf_dir) if "tc" in tc] - subtest = set([test]).issubset(testcases) - if not subtest: - raise ValueError("'%s', testcase not supported." % test) - - os.chdir(vnf_dir) - # fixme: Use REST APIs to initiate testcases - subprocess.check_output(["vnftest", "--debug", - "task", "start", test]) - self.generate_final_report(test) - except (IOError, ValueError): - print("Value/I/O error...") - except BaseException: - print("Test failed. Please verify test inputs & re-run the test..") - print("eg: NSBperf.py --vnf <vnf untertest> --test <test yaml>") - - def main(self): - """Main function. - """ - test_path = os.path.join(REPO_PATH, "../samples/vnf_samples/nsut/") - os.chdir(os.path.join(REPO_PATH, "../")) - args = self.parse_arguments() - - # if required, handle list-* operations - self.handle_list_options(args, test_path) - - # check for input params - self.terminate_if_less_options(args) - - # run test - self.run_test(args, test_path) - -if __name__ == "__main__": - signal.signal(signal.SIGINT, sigint_handler) - NS_CLI = VnftestNSCli() - NS_CLI.main() diff --git a/vnftest/core/report.py b/vnftest/core/report.py index bb791dc..b8f8bb7 100644 --- a/vnftest/core/report.py +++ b/vnftest/core/report.py @@ -18,14 +18,14 @@ from __future__ import absolute_import from __future__ import print_function -import ast +# import ast import re import uuid from django.conf import settings from django.template import Context from django.template import Template -from oslo_utils import encodeutils +# from oslo_utils import encodeutils from oslo_utils import uuidutils from vnftest.common import constants as consts @@ -37,8 +37,6 @@ settings.configure() class Report(object): """Report commands. - - Set of commands to manage benchmark tasks. """ def __init__(self): @@ -83,39 +81,39 @@ class Report(object): """Start report generation.""" self._validate(args.yaml_name[0], args.task_id[0]) - self.db_fieldkeys = self._get_fieldkeys() + # self.db_fieldkeys = self._get_fieldkeys() - self.db_task = self._get_tasks() + # self.db_task = self._get_tasks() - field_keys = [] + # field_keys = [] temp_series = [] table_vals = {} - field_keys = [encodeutils.to_utf8(field['fieldKey']) - for field in self.db_fieldkeys] - - for key in field_keys: - self.Timestamp = [] - series = {} - values = [] - for task in self.db_task: - task_time = encodeutils.to_utf8(task['time']) - if not isinstance(task_time, str): - task_time = str(task_time, 'utf8') - key = str(key, 'utf8') - task_time = task_time[11:] - head, sep, tail = task_time.partition('.') - task_time = head + "." + tail[:6] - self.Timestamp.append(task_time) - if isinstance(task[key], float) is True: - values.append(task[key]) - else: - values.append(ast.literal_eval(task[key])) - table_vals['Timestamp'] = self.Timestamp - table_vals[key] = values - series['name'] = key - series['data'] = values - temp_series.append(series) + # field_keys = [encodeutils.to_utf8(field['fieldKey']) + # for field in self.db_fieldkeys] + + # for key in field_keys: + # self.Timestamp = [] + # series = {} + # values = [] + # for task in self.db_task: + # task_time = encodeutils.to_utf8(task['time']) + # if not isinstance(task_time, str): + # task_time = str(task_time, 'utf8') + # key = str(key, 'utf8') + # task_time = task_time[11:] + # head, sep, tail = task_time.partition('.') + # task_time = head + "." + tail[:6] + # self.Timestamp.append(task_time) + # if isinstance(task[key], float) is True: + # values.append(task[key]) + # else: + # values.append(ast.literal_eval(task[key])) + # table_vals['Timestamp'] = self.Timestamp + # table_vals[key] = values + # series['name'] = key + # series['data'] = values + # temp_series.append(series) Template_html = Template(template) Context_html = Context({"series": temp_series, diff --git a/vnftest/core/task.py b/vnftest/core/task.py index a2963a5..8ce897b 100644 --- a/vnftest/core/task.py +++ b/vnftest/core/task.py @@ -258,7 +258,8 @@ class Task(object): # pragma: no cover def _run(self, steps, run_in_parallel, output_file): """Deploys context and calls runners""" - self.context.deploy() + if self.context: + self.context.deploy() background_runners = [] result = [] @@ -547,31 +548,6 @@ def _is_background_step(step): return False -def parse_nodes_with_context(step_cfg): - """parse the 'nodes' fields in step """ - # ensure consistency in node instantiation order - return OrderedDict((nodename, Context.get_server(step_cfg["nodes"][nodename])) - for nodename in sorted(step_cfg["nodes"])) - - -def get_networks_from_nodes(nodes): - """parse the 'nodes' fields in step """ - networks = {} - for node in nodes.values(): - if not node: - continue - interfaces = node.get('interfaces', {}) - for interface in interfaces.values(): - # vld_id is network_name - network_name = interface.get('network_name') - if not network_name: - continue - network = Context.get_network(network_name) - if network: - networks[network['name']] = network - return networks - - def runner_join(runner, background_runners, outputs, result): """join (wait for) a runner, exit process at runner failure :param background_runners: diff --git a/vnftest/resources/__init__.py b/vnftest/resources/__init__.py new file mode 100644 index 0000000..e69de29 --- /dev/null +++ b/vnftest/resources/__init__.py diff --git a/vnftest/resources/scripts/install/sample.bash b/vnftest/resources/scripts/install/sample.bash new file mode 100644 index 0000000..de1af20 --- /dev/null +++ b/vnftest/resources/scripts/install/sample.bash @@ -0,0 +1,25 @@ +#!/bin/bash + +############################################################################## +# Copyright 2018 EuropeanSoftwareMarketingLtd. +# =================================================================== +# Licensed under the ApacheLicense, Version2.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 +# +# 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 +############################################################################## +# vnftest comment: this is a modified copy of +# yardstick/resources/scripts/install/sample.bash + +# Sample plugin installation script + +set -e + +cat > test.sh <<EOF +echo "{\"Test Output\": \"Hello world!\"}" +EOF diff --git a/vnftest/resources/scripts/remove/sample.bash b/vnftest/resources/scripts/remove/sample.bash new file mode 100644 index 0000000..576d9a7 --- /dev/null +++ b/vnftest/resources/scripts/remove/sample.bash @@ -0,0 +1,21 @@ +#!/bin/bash + +############################################################################## +# Copyright 2018 EuropeanSoftwareMarketingLtd. +# =================================================================== +# Licensed under the ApacheLicense, Version2.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 +# +# 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 +############################################################################## +# vnftest comment: this is a modified copy of +# yardstick/resources/scripts/remove/sample.bash + +set -e + +rm test.sh diff --git a/vnftest/steps/dummy/dummy.py b/vnftest/steps/dummy/dummy.py index 650fdb4..53a5dae 100644 --- a/vnftest/steps/dummy/dummy.py +++ b/vnftest/steps/dummy/dummy.py @@ -35,7 +35,6 @@ class Dummy(base.Step): self.setup_done = True def run(self, result): - """execute the benchmark""" if not self.setup_done: self.setup() diff --git a/vnftest/tests/__init__.py b/vnftest/tests/__init__.py new file mode 100644 index 0000000..061e263 --- /dev/null +++ b/vnftest/tests/__init__.py @@ -0,0 +1,77 @@ +############################################################################## +# Copyright 2018 EuropeanSoftwareMarketingLtd. +# =================================================================== +# Licensed under the ApacheLicense, Version2.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 +# +# 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 +############################################################################## +# vnftest comment: this is a modified copy of +# yardstick/tests/__init__.py + +import mock + + +STL_MOCKS = { + 'trex_stl_lib': mock.MagicMock(), + 'trex_stl_lib.base64': mock.MagicMock(), + 'trex_stl_lib.binascii': mock.MagicMock(), + 'trex_stl_lib.collections': mock.MagicMock(), + 'trex_stl_lib.copy': mock.MagicMock(), + 'trex_stl_lib.datetime': mock.MagicMock(), + 'trex_stl_lib.functools': mock.MagicMock(), + 'trex_stl_lib.imp': mock.MagicMock(), + 'trex_stl_lib.inspect': mock.MagicMock(), + 'trex_stl_lib.json': mock.MagicMock(), + 'trex_stl_lib.linecache': mock.MagicMock(), + 'trex_stl_lib.math': mock.MagicMock(), + 'trex_stl_lib.os': mock.MagicMock(), + 'trex_stl_lib.platform': mock.MagicMock(), + 'trex_stl_lib.pprint': mock.MagicMock(), + 'trex_stl_lib.random': mock.MagicMock(), + 'trex_stl_lib.re': mock.MagicMock(), + 'trex_stl_lib.scapy': mock.MagicMock(), + 'trex_stl_lib.socket': mock.MagicMock(), + 'trex_stl_lib.string': mock.MagicMock(), + 'trex_stl_lib.struct': mock.MagicMock(), + 'trex_stl_lib.sys': mock.MagicMock(), + 'trex_stl_lib.threading': mock.MagicMock(), + 'trex_stl_lib.time': mock.MagicMock(), + 'trex_stl_lib.traceback': mock.MagicMock(), + 'trex_stl_lib.trex_stl_async_client': mock.MagicMock(), + 'trex_stl_lib.trex_stl_client': mock.MagicMock(), + 'trex_stl_lib.trex_stl_exceptions': mock.MagicMock(), + 'trex_stl_lib.trex_stl_ext': mock.MagicMock(), + 'trex_stl_lib.trex_stl_jsonrpc_client': mock.MagicMock(), + 'trex_stl_lib.trex_stl_packet_builder_interface': mock.MagicMock(), + 'trex_stl_lib.trex_stl_packet_builder_scapy': mock.MagicMock(), + 'trex_stl_lib.trex_stl_port': mock.MagicMock(), + 'trex_stl_lib.trex_stl_stats': mock.MagicMock(), + 'trex_stl_lib.trex_stl_streams': mock.MagicMock(), + 'trex_stl_lib.trex_stl_types': mock.MagicMock(), + 'trex_stl_lib.types': mock.MagicMock(), + 'trex_stl_lib.utils': mock.MagicMock(), + 'trex_stl_lib.utils.argparse': mock.MagicMock(), + 'trex_stl_lib.utils.collections': mock.MagicMock(), + 'trex_stl_lib.utils.common': mock.MagicMock(), + 'trex_stl_lib.utils.json': mock.MagicMock(), + 'trex_stl_lib.utils.os': mock.MagicMock(), + 'trex_stl_lib.utils.parsing_opts': mock.MagicMock(), + 'trex_stl_lib.utils.pwd': mock.MagicMock(), + 'trex_stl_lib.utils.random': mock.MagicMock(), + 'trex_stl_lib.utils.re': mock.MagicMock(), + 'trex_stl_lib.utils.string': mock.MagicMock(), + 'trex_stl_lib.utils.sys': mock.MagicMock(), + 'trex_stl_lib.utils.text_opts': mock.MagicMock(), + 'trex_stl_lib.utils.text_tables': mock.MagicMock(), + 'trex_stl_lib.utils.texttable': mock.MagicMock(), + 'trex_stl_lib.warnings': mock.MagicMock(), + 'trex_stl_lib.yaml': mock.MagicMock(), + 'trex_stl_lib.zlib': mock.MagicMock(), + 'trex_stl_lib.zmq': mock.MagicMock(), +} diff --git a/vnftest/tests/fixture.py b/vnftest/tests/fixture.py new file mode 100644 index 0000000..ef19cfd --- /dev/null +++ b/vnftest/tests/fixture.py @@ -0,0 +1,48 @@ +############################################################################## +# Copyright 2018 EuropeanSoftwareMarketingLtd. +# =================================================================== +# Licensed under the ApacheLicense, Version2.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 +# +# 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 +############################################################################## +# vnftest comment: this is a modified copy of +# yardstick/tests/fixture.py + +import fixtures +import mock +import six + +from vnftest.common import task_template + + +class PluginParserFixture(fixtures.Fixture): + """PluginParser fixture. + + This class is intended to be used as a fixture within unit tests and + therefore consumers must register it using useFixture() within their + unit test class. + """ + + def __init__(self, rendered_plugin): + super(PluginParserFixture, self).__init__() + self._rendered_plugin = rendered_plugin + + def _setUp(self): + self.addCleanup(self._restore) + self._mock_tasktemplate_render = mock.patch.object( + task_template.TaskTemplate, 'render') + self.mock_tasktemplate_render = self._mock_tasktemplate_render.start() + self.mock_tasktemplate_render.return_value = self._rendered_plugin + self._mock_open = mock.patch.object(six.moves.builtins, 'open', create=True) + self.mock_open = self._mock_open.start() + self.mock_open.side_effect = mock.mock_open() + + def _restore(self): + self._mock_tasktemplate_render.stop() + self._mock_open.stop() diff --git a/vnftest/tests/unit/core/__init__.py b/vnftest/tests/unit/core/__init__.py new file mode 100644 index 0000000..e69de29 --- /dev/null +++ b/vnftest/tests/unit/core/__init__.py diff --git a/vnftest/tests/unit/core/no_constraint_no_args_step_sample.yaml b/vnftest/tests/unit/core/no_constraint_no_args_step_sample.yaml new file mode 100644 index 0000000..4272d70 --- /dev/null +++ b/vnftest/tests/unit/core/no_constraint_no_args_step_sample.yaml @@ -0,0 +1,28 @@ +############################################################################## +# Copyright 2018 EuropeanSoftwareMarketingLtd. +# =================================================================== +# Licensed under the ApacheLicense, Version2.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 +# +# 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 +############################################################################## +# vnftest comment: this is a modified copy of +# yardstick/tests/unit/benchmark/core/no_constraint_no_args_scenario_sample.yaml + +--- + +schema: "vnftest:suite:0.1" + +name: "suite_1" +test_cases_dir: "tests/onap/test_cases/" +test_cases: +- + file_name: onap_vnftest_tc001.yaml +- + file_name: onap_vnftest_tc002.yaml + diff --git a/vnftest/tests/unit/core/no_constraint_with_args_step_sample.yaml b/vnftest/tests/unit/core/no_constraint_with_args_step_sample.yaml new file mode 100644 index 0000000..3667230 --- /dev/null +++ b/vnftest/tests/unit/core/no_constraint_with_args_step_sample.yaml @@ -0,0 +1,30 @@ +############################################################################## +# Copyright 2018 EuropeanSoftwareMarketingLtd. +# =================================================================== +# Licensed under the ApacheLicense, Version2.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 +# +# 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 +############################################################################## +# vnftest comment: this is a modified copy of +# yardstick/tests/unit/benchmark/core/no_constraint_with_args_scenario_sample.yaml + +--- + +schema: "vnftest:suite:0.1" + +name: "suite_1" +test_cases_dir: "tests/onap/test_cases/" +test_cases: +- + file_name: onap_vnftest_tc001.yaml +- + file_name: onap_vnftest_tc002.yaml + task_args: + huawei-pod1: '{"host": "node1.LF","target": "node2.LF"}' + diff --git a/vnftest/tests/unit/core/test_plugin.py b/vnftest/tests/unit/core/test_plugin.py new file mode 100644 index 0000000..6f1bff8 --- /dev/null +++ b/vnftest/tests/unit/core/test_plugin.py @@ -0,0 +1,149 @@ +############################################################################## +# Copyright 2018 EuropeanSoftwareMarketingLtd. +# =================================================================== +# Licensed under the ApacheLicense, Version2.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 +# +# 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 +############################################################################## +# vnftest comment: this is a modified copy of +# yardstick/tests/unit/benchmark/core/test_plugin.py + +import copy +import os +import pkg_resources + +import mock +import testtools + +from vnftest import ssh +from vnftest.core import plugin +from vnftest.tests import fixture + + +class PluginTestCase(testtools.TestCase): + + FILE = """ +schema: "vnftest:plugin:0.1" + +plugins: + name: sample + +deployment: + ip: 10.1.0.50 + user: root + password: root +""" + + NAME = 'sample' + DEPLOYMENT = {'ip': '10.1.0.50', 'user': 'root', 'password': 'root'} + + def setUp(self): + super(PluginTestCase, self).setUp() + self.plugin_parser = plugin.PluginParser(mock.Mock()) + self.plugin = plugin.Plugin() + self.useFixture(fixture.PluginParserFixture(PluginTestCase.FILE)) + + self._mock_ssh_from_node = mock.patch.object(ssh.SSH, 'from_node') + self.mock_ssh_from_node = self._mock_ssh_from_node.start() + self.mock_ssh_obj = mock.Mock() + self.mock_ssh_from_node.return_value = self.mock_ssh_obj + self.mock_ssh_obj.wait = mock.Mock() + self.mock_ssh_obj._put_file_shell = mock.Mock() + + self.addCleanup(self._cleanup) + + def _cleanup(self): + self._mock_ssh_from_node.stop() + + def test_install(self): + args = mock.Mock() + args.input_file = [mock.Mock()] + with mock.patch.object(self.plugin, '_install_setup') as \ + mock_install, \ + mock.patch.object(self.plugin, '_run') as mock_run: + self.plugin.install(args) + mock_install.assert_called_once_with(PluginTestCase.NAME, + PluginTestCase.DEPLOYMENT) + mock_run.assert_called_once_with(PluginTestCase.NAME) + + def test_remove(self): + args = mock.Mock() + args.input_file = [mock.Mock()] + with mock.patch.object(self.plugin, '_remove_setup') as \ + mock_remove, \ + mock.patch.object(self.plugin, '_run') as mock_run: + self.plugin.remove(args) + mock_remove.assert_called_once_with(PluginTestCase.NAME, + PluginTestCase.DEPLOYMENT) + mock_run.assert_called_once_with(PluginTestCase.NAME) + + @mock.patch.object(pkg_resources, 'resource_filename', + return_value='script') + def test__install_setup(self, mock_resource_filename): + plugin_name = 'plugin_name' + self.plugin._install_setup(plugin_name, PluginTestCase.DEPLOYMENT) + mock_resource_filename.assert_called_once_with( + 'vnftest.resources', 'scripts/install/' + plugin_name + '.bash') + self.mock_ssh_from_node.assert_called_once_with( + PluginTestCase.DEPLOYMENT) + self.mock_ssh_obj.wait.assert_called_once_with(timeout=600) + self.mock_ssh_obj._put_file_shell.assert_called_once_with( + 'script', '~/{0}.sh'.format(plugin_name)) + + @mock.patch.object(pkg_resources, 'resource_filename', + return_value='script') + @mock.patch.object(os, 'environ', return_value='1.2.3.4') + def test__install_setup_with_ip_local(self, mock_os_environ, + mock_resource_filename): + plugin_name = 'plugin_name' + deployment = copy.deepcopy(PluginTestCase.DEPLOYMENT) + deployment['ip'] = 'local' + self.plugin._install_setup(plugin_name, deployment) + mock_os_environ.__getitem__.assert_called_once_with('JUMP_HOST_IP') + mock_resource_filename.assert_called_once_with( + 'vnftest.resources', + 'scripts/install/' + plugin_name + '.bash') + self.mock_ssh_from_node.assert_called_once_with( + deployment, overrides={'ip': os.environ["JUMP_HOST_IP"]}) + self.mock_ssh_obj.wait.assert_called_once_with(timeout=600) + self.mock_ssh_obj._put_file_shell.assert_called_once_with( + 'script', '~/{0}.sh'.format(plugin_name)) + + @mock.patch.object(pkg_resources, 'resource_filename', + return_value='script') + def test__remove_setup(self, mock_resource_filename): + plugin_name = 'plugin_name' + self.plugin._remove_setup(plugin_name, PluginTestCase.DEPLOYMENT) + mock_resource_filename.assert_called_once_with( + 'vnftest.resources', + 'scripts/remove/' + plugin_name + '.bash') + self.mock_ssh_from_node.assert_called_once_with( + PluginTestCase.DEPLOYMENT) + self.mock_ssh_obj.wait.assert_called_once_with(timeout=600) + self.mock_ssh_obj._put_file_shell.assert_called_once_with( + 'script', '~/{0}.sh'.format(plugin_name)) + + @mock.patch.object(pkg_resources, 'resource_filename', + return_value='script') + @mock.patch.object(os, 'environ', return_value='1.2.3.4') + def test__remove_setup_with_ip_local(self, mock_os_environ, + mock_resource_filename): + plugin_name = 'plugin_name' + deployment = copy.deepcopy(PluginTestCase.DEPLOYMENT) + deployment['ip'] = 'local' + self.plugin._remove_setup(plugin_name, deployment) + mock_os_environ.__getitem__.assert_called_once_with('JUMP_HOST_IP') + mock_resource_filename.assert_called_once_with( + 'vnftest.resources', + 'scripts/remove/' + plugin_name + '.bash') + self.mock_ssh_from_node.assert_called_once_with( + deployment, overrides={'ip': os.environ["JUMP_HOST_IP"]}) + self.mock_ssh_obj.wait.assert_called_once_with(timeout=600) + self.mock_ssh_obj._put_file_shell.mock_os_environ( + 'script', '~/{0}.sh'.format(plugin_name)) diff --git a/vnftest/tests/unit/core/test_report.py b/vnftest/tests/unit/core/test_report.py new file mode 100644 index 0000000..0bb17e3 --- /dev/null +++ b/vnftest/tests/unit/core/test_report.py @@ -0,0 +1,59 @@ +############################################################################## +# Copyright 2018 EuropeanSoftwareMarketingLtd. +# =================================================================== +# Licensed under the ApacheLicense, Version2.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 +# +# 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 +############################################################################## +# vnftest comment: this is a modified copy of +# yardstick/tests/unit/benchmark/core/test_report.py + +from __future__ import print_function + +from __future__ import absolute_import + +import unittest +import uuid + +try: + from unittest import mock +except ImportError: + import mock + +from vnftest.core import report +from vnftest.cmd.commands import change_osloobj_to_paras + +FAKE_YAML_NAME = 'fake_name' +FAKE_TASK_ID = str(uuid.uuid4()) +DUMMY_TASK_ID = 'aaaaaa-aaaaaaaa-aaaaaaaaaa-aaaaaa' + + +class ReportTestCase(unittest.TestCase): + + def setUp(self): + super(ReportTestCase, self).setUp() + self.param = change_osloobj_to_paras({}) + self.param.yaml_name = [FAKE_YAML_NAME] + self.param.task_id = [FAKE_TASK_ID] + self.rep = report.Report() + + @mock.patch('vnftest.core.report.Report._validate') + def test_generate_success(self, mock_valid): + self.rep.generate(self.param) + mock_valid.assert_called_once_with(FAKE_YAML_NAME, FAKE_TASK_ID) + + # pylint: disable=deprecated-method + def test_invalid_yaml_name(self): + self.assertRaisesRegexp(ValueError, "yaml*", self.rep._validate, + 'F@KE_NAME', FAKE_TASK_ID) + + # pylint: disable=deprecated-method + def test_invalid_task_id(self): + self.assertRaisesRegexp(ValueError, "task*", self.rep._validate, + FAKE_YAML_NAME, DUMMY_TASK_ID) diff --git a/vnftest/tests/unit/core/test_task.py b/vnftest/tests/unit/core/test_task.py new file mode 100644 index 0000000..b136960 --- /dev/null +++ b/vnftest/tests/unit/core/test_task.py @@ -0,0 +1,150 @@ +############################################################################## +# Copyright 2018 EuropeanSoftwareMarketingLtd. +# =================================================================== +# Licensed under the ApacheLicense, Version2.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 +# +# 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 +############################################################################## +# vnftest comment: this is a modified copy of +# yardstick/tests/unit/benchmark/core/test_task.py + +import unittest + +import mock +import os + +from vnftest.common import constants as consts +from vnftest.core import task + + +class TaskTestCase(unittest.TestCase): + + def test_set_dispatchers(self): + t = task.Task() + output_config = {"DEFAULT": {"dispatcher": "file, http"}} + t._set_dispatchers(output_config) + self.assertEqual(output_config, output_config) + + @mock.patch.object(task, 'DispatcherBase') + def test__do_output(self, mock_dispatcher): + t = task.Task() + output_config = {"DEFAULT": {"dispatcher": "file, http"}} + + dispatcher1 = mock.MagicMock() + dispatcher1.__dispatcher_type__ = 'file' + + dispatcher2 = mock.MagicMock() + dispatcher2.__dispatcher_type__ = 'http' + + mock_dispatcher.get = mock.MagicMock(return_value=[dispatcher1, + dispatcher2]) + self.assertIsNone(t._do_output(output_config, {})) + + @mock.patch.object(task, 'Context') + @mock.patch.object(task, 'base_runner') + def test_run(self, mock_base_runner, *args): + step = { + 'runner': { + 'duration': 60, + 'interval': 1, + 'type': 'Duration' + }, + 'type': 'Dummy' + } + + t = task.Task() + runner = mock.Mock() + runner.join.return_value = 0 + runner.get_output.return_value = {} + runner.get_result.return_value = [] + mock_base_runner.Runner.get.return_value = runner + t._run([step], False, "vnftest.out") + self.assertTrue(runner.run.called) + + def test_parse_suite_no_constraint_no_args(self): + SAMPLE_step_PATH = "no_constraint_no_args_step_sample.yaml" + t = task.TaskParser(self._get_file_abspath(SAMPLE_step_PATH)) + with mock.patch.object(os, 'environ', + new={'NODE_NAME': 'huawei-pod1', 'INSTALLER_TYPE': 'compass'}): + task_files, task_args, task_args_fnames = t.parse_suite() + + self.assertEqual(task_files[0], self.change_to_abspath( + 'tests/onap/test_cases/onap_vnftest_tc001.yaml')) + self.assertEqual(task_files[1], self.change_to_abspath( + 'tests/onap/test_cases/onap_vnftest_tc002.yaml')) + self.assertIsNone(task_args[0]) + self.assertIsNone(task_args[1]) + self.assertIsNone(task_args_fnames[0]) + self.assertIsNone(task_args_fnames[1]) + + def test_parse_suite_no_constraint_with_args(self): + SAMPLE_step_PATH = "no_constraint_with_args_step_sample.yaml" + t = task.TaskParser(self._get_file_abspath(SAMPLE_step_PATH)) + with mock.patch.object(os, 'environ', + new={'NODE_NAME': 'huawei-pod1', 'INSTALLER_TYPE': 'compass'}): + task_files, task_args, task_args_fnames = t.parse_suite() + + self.assertEqual(task_files[0], self.change_to_abspath( + 'tests/onap/test_cases/onap_vnftest_tc001.yaml')) + self.assertEqual(task_files[1], self.change_to_abspath( + 'tests/onap/test_cases/onap_vnftest_tc002.yaml')) + self.assertIsNone(task_args[0]) + self.assertEqual(task_args[1], + '{"host": "node1.LF","target": "node2.LF"}') + self.assertIsNone(task_args_fnames[0]) + self.assertIsNone(task_args_fnames[1]) + + def test_parse_suite_with_constraint_no_args(self): + SAMPLE_step_PATH = "with_constraint_no_args_step_sample.yaml" + t = task.TaskParser(self._get_file_abspath(SAMPLE_step_PATH)) + with mock.patch.object(os, 'environ', + new={'NODE_NAME': 'huawei-pod1', 'INSTALLER_TYPE': 'compass'}): + task_files, task_args, task_args_fnames = t.parse_suite() + self.assertEqual(task_files[0], self.change_to_abspath( + 'tests/onap/test_cases/onap_vnftest_tc001.yaml')) + self.assertEqual(task_files[1], self.change_to_abspath( + 'tests/onap/test_cases/onap_vnftest_tc002.yaml')) + self.assertIsNone(task_args[0]) + self.assertIsNone(task_args[1]) + self.assertIsNone(task_args_fnames[0]) + self.assertIsNone(task_args_fnames[1]) + + def test_parse_suite_with_constraint_with_args(self): + SAMPLE_step_PATH = "with_constraint_with_args_step_sample.yaml" + t = task.TaskParser(self._get_file_abspath(SAMPLE_step_PATH)) + with mock.patch('os.environ', + new={'NODE_NAME': 'huawei-pod1', 'INSTALLER_TYPE': 'compass'}): + task_files, task_args, task_args_fnames = t.parse_suite() + + self.assertEqual(task_files[0], self.change_to_abspath( + 'tests/onap/test_cases/onap_vnftest_tc001.yaml')) + self.assertEqual(task_files[1], self.change_to_abspath( + 'tests/onap/test_cases/onap_vnftest_tc002.yaml')) + self.assertIsNone(task_args[0]) + self.assertEqual(task_args[1], + '{"host": "node1.LF","target": "node2.LF"}') + self.assertIsNone(task_args_fnames[0]) + self.assertIsNone(task_args_fnames[1]) + + @mock.patch('six.moves.builtins.open', side_effect=mock.mock_open()) + @mock.patch.object(task, 'utils') + @mock.patch('logging.root') + def test_set_log(self, mock_logging_root, *args): + task_obj = task.Task() + task_obj.task_id = 'task_id' + task_obj._set_log() + mock_logging_root.addHandler.assert_called() + + def _get_file_abspath(self, filename): + curr_path = os.path.dirname(os.path.abspath(__file__)) + file_path = os.path.join(curr_path, filename) + return file_path + + def change_to_abspath(self, filepath): + return os.path.join(consts.VNFTEST_ROOT_PATH, filepath) diff --git a/vnftest/tests/unit/core/test_testcase.py b/vnftest/tests/unit/core/test_testcase.py new file mode 100644 index 0000000..0ba4873 --- /dev/null +++ b/vnftest/tests/unit/core/test_testcase.py @@ -0,0 +1,40 @@ +############################################################################## +# Copyright 2018 EuropeanSoftwareMarketingLtd. +# =================================================================== +# Licensed under the ApacheLicense, Version2.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 +# +# 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 +############################################################################## +# vnftest comment: this is a modified copy of +# yardstick/tests/unit/benchmark/core/test_testcase.py + +from __future__ import absolute_import +import unittest + +from vnftest.core import testcase + + +class Arg(object): + + def __init__(self): + self.casename = ('onap_vnftest_tc001',) + + +class TestcaseUT(unittest.TestCase): + + def test_list_all(self): + t = testcase.Testcase() + result = t.list_all("") + self.assertIsInstance(result, list) + + def test_show(self): + t = testcase.Testcase() + casename = Arg() + result = t.show(casename) + self.assertTrue(result) diff --git a/vnftest/tests/unit/core/with_constraint_no_args_step_sample.yaml b/vnftest/tests/unit/core/with_constraint_no_args_step_sample.yaml new file mode 100644 index 0000000..f9524fb --- /dev/null +++ b/vnftest/tests/unit/core/with_constraint_no_args_step_sample.yaml @@ -0,0 +1,31 @@ +############################################################################## +# Copyright 2018 EuropeanSoftwareMarketingLtd. +# =================================================================== +# Licensed under the ApacheLicense, Version2.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 +# +# 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 +############################################################################## +# vnftest comment: this is a modified copy of +# yardstick/tests/unit/benchmark/core/with_constraint_no_args_scenario_sample.yaml + +--- + +schema: "vnftest:suite:0.1" + +name: "suite_1" +test_cases_dir: "tests/onap/test_cases/" +test_cases: +- + file_name: onap_vnftest_tc001.yaml +- + file_name: onap_vnftest_tc002.yaml + constraint: + installer: compass + pod: huawei-pod1 + diff --git a/vnftest/tests/unit/core/with_constraint_with_args_step_sample.yaml b/vnftest/tests/unit/core/with_constraint_with_args_step_sample.yaml new file mode 100644 index 0000000..53c8390 --- /dev/null +++ b/vnftest/tests/unit/core/with_constraint_with_args_step_sample.yaml @@ -0,0 +1,33 @@ +############################################################################## +# Copyright 2018 EuropeanSoftwareMarketingLtd. +# =================================================================== +# Licensed under the ApacheLicense, Version2.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 +# +# 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 +############################################################################## +# vnftest comment: this is a modified copy of +# yardstick/tests/unit/benchmark/core/with_constraint_with_args_scenario_sample.yaml + +--- + +schema: "vnftest:suite:0.1" + +name: "suite_1" +test_cases_dir: "tests/onap/test_cases/" +test_cases: +- + file_name: onap_vnftest_tc001.yaml +- + file_name: onap_vnftest_tc002.yaml + constraint: + installer: compass + pod: huawei-pod1 + task_args: + huawei-pod1: '{"host": "node1.LF","target": "node2.LF"}' + diff --git a/vnftest/tests/unit/onap/__init__.py b/vnftest/tests/unit/onap/__init__.py new file mode 100644 index 0000000..e69de29 --- /dev/null +++ b/vnftest/tests/unit/onap/__init__.py diff --git a/vnftest/tests/unit/onap/test_onap_api_call.py b/vnftest/tests/unit/onap/test_onap_api_call.py new file mode 100644 index 0000000..2b6d79d --- /dev/null +++ b/vnftest/tests/unit/onap/test_onap_api_call.py @@ -0,0 +1,60 @@ +############################################################################## +# Copyright 2018 EuropeanSoftwareMarketingLtd. +# =================================================================== +# Licensed under the ApacheLicense, Version2.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 +# +# 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 mock +import testtools + +from vnftest.contexts.base import Context +from vnftest.core import task +from vnftest.onap.onap_api_call import OnapApiCall + + +class OnapApiCallTestCase(testtools.TestCase): + + step = { + 'type': 'OnapApiCall', + 'options': { + 'file': "dummy.yaml", + 'input': + [{ + 'parameter_name': "input1", + 'value': "value1" + }], + 'output': + [{ + 'parameter_name': "output1", + 'value': "[value]" + }]}, + 'sla': { + 'action': 'assert', + 'value': "{output1}", + 'equals': "output1", + 'retries': 5, + 'interval': 5} + } + NAME = 'sample' + + def setUp(self): + super(OnapApiCallTestCase, self).setUp() + + @mock.patch('vnftest.onap.onap_api_call.OnapApiCall.execute_operation_impl') + def test_run(self, mock_execute_operation): + mock_execute_operation.return_value = {'body': {'value': 'output1'}} + t = task.Task() + context_cfg = {} + context = Context.get("CSAR") + context.init(context_cfg) + t.context = context + output = t._run([OnapApiCallTestCase.step], False, "vnftest.out") + self.assertEquals(output[0]['data']['output1'], 'output1') |