Raise Authentication exceptions

ChangeLog

@@ -1,3 +1,7 @@
+2017.03.09, Version 2.0.5 (BETA)
+
+    - Raise Authentication Errors on connect.
+
 2017.02.27, Version 2.0.4 (BETA)
 
     - Check for correct types using assert in query method.

setup.py

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

siridb/connector/__init__.py

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

siridb/connector/lib/connection.py

@@ -9,17 +9,18 @@
 from .protomap import CPROTO_REQ_PING
 from .protomap import FILE_MAP
 
+
 class SiriDBConnection():
 
     def __init__(self,
-                username,
-                password,
-                dbname,
-                host='127.0.0.1',
-                port=DEFAULT_CLIENT_PORT,
-                loop=None,
-                timeout=10,
-                protocol=_SiriDBProtocol):
+                 username,
+                 password,
+                 dbname,
+                 host='127.0.0.1',
+                 port=DEFAULT_CLIENT_PORT,
+                 loop=None,
+                 timeout=10,
+                 protocol=_SiriDBProtocol):
         self._loop = loop or asyncio.get_event_loop()
         client = self._loop.create_connection(
             lambda: protocol(username, password, dbname),
@@ -35,6 +36,7 @@ async def _wait_for_auth(self):
         except Exception as exc:
             logging.debug('Authentication failed: {}'.format(exc))
             self._transport.close()
+            raise exc
         else:
             self._protocol.on_authenticated()
 
@@ -133,6 +135,7 @@ async def connect(self,
         except Exception as exc:
             logging.debug('Authentication failed: {}'.format(exc))
             _transport.close()
+            raise exc
         else:
             self._protocol.on_authenticated()