summaryrefslogtreecommitdiff
path: root/common/src/leap/soledad
diff options
context:
space:
mode:
Diffstat (limited to 'common/src/leap/soledad')
-rw-r--r--common/src/leap/soledad/common/l2db/remote/http_client.py43
1 files changed, 5 insertions, 38 deletions
diff --git a/common/src/leap/soledad/common/l2db/remote/http_client.py b/common/src/leap/soledad/common/l2db/remote/http_client.py
index eea42888..a65264b6 100644
--- a/common/src/leap/soledad/common/l2db/remote/http_client.py
+++ b/common/src/leap/soledad/common/l2db/remote/http_client.py
@@ -1,5 +1,4 @@
# Copyright 2011-2012 Canonical Ltd.
-# Copyright 2016 LEAP Encryption Access Project
#
# This file is part of u1db.
#
@@ -18,7 +17,6 @@
"""Base class to make requests to a remote HTTP server."""
import httplib
-from oauth import oauth
try:
import simplejson as json
except ImportError:
@@ -33,9 +31,7 @@ from time import sleep
from leap.soledad.common.l2db import errors
from leap.soledad.common.l2db.remote import http_errors
-from leap.soledad.common.l2db.remote.ssl_match_hostname import ( # noqa
- CertificateError,
- match_hostname)
+from leap.soledad.common.l2db.remote.ssl_match_hostname import match_hostname
# Ubuntu/debian
# XXX other...
@@ -68,7 +64,7 @@ class _VerifiedHTTPSConnection(httplib.HTTPSConnection):
cert_opts = {
'cert_reqs': ssl.CERT_REQUIRED,
'ca_certs': CA_CERTS
- }
+ }
else:
# XXX no cert verification implemented elsewhere for now
cert_opts = {}
@@ -83,13 +79,6 @@ class _VerifiedHTTPSConnection(httplib.HTTPSConnection):
class HTTPClientBase(object):
"""Base class to make requests to a remote HTTP server."""
- # by default use HMAC-SHA1 OAuth signature method to not disclose
- # tokens
- # NB: given that the content bodies are not covered by the
- # signatures though, to achieve security (against man-in-the-middle
- # attacks for example) one would need HTTPS
- oauth_signature_method = oauth.OAuthSignatureMethod_HMAC_SHA1()
-
# Will use these delays to retry on 503 befor finally giving up. The final
# 0 is there to not wait after the final try fails.
_delays = (1, 1, 2, 4, 0)
@@ -108,12 +97,6 @@ class HTTPClientBase(object):
raise errors.UnknownAuthMethod(auth_meth)
set_creds(**credentials)
- def set_oauth_credentials(self, consumer_key, consumer_secret,
- token_key, token_secret):
- self._creds = {'oauth': (
- oauth.OAuthConsumer(consumer_key, consumer_secret),
- oauth.OAuthToken(token_key, token_secret))}
-
def _ensure_connection(self):
if self._conn is not None:
return
@@ -149,7 +132,6 @@ class HTTPClientBase(object):
except ValueError:
pass
else:
- print "ERROR--->", respdic
self._error(respdic)
# special case
if resp.status == 503:
@@ -157,25 +139,10 @@ class HTTPClientBase(object):
raise errors.HTTPError(resp.status, body, headers)
def _sign_request(self, method, url_query, params):
- if 'oauth' in self._creds:
- consumer, token = self._creds['oauth']
- full_url = "%s://%s%s" % (self._url.scheme, self._url.netloc,
- url_query)
- oauth_req = oauth.OAuthRequest.from_consumer_and_token(
- consumer, token,
- http_method=method,
- parameters=params,
- http_url=full_url
- )
- oauth_req.sign_request(
- self.oauth_signature_method, consumer, token)
- # Authorization: OAuth ...
- return oauth_req.to_header().items()
- else:
- return []
+ raise NotImplementedError
def _request(self, method, url_parts, params=None, body=None,
- content_type=None):
+ content_type=None):
self._ensure_connection()
unquoted_url = url_query = self._url.path
if url_parts:
@@ -209,7 +176,7 @@ class HTTPClientBase(object):
raise e
def _request_json(self, method, url_parts, params=None, body=None,
- content_type=None):
+ content_type=None):
res, headers = self._request(method, url_parts, params, body,
content_type)
return json.loads(res), headers