|
17 | 17 |
|
18 | 18 | from src.core.configs import BUTTON_HEIGHT, WIDTH_WIDE_BUTTON, api_id, api_hash |
19 | 19 | from src.core.database.account import ( |
20 | | - getting_account, write_account_to_db, delete_account_from_db, update_phone_by_session, Account |
| 20 | + getting_account, write_account_to_db, delete_account_from_db, update_phone_by_session, Account, |
| 21 | + delete_invalid_accounts_from_database |
21 | 22 | ) |
22 | 23 | from src.core.utils import Utils |
23 | 24 | from src.features.proxy.checking_proxy import Proxy |
@@ -388,29 +389,12 @@ async def account_connection_menu(self): |
388 | 389 | max_lines=1 |
389 | 390 | ) |
390 | 391 |
|
391 | | - async def delete_invalid_accounts_from_database(): |
| 392 | + async def delete_invalid_accounts_from_databases(): |
392 | 393 | """ |
393 | | - Очистка базы данных от аккаунтов, которые были занесены в базу данных. Перед удалением, аккаунты сохраняются в файл. |
394 | | - :return: None |
| 394 | + Очистка базы данных с аккаунтами |
| 395 | + :return: |
395 | 396 | """ |
396 | | - accounts = [] |
397 | | - for record in Account.select(Account.session_string, Account.phone_number): |
398 | | - accounts.append(f"{record.session_string};{record.phone_number}") |
399 | | - |
400 | | - logger.info(f"Сохраняем аккаунты в файл: {accounts}") |
401 | | - |
402 | | - # Дозаписываем данные в txt файл (режим 'a') |
403 | | - with open('user_data/accounts.txt', 'a', encoding='utf-8') as f: |
404 | | - for account in accounts: |
405 | | - f.write(account + '\n') |
406 | | - |
407 | | - # Очищаем базу данных |
408 | | - query = Account.delete() |
409 | | - query.execute() |
410 | | - |
411 | | - await self.gui_program.show_notification( # ✅ Показываем уведомление пользователю |
412 | | - message="✅ Все аккаунты сохранены в user_data/accounts.txt и удалены из базы данных." |
413 | | - ) |
| 397 | + await delete_invalid_accounts_from_database(self.gui_program) |
414 | 398 |
|
415 | 399 | async def connecting_number_accounts(_) -> None: |
416 | 400 | """Подключение аккаунта Telegram по номеру телефона""" |
@@ -638,7 +622,7 @@ async def handle_get_directory_path(e: ft.Event[ft.Button]): |
638 | 622 | content="Очистить базу данных", |
639 | 623 | width=WIDTH_WIDE_BUTTON, |
640 | 624 | height=BUTTON_HEIGHT, |
641 | | - on_click=delete_invalid_accounts_from_database |
| 625 | + on_click=delete_invalid_accounts_from_databases |
642 | 626 | ), |
643 | 627 | await self.gui_program.diver_castom(), # Горизонтальная линия |
644 | 628 | # "Подключение аккаунта Telegram по номеру телефона.", |
|
0 commit comments