Skip to content

Commit

Permalink
Merge pull request #137 from ably/fix136
Browse files Browse the repository at this point in the history
Fix authentication with auth_url
  • Loading branch information
jdavid authored Jan 11, 2019
2 parents 6515a58 + da30fcf commit 28a2b2f
Show file tree
Hide file tree
Showing 4 changed files with 16 additions and 8 deletions.
2 changes: 1 addition & 1 deletion ably/rest/auth.py
Original file line number Diff line number Diff line change
Expand Up @@ -161,7 +161,7 @@ def request_token(self, token_params=None,
elif isinstance(token_request, dict) and 'issued' in token_request:
return TokenDetails.from_dict(token_request)
elif isinstance(token_request, dict):
token_request = TokenRequest(**token_request)
token_request = TokenRequest.from_json(token_request)
elif isinstance(token_request, six.text_type):
return TokenDetails(token=token_request)
# python2
Expand Down
1 change: 0 additions & 1 deletion ably/rest/channel.py
Original file line number Diff line number Diff line change
Expand Up @@ -66,7 +66,6 @@ def history(self, direction=None, limit=None, start=None, end=None, timeout=None
return PaginatedResult.paginated_query(
self.ably.http, url=path, response_processor=message_handler)

@catch_all
def publish(self, name=None, data=None, client_id=None, extras=None,
messages=None, timeout=None):
"""Publishes a message on this channel.
Expand Down
19 changes: 14 additions & 5 deletions test/ably/resttoken_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -245,18 +245,27 @@ def test_token_request_can_be_used_to_get_a_token(self):
key_name=self.key_name, key_secret=self.key_secret)
self.assertIsInstance(token_request, TokenRequest)

def auth_callback(token_params):
return token_request

ably = AblyRest(auth_callback=auth_callback,
ably = AblyRest(auth_callback=lambda x: token_request,
rest_host=test_vars["host"],
port=test_vars["port"],
tls_port=test_vars["tls_port"],
tls=test_vars["tls"],
use_binary_protocol=self.use_binary_protocol)

token = ably.auth.authorize()
self.assertIsInstance(token, TokenDetails)

def test_token_request_dict_can_be_used_to_get_a_token(self):
token_request = self.ably.auth.create_token_request(
key_name=self.key_name, key_secret=self.key_secret)
self.assertIsInstance(token_request, TokenRequest)

ably = AblyRest(auth_callback=lambda x: token_request.to_dict(),
rest_host=test_vars["host"],
port=test_vars["port"],
tls_port=test_vars["tls_port"],
tls=test_vars["tls"],
use_binary_protocol=self.use_binary_protocol)
token = ably.auth.authorize()
self.assertIsInstance(token, TokenDetails)

# TE6
Expand Down
2 changes: 1 addition & 1 deletion tox.ini
Original file line number Diff line number Diff line change
Expand Up @@ -10,7 +10,7 @@ deps =
-rrequirements-test.txt

commands =
py.test -n auto --tb=short test
py.test -n auto --tb=long test

[testenv:flake8]
commands =
Expand Down

0 comments on commit 28a2b2f

Please sign in to comment.