Updates for v1.2.1 (#81)

* Update jwt token update_token method to the latest azure-identity api

* Update expire_at implementation

* Update expire_at of jwt token according to azure-identity api

* remove unused import

* Fix pylint error

Author: yunhaoling

HISTORY.rst

@@ -3,6 +3,12 @@
 Release History
 ===============
 
+1.2.1 (2019-06-20)
+++++++++++++++++++
+
+- Updated the implementation of `update_token()` in `JWTTokenAuth` and `JWTTokenAsync` (issue #80).
+
+
 1.2.0 (2019-04-16)
 ++++++++++++++++++
 

setup.py

@@ -149,7 +149,7 @@ def get_latest_windows_sdk():
     platform_libs_path = os.path.join(lib_path, latest_libs_dir, "um", 'x64' if is_x64 else 'x86')
     if not os.path.isdir(platform_libs_path):
         print("Warning - build may fail: Windows SDK v{} libraries {} not found at path {}.".format(
-            latest_sdk_version, latest_libs_dir, sdk_platform_libs_pathpath))
+            latest_sdk_version, latest_libs_dir, platform_libs_path))
     else:
         print("Adding Windows SDK v{} libraries {} to search path, installed at {}".format(
             latest_sdk_version, latest_libs_dir, platform_libs_path))

uamqp/__init__.py

@@ -33,7 +33,7 @@
     pass  # Async not supported.
 
 
-__version__ = "1.2.0"
+__version__ = "1.2.1"
 
 
 _logger = logging.getLogger(__name__)

uamqp/authentication/cbs_auth.py

@@ -418,5 +418,6 @@ def __init__(self, audience, uri,
         self.set_io(self.hostname, port, http_proxy, transport_type)
 
     def update_token(self):
-        self.expires_at = time.time() + self.expires_in.seconds
-        self.token = self._encode(self.get_token())
+        access_token = self.get_token()
+        self.expires_at = access_token.expires_on
+        self.token = self._encode(access_token.token)

uamqp/authentication/cbs_auth_async.py

@@ -9,7 +9,6 @@
 import asyncio
 import datetime
 import logging
-import time
 
 from uamqp import c_uamqp, compat, constants, errors
 from uamqp.utils import get_running_loop
@@ -279,5 +278,6 @@ def __init__(self, audience, uri,
         self.set_io(self.hostname, port, http_proxy, transport_type)
 
     async def update_token(self):
-        self.expires_at = time.time() + self.expires_in.seconds
-        self.token = self._encode(await self.get_token())
+        access_token = await self.get_token()
+        self.expires_at = access_token.expires_on
+        self.token = self._encode(access_token.token)