Merge pull request #196 from shlomikushchi/rc4_better_exception

Not all errors are authentication errors.

Author: Shlomi Kushchi

alpaca_trade_api/stream2.py

@@ -39,11 +39,18 @@ async def _connect(self):
             r = r.decode('utf-8')
         msg = json.loads(r)
 
-        if msg.get('data', {}).get('status') != 'authorized':
-            raise ValueError(
-                ("Invalid Alpaca API credentials, Failed to authenticate: {}"
-                    .format(msg))
-            )
+        if msg.get('data', {}).get('status'):
+            status = msg.get('data').get('status')
+            if status != 'authorized':
+                raise ValueError(
+                    (f"Invalid Alpaca API credentials, Failed to "
+                     f"authenticate: {msg}")
+                )
+            else:
+                self._retries = 0
+        elif msg.get('data', {}).get('error'):
+            raise Exception(f"Error while connecting to {self._endpoint}:"
+                            f"{msg.get('data').get('error')}")
         else:
             self._retries = 0