MatrixSynapse/synapse/http/client.py

293 lines
9.4 KiB
Python
Raw Normal View History

2014-08-12 16:10:52 +02:00
# -*- coding: utf-8 -*-
2015-01-06 14:21:39 +01:00
# Copyright 2014, 2015 OpenMarket Ltd
2014-08-12 16:10:52 +02:00
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
from OpenSSL import SSL
from OpenSSL.SSL import VERIFY_NONE
2014-08-12 16:10:52 +02:00
from synapse.api.errors import CodeMessageException
from synapse.util.logcontext import preserve_context_over_fn
import synapse.metrics
from canonicaljson import encode_canonical_json
from twisted.internet import defer, reactor, ssl
2014-10-30 02:21:33 +01:00
from twisted.web.client import (
Agent, readBody, FileBodyProducer, PartialDownloadError,
2014-10-30 02:21:33 +01:00
)
2014-08-12 16:10:52 +02:00
from twisted.web.http_headers import Headers
from StringIO import StringIO
2015-02-11 15:23:10 +01:00
import simplejson as json
2014-08-12 16:10:52 +02:00
import logging
import urllib
logger = logging.getLogger(__name__)
metrics = synapse.metrics.get_metrics_for(__name__)
2015-03-12 17:24:38 +01:00
outgoing_requests_counter = metrics.register_counter(
"requests",
2015-03-06 16:28:06 +01:00
labels=["method"],
)
2015-03-12 17:24:38 +01:00
incoming_responses_counter = metrics.register_counter(
"responses",
labels=["method", "code"],
)
2014-08-12 16:10:52 +02:00
class SimpleHttpClient(object):
"""
2014-11-20 19:00:10 +01:00
A simple, no-frills HTTP client with methods that wrap up common ways of
using HTTP in Matrix
"""
def __init__(self, hs):
self.hs = hs
# The default context factory in Twisted 14.0.0 (which we require) is
2014-11-20 19:00:10 +01:00
# BrowserLikePolicyForHTTPS which will do regular cert validation
# 'like a browser'
self.agent = Agent(
reactor,
connectTimeout=15,
contextFactory=hs.get_http_client_context_factory()
)
2015-10-06 03:49:39 +02:00
self.user_agent = hs.version_string
if hs.config.user_agent_suffix:
2015-10-06 16:53:33 +02:00
self.user_agent = "%s %s" % (self.user_agent, hs.config.user_agent_suffix,)
def request(self, method, uri, *args, **kwargs):
# A small wrapper around self.agent.request() so we can easily attach
# counters to it
outgoing_requests_counter.inc(method)
d = preserve_context_over_fn(
self.agent.request,
method, uri, *args, **kwargs
)
logger.info("Sending request %s %s", method, uri)
def _cb(response):
incoming_responses_counter.inc(method, response.code)
logger.info(
"Received response to %s %s: %s",
method, uri, response.code
)
return response
2015-03-12 17:24:38 +01:00
def _eb(failure):
incoming_responses_counter.inc(method, "ERR")
logger.info(
"Error sending request to %s %s: %s %s",
method, uri, failure.type, failure.getErrorMessage()
)
return failure
2015-03-12 17:24:38 +01:00
d.addCallbacks(_cb, _eb)
return d
2014-11-20 14:53:34 +01:00
@defer.inlineCallbacks
def post_urlencoded_get_json(self, uri, args={}):
# TODO: Do we ever want to log message contents?
2014-11-20 14:53:34 +01:00
logger.debug("post_urlencoded_get_json args: %s", args)
2014-11-20 14:53:34 +01:00
query_bytes = urllib.urlencode(args, True)
response = yield self.request(
2014-11-20 14:53:34 +01:00
"POST",
uri.encode("ascii"),
headers=Headers({
b"Content-Type": [b"application/x-www-form-urlencoded"],
b"User-Agent": [self.user_agent],
}),
bodyProducer=FileBodyProducer(StringIO(query_bytes))
2014-11-20 14:53:34 +01:00
)
2015-06-19 12:45:55 +02:00
body = yield preserve_context_over_fn(readBody, response)
2014-11-20 14:53:34 +01:00
defer.returnValue(json.loads(body))
@defer.inlineCallbacks
def post_json_get_json(self, uri, post_json):
json_str = encode_canonical_json(post_json)
logger.debug("HTTP POST %s -> %s", json_str, uri)
response = yield self.request(
"POST",
uri.encode("ascii"),
headers=Headers({
b"Content-Type": [b"application/json"],
b"User-Agent": [self.user_agent],
}),
bodyProducer=FileBodyProducer(StringIO(json_str))
)
2015-06-19 12:45:55 +02:00
body = yield preserve_context_over_fn(readBody, response)
defer.returnValue(json.loads(body))
2014-11-20 14:53:34 +01:00
@defer.inlineCallbacks
def get_json(self, uri, args={}):
""" Gets some json from the given URI.
2014-11-20 14:53:34 +01:00
Args:
uri (str): The URI to request, not including query parameters
2014-11-20 14:53:34 +01:00
args (dict): A dictionary used to create query strings, defaults to
None.
**Note**: The value of each key is assumed to be an iterable
and *not* a string.
Returns:
Deferred: Succeeds when we get *any* 2xx HTTP response, with the
HTTP body as JSON.
Raises:
2015-02-11 17:41:16 +01:00
On a non-2xx HTTP response. The response body will be used as the
error message.
2014-11-20 14:53:34 +01:00
"""
body = yield self.get_raw(uri, args)
defer.returnValue(json.loads(body))
@defer.inlineCallbacks
def put_json(self, uri, json_body, args={}):
""" Puts some json to the given URI.
Args:
uri (str): The URI to request, not including query parameters
json_body (dict): The JSON to put in the HTTP body,
args (dict): A dictionary used to create query strings, defaults to
None.
**Note**: The value of each key is assumed to be an iterable
and *not* a string.
Returns:
Deferred: Succeeds when we get *any* 2xx HTTP response, with the
HTTP body as JSON.
Raises:
On a non-2xx HTTP response.
"""
if len(args):
query_bytes = urllib.urlencode(args, True)
uri = "%s?%s" % (uri, query_bytes)
2014-11-20 14:53:34 +01:00
json_str = encode_canonical_json(json_body)
response = yield self.request(
"PUT",
uri.encode("ascii"),
headers=Headers({
b"User-Agent": [self.user_agent],
"Content-Type": ["application/json"]
}),
bodyProducer=FileBodyProducer(StringIO(json_str))
2014-11-20 14:53:34 +01:00
)
2015-06-19 12:45:55 +02:00
body = yield preserve_context_over_fn(readBody, response)
2014-11-20 14:53:34 +01:00
if 200 <= response.code < 300:
defer.returnValue(json.loads(body))
else:
# NB: This is explicitly not json.loads(body)'d because the contract
# of CodeMessageException is a *string* message. Callers can always
# load it into JSON if they want.
raise CodeMessageException(response.code, body)
2014-11-20 14:53:34 +01:00
@defer.inlineCallbacks
def get_raw(self, uri, args={}):
""" Gets raw text from the given URI.
Args:
uri (str): The URI to request, not including query parameters
args (dict): A dictionary used to create query strings, defaults to
None.
**Note**: The value of each key is assumed to be an iterable
and *not* a string.
Returns:
Deferred: Succeeds when we get *any* 2xx HTTP response, with the
HTTP body at text.
Raises:
On a non-2xx HTTP response. The response body will be used as the
error message.
"""
if len(args):
query_bytes = urllib.urlencode(args, True)
uri = "%s?%s" % (uri, query_bytes)
response = yield self.request(
"GET",
uri.encode("ascii"),
headers=Headers({
b"User-Agent": [self.user_agent],
})
)
2015-06-19 12:45:55 +02:00
body = yield preserve_context_over_fn(readBody, response)
if 200 <= response.code < 300:
defer.returnValue(body)
else:
raise CodeMessageException(response.code, body)
2014-11-20 14:53:34 +01:00
class CaptchaServerHttpClient(SimpleHttpClient):
2014-11-20 14:53:34 +01:00
"""
Separate HTTP client for talking to google's captcha servers
Only slightly special because accepts partial download responses
used only by c/s api v1
2014-11-20 14:53:34 +01:00
"""
@defer.inlineCallbacks
def post_urlencoded_get_raw(self, url, args={}):
query_bytes = urllib.urlencode(args, True)
response = yield self.request(
"POST",
url.encode("ascii"),
bodyProducer=FileBodyProducer(StringIO(query_bytes)),
headers=Headers({
b"Content-Type": [b"application/x-www-form-urlencoded"],
b"User-Agent": [self.user_agent],
})
)
try:
2015-06-19 12:45:55 +02:00
body = yield preserve_context_over_fn(readBody, response)
defer.returnValue(body)
except PartialDownloadError as e:
# twisted dislikes google's response, no content length.
2014-11-20 14:53:34 +01:00
defer.returnValue(e.response)
2014-08-12 16:10:52 +02:00
2014-10-30 12:10:17 +01:00
2014-08-12 16:10:52 +02:00
def _print_ex(e):
if hasattr(e, "reasons") and e.reasons:
for ex in e.reasons:
_print_ex(ex)
else:
logger.exception(e)
class InsecureInterceptableContextFactory(ssl.ContextFactory):
"""
Factory for PyOpenSSL SSL contexts which accepts any certificate for any domain.
Do not use this since it allows an attacker to intercept your communications.
2015-09-09 14:05:00 +02:00
"""
def __init__(self):
self._context = SSL.Context(SSL.SSLv23_METHOD)
self._context.set_verify(VERIFY_NONE, lambda *_: None)
def getContext(self, hostname, port):
return self._context