mirror of
https://github.com/httprunner/httprunner.git
synced 2026-05-17 05:07:37 +08:00
refactor variable context:
1, variable context has two level, testset and testcase; 2, testset level variables can be used in whole test suite, while testcase level variables can only be used in testcase; 3, when variable binds with functions, the funtions will be called and the result will be set to the variable.
This commit is contained in:
@@ -1 +1 @@
|
||||
__version__ = '0.1.0'
|
||||
__version__ = '0.2.0'
|
||||
102
ate/context.py
102
ate/context.py
@@ -21,10 +21,10 @@ class Context(object):
|
||||
"""
|
||||
def __init__(self):
|
||||
self.testset_config = {}
|
||||
self.testset_shared_variables_mapping = dict()
|
||||
self.testset_shared_variables_mapping = OrderedDict()
|
||||
|
||||
self.testcase_config = {}
|
||||
self.testcase_variables_mapping = dict()
|
||||
self.testcase_variables_mapping = OrderedDict()
|
||||
self.init_context()
|
||||
|
||||
def init_context(self, level='testset'):
|
||||
@@ -34,12 +34,12 @@ class Context(object):
|
||||
"""
|
||||
if level == "testset":
|
||||
self.testset_config["functions"] = {}
|
||||
self.testset_config["variables"] = OrderedDict()
|
||||
self.testset_config["request"] = {}
|
||||
self.testset_shared_variables_mapping = {}
|
||||
|
||||
self.testcase_config["functions"] = {}
|
||||
self.testcase_config["variables"] = OrderedDict()
|
||||
# testcase config shall inherit from testset configs,
|
||||
# but can not change testset configs, that's why we use copy.deepcopy here.
|
||||
self.testcase_config["functions"] = copy.deepcopy(self.testset_config["functions"])
|
||||
self.testcase_config["request"] = {}
|
||||
self.testcase_variables_mapping = copy.deepcopy(self.testset_shared_variables_mapping)
|
||||
|
||||
@@ -64,7 +64,7 @@ class Context(object):
|
||||
function = eval(function)
|
||||
eval_function_binds[func_name] = function
|
||||
|
||||
self.__update_context_config(level, "functions", eval_function_binds)
|
||||
self.__update_context_functions_config(level, eval_function_binds)
|
||||
|
||||
def import_module_functions(self, modules, level="testcase"):
|
||||
""" import modules and bind all functions within the context
|
||||
@@ -73,11 +73,14 @@ class Context(object):
|
||||
for module_name in modules:
|
||||
imported = importlib.import_module(module_name)
|
||||
imported_functions_dict = dict(filter(is_function, vars(imported).items()))
|
||||
self.__update_context_config(level, "functions", imported_functions_dict)
|
||||
self.__update_context_functions_config(level, imported_functions_dict)
|
||||
|
||||
def register_variables_config(self, variable_binds, level="testcase"):
|
||||
""" register variable configs
|
||||
@param (list) variable_binds, variable can be value or custom function
|
||||
def bind_variables(self, variable_binds, level="testcase"):
|
||||
""" bind variables to testset context or current testcase context.
|
||||
variables in testset context can be used in all testcases of current test suite.
|
||||
|
||||
@param (list) variable_binds, variable can be value or custom function.
|
||||
if value is function, it will be called and bind result to variable.
|
||||
e.g.
|
||||
[
|
||||
{"TOKEN": "debugtalk"},
|
||||
@@ -86,71 +89,56 @@ class Context(object):
|
||||
{"md5": "${gen_md5($TOKEN, $json, $random)}"}
|
||||
]
|
||||
"""
|
||||
if level == "testset":
|
||||
for variable_bind in variable_binds:
|
||||
self.testset_config["variables"].update(variable_bind)
|
||||
elif level == "testcase":
|
||||
self.testcase_config["variables"] = copy.deepcopy(self.testset_config["variables"])
|
||||
for variable_bind in variable_binds:
|
||||
self.testcase_config["variables"].update(variable_bind)
|
||||
for variable_bind in variable_binds:
|
||||
for variable_name, value in variable_bind.items():
|
||||
variable_evale_value = self.get_eval_value(value)
|
||||
|
||||
def register_request(self, request_dict, level="testcase"):
|
||||
self.__update_context_config(level, "request", request_dict)
|
||||
if level == "testset":
|
||||
self.testset_shared_variables_mapping[variable_name] = variable_evale_value
|
||||
|
||||
def __update_context_config(self, level, config_type, config_mapping):
|
||||
self.testcase_variables_mapping[variable_name] = variable_evale_value
|
||||
|
||||
def __update_context_functions_config(self, level, config_mapping):
|
||||
"""
|
||||
@param level: testset or testcase
|
||||
@param config_type: functions, variables or request
|
||||
@param config_mapping: functions config mapping or variables config mapping
|
||||
@param config_type: functions
|
||||
@param config_mapping: functions config mapping
|
||||
"""
|
||||
if level == "testset":
|
||||
self.testset_config[config_type].update(config_mapping)
|
||||
elif level == "testcase":
|
||||
self.testcase_config[config_type].update(config_mapping)
|
||||
self.testset_config["functions"].update(config_mapping)
|
||||
|
||||
self.testcase_config["functions"].update(config_mapping)
|
||||
|
||||
def register_request(self, request_dict, level="testcase"):
|
||||
self.__update_context_request_config(level, request_dict)
|
||||
|
||||
def __update_context_request_config(self, level, config_mapping):
|
||||
"""
|
||||
@param level: testset or testcase
|
||||
@param config_type: request
|
||||
@param config_mapping: request config mapping
|
||||
"""
|
||||
if level == "testset":
|
||||
self.testset_config["request"].update(config_mapping)
|
||||
|
||||
self.testcase_config["request"] = utils.deep_update_dict(
|
||||
copy.deepcopy(self.testset_config["request"]),
|
||||
config_mapping
|
||||
)
|
||||
|
||||
def get_parsed_request(self):
|
||||
""" get parsed request, with each variable replaced by bind value.
|
||||
testcase request shall inherit from testset request configs,
|
||||
but can not change testset configs, that's why we use copy.deepcopy here.
|
||||
"""
|
||||
testcase_request_config = utils.deep_update_dict(
|
||||
copy.deepcopy(self.testset_config["request"]),
|
||||
self.testcase_config["request"]
|
||||
)
|
||||
|
||||
parsed_request = testcase.parse_template(
|
||||
testcase_request_config,
|
||||
self._get_evaluated_testcase_variables()
|
||||
self.testcase_config["request"],
|
||||
self.testcase_variables_mapping
|
||||
)
|
||||
|
||||
return parsed_request
|
||||
|
||||
def bind_extracted_variables(self, variables_mapping):
|
||||
""" bind extracted variable to current testcase context and testset context.
|
||||
since extracted variable maybe used in current testcase and next testcases.
|
||||
"""
|
||||
self.testset_shared_variables_mapping.update(variables_mapping)
|
||||
self.testcase_variables_mapping.update(variables_mapping)
|
||||
|
||||
def get_testcase_variables_mapping(self):
|
||||
return self.testcase_variables_mapping
|
||||
|
||||
def _get_evaluated_testcase_variables(self):
|
||||
""" variables in variables_config will be evaluated each time
|
||||
"""
|
||||
testcase_functions_config = copy.deepcopy(self.testset_config["functions"])
|
||||
testcase_functions_config.update(self.testcase_config["functions"])
|
||||
self.testcase_config["functions"] = testcase_functions_config
|
||||
|
||||
testcase_variables_config = copy.deepcopy(self.testset_config["variables"])
|
||||
testcase_variables_config.update(self.testcase_config["variables"])
|
||||
self.testcase_config["variables"] = testcase_variables_config
|
||||
|
||||
for var_name, var_value in self.testcase_config["variables"].items():
|
||||
self.testcase_variables_mapping[var_name] = self.get_eval_value(var_value)
|
||||
|
||||
return self.testcase_variables_mapping
|
||||
|
||||
def get_eval_value(self, data):
|
||||
""" evaluate data recursively, each variable in data will be evaluated.
|
||||
"""
|
||||
|
||||
@@ -54,23 +54,27 @@ class ResponseObject(object):
|
||||
|
||||
def extract_response(self, extract_binds):
|
||||
""" extract content from requests.Response
|
||||
@param (dict) extract_binds
|
||||
{
|
||||
"resp_status_code": "status_code",
|
||||
"resp_headers_content_type": "headers.content-type",
|
||||
"resp_content": "content",
|
||||
"resp_content_person_first_name": "content.person.name.first_name"
|
||||
}
|
||||
@param (list) extract_binds
|
||||
[
|
||||
{"resp_status_code": "status_code"},
|
||||
{"resp_headers_content_type": "headers.content-type"},
|
||||
{"resp_content": "content"},
|
||||
{"resp_content_person_first_name": "content.person.name.first_name"}
|
||||
]
|
||||
@return (list) variable binds list
|
||||
"""
|
||||
extracted_variables_mapping = {}
|
||||
extracted_variables_mapping_list = []
|
||||
|
||||
for key, field in extract_binds.items():
|
||||
if not isinstance(field, utils.string_type):
|
||||
raise exception.ParamsError("invalid extract_binds!")
|
||||
for extract_bind in extract_binds:
|
||||
for key, field in extract_bind.items():
|
||||
if not isinstance(field, utils.string_type):
|
||||
raise exception.ParamsError("invalid extract_binds!")
|
||||
|
||||
extracted_variables_mapping[key] = self.extract_field(field)
|
||||
extracted_variables_mapping_list.append(
|
||||
{key: self.extract_field(field)}
|
||||
)
|
||||
|
||||
return extracted_variables_mapping
|
||||
return extracted_variables_mapping_list
|
||||
|
||||
def validate(self, validators, variables_mapping):
|
||||
""" Bind named validators to value within the context.
|
||||
|
||||
@@ -45,7 +45,7 @@ class Runner(object):
|
||||
self.context.import_module_functions(module_functions, level)
|
||||
|
||||
variable_binds = config_dict.get('variable_binds', [])
|
||||
self.context.register_variables_config(variable_binds, level)
|
||||
self.context.bind_variables(variable_binds, level)
|
||||
|
||||
request_config = config_dict.get('request', {})
|
||||
if level == "testset":
|
||||
@@ -93,8 +93,8 @@ class Runner(object):
|
||||
resp_obj = response.ResponseObject(resp)
|
||||
|
||||
extract_binds = testcase.get("extract_binds", {})
|
||||
extracted_variables_mapping = resp_obj.extract_response(extract_binds)
|
||||
self.context.bind_extracted_variables(extracted_variables_mapping)
|
||||
extracted_variables_mapping_list = resp_obj.extract_response(extract_binds)
|
||||
self.context.bind_variables(extracted_variables_mapping_list, level="testset")
|
||||
|
||||
validators = testcase.get("validators", [])
|
||||
diff_content_list = resp_obj.validate(
|
||||
|
||||
Reference in New Issue
Block a user