Matrix-Mirrors/anonymousland-synapse
1
0
Fork 0
mirror of https://git.anonymousland.org/anonymousland/synapse.git synced 2024-12-25 12:19:21 -05:00
Code Issues Packages Projects Releases Wiki Activity

Fix syntax issues

Browse Source
This commit is contained in:
Andrew Morgan 2019-03-13 18:35:21 +00:00
parent 09626bfd39
commit 5526b054aa
1 changed files with 10 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
synapse/http/matrixfederationclient.py
View File

@ -190,6 +190,7 @@ class MatrixFederationHttpClient(object):
@defer.inlineCallbacks
def _send_request_with_optional_trailing_slash(
self,
request,
try_trailing_slash_on_400=False,
backoff_on_404=False,
@ -215,7 +216,7 @@ class MatrixFederationHttpClient(object):
Deferred[twisted.web.client.Response]: resolves with the HTTP
response object on success.
"""
response = self._send_request(**kwargs)
response = yield self._send_request(**kwargs)
if not try_trailing_slash_on_400:
defer.returnValue(response)
@ -225,6 +226,9 @@ class MatrixFederationHttpClient(object):
self.hs.get_reactor(), self.default_timeout, request, response,
)
logger.info(" *** BODY IS *** ")
logger.info(body)
# Retry with a trailing slash if we received a 400 with
# 'M_UNRECOGNIZED' which some endpoints can return when omitting a
# trailing slash on Synapse <=v0.99.2.
@ -588,15 +592,10 @@ class MatrixFederationHttpClient(object):
request, try_trailing_slash_on_400, backoff_on_404, **send_request_args,
)
# If enabled, retry with a trailing slash if we received a 400
if try_trailing_slash_on_400 and response.code == 400:
args["path"] += "/"
response = yield self._send_request(**send_request_args)
body = yield _handle_json_response(
self.hs.get_reactor(), self.default_timeout, request, response,
)
defer.returnValue(body)
@defer.inlineCallbacks
@ -713,6 +712,10 @@ class MatrixFederationHttpClient(object):
request, try_trailing_slash_on_400, False, **send_request_args,
)
body = yield _handle_json_response(
self.hs.get_reactor(), self.default_timeout, request, response,
)
defer.returnValue(body)
@defer.inlineCallbacks