Allow arbirtrary matcher to be add to match
To handle requests for additional features on matching add a callback function that can match anything on the request object. This is easier than adding every combination of matcher option - though we should still add things that are commonly used. Change-Id: I300f74a1f2103545eca60087b2352a535add188d Closes-Bug: #1657308
This commit is contained in:
parent
95dffefe83
commit
10c84747e0
@ -209,6 +209,38 @@ Only the headers that are provided need match, any additional headers will be ig
|
||||
requests_mock.exceptions.NoMockAddress: No mock address: POST mock://test.com/headers
|
||||
|
||||
|
||||
Additional Matchers
|
||||
===================
|
||||
|
||||
As distinct from `Custom Matching` below we can add an additional matcher callback that lets us do more dynamic matching in addition to the standard options.
|
||||
This is handled by a callback function that takes the request as a parameter:
|
||||
|
||||
.. doctest::
|
||||
:hide:
|
||||
|
||||
>>> import requests
|
||||
>>> import requests_mock
|
||||
>>> adapter = requests_mock.Adapter()
|
||||
>>> session = requests.Session()
|
||||
>>> session.mount('mock', adapter)
|
||||
|
||||
.. doctest::
|
||||
|
||||
>>> def match_request_text(request):
|
||||
... # request.text may be None, or '' prevents a TypeError.
|
||||
... return 'hello' in (request.text or '')
|
||||
...
|
||||
>>> adapter.register_uri('POST', 'mock://test.com/additional', additional_matcher=match_request_text, text='resp')
|
||||
>>> session.post('mock://test.com/headers', data='hello world').text
|
||||
'resp'
|
||||
>>> resp = session.post('mock://test.com/additional', data='goodbye world')
|
||||
Traceback (most recent call last):
|
||||
...
|
||||
requests_mock.exceptions.NoMockAddress: No mock address: POST mock://test.com/additional
|
||||
|
||||
Using this mechanism lets you do custom handling such as parsing yaml or XML structures and matching on features of that data or anything else that is not directly handled via the provided matchers rather than build in every possible option to `requests_mock`.
|
||||
|
||||
|
||||
Custom Matching
|
||||
===============
|
||||
|
||||
|
@ -66,7 +66,7 @@ class _Matcher(_RequestHistoryTracker):
|
||||
"""Contains all the information about a provided URL to match."""
|
||||
|
||||
def __init__(self, method, url, responses, complete_qs, request_headers,
|
||||
real_http, case_sensitive):
|
||||
additional_matcher, real_http, case_sensitive):
|
||||
"""
|
||||
:param bool complete_qs: Match the entire query string. By default URLs
|
||||
match if all the provided matcher query arguments are matched and
|
||||
@ -81,6 +81,7 @@ class _Matcher(_RequestHistoryTracker):
|
||||
self._complete_qs = complete_qs
|
||||
self._request_headers = request_headers
|
||||
self._real_http = real_http
|
||||
self._additional_matcher = additional_matcher
|
||||
|
||||
# url can be a regex object or ANY so don't always run urlparse
|
||||
if isinstance(url, six.string_types):
|
||||
@ -169,10 +170,20 @@ class _Matcher(_RequestHistoryTracker):
|
||||
|
||||
return True
|
||||
|
||||
def _match_additional(self, request):
|
||||
if callable(self._additional_matcher):
|
||||
return self._additional_matcher(request)
|
||||
|
||||
if self._additional_matcher is not None:
|
||||
raise TypeError("Unexpected format of additional matcher.")
|
||||
|
||||
return True
|
||||
|
||||
def _match(self, request):
|
||||
return (self._match_method(request) and
|
||||
self._match_url(request) and
|
||||
self._match_headers(request))
|
||||
self._match_headers(request) and
|
||||
self._match_additional(request))
|
||||
|
||||
def __call__(self, request):
|
||||
if not self._match(request):
|
||||
@ -231,6 +242,7 @@ class Adapter(BaseAdapter, _RequestHistoryTracker):
|
||||
:param str url: The URL to match.
|
||||
"""
|
||||
complete_qs = kwargs.pop('complete_qs', False)
|
||||
additional_matcher = kwargs.pop('additional_matcher', None)
|
||||
request_headers = kwargs.pop('request_headers', {})
|
||||
real_http = kwargs.pop('_real_http', False)
|
||||
|
||||
@ -255,6 +267,7 @@ class Adapter(BaseAdapter, _RequestHistoryTracker):
|
||||
responses,
|
||||
case_sensitive=self._case_sensitive,
|
||||
complete_qs=complete_qs,
|
||||
additional_matcher=additional_matcher,
|
||||
request_headers=request_headers,
|
||||
real_http=real_http)
|
||||
self.add_matcher(matcher)
|
||||
|
@ -27,24 +27,28 @@ class TestMatcher(base.TestCase):
|
||||
request_method='GET',
|
||||
complete_qs=False,
|
||||
headers=None,
|
||||
request_data=None,
|
||||
request_headers={},
|
||||
additional_matcher=None,
|
||||
real_http=False,
|
||||
case_sensitive=False):
|
||||
matcher = adapter._Matcher(matcher_method,
|
||||
target,
|
||||
[],
|
||||
complete_qs,
|
||||
request_headers,
|
||||
complete_qs=complete_qs,
|
||||
additional_matcher=additional_matcher,
|
||||
request_headers=request_headers,
|
||||
real_http=real_http,
|
||||
case_sensitive=case_sensitive)
|
||||
request = adapter._RequestObjectProxy._create(request_method,
|
||||
url,
|
||||
headers)
|
||||
headers,
|
||||
data=request_data)
|
||||
return matcher._match(request)
|
||||
|
||||
def assertMatch(self,
|
||||
target,
|
||||
url,
|
||||
target=ANY,
|
||||
url='http://example.com/requests-mock',
|
||||
matcher_method='GET',
|
||||
request_method='GET',
|
||||
**kwargs):
|
||||
@ -58,8 +62,8 @@ class TestMatcher(base.TestCase):
|
||||
(matcher_method, target, request_method, url))
|
||||
|
||||
def assertMatchBoth(self,
|
||||
target,
|
||||
url,
|
||||
target=ANY,
|
||||
url='http://example.com/requests-mock',
|
||||
matcher_method='GET',
|
||||
request_method='GET',
|
||||
**kwargs):
|
||||
@ -75,8 +79,8 @@ class TestMatcher(base.TestCase):
|
||||
**kwargs)
|
||||
|
||||
def assertNoMatch(self,
|
||||
target,
|
||||
url,
|
||||
target=ANY,
|
||||
url='http://example.com/requests-mock',
|
||||
matcher_method='GET',
|
||||
request_method='GET',
|
||||
**kwargs):
|
||||
@ -90,8 +94,8 @@ class TestMatcher(base.TestCase):
|
||||
(matcher_method, target, request_method, url))
|
||||
|
||||
def assertNoMatchBoth(self,
|
||||
target,
|
||||
url,
|
||||
target=ANY,
|
||||
url='http://example.com/requests-mock',
|
||||
matcher_method='GET',
|
||||
request_method='GET',
|
||||
**kwargs):
|
||||
@ -265,3 +269,18 @@ class TestMatcher(base.TestCase):
|
||||
|
||||
self.assertSensitiveMatch('http://abc.com/path?abcd=efGH',
|
||||
'http://abc.com/path?abcd=eFGH')
|
||||
|
||||
def test_additional_matcher(self):
|
||||
|
||||
def test_match_body(request):
|
||||
return 'hello' in request.text
|
||||
|
||||
self.assertMatch(request_method='POST',
|
||||
matcher_method='POST',
|
||||
request_data='hello world',
|
||||
additional_matcher=test_match_body)
|
||||
|
||||
self.assertNoMatch(request_method='POST',
|
||||
matcher_method='POST',
|
||||
request_data='goodbye world',
|
||||
additional_matcher=test_match_body)
|
||||
|
@ -409,3 +409,20 @@ class MockerHttpMethodsTests(base.TestCase):
|
||||
|
||||
self.assertEqual(6, m1.call_count)
|
||||
self.assertEqual(2, r1.call_count)
|
||||
|
||||
@requests_mock.mock()
|
||||
def test_mocker_additional(self, m):
|
||||
url = 'http://www.example.com'
|
||||
good_text = 'success'
|
||||
|
||||
def additional_cb(req):
|
||||
return 'hello' in req.text
|
||||
|
||||
m.post(url, additional_matcher=additional_cb, text=good_text)
|
||||
|
||||
self.assertEqual(good_text,
|
||||
requests.post(url, data='hello world').text)
|
||||
self.assertRaises(exceptions.NoMockAddress,
|
||||
requests.post,
|
||||
url,
|
||||
data='goodbye world')
|
||||
|
Loading…
Reference in New Issue
Block a user