mirror of
https://git.anonymousland.org/anonymousland/synapse.git
synced 2024-12-19 22:44:18 -05:00
Actually make 3PU lookup calls out to ASes
This commit is contained in:
parent
fa87c981e1
commit
3ec10dffd6
@ -71,8 +71,17 @@ class ApplicationServiceApi(SimpleHttpClient):
|
|||||||
logger.warning("query_alias to %s threw exception %s", uri, ex)
|
logger.warning("query_alias to %s threw exception %s", uri, ex)
|
||||||
defer.returnValue(False)
|
defer.returnValue(False)
|
||||||
|
|
||||||
|
@defer.inlineCallbacks
|
||||||
def query_3pu(self, service, protocol, fields):
|
def query_3pu(self, service, protocol, fields):
|
||||||
return False
|
uri = service.url + ("/3pu/%s" % urllib.quote(protocol))
|
||||||
|
response = None
|
||||||
|
try:
|
||||||
|
response = yield self.get_json(uri, fields)
|
||||||
|
defer.returnValue(response)
|
||||||
|
except:
|
||||||
|
# TODO: would be noisy to log lookup failures, but we want to log
|
||||||
|
# other things. Hrm.
|
||||||
|
defer.returnValue([])
|
||||||
|
|
||||||
@defer.inlineCallbacks
|
@defer.inlineCallbacks
|
||||||
def push_bulk(self, service, events, txn_id=None):
|
def push_bulk(self, service, events, txn_id=None):
|
||||||
|
Loading…
Reference in New Issue
Block a user