Added winned movie post after poll ends

src/fedi_api.py

@@ -25,25 +25,31 @@ def get_notifications():
 
 
 def mark_as_read_notification(id_notification):
+    success = 0
+    while success == 0:
+        try:
             r = requests.post(instance_point + f"/notifications/{id_notification}/dismiss", headers=headers)
+            r.raise_for_status()
+            success = 1
             return r.json()
+        except:
+            logger.exception(f'Error read notification {id_notification}')
+            time.sleep(30)
+            logger.info('Retrying read notification {id_notification}...')
 
 
 def get_status_context(status_id):
+    success = 0
+    while success == 0:
+        try:
             r = requests.get(instance_point + f"/statuses/{status_id}/context", headers=headers)
-    if r.status_code == 200:
+            r.raise_for_status()
+            success = 1
             return r.json()
-    else:
+        except:
-        http_code = r.status_code
+            logger.exception(f'Ошибка получения контекста треда {status_id}')
-        logger.error(f'Ошибка получения контекста треда {status_id}: {http_code}')
-        logger.error(str(r.headers))
-        while r.status_code != 200:
             time.sleep(30)
             logger.info('Повторный запрос треда...')
-            r = requests.get(instance_point + f"/statuses/{status_id}/context", headers=headers)
-        return r.json()
-
-        
         
 
 def get_status(status_id):
@@ -69,8 +75,16 @@ def post_status(text, reply_to_status_id=None, poll_options=None, poll_expires=3
     }
     if attachments:
         params['media_ids'] = attachments
+    success = 0
+    while success == 0:
+        try:
             r = requests.post(instance_point + "/statuses", json=params, headers=headers)
+            r.raise_for_status()
+            success = 1
             return r.json()
+        except:
+            logger.exception('Error send status, retrying...')
+            time.sleep(5)
 
 
 def upload_attachment(file_path):
@@ -88,9 +102,15 @@ def mute_user(acct_id=str, acct=str, duration=None):
     params = {
         "duration": duration
     }
+    success = 0
+    while success == 0:
+        try:
             r = requests.post(instance_point + '/accounts' + f"/{acct_id}/mute", params, headers=headers)
-    if r.status_code == 200:
+            r.raise_for_status() 
             logger.info(f'Пользователь {acct} был заглушен на {duration} secs')
-    else:
+            success = 1
-        logger.error(f'Ошибка глушения {r.status_code} - {acct}')
+        except:
+            logger.exception(f'Ошибка глушения {acct}')
+            time.sleep(5)
+            logger.info(f'Повторное глушение {acct}...')
 

src/fmn_poll.py

@@ -62,8 +62,23 @@ def get_winner_movie(poll_status_id=str):
             create_tie_breaker()
     else:
         movie = winned_movies[0]
-        logger.warning("Победил " + str(movie))
         mark_as_watched_movie(movie[1], movie[2], movie[3])
+
+        acct_suggested = movie[0]
+        orig_name = movie[1]
+        ru_name = movie[2]
+        year = movie[3]
+        win_variant = f"{orig_name} / {ru_name}, {year}"
+        if ru_name is None:
+            win_variant = f"{orig_name}, {year}"
+        if orig_name is None:
+            win_variant = f"{ru_name}, {year}"
+        text_winned = f'''Голосование завершилось! Победил вариант предложенный @{acct_suggested}:
+        {win_variant}
+        '''.replace('\t', '') 
+
+        logger.warning("Победил " + str(movie))
+        post_status(text_winned, attachments=[upload_attachment('src/FMN.png')])
         clear_all_states()
         reset_poll()