if "ok" in status_text:
return f'ok'
elif "on1" in status_text:
return f'on1'
elif "on2" in status_text:
return f'on2'
else:
return f'Недоступен.'result = await check_text(text)
if result == 'ok':
logger.info(f'{text} - Доступен.')
elif result == 'on1':
logger.info(f'{text} - Занят.')
elif result == 'on2':
logger.info(f'{text} - Занят, под заказ.')
elif result == 'on3':
logger.info(f'{text} - Занят, в расрочку.')
else:
logger.info(f'Недоступен.')if result == 'ok':
if not is_already_recorded(text):
with open(get_free_filename(current_filename), 'a') as free_file:
free_file.write(text + '\n')
await send_notification(ADMIN_CHAT_ID, result)if await check_text(text):
result = await check_text(text)
if result.success:
logger.info('{result.text}: {result.status}')
else:
logger.info('{result.text}: {result.status}')
if result is not None:
if not is_already_recorded(text):
with open(get_free_filename(current_filename), 'a') as free_file:
free_file.write(text + '\n')
await send_notification(ADMIN_CHAT_ID, result)
delay = random.randint(100, 200)
await asyncio.sleep(delay)
except Exception as e:
logger.error(f'Ошибка при проверке {result.text}: {str(e)}')
if "502 Bad Gateway" in str(e):
logger.warning("Ошибка Bad Gateway. Слишком много запросов. Или сайт не доступен, возможно проблемы с интернетом или их сервером. Через 300 секунд, проверка продолжится.")
await asyncio.sleep(300)
result = await check_text(text)
if result:
logger.info(f'{result}') #показываем результат в консоле
else:
logger.info(f'{text}: {result}') #отправляем результат в бота
