--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+flask\r
+flask_cors\r
+pyyaml\r
+pyaml\r
+requests
\ No newline at end of file
--- /dev/null
+#!/usr/bin/env python\r
+##############################################################################\r
+# Copyright (c) 2018 Huawei Technologies Co.,Ltd and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+'''This file realize the function of how to setup server of testing-scheduler\r
+to your environment. This use setuptools tool to setup'''\r
+\r
+from setuptools import setup, find_packages\r
+\r
+\r
+setup(\r
+ name="testing-scheduler-server",\r
+ version="0.1",\r
+ packages=find_packages(),\r
+ include_package_data=True,\r
+ package_data={\r
+ 'src': [\r
+ 'env/context/*.yaml',\r
+ 'env/service/*.yaml',\r
+ 'conductor_processor/*.json'\r
+ ],\r
+ 'test': [\r
+ 'test_case/*/*.yaml'\r
+ ]\r
+ }\r
+)\r
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+---\r
+\r
+hosts:\r
+ node26:\r
+ name: node26\r
+ ip: 192.168.1.26\r
+ port: 22\r
+ user: root\r
+ password: 123456\r
+\r
+ node27:\r
+ name: node27\r
+ ip: 192.168.1.27\r
+ port: 22\r
+ user: root\r
+ password: 123456\r
+\r
+ node28:\r
+ name: node28\r
+ ip: 192.168.1.28\r
+ port: 22\r
+ user: root\r
+ password: 123456\r
+\r
+ node29:\r
+ name: node29\r
+ ip: 192.168.1.29\r
+ port: 22\r
+ user: root\r
+ password: 123456\r
+\r
+ node30:\r
+ name: node30\r
+ ip: 192.168.1.30\r
+ port: 22\r
+ user: root\r
+ password: 123456\r
+\r
+ node31:\r
+ name: node31\r
+ ip: 192.168.1.31\r
+ port: 22\r
+ user: root\r
+ password: 123456\r
+\r
+ node32:\r
+ name: node32\r
+ ip: 192.168.1.32\r
+ port: 22\r
+ user: root\r
+ password: 123456\r
+\r
+\r
+cassandra:\r
+ name: node24\r
+ ip: 192.168.1.24\r
+ port: 22\r
+ user: root\r
+ password: 123456\r
+\r
+sprout:\r
+ name: node32\r
+ ip: 192.168.1.32\r
+ port: 22\r
+ user: root\r
+ password: 123456
\ No newline at end of file
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+---\r
+\r
+ansible:\r
+ apis:\r
+ - method: POST\r
+ name: faultload\r
+ params:\r
+ - description: call user count\r
+ name: call_user\r
+ - description: workload time\r
+ name: duration\r
+ - description: faultload time\r
+ name: fault_duration\r
+ - description: register speed\r
+ name: initial_reg_rate\r
+ - description: multiplier\r
+ name: multiplier\r
+ - description: register user count\r
+ name: reg_user\r
+ baseuri: faultload\r
+ template:\r
+ uri: ((baseuri))\r
+ body:\r
+ call_user: ((call_user))\r
+ duration: ((duration))\r
+ fault_duration: ((fault_duration))\r
+ initial_reg_rate: ((initial_reg_rate))\r
+ multiplier: ((multiplier))\r
+ reg_user: ((reg_user))\r
+\r
+ - method: POST\r
+ name: workload\r
+ params:\r
+ - description: call user count\r
+ name: call_user\r
+ - description: workload time\r
+ name: duration\r
+ - description: register speed\r
+ name: initial_reg_rate\r
+ - description: multiplier\r
+ name: multiplier\r
+ - description: register user count\r
+ name: reg_user\r
+ baseuri: workload\r
+ template:\r
+ uri: ((baseuri))\r
+ body:\r
+ call_user: ((call_user))\r
+ duration: ((duration))\r
+ fault_duration: ((fault_duration))\r
+ initial_reg_rate: ((initial_reg_rate))\r
+ multiplier: ((multiplier))\r
+ reg_user: ((reg_user))\r
+\r
+ ip: 100.64.227.222\r
+ port: 9006\r
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+---\r
+\r
+greet:\r
+ ip: t-scheduler-server\r
+ port: 5312\r
+ apis:\r
+ -\r
+ name: greet\r
+ method: GET\r
+ baseuri: greet\r
+ params:\r
+ - name: name\r
+ description: user name\r
+ template:\r
+ uri: ((baseuri))?name=((name))\r
+ response:\r
+ result: int\r
+ next:\r
+ aa: str\r
+ bb: int\r
+ -\r
+ name: answer\r
+ method: POST\r
+ baseuri: answer\r
+ params:\r
+ - name: ping\r
+ description: param ping\r
+ template:\r
+ uri: ((baseuri))\r
+ body:\r
+ ping: ((ping))\r
+\r
+ -\r
+ name: ten\r
+ method: GET\r
+ baseuri: ten\r
+ template:\r
+ uri: ((baseuri))\r
+\r
+\r
+ -\r
+ name: switch\r
+ method: GET\r
+ baseuri: switch\r
+ template:\r
+ uri: ((baseuri))\r
+ return:\r
+ -\r
+ result\r
+\r
+ -\r
+ name: switch_2\r
+ method: GET\r
+ baseuri: switch_2\r
+ template:\r
+ uri: ((baseuri))\r
+ return:\r
+ -\r
+ result\r
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+from src.step.test_step import TestStep\r
+import os\r
+import yaml\r
+import re\r
+\r
+\r
+class GeneralTestStep(TestStep):\r
+ __step_type__ = "test"\r
+\r
+ def __init__(self, id, name, service, action, args, context):\r
+ super(GeneralTestStep, self).__init__(\r
+ self.__step_type__, id, name, service, action, args, context)\r
+ self._stepParse()\r
+ self.action()\r
+\r
+ def _contextTransform(self, argsDict):\r
+ for (k, v) in argsDict.items():\r
+ if isinstance(v, str):\r
+ if re.match('^\(\(context\..*\)\)', v):\r
+ v = v[10:-2]\r
+ layers = v.split(".")\r
+ contextData = self._context\r
+ for layer in layers:\r
+ contextData = contextData[layer]\r
+ argsDict[k] = contextData\r
+ elif isinstance(v, dict):\r
+ self._contextTransform(v)\r
+\r
+ def _stepParse(self):\r
+ self._args_temp = self._args\r
+ self._args = {}\r
+\r
+ # transform the service config\r
+ envFilePath = os.path.join(\r
+ self._getCurrentDir(), "..", "env",\r
+ "service", self._serviceName + ".yaml")\r
+ requestParam = {}\r
+ with open(envFilePath, 'r') as f:\r
+ conf = yaml.load(f)\r
+ conf = conf[self._serviceName]\r
+ for apiItem in conf["apis"]:\r
+ if apiItem['name'] == self._serviceInterface:\r
+ interfaceConf = apiItem\r
+ if interfaceConf is None:\r
+ return\r
+\r
+ # transform the args config\r
+ self._contextTransform(self._args_temp)\r
+\r
+ interfaceUri = interfaceConf['baseuri'] + \\r
+ interfaceConf['template']['uri'][11:]\r
+ interfaceUri = "http://%s:%s/%s" % (\r
+ conf['ip'], conf['port'], interfaceUri)\r
+ requestParam['uri'] = self._uriTransform(interfaceUri)\r
+\r
+ requestParam['method'] = interfaceConf['method']\r
+ if requestParam["method"] == "POST":\r
+ requestParam['body'] = interfaceConf['template']['body']\r
+ self._paramTransform(requestParam['body'], self._args_temp)\r
+ self._args['http_request'] = requestParam\r
+\r
+ def _uriTransform(self, uri):\r
+ return re.sub("\(\(.*?\)\)", self._uriResReplace, uri)\r
+\r
+ def _uriResReplace(self, match):\r
+ matchTrim = match.group()[2:-2]\r
+ return self._args_temp[matchTrim]\r
+\r
+ def _paramTransform(self, argsTemplate, argsDict):\r
+ for (k, v) in argsTemplate.items():\r
+ if isinstance(v, str):\r
+ if re.match('^\(\(.*\)\)', v):\r
+ argsTemplate[k] = argsDict[v[2:-2]]\r
+ elif isinstance(v, dict):\r
+ self._paramTransform(v, argsDict)\r
+\r
+ def start(self):\r
+ pass\r
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+import json\r
+import os\r
+from src.step.test_step import TestStep\r
+\r
+\r
+class MonitorStep(TestStep):\r
+ __step_type__ = 'monitor'\r
+\r
+ def __init__(self, name, service, action, args):\r
+ super(MonitorStep, self).__init__(name, service, action, args)\r
+ self._argsParse()\r
+ self.action()\r
+\r
+ def _argsParse(self):\r
+ if self._call == "REST":\r
+ currentDirPath = os.path.dirname(os.path.abspath(__file__))\r
+ envDirPath = os.path.abspath(os.path.join(\r
+ currentDirPath, os.pardir, os.pardir, 'env'))\r
+ envFilePath = os.path.join(\r
+ envDirPath, "%s.json" % self._service['name'])\r
+ with open(envFilePath) as f:\r
+ propDict = json.load(f)\r
+ self._args['ip'] = propDict['ip']\r
+ self._args['port'] = propDict['port']\r
+ self._args['api'] = "%s/%s" % (\r
+ propDict['api_map']['workload'], self._args['command'])\r
+ exclude = {'ip', 'port', 'api', 'command', 'method'}\r
+ self._args['req_body'] = {\r
+ key: value for key, value in\r
+ self._args.items() if key not in exclude}\r
+\r
+ def setUp(self):\r
+ print "monitor setUp"\r
+\r
+ def uninstall(self):\r
+ print "monitor uninstall"\r
+\r
+ def start(self):\r
+ print "monitor start...."\r
+\r
+ def stop(self):\r
+ print "monitor stop"\r
+\r
+\r
+if __name__ == "__main__":\r
+ service = {"name": "ansible", "call": "REST"}\r
+ monitor = MonitorStep(\r
+ "monitor_cpu", service, "start", **{"target": "abc:qq"})\r
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+from src.step.test_step import TestStep\r
+import os\r
+import sys\r
+\r
+\r
+class TestStepManager(object):\r
+ def __init__(self, context):\r
+ self._context = context\r
+\r
+ currentDirPath = os.path.dirname(os.path.abspath(__file__))\r
+ sys.path.append(currentDirPath)\r
+\r
+ excludeFiles = ('__init__.py', 'step_manager.py', 'test_step.py')\r
+ for fileName in os.listdir(currentDirPath):\r
+ if os.path.isfile(os.path.join(currentDirPath, fileName)) and \\r
+ os.path.splitext(fileName)[1] == '.py' and \\r
+ fileName not in excludeFiles:\r
+ __import__(os.path.splitext(fileName)[0])\r
+\r
+ def getStepObj(self, type, id, name, service, action, args):\r
+ for subclass in TestStep.__subclasses__():\r
+ if type == subclass.__step_type__:\r
+ return subclass(id, name, service, action, args, self._context)\r
+\r
+\r
+if __name__ == "__main__":\r
+ tsMgr = TestStepManager()\r
+ args = {'command': 'greet', 'method': 'POST', 'args': {'name': 'leo'}}\r
+ stepObj = tsMgr.getStepObj('test', 1, 'test_cpu', {\r
+ 'name': 'greet', 'call': 'REST'}, 'start', args)\r
+ print stepObj\r
+ print stepObj.__class__.__mro__\r
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+import os\r
+\r
+\r
+class TestStep(object):\r
+ def __init__(self, type, id, name, service, action, args, context):\r
+ self._type = type\r
+ self._id = id\r
+ self._name = name\r
+ self._serviceName = service['name']\r
+ self._serviceInterface = service['interface']\r
+ self._action = action\r
+ self._args = args\r
+ self._context = context\r
+\r
+ def getId(self):\r
+ return self._id\r
+\r
+ def getName(self):\r
+ return self._name\r
+\r
+ def getServiceName(self):\r
+ return self._serviceName\r
+\r
+ def getCallFunction(self):\r
+ return self._callType\r
+\r
+ def getArgs(self):\r
+ return self._args\r
+\r
+ def action(self):\r
+ f = getattr(self, self._action)\r
+ f()\r
+\r
+ def _argsParse(self):\r
+ pass\r
+\r
+ def _getCurrentDir(self):\r
+ return os.path.dirname(__file__)\r
+\r
+ def __str__(self):\r
+ return str(self.__dict__)\r
+\r
+\r
+if __name__ == "__main__":\r
+ args = {'command': 'start'}\r
+ stepObj = TestStep('test_cpu', 'ansible', 'REST', **args)\r
+ print stepObj\r
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+import json\r
+import os\r
+from src.step.test_step import TestStep\r
+\r
+\r
+class WorkloadStep(TestStep):\r
+ __step_type__ = 'workload'\r
+\r
+ def __init__(self, id, name, service, action, args):\r
+ super(WorkloadStep, self).__init__(\r
+ self.__step_type__, id, name, service, action, args)\r
+ self._argsParse()\r
+ self._action()\r
+\r
+ def _argsParse(self):\r
+ if self._callType == "REST":\r
+ currentDirPath = os.path.dirname(os.path.abspath(__file__))\r
+ envDirPath = os.path.abspath(\r
+ os.path.join(currentDirPath, os.pardir, os.pardir, 'env'))\r
+ envFilePath = os.path.join(\r
+ envDirPath, "%s.json" % self._service['name'])\r
+ with open(envFilePath) as f:\r
+ propDict = json.load(f)\r
+ self._args['ip'] = propDict['ip']\r
+ self._args['port'] = propDict['port']\r
+ self._args['api'] = "%s/%s" % (\r
+ propDict['api_map']['workload'], self._args['command'])\r
+ exclude = {'ip', 'port', 'api', 'command', 'method'}\r
+ self._args['req_body'] = {\r
+ key: value for key, value in\r
+ self._args.items() if key not in exclude}\r
+\r
+ def _start(self):\r
+ print "workload start"\r
+\r
+ def _stop(self):\r
+ print "workload stop"\r
--- /dev/null
+#!/usr/bin/env python\r
+\r
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+import click\r
+import os\r
+import yaml\r
+import json\r
+import collections\r
+from src.step.step_manager import TestStepManager\r
+from src.conductor_processor.workflow import WorkflowFile\r
+from conductorclient.run_new_workflow import WorkflowMgr\r
+\r
+BASE_DIR = os.path.dirname(os.path.abspath(__file__))\r
+CONDUCTOR_SERVER_ADDR = "http://conductor_conductor-server_1:8080"\r
+STORE_TASK_PATH = "/tmp/generate_task.json"\r
+STORE_WF_PATH = "/tmp/generate_workflow.json"\r
+\r
+\r
+@click.command()\r
+@click.option("--filepath", help="file path of test case")\r
+def cmdParse(filepath):\r
+ parse(filepath)\r
+\r
+\r
+def parse(filepath):\r
+ filePrefix, fileName = os.path.split(filepath)\r
+ print '------------ start to parse the test case:' + \\r
+ '%s ----------------' % fileName\r
+ with open(filepath) as f:\r
+ yaml_file = yaml.load(f)\r
+ parseTestcase(yaml_file['schema'], fileName)\r
+\r
+ workflowId = runWorkFlow()\r
+ print '------------------- parse executes end -------------------------'\r
+\r
+ return workflowId\r
+\r
+\r
+def parseTestcase(schema, tcName='testcase0'):\r
+ if schema is None:\r
+ return parseLog(False, reason='schema not found.')\r
+ steps = schema['steps']\r
+ if steps is None:\r
+ return parseLog(False, reason='steps is invalid.')\r
+ flows = schema['flows']\r
+ if flows is None:\r
+ return parseLog(False, reasion='flows is invalid.')\r
+ # steps is a list, step is dict. no json here.\r
+ # steps = sorted(steps, sortById)\r
+\r
+ # load context\r
+ contextDict = {}\r
+ contextDir = os.path.join(BASE_DIR, "env", "context", "context.yaml")\r
+ with open(contextDir, "r") as f:\r
+ contextDict = yaml.load(f)\r
+ #\r
+ testStepMgr = TestStepManager(contextDict)\r
+\r
+ stepObjArr = []\r
+ for step in steps:\r
+ if 'args' not in step:\r
+ step['args'] = {}\r
+ # type and action can be extended, default couple is 'test' & 'start'.\r
+ if 'type' not in step:\r
+ step['type'] = 'test'\r
+ step['action'] = 'start'\r
+\r
+ stepObj = testStepMgr.getStepObj(\r
+ step['type'], step['id'], step['name'], step['service'],\r
+ step['action'], step['args'])\r
+ stepObjArr.append(stepObj)\r
+\r
+ # generate workflow by 'flow' and 'step'\r
+ tcName = os.path.splitext(tcName)[0]\r
+ wfFileObj = WorkflowFile(tcName)\r
+ workflowDict, taskMetaList = wfFileObj.generateMetaData(flows, stepObjArr)\r
+\r
+ with open(STORE_TASK_PATH, 'w') as f:\r
+ f.write(json.dumps({'task_group': taskMetaList}, indent=True))\r
+ with open(STORE_WF_PATH, 'w') as f:\r
+ f.write(json.dumps(workflowDict, indent=True))\r
+\r
+\r
+def parseWebTestcase(webTestcase):\r
+ print 'parseWebTestcase----------------------------'\r
+\r
+ stepList = webTestcase['stepList']\r
+ mainOrdersList = webTestcase['mainOrdersList']\r
+ subflowList = webTestcase['subflowList']\r
+\r
+ parseData = collections.OrderedDict()\r
+ parseData['schema'] = collections.OrderedDict()\r
+ parseData['schema']['steps'] = []\r
+ parseData['schema']['flows'] = []\r
+\r
+ parseStepList = parseData['schema']['steps']\r
+ parseFlowList = parseData['schema']['flows']\r
+ stepIndexDict = {}\r
+ # parse stepList\r
+ for index in range(len(stepList)):\r
+ stepItem = stepList[index]\r
+ parseStep = collections.OrderedDict()\r
+\r
+ parseStep['id'] = index + 1\r
+ parseStep['name'] = stepItem['name']\r
+ parseStep['service'] = collections.OrderedDict()\r
+ parseStep['service']['name'] = stepItem['service']\r
+ parseStep['service']['interface'] = stepItem['action']\r
+ parseStep['action'] = 'start'\r
+ parseStep['args'] = {}\r
+ for paramItem in stepItem['params']:\r
+ parseStep['args'][paramItem['key']] = transParamString(\r
+ paramItem['value'])\r
+\r
+ parseStepList.append(parseStep)\r
+ stepIndexDict[parseStep['name']] = parseStep['id']\r
+ # parse flows\r
+ # parse mainflow\r
+ print stepIndexDict\r
+ typeDict = {1: 'normal', 2: 'switch', 3: 'parallel'}\r
+ mainFlow = collections.OrderedDict()\r
+ mainFlow['name'] = 'main'\r
+ mainFlow['orders'] = []\r
+ mainFlow['orders'] = parseOrderList(\r
+ mainOrdersList, stepIndexDict, typeDict)\r
+ parseFlowList.append(mainFlow)\r
+\r
+ # parse subflow\r
+ for subflowItem in subflowList:\r
+ replaceSubflow = collections.OrderedDict()\r
+ replaceSubflow['name'] = subflowItem['name']\r
+ replaceSubflow['orders'] = parseOrderList(\r
+ subflowItem['orderList'], stepIndexDict, typeDict)\r
+ parseFlowList.append(replaceSubflow)\r
+\r
+ print 'END parseWebTestcase----------------------------'\r
+ return parseData\r
+\r
+\r
+# parse orderlist from web edition to server edition\r
+def parseOrderList(orderList, stepIndexDict, typeDict):\r
+ replaceList = []\r
+ for orderItem in orderList:\r
+ replaceOrder = collections.OrderedDict()\r
+ orderType = typeDict[orderItem['type']]\r
+ replaceOrder['type'] = orderType\r
+ if orderType == 'normal':\r
+ stepId = stepIndexDict[orderItem['step']]\r
+ replaceOrder['step'] = stepId\r
+ elif orderType == 'switch':\r
+ replaceOrder['value'] = orderItem['value']\r
+ replaceOrder['cases'] = collections.OrderedDict()\r
+ for caseItem in orderItem['cases']:\r
+ caseValue = caseItem['value']\r
+ caseOrderType = caseItem['orderType']\r
+ caseOrderValue = caseItem['orderValue']\r
+ if caseOrderType == "step":\r
+ orderInCase = collections.OrderedDict()\r
+ orderInCase['type'] = 'normal'\r
+ orderInCase['step'] = stepIndexDict[caseOrderValue]\r
+ replaceOrder['cases'][caseValue] = [orderInCase]\r
+ else:\r
+ replaceOrder['cases'][caseValue] = caseOrderValue\r
+ else:\r
+ replaceOrder['parallel'] = collections.OrderedDict()\r
+ pIndex = 1\r
+ for branchItem in orderItem['branches']:\r
+ pKey = 'p' + str(pIndex)\r
+ branchOrderType = branchItem['orderType']\r
+ branchOrderValue = branchItem['orderValue']\r
+ if branchOrderType == "step":\r
+ replaceBranchItem = collections.OrderedDict()\r
+ replaceBranchItem['type'] = 'normal'\r
+ replaceBranchItem['step'] = stepIndexDict[branchOrderValue]\r
+ replaceOrder['parallel'][pKey] = [replaceBranchItem]\r
+ else:\r
+ replaceOrder['parallel'][pKey] = branchOrderValue\r
+ pIndex += 1\r
+ replaceList.append(replaceOrder)\r
+ return replaceList\r
+\r
+\r
+def transParamString(val):\r
+ if type(val) != str:\r
+ return val\r
+ if '.' not in val:\r
+ if val.isdigit():\r
+ return int(val)\r
+ try:\r
+ f = float(val)\r
+ return f\r
+ except ValueError:\r
+ return val\r
+\r
+\r
+def getWebTestcase(originTcDict):\r
+ print "getWebTestcase----------------------------------"\r
+ webTcDict = {\r
+ "stepList": [],\r
+ "mainOrdersList": [],\r
+ "subflowList": []\r
+ }\r
+ stepList = webTcDict['stepList']\r
+ subflowList = webTcDict['subflowList']\r
+ if originTcDict is None:\r
+ return webTcDict\r
+ originContent = originTcDict['schema']\r
+ originSteps = originContent['steps']\r
+ stepIndexDict = {}\r
+ # transform steps to stepList\r
+ for stepItem in originSteps:\r
+ replaceStep = {}\r
+ replaceStep['name'] = stepItem['name']\r
+ replaceStep['service'] = stepItem['service']['name']\r
+ replaceStep['action'] = stepItem['service']['interface']\r
+ replaceStep['params'] = []\r
+ if 'args' in stepItem:\r
+ for (key, value) in stepItem['args'].items():\r
+ replaceParam = {}\r
+ replaceParam['key'] = key\r
+ replaceParam['value'] = value\r
+ replaceStep['params'].append(replaceParam)\r
+ stepList.append(replaceStep)\r
+ stepIndexDict[stepItem['id']] = stepItem['name']\r
+\r
+ # transform main flow\r
+ originFlows = originContent['flows']\r
+ originMainflow = {}\r
+ for flowIndex in range(len(originFlows)):\r
+ flowItem = originFlows[flowIndex]\r
+ if flowItem['name'] == 'main':\r
+ originMainflow = flowItem\r
+ originFlows.pop(flowIndex)\r
+ break\r
+ typeDict = {'normal': 1, 'switch': 2, 'parallel': 3}\r
+ webTcDict['mainOrdersList'] = getOrderList(\r
+ originMainflow['orders'], stepIndexDict, typeDict)\r
+\r
+ # transform subflows\r
+ for originSubflow in originFlows:\r
+ replaceSubflow = {}\r
+ replaceSubflow['name'] = originSubflow['name']\r
+ replaceSubflow['orderList'] = getOrderList(\r
+ originSubflow['orders'], stepIndexDict, typeDict)\r
+ subflowList.append(replaceSubflow)\r
+\r
+ # return web edition of testcase\r
+ print "END getWebTestcase----------------------------------"\r
+ return webTcDict\r
+\r
+\r
+def getOrderList(originOrderList, stepIndexDict, typeDict):\r
+ replaceOrderList = []\r
+ for orderItem in originOrderList:\r
+ replaceOrderItem = {}\r
+ orderType = orderItem['type']\r
+ replaceOrderItem['type'] = typeDict[orderType]\r
+ if orderType == 'normal':\r
+ stepName = stepIndexDict[orderItem['step']]\r
+ replaceOrderItem['step'] = stepName\r
+ elif orderType == 'switch':\r
+ replaceOrderItem['value'] = orderItem['value']\r
+ replaceOrderItem['cases'] = []\r
+ for (caseValue, ordersInCase) in orderItem['cases'].items():\r
+ replaceCase = {}\r
+ replaceCase['value'] = caseValue\r
+ if type(ordersInCase) == list:\r
+ replaceCase['orderType'] = 'step'\r
+ caseStepName = stepIndexDict[ordersInCase[0]['step']]\r
+ replaceCase['orderValue'] = caseStepName\r
+ else:\r
+ replaceCase['orderType'] = 'flow'\r
+ replaceCase['orderValue'] = ordersInCase\r
+ replaceOrderItem['cases'].append(replaceCase)\r
+ else:\r
+ replaceOrderItem['branches'] = []\r
+ for paraIndex in orderItem['parallel']:\r
+ paraItem = orderItem['parallel'][paraIndex]\r
+ replaceBranch = {}\r
+ if type(paraItem) == list:\r
+ replaceBranch['orderType'] = 'step'\r
+ branchStepName = stepIndexDict[paraItem[0]['step']]\r
+ replaceBranch['orderValue'] = branchStepName\r
+ else:\r
+ replaceBranch['orderType'] = 'flow'\r
+ replaceBranch['orderValue'] = paraItem\r
+ replaceOrderItem['branches'].append(replaceBranch)\r
+ replaceOrderList.append(replaceOrderItem)\r
+\r
+ return replaceOrderList\r
+\r
+\r
+def runWorkFlow():\r
+ wfMgr = WorkflowMgr(CONDUCTOR_SERVER_ADDR)\r
+ wfMgr.setTaskDefFromFile(STORE_TASK_PATH)\r
+ wfMgr.setWorkflowFromFile(STORE_WF_PATH)\r
+ inputParam = {'input': 'fake'}\r
+ workflowId = wfMgr.startWorkflow(inputParam)\r
+ return workflowId\r
+\r
+\r
+def parseLog(flag, **msg):\r
+ return {'result': flag, 'message': msg}\r
+\r
+\r
+if __name__ == "__main__":\r
+ cmdParse()\r
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+---\r
+# description: test conductor basic logic\r
+# this testcase contains a single step for scheduling.\r
+\r
+schema:\r
+ steps:\r
+ -\r
+ id: 1\r
+ name: make_a_greet\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ args:\r
+ name: leo\r
+ flows:\r
+ -\r
+ name: main\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 1
\ No newline at end of file
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+---\r
+# description: test conductor basic logic\r
+# 5 steps while only 2 in them will be executed.\r
+\r
+schema:\r
+ steps:\r
+ -\r
+ id: 1\r
+ name: make_a_greet\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ args:\r
+ name: leo\r
+\r
+ -\r
+ id: 2\r
+ name: response_the_greet\r
+ service:\r
+ name: greet\r
+ interface: answer\r
+ args:\r
+ ping: ping_from_leo\r
+\r
+ -\r
+ id: 3\r
+ name: make_a_greet_3\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ args:\r
+ name: leo_@\r
+\r
+ -\r
+ id: 4\r
+ name: make_a_greet_4\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ args:\r
+ name: leo_@\r
+\r
+ -\r
+ id: 5\r
+ name: make_a_greet_5\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ action: start\r
+ args:\r
+ name: leo_@\r
+\r
+\r
+ flows:\r
+ -\r
+ name: main\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 1\r
+ -\r
+ type: normal\r
+ step: 2\r
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+---\r
+# description: test conductor basic logic of switch\r
+# switch will determine the next case to execute based\r
+# on the "value", and "value" can be assigned by the\r
+# previous step's output.\r
+# The testcase below is an example.\r
+# To referring the step's output, using ((x.y)).\r
+# x is the id of the step,\r
+# y is the output key of the step.\r
+\r
+schema:\r
+ steps:\r
+ -\r
+ id: 1\r
+ name: choose_greet_type\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: switch\r
+ action: start\r
+\r
+ -\r
+ id: 2\r
+ name: response_the_greet\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: answer\r
+ action: start\r
+ args:\r
+ ping: ping_from_leo\r
+\r
+ -\r
+ id: 3\r
+ name: make_a_greet_2\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ action: start\r
+ args:\r
+ name: leo_@\r
+\r
+ flows:\r
+ -\r
+ name: main\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 1\r
+ -\r
+ type: switch\r
+ value: ((1.result))\r
+ cases:\r
+ A:\r
+ -\r
+ type: normal\r
+ step: 2\r
+ B:\r
+ -\r
+ type: normal\r
+ step: 3\r
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+---\r
+# description: test useless sub workflow\r
+# In this testcase, there is a subflow whose name\r
+# is 'flow-1' which will not be executed because no\r
+# other flow refers to it.\r
+# This testcase is used to test that besides main flow,\r
+# whether subflow can be parsed without exception.\r
+\r
+schema:\r
+ steps:\r
+ -\r
+ id: 1\r
+ name: choose_greet_type\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: switch\r
+ action: start\r
+\r
+ -\r
+ id: 2\r
+ name: response_the_greet\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: answer\r
+ action: start\r
+ args:\r
+ ping: ping_from_leo\r
+\r
+ -\r
+ id: 3\r
+ name: make_a_greet_2\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ action: start\r
+ args:\r
+ name: leo_@\r
+\r
+ -\r
+ id: 4\r
+ name: make_a_greet_3\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ action: start\r
+ args:\r
+ name: leo_@\r
+\r
+ flows:\r
+ -\r
+ name: main\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 1\r
+ -\r
+ type: switch\r
+ value: ((1.result))\r
+ cases:\r
+ A:\r
+ -\r
+ type: normal\r
+ step: 2\r
+ B:\r
+ -\r
+ type: normal\r
+ step: 3\r
+ -\r
+ name: flow-1\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 4\r
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+---\r
+# description: test conductor basic logic of sub flow.\r
+\r
+schema:\r
+ steps:\r
+ -\r
+ id: 1\r
+ name: choose_greet_type\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: switch\r
+ action: start\r
+\r
+ -\r
+ id: 2\r
+ name: response_the_greet\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: answer\r
+ action: start\r
+ args:\r
+ ping: ping_from_leo\r
+\r
+ -\r
+ id: 3\r
+ name: make_a_greet_2\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ action: start\r
+ args:\r
+ name: leo_@\r
+\r
+ flows:\r
+ -\r
+ name: main\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 1\r
+ -\r
+ type: switch\r
+ value: ((1.result))\r
+ cases:\r
+ A: flow-1\r
+ B: flow-2\r
+ -\r
+ name: flow-1\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 2\r
+ -\r
+ name: flow-2\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 3\r
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+---\r
+# description: test conductor basic logic of switch.\r
+# switch nested in switch by using subflow.\r
+\r
+schema:\r
+ steps:\r
+ -\r
+ id: 1\r
+ name: choose_greet_type\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: switch\r
+ action: start\r
+\r
+ -\r
+ id: 2\r
+ name: response_the_greet\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: answer\r
+ action: start\r
+ args:\r
+ ping: ping_from_leo\r
+\r
+ -\r
+ id: 3\r
+ name: choose_greet_type_2\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: switch_2\r
+ action: start\r
+\r
+ -\r
+ id: 4\r
+ name: make_a_greet\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ action: start\r
+ args:\r
+ name: leo_@\r
+\r
+ -\r
+ id: 5\r
+ name: response_the_greet_2\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: answer\r
+ action: start\r
+ args:\r
+ ping: ping_from_leo_2\r
+\r
+ flows:\r
+ -\r
+ name: main\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 1\r
+ -\r
+ type: switch\r
+ value: ((1.result))\r
+ cases:\r
+ A:\r
+ -\r
+ type: normal\r
+ step: 2\r
+ B: flow-1\r
+ -\r
+ name: flow-1\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 3\r
+ -\r
+ type: switch\r
+ value: ((3.result))\r
+ cases:\r
+ C:\r
+ -\r
+ type: normal\r
+ step: 4\r
+ D:\r
+ -\r
+ type: normal\r
+ step: 5\r
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+---\r
+# description: test conductor basic logic of parallel\r
+\r
+schema:\r
+ steps:\r
+ -\r
+ id: 1\r
+ name: choose_greet_type\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: switch\r
+ action: start\r
+\r
+ -\r
+ id: 2\r
+ name: response_the_greet\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: answer\r
+ action: start\r
+ args:\r
+ ping: ping_from_leo\r
+\r
+ -\r
+ id: 3\r
+ name: make_a_greet\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ action: start\r
+ args:\r
+ name: leo_@\r
+\r
+ -\r
+ id: 4\r
+ name: make_a_greet_2\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ action: start\r
+ args:\r
+ name: leo_@\r
+\r
+ flows:\r
+ -\r
+ name: main\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 1\r
+ -\r
+ type: parallel\r
+ parallel:\r
+ p1: flow-1\r
+ p2:\r
+ -\r
+ type: normal\r
+ step: 4\r
+ -\r
+ name: flow-1\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 2\r
+ -\r
+ type: normal\r
+ step: 3\r
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+---\r
+# description: test conductor basic logic of parallel + switch\r
+\r
+schema:\r
+ steps:\r
+ -\r
+ id: 1\r
+ name: make_a_greet\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ action: start\r
+ args:\r
+ name: leo_@\r
+ -\r
+ id: 2\r
+ name: choose_greet_type\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: switch\r
+ action: start\r
+\r
+ -\r
+ id: 3\r
+ name: response_the_greet\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: answer\r
+ action: start\r
+ args:\r
+ ping: ping_from_leo\r
+\r
+ -\r
+ id: 4\r
+ name: make_a_greet\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ action: start\r
+ args:\r
+ name: leo_@\r
+\r
+ -\r
+ id: 5\r
+ name: make_a_greet_2\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ action: start\r
+ args:\r
+ name: leo_@\r
+\r
+\r
+ flows:\r
+ -\r
+ name: main\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 1\r
+ -\r
+ type: parallel\r
+ parallel:\r
+ p1: flow-1\r
+ p2:\r
+ -\r
+ type: normal\r
+ step: 5\r
+ -\r
+ name: flow-1\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 2\r
+ -\r
+ type: switch\r
+ value: ((2.result))\r
+ cases:\r
+ A:\r
+ -\r
+ type: normal\r
+ step: 3\r
+ B:\r
+ -\r
+ type: normal\r
+ step: 4
\ No newline at end of file
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+---\r
+# description: test conductor basic logic of parallel.\r
+# parallel nested in parallel using subflow\r
+\r
+schema:\r
+ steps:\r
+ -\r
+ id: 1\r
+ name: make_a_greet\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ action: start\r
+ args:\r
+ name: leo_@\r
+ -\r
+ id: 2\r
+ name: choose_greet_type\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: switch\r
+ action: start\r
+\r
+ -\r
+ id: 3\r
+ name: response_the_greet\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: answer\r
+ action: start\r
+ args:\r
+ ping: ping_from_leo\r
+\r
+ -\r
+ id: 4\r
+ name: make_a_greet\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ action: start\r
+ args:\r
+ name: leo_@\r
+\r
+ -\r
+ id: 5\r
+ name: make_a_greet_2\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ action: start\r
+ args:\r
+ name: leo_@\r
+\r
+ -\r
+ id: 6\r
+ name: make_a_greet_3\r
+ type: test\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ action: start\r
+ args:\r
+ name: leo_@\r
+\r
+\r
+ flows:\r
+ -\r
+ name: main\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 1\r
+ -\r
+ type: parallel\r
+ parallel:\r
+ p1: flow-p1\r
+ p2:\r
+ -\r
+ type: normal\r
+ step: 6\r
+ -\r
+ name: flow-p1\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 2\r
+ -\r
+ type: parallel\r
+ parallel:\r
+ p1:\r
+ -\r
+ type: normal\r
+ step: 3\r
+ p2:\r
+ -\r
+ type: normal\r
+ step: 4\r
+ -\r
+ type: normal\r
+ step: 5
\ No newline at end of file
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+---\r
+# description: test use param of the context\r
+# we can using the context param just like environment variable by\r
+# writting ((context.a.b.c)).\r
+# 'context' is a constant string,\r
+# a, b, c is the key in the context yaml file (src/env/context/context.yaml).\r
+\r
+schema:\r
+ steps:\r
+ -\r
+ id: 1\r
+ name: make_a_greet\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ args:\r
+ name: leo\r
+\r
+ -\r
+ id: 2\r
+ name: response_the_greet\r
+ service:\r
+ name: greet\r
+ interface: answer\r
+ args:\r
+ ping: ((context.sprout.name))\r
+\r
+ flows:\r
+ -\r
+ name: main\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 1\r
+ -\r
+ type: normal\r
+ step: 2\r
+ context: clearwater-conf.yaml\r
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+---\r
+# description: test switch value used step-1's output.\r
+# to referring the step's output, using ((x.y)).\r
+# x is the id of the step,\r
+# y is the output key of the step.\r
+\r
+schema:\r
+ steps:\r
+ -\r
+ id: 1\r
+ name: get-switch\r
+ service:\r
+ name: greet\r
+ interface: switch\r
+ args:\r
+ name: leo\r
+\r
+ -\r
+ id: 2\r
+ name: greet1\r
+ service:\r
+ name: greet\r
+ interface: answer\r
+ args:\r
+ ping: ping_from_Leo\r
+\r
+ -\r
+ id: 3\r
+ name: greet2\r
+ service:\r
+ name: greet\r
+ interface: answer\r
+ args:\r
+ ping: ping_from_Leo_2\r
+\r
+ flows:\r
+ -\r
+ name: main\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 1\r
+ -\r
+ type: switch\r
+ value: ((1.result))\r
+ cases:\r
+ A:\r
+ -\r
+ type: normal\r
+ step: 2\r
+ B:\r
+ -\r
+ type: normal\r
+ step: 3
\ No newline at end of file
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+---\r
+# description: test switch and step-2 used step-1's output\r
+\r
+schema:\r
+ steps:\r
+ -\r
+ id: 1\r
+ name: get-switch\r
+ service:\r
+ name: greet\r
+ interface: switch\r
+ args:\r
+ name: leo\r
+\r
+ -\r
+ id: 2\r
+ name: greet1\r
+ service:\r
+ name: greet\r
+ interface: answer\r
+ args:\r
+ ping: ((1.result))\r
+\r
+ -\r
+ id: 3\r
+ name: greet2\r
+ service:\r
+ name: greet\r
+ interface: answer\r
+ args:\r
+ ping: ping_from_Leo_2\r
+\r
+ flows:\r
+ -\r
+ name: main\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 1\r
+ -\r
+ type: switch\r
+ value: ((1.result))\r
+ cases:\r
+ A:\r
+ -\r
+ type: normal\r
+ step: 2\r
+ B:\r
+ -\r
+ type: normal\r
+ step: 3
\ No newline at end of file
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+---\r
+schema:\r
+ steps:\r
+ -\r
+ id: 1\r
+ name: suitetest_00\r
+ service:\r
+ name: greet\r
+ interface: ten\r
+ args:\r
+ name: leo\r
+ flows:\r
+ -\r
+ name: main\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 1
\ No newline at end of file
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+---\r
+schema:\r
+ steps:\r
+ -\r
+ id: 1\r
+ name: suitetest_01\r
+ service:\r
+ name: greet\r
+ interface: ten\r
+ args:\r
+ name: leo\r
+ flows:\r
+ -\r
+ name: main\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 1
\ No newline at end of file
--- /dev/null
+##############################################################################\r
+# Copyright (c) 2018 HUAWEI TECHNOLOGIES CO.,LTD and others.\r
+#\r
+# All rights reserved. This program and the accompanying materials\r
+# are made available under the terms of the Apache License, Version 2.0\r
+# which accompanies this distribution, and is available at\r
+# http://www.apache.org/licenses/LICENSE-2.0\r
+##############################################################################\r
+\r
+---\r
+schema:\r
+ steps:\r
+ -\r
+ id: 1\r
+ name: suitetest_01\r
+ service:\r
+ name: greet\r
+ interface: greet\r
+ args:\r
+ name: leo\r
+ flows:\r
+ -\r
+ name: main\r
+ orders:\r
+ -\r
+ type: normal\r
+ step: 1
\ No newline at end of file
Code Review / bottlenecks.git / commitdiff