Merge branch 'master' into add-swimlane

automon/integrations/cryptocurrency/robinhood.py

@@ -65,3 +65,14 @@ def __eq__(self, other):
                 return True
             logger.debug(f'different {other}')
         return False
+
+
+class RobinhoodAPI(object):
+    summary = 'https://status.robinhood.com/api/v2/summary.json'
+    status = 'https://status.robinhood.com/api/v2/status.json'
+    components = 'https://status.robinhood.com/api/v2/components.json'
+    incidents_unresolved = 'https://status.robinhood.com/api/v2/incidents/unresolved.json'
+    incidents_all = 'https://status.robinhood.com/api/v2/incidents.json'
+    scheduled_maintenance_upcoming = 'https://status.robinhood.com/api/v2/scheduled-maintenances/upcoming.json'
+    scheduled_maintenance_active = 'https://status.robinhood.com/api/v2/scheduled-maintenances/active.json'
+    scheduled_maintenance_all = 'https://status.robinhood.com/api/v2/scheduled-maintenances.json'

automon/integrations/requestsWrapper/config.py

@@ -11,8 +11,9 @@ class RequestsConfig(object):
     def __init__(self):
         pass
 
-    def is_ready(self):
+    def __repr__(self):
         return f'{NotImplemented}'
 
-    def __repr__(self):
+    @property
+    def is_ready(self):
         return f'{NotImplemented}'

automon/integrations/requestsWrapper/rest.py

@@ -20,17 +20,17 @@ def isConnected(self):
             return True
         return False
 
-    def get(self, url: str, data: str = None, headers: dict = None) -> bool:
-        return self.requests.get(url=url, data=data, headers=headers)
+    async def get(self, url: str, data: str = None, headers: dict = None) -> bool:
+        return await self.requests.get(url=url, data=data, headers=headers)
 
-    def post(self, url: str, data: str = None, headers: dict = None) -> bool:
-        return self.requests.post(url=url, data=data, headers=headers)
+    async def post(self, url: str, data: str = None, headers: dict = None) -> bool:
+        return await self.requests.post(url=url, data=data, headers=headers)
 
-    def delete(self, url: str, data: str = None, headers: dict = None) -> bool:
-        return self.requests.delete(url=url, data=data, headers=headers)
+    async def delete(self, url: str, data: str = None, headers: dict = None) -> bool:
+        return await self.requests.delete(url=url, data=data, headers=headers)
 
-    def patch(self, url: str, data: str = None, headers: dict = None) -> bool:
-        return self.requests.patch(url=url, data=data, headers=headers)
+    async def patch(self, url: str, data: str = None, headers: dict = None) -> bool:
+        return await self.requests.patch(url=url, data=data, headers=headers)
 
     def __repr__(self):
         return f'{self.__dict__}'

automon/integrations/requestsWrapper/tests/test_requests.py

@@ -1,3 +1,4 @@
+import asyncio
 import unittest
 
 from automon.integrations.requestsWrapper import RequestsClient
@@ -8,9 +9,9 @@
 
 class Client(unittest.TestCase):
     def test_get(self):
-        r.get('https://1.1.1.1')
-        r.requests.get('https://1.1.1.1')
-        self.assertFalse(r.get('x://127.0.0.1'))
+        self.assertTrue(asyncio.run(r.get('https://1.1.1.1')))
+        self.assertTrue(r.requests.get('https://1.1.1.1'))
+        self.assertFalse(asyncio.run(r.get('x://127.0.0.1')))
 
 
 class Config(unittest.TestCase):

automon/integrations/requestsWrapper/tests/test_rest.py

@@ -1,3 +1,4 @@
+import asyncio
 import unittest
 
 from automon.integrations.requestsWrapper.rest import BaseRestClient
@@ -7,9 +8,9 @@
 
 class Client(unittest.TestCase):
     def test_get(self):
-        r.get('https://1.1.1.1')
-        r.requests.get('https://1.1.1.1')
-        self.assertFalse(r.get('x://127.0.0.1'))
+        self.assertTrue(asyncio.run(r.get('https://1.1.1.1')))
+        self.assertTrue(r.requests.get('https://1.1.1.1'))
+        self.assertFalse(asyncio.run(r.get('x://127.0.0.1')))
 
 
 if __name__ == '__main__':

automon/integrations/requestsWrapper/tests/test_rest_inherit.py

@@ -1,3 +1,4 @@
+import asyncio
 import unittest
 
 from automon.integrations.requestsWrapper.rest import BaseRestClient
@@ -12,7 +13,7 @@ def __init__(self):
 
 class Client(unittest.TestCase):
     def test_get(self):
-        Test().get(url='https://1.1.1.1')
+        self.assertTrue(asyncio.run(Test().get(url='https://1.1.1.1')))
 
 
 if __name__ == '__main__':