mirror of
https://github.com/httprunner/httprunner.git
synced 2026-09-05 23:51:25 +08:00
refactor: extract status_code
This commit is contained in:
+14
-1
@@ -72,7 +72,18 @@ class ResponseObject(object):
|
|||||||
top_query = field
|
top_query = field
|
||||||
sub_query = None
|
sub_query = None
|
||||||
|
|
||||||
if top_query == "cookies":
|
# status_code
|
||||||
|
if top_query == "status_code":
|
||||||
|
if sub_query:
|
||||||
|
# status_code.XX
|
||||||
|
err_msg = u"ParamsError: {}\n".format(field)
|
||||||
|
logger.log_error(err_msg)
|
||||||
|
raise exceptions.ParamsError(err_msg)
|
||||||
|
|
||||||
|
return self.status_code
|
||||||
|
|
||||||
|
# cookies
|
||||||
|
elif top_query == "cookies":
|
||||||
cookies = self.cookies
|
cookies = self.cookies
|
||||||
try:
|
try:
|
||||||
return cookies[sub_query]
|
return cookies[sub_query]
|
||||||
@@ -82,6 +93,8 @@ class ResponseObject(object):
|
|||||||
err_msg += u"attribute: {}".format(sub_query)
|
err_msg += u"attribute: {}".format(sub_query)
|
||||||
logger.log_error(err_msg)
|
logger.log_error(err_msg)
|
||||||
raise exceptions.ParamsError(err_msg)
|
raise exceptions.ParamsError(err_msg)
|
||||||
|
|
||||||
|
# elapsed
|
||||||
elif top_query == "elapsed":
|
elif top_query == "elapsed":
|
||||||
if sub_query in ["days", "seconds", "microseconds"]:
|
if sub_query in ["days", "seconds", "microseconds"]:
|
||||||
return getattr(self.elapsed, sub_query)
|
return getattr(self.elapsed, sub_query)
|
||||||
|
|||||||
@@ -27,6 +27,39 @@ class TestResponse(ApiServerUnittest):
|
|||||||
resp_obj = response.ResponseObject(resp)
|
resp_obj = response.ResponseObject(resp)
|
||||||
self.assertEqual(bytes, type(resp_obj.content))
|
self.assertEqual(bytes, type(resp_obj.content))
|
||||||
|
|
||||||
|
def test_extract_response_status_code(self):
|
||||||
|
resp = requests.post(
|
||||||
|
url="http://127.0.0.1:3458/anything",
|
||||||
|
json={
|
||||||
|
'success': False,
|
||||||
|
"person": {
|
||||||
|
"name": {
|
||||||
|
"first_name": "Leo",
|
||||||
|
"last_name": "Lee",
|
||||||
|
},
|
||||||
|
"age": 29,
|
||||||
|
"cities": ["Guangzhou", "Shenzhen"]
|
||||||
|
}
|
||||||
|
}
|
||||||
|
)
|
||||||
|
resp_obj = response.ResponseObject(resp)
|
||||||
|
|
||||||
|
extract_binds_list = [
|
||||||
|
{"resp_status_code": "status_code"}
|
||||||
|
]
|
||||||
|
extract_binds_dict = resp_obj.extract_response(extract_binds_list)
|
||||||
|
|
||||||
|
self.assertEqual(
|
||||||
|
extract_binds_dict["resp_status_code"],
|
||||||
|
200
|
||||||
|
)
|
||||||
|
|
||||||
|
extract_binds_list = [
|
||||||
|
{"resp_status_code": "status_code.xx"}
|
||||||
|
]
|
||||||
|
with self.assertRaises(exceptions.ParamsError):
|
||||||
|
resp_obj.extract_response(extract_binds_list)
|
||||||
|
|
||||||
def test_extract_response_json(self):
|
def test_extract_response_json(self):
|
||||||
resp = requests.post(
|
resp = requests.post(
|
||||||
url="http://127.0.0.1:3458/anything",
|
url="http://127.0.0.1:3458/anything",
|
||||||
|
|||||||
Reference in New Issue
Block a user