# interpreted as representing official policies, either expressed
# or implied, of GRNET S.A.
-from mock import patch
+from mock import patch, call
from unittest import TestCase
from kamaki.clients.astakos import AstakosClient
def release(self):
pass
-khttp = 'kamaki.clients.connection.kamakicon.KamakiHTTPConnection'
+astakos_pkg = 'kamaki.clients.astakos.AstakosClient'
class Astakos(TestCase):
def tearDown(self):
FR.json = example
- @patch('%s.perform_request' % khttp, return_value=FR())
- def _authenticate(self, PR):
+ @patch('%s.get' % astakos_pkg, return_value=FR())
+ def _authenticate(self, get):
r = self.client.authenticate()
+ self.assertEqual(get.mock_calls[-1], call('/im/authenticate'))
self.cached = True
return r
def test_authenticate(self):
r = self._authenticate()
- self.assertEqual(self.client.http_client.url, self.url)
- self.assertEqual(self.client.http_client.path, '/im/authenticate')
for term, val in example.items():
self.assertTrue(term in r)
self.assertEqual(val, r[term])
class KamakiConnectionError(Exception):
- errno = None
def __init__(self, message, errno=None):
super(KamakiConnectionError, self).__init__(message)
- if errno:
- self.errno = errno
+ self.errno = errno if errno else 0
class KamakiResponseError(Exception):
- errno = None
def __init__(self, message, errno=None):
super(KamakiResponseError, self).__init__(message)
- if errno:
- self.errno = errno
+ self.errno = errno if errno else 0
class PithosClient(PithosRestAPI):
"""GRNet Pithos API client"""
- _thread_exceptions = []
-
def __init__(self, base_url, token, account=None, container=None):
super(PithosClient, self).__init__(base_url, token, account, container)