Fixed issue #2

ChangeLog

@@ -1,7 +1,11 @@
+2016.10.22, Version 2.0.3 (BETA)
+
+    - Fixed handling authentication errors correctly. (issue #2)
+
 2016.10.21, Version 2.0.2 (BETA)
 
     - Added is_closed property to client.
-    - New and closed connections logging is set from info to debug
+    - New and closed connections logging is set from info to debug. (issue #1)
 
 2016.10.03, Version 2.0.1 (BETA)
 

setup.py

@@ -1,7 +1,7 @@
 from distutils.core import setup
 import setuptools
 
-VERSION = '2.0.2'
+VERSION = '2.0.3'
 
 setup(
     name='siridb-connector',

siridb/connector/__init__.py

@@ -8,7 +8,7 @@
 from .lib.client import SiriDBClient
 
 
-__version_info__ = (2, 0, 2)
+__version_info__ = (2, 0, 3)
 __version__ = '.'.join(map(str, __version_info__))
 __maintainer__ = 'Jeroen van der Heijden'
 __email__ = '[email protected]'
@@ -20,7 +20,6 @@
     'SiriDBProtocol',
 ]
 
-
 class SiriDBProtocol(_SiriDBProtocol):
 
     def on_connection_made(self):

siridb/connector/lib/client.py

@@ -169,13 +169,11 @@ def _log_connect_result(result):
         for r in result:
             if r:
                 logging.error(r)
-                if isinstance(r, (IndexError, AuthenticationError)):
-                    break
 
     async def connect(self, timeout=None):
         self._retry_connect = True
         result = await self._connect(timeout)
-        if result and set(result) - {None}:
+        if result and set(result) - {None} and self._connect_task is None:
             self._connect_task = asyncio.ensure_future(self._connect_loop())
         return result
 

siridb/connector/lib/protocol.py

@@ -85,8 +85,13 @@ def connection_made(self, transport):
         override asyncio.Protocol
         '''
         def finished(future):
-            if not future.exception():
+            exc = future.exception()
+            if not exc:
                 self.on_authenticated()
+            else:
+                logging.debug('Authentication failed: {}'.format(exc))
+                self.transport.close()
+
 
         self._connected = True
         self.transport = transport