mirror of
https://github.com/BEDOLAGA-DEV/remnawave-bedolaga-telegram-bot.git
synced 2026-03-03 00:31:24 +00:00
fix: suppress startup log noise (~350 lines → ~30)
- Suppress migration logger to WARNING during startup (main.py) - Remove debug logs from get_traffic_packages() leaking before structlog init - Downgrade handler registration logs to debug (start.py) - Remove duplicate section headers from migration orchestrator
This commit is contained in:
@@ -2141,14 +2141,9 @@ class Settings(BaseSettings):
|
||||
packages = []
|
||||
config_str = self.TRAFFIC_PACKAGES_CONFIG.strip()
|
||||
|
||||
logger.debug('CONFIG STRING', config_str=config_str)
|
||||
|
||||
if not config_str:
|
||||
logger.debug('CONFIG EMPTY, USING FALLBACK')
|
||||
return self._get_fallback_traffic_packages()
|
||||
|
||||
logger.debug('PARSING CONFIG...')
|
||||
|
||||
for package_config in config_str.split(','):
|
||||
package_config = package_config.strip()
|
||||
if not package_config:
|
||||
@@ -2167,11 +2162,10 @@ class Settings(BaseSettings):
|
||||
except ValueError:
|
||||
continue
|
||||
|
||||
logger.debug('PARSED packages from config', packages_count=len(packages))
|
||||
return packages if packages else self._get_fallback_traffic_packages()
|
||||
|
||||
except Exception as e:
|
||||
logger.info('ERROR PARSING CONFIG', error=e)
|
||||
logger.warning('ERROR PARSING CONFIG', error=e)
|
||||
return self._get_fallback_traffic_packages()
|
||||
|
||||
def is_version_check_enabled(self) -> bool:
|
||||
|
||||
@@ -6816,14 +6816,12 @@ async def run_universal_migration():
|
||||
else:
|
||||
logger.warning('⚠️ Не удалось обновить колонку last_pinned_message_id')
|
||||
|
||||
logger.info('=== ДОБАВЛЕНИЕ МЕДИА ПОЛЕЙ В BROADCAST_HISTORY ===')
|
||||
media_fields_added = await add_media_fields_to_broadcast_history()
|
||||
if media_fields_added:
|
||||
logger.info('✅ Медиа поля в broadcast_history готовы')
|
||||
else:
|
||||
logger.warning('⚠️ Проблемы с добавлением медиа полей')
|
||||
|
||||
logger.info('=== ДОБАВЛЕНИЕ EMAIL ПОЛЕЙ В BROADCAST_HISTORY ===')
|
||||
email_fields_added = await add_email_fields_to_broadcast_history()
|
||||
if email_fields_added:
|
||||
logger.info('✅ Email поля в broadcast_history готовы')
|
||||
@@ -6945,7 +6943,6 @@ async def run_universal_migration():
|
||||
except Exception as e:
|
||||
logger.warning('⚠️ Проблемы с созданием таблицы support_audit_logs', error=e)
|
||||
|
||||
logger.info('=== НАСТРОЙКА ПРОМО ГРУПП ===')
|
||||
promo_groups_ready = await ensure_promo_groups_setup()
|
||||
if promo_groups_ready:
|
||||
logger.info('✅ Промо группы готовы')
|
||||
|
||||
@@ -2150,47 +2150,47 @@ async def required_sub_channel_check(
|
||||
|
||||
|
||||
def register_handlers(dp: Dispatcher):
|
||||
logger.info('🔧 === НАЧАЛО регистрации обработчиков start.py ===')
|
||||
logger.debug('=== НАЧАЛО регистрации обработчиков start.py ===')
|
||||
|
||||
dp.message.register(cmd_start, Command('start'))
|
||||
logger.info('✅ Зарегистрирован cmd_start')
|
||||
logger.debug('Зарегистрирован cmd_start')
|
||||
|
||||
dp.callback_query.register(
|
||||
process_rules_accept,
|
||||
F.data.in_(['rules_accept', 'rules_decline']),
|
||||
StateFilter(RegistrationStates.waiting_for_rules_accept),
|
||||
)
|
||||
logger.info('✅ Зарегистрирован process_rules_accept')
|
||||
logger.debug('Зарегистрирован process_rules_accept')
|
||||
|
||||
dp.callback_query.register(
|
||||
process_privacy_policy_accept,
|
||||
F.data.in_(['privacy_policy_accept', 'privacy_policy_decline']),
|
||||
StateFilter(RegistrationStates.waiting_for_privacy_policy_accept),
|
||||
)
|
||||
logger.info('✅ Зарегистрирован process_privacy_policy_accept')
|
||||
logger.debug('Зарегистрирован process_privacy_policy_accept')
|
||||
|
||||
dp.callback_query.register(
|
||||
process_language_selection,
|
||||
F.data.startswith('language_select:'),
|
||||
StateFilter(RegistrationStates.waiting_for_language),
|
||||
)
|
||||
logger.info('✅ Зарегистрирован process_language_selection')
|
||||
logger.debug('Зарегистрирован process_language_selection')
|
||||
|
||||
dp.callback_query.register(
|
||||
process_referral_code_skip, F.data == 'referral_skip', StateFilter(RegistrationStates.waiting_for_referral_code)
|
||||
)
|
||||
logger.info('✅ Зарегистрирован process_referral_code_skip')
|
||||
logger.debug('Зарегистрирован process_referral_code_skip')
|
||||
|
||||
dp.message.register(process_referral_code_input, StateFilter(RegistrationStates.waiting_for_referral_code))
|
||||
logger.info('✅ Зарегистрирован process_referral_code_input')
|
||||
logger.debug('Зарегистрирован process_referral_code_input')
|
||||
|
||||
dp.message.register(
|
||||
handle_potential_referral_code,
|
||||
StateFilter(RegistrationStates.waiting_for_rules_accept, RegistrationStates.waiting_for_referral_code),
|
||||
)
|
||||
logger.info('✅ Зарегистрирован handle_potential_referral_code')
|
||||
logger.debug('Зарегистрирован handle_potential_referral_code')
|
||||
|
||||
dp.callback_query.register(required_sub_channel_check, F.data.in_(['sub_channel_check']))
|
||||
logger.info('✅ Зарегистрирован required_sub_channel_check')
|
||||
logger.debug('Зарегистрирован required_sub_channel_check')
|
||||
|
||||
logger.info('🔧 === КОНЕЦ регистрации обработчиков start.py ===')
|
||||
logger.debug('=== КОНЕЦ регистрации обработчиков start.py ===')
|
||||
|
||||
8
main.py
8
main.py
@@ -189,7 +189,13 @@ async def main():
|
||||
success_message='Миграция завершена успешно',
|
||||
) as stage:
|
||||
try:
|
||||
migration_success = await run_universal_migration()
|
||||
migration_log = logging.getLogger('app.database.universal_migration')
|
||||
original_level = migration_log.level
|
||||
migration_log.setLevel(logging.WARNING)
|
||||
try:
|
||||
migration_success = await run_universal_migration()
|
||||
finally:
|
||||
migration_log.setLevel(original_level)
|
||||
if migration_success:
|
||||
stage.success('Миграция завершена успешно')
|
||||
else:
|
||||
|
||||
Reference in New Issue
Block a user