mirror of
https://gitea.phreedom.club/localhost_frssoft/FMN_bot.git
synced 2024-11-26 04:51:28 +00:00
Compare commits
No commits in common. "e782cacf5a7b9b926b5deac1208dcd21fbc84ea2" and "f3ef0e45313601542ed2ab041cb0ce23665e85e9" have entirely different histories.
e782cacf5a
...
f3ef0e4531
|
@ -25,31 +25,25 @@ 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}...')
|
||||
r = requests.post(instance_point + f"/notifications/{id_notification}/dismiss", headers=headers)
|
||||
return r.json()
|
||||
|
||||
|
||||
def get_status_context(status_id):
|
||||
success = 0
|
||||
while success == 0:
|
||||
try:
|
||||
r = requests.get(instance_point + f"/statuses/{status_id}/context", headers=headers)
|
||||
r.raise_for_status()
|
||||
success = 1
|
||||
return r.json()
|
||||
except:
|
||||
logger.exception(f'Ошибка получения контекста треда {status_id}')
|
||||
r = requests.get(instance_point + f"/statuses/{status_id}/context", headers=headers)
|
||||
if r.status_code == 200:
|
||||
return r.json()
|
||||
else:
|
||||
http_code = r.status_code
|
||||
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):
|
||||
|
@ -75,16 +69,8 @@ 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)
|
||||
r = requests.post(instance_point + "/statuses", json=params, headers=headers)
|
||||
return r.json()
|
||||
|
||||
|
||||
def upload_attachment(file_path):
|
||||
|
@ -102,15 +88,9 @@ 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)
|
||||
r.raise_for_status()
|
||||
logger.info(f'Пользователь {acct} был заглушен на {duration} secs')
|
||||
success = 1
|
||||
except:
|
||||
logger.exception(f'Ошибка глушения {acct}')
|
||||
time.sleep(5)
|
||||
logger.info(f'Повторное глушение {acct}...')
|
||||
r = requests.post(instance_point + '/accounts' + f"/{acct_id}/mute", params, headers=headers)
|
||||
if r.status_code == 200:
|
||||
logger.info(f'Пользователь {acct} был заглушен на {duration} secs')
|
||||
else:
|
||||
logger.error(f'Ошибка глушения {r.status_code} - {acct}')
|
||||
|
||||
|
|
|
@ -62,23 +62,8 @@ def get_winner_movie(poll_status_id=str):
|
|||
create_tie_breaker()
|
||||
else:
|
||||
movie = winned_movies[0]
|
||||
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')])
|
||||
mark_as_watched_movie(movie[1], movie[2], movie[3])
|
||||
clear_all_states()
|
||||
reset_poll()
|
||||
|
||||
|
|
Loading…
Reference in a new issue