From b8fbbd9efbf8ad102666c2695b68920125eb12c9 Mon Sep 17 00:00:00 2001
From: Fabian <ffabi1997@gmail.com>
Date: Tue, 31 Mar 2020 23:34:48 +0200
Subject: [PATCH] debug function should be called, not DEBUG

---
 app.py | 30 ++++++++++++++----------------
 1 file changed, 14 insertions(+), 16 deletions(-)

diff --git a/app.py b/app.py
index 47b7fc8..ce3a7ff 100644
--- a/app.py
+++ b/app.py
@@ -21,52 +21,50 @@ sentry_sdk.init("https://0a106e104e114bc9a3fa47f9cb0db2f4@sentry.kmlabz.com/10")
 
 
 def main():
-    logging.basicConfig(filename='', level=logging.DEBUG)
+    logging.basicConfig(filename = '', level = logging.DEBUG)
 
-    r = redis.Redis(host='localhost', port=6379, db=0)
+    r = redis.Redis(host = 'localhost', port = 6379, db = 0)
 
     ip_list = os.environ['INITIAL_SERVERS'].split(',')
-    logging.DEBUG('Get consumer list from environ at first: Done')
+    logging.debug('Get consumer list from environ at first: Done')
     consumer_list_redis = json.loads((r.get('consumer_list') or b'{}').decode('utf-8'))
-    logging.DEBUG('Get consumer list from redis at first: Done')
-    temp_dict = {}
+    logging.debug('Get consumer list from redis at first: Done')
+    temp_dict = { }
 
     for ip in ip_list:
 
         try:
-            response = requests.post(f"http://{ip}/sync", json={'uuid': os.environ['LOCAL_UUID']})
+            response = requests.post(f"http://{ip}/sync", json = { 'uuid': os.environ['LOCAL_UUID'] })
         except requests.exceptions.ConnectionError:
             continue
 
         if response.status_code == 200:
-            temp_dict[response.json()['uuid']] = {'ip': ip}
+            temp_dict[response.json()['uuid']] = { 'ip': ip }
 
     consumer_list_redis.update(temp_dict)
     r.set('consumer_list', json.dumps(consumer_list_redis).encode('utf-8'))
-    logging.DEBUG('Update redis consumers ip list from first answers: Done')
+    logging.debug('Update redis consumers ip list from first answers: Done')
     while True:
-        logging.DEBUG('Infinite Cycle start : Done')
+        logging.debug('Infinite Cycle start : Done')
         consumer_list_redis = json.loads((r.get('consumer_list') or b'{}').decode('utf-8'))
-        logging.DEBUG('Get consumer list from redis: Done')
+        logging.debug('Get consumer list from redis: Done')
         for uuid, info in consumer_list_redis.items():
             ip = info['ip']
             try:
-                response = requests.post(f"http://{ip}/sync", json={'uuid': os.environ['LOCAL_UUID']})
+                response = requests.post(f"http://{ip}/sync", json = { 'uuid': os.environ['LOCAL_UUID'] })
             except requests.exceptions.ConnectionError:
                 continue
 
             if response.status_code == 200:
-                temp_dict[response.json()['uuid']] = {'ip': ip}
+                temp_dict[response.json()['uuid']] = { 'ip': ip }
 
         consumer_list_redis.update(temp_dict)
         r.set('consumer_list', json.dumps(consumer_list_redis).encode('utf-8'))
-        logging.DEBUG('Update redis consumer ip list from answers: Done')
+        logging.debug('Update redis consumer ip list from answers: Done')
 
-        logging.DEBUG('Waiting for next turn')
+        logging.debug('Waiting for next turn')
         time.sleep(30)
 
-    LOG.ERROR('While get rekt')
-
 
 if __name__ == "__main__":
     try: