localhost_frssoft/FMN_bot
localhost_frssoft/FMN_bot
1
0
Fork 0
mirror of https://gitea.phreedom.club/localhost_frssoft/FMN_bot.git synced 2024-11-25 13:21:29 +00:00
Code Issues Projects Releases Wiki Activity

Added some exceptions handlers in fedi api

Browse source
This commit is contained in:
localhost_frssoft 2022-09-06 22:12:30 +03:00
parent f3ef0e4531
commit f142d5451f
1 changed files with 41 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

62
src/fedi_api.py
View file

@ -25,25 +25,31 @@ def get_notifications():
def mark_as_read_notification(id_notification):
r = requests.post(instance_point + f"/notifications/{id_notification}/dismiss", headers=headers)
return r.json()
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):
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:
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}')
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
r = requests.post(instance_point + "/statuses", json=params, headers=headers)
return r.json()
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
}
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}')
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}...')