From cec3bcb5005f1e8b8f24265ddb8f0b2261887fa4 Mon Sep 17 00:00:00 2001
From: UdoChudo <stream@udochudo.ru>
Date: Mon, 23 Jun 2025 00:37:50 +0500
Subject: [PATCH] chore: (app structure) remove unused modules

Signed-off-by: UdoChudo <stream@udochudo.ru>
---
 app/services/notifications_service.py | 28 ---------
 app/services/rabbitmq_service.py      | 86 ---------------------------
 2 files changed, 114 deletions(-)
 delete mode 100644 app/services/notifications_service.py
 delete mode 100644 app/services/rabbitmq_service.py

diff --git a/app/services/notifications_service.py b/app/services/notifications_service.py
deleted file mode 100644
index 71171be..0000000
--- a/app/services/notifications_service.py
+++ /dev/null
@@ -1,28 +0,0 @@
-# from utilities.notification_manager import NotificationManager
-# from utilities.telegram_utilities import extract_region_number, format_message
-# from flask import current_app
-#
-#
-#
-# class NotificationService:
-#     def __init__(self):
-#         self.logger = current_app.logger
-#         self.manager = NotificationManager(self.logger)
-#
-#     def process_notification(self, data):
-#         self.logger.info(f"Получены данные уведомления: {data}")
-#
-#         region_id = extract_region_number(data.get("host"))
-#         if region_id is None:
-#             self.logger.error(f"Не удалось извлечь номер региона из host: {data.get('host')}")
-#             return {"status": "error", "message": "Invalid host format"}, 400
-#
-#         self.logger.debug(f"Извлечён номер региона: {region_id}")
-#
-#         subscribers = self.manager.get_subscribers(region_id, data['severity'])
-#
-#         if self.manager.is_region_active(region_id):
-#             message = format_message(data)
-#             self.manager.send_notifications(subscribers, message)
-#
-#         return {"status": "success"}, 200
diff --git a/app/services/rabbitmq_service.py b/app/services/rabbitmq_service.py
deleted file mode 100644
index 707f8b2..0000000
--- a/app/services/rabbitmq_service.py
+++ /dev/null
@@ -1,86 +0,0 @@
-import asyncio
-import json
-import logging
-from app import app, Users
-import aio_pika
-import pika
-
-from config import RABBITMQ_LOGIN, RABBITMQ_PASS, RABBITMQ_HOST, RABBITMQ_QUEUE, RABBITMQ_URL_FULL
-
-logger = logging.getLogger(__name__)
-
-rate_limit_semaphore = asyncio.Semaphore(25)
-
-def rabbitmq_connection():
-    credentials = pika.PlainCredentials(RABBITMQ_LOGIN, RABBITMQ_PASS)
-    parameters = pika.ConnectionParameters(
-        host=RABBITMQ_HOST,
-        credentials=credentials,
-        heartbeat=600,
-        blocked_connection_timeout=300
-    )
-    connection = pika.BlockingConnection(parameters)
-    channel = connection.channel()
-    channel.queue_declare(queue=RABBITMQ_QUEUE, durable=True)
-    return connection, channel
-
-def send_to_queue(message):
-    connection, channel = rabbitmq_connection()
-    channel.basic_publish(
-        exchange='',
-        routing_key=RABBITMQ_QUEUE,
-        body=json.dumps(message),
-        properties=pika.BasicProperties(
-            delivery_mode=2,
-        ))
-    connection.close()
-
-async def send_message(chat_id, message, backend_bot, is_notification=False):
-    telegram_id = "unknown"
-    try:
-        if is_notification:
-            await rate_limit_semaphore.acquire()
-
-        def get_user():
-            with app.app_context():
-                user = Users.query.get(chat_id)
-                return user.telegram_id if user else "unknown"
-
-        telegram_id = await asyncio.to_thread(get_user)
-
-        await asyncio.to_thread(backend_bot.bot.send_message, chat_id, message, parse_mode='HTML')
-
-        formatted_message = message.replace('\n', ' ').replace('\r', '')
-        logger.info(f'Send notification to {telegram_id} ({chat_id}) from RabbitMQ [{formatted_message}]')
-
-    except Exception as e:
-        logger.error(f"Error sending message to {telegram_id} ({chat_id}): {e}")
-    finally:
-        if is_notification:
-            rate_limit_semaphore.release()
-
-async def consume_from_queue(backend_bot):
-    while True:
-        try:
-            connection = await aio_pika.connect_robust(RABBITMQ_URL_FULL)
-            async with connection:
-                channel = await connection.channel()
-                queue = await channel.declare_queue(RABBITMQ_QUEUE, durable=True)
-
-                async for message in queue:
-                    async with message.process():
-                        try:
-                            data = json.loads(message.body.decode('utf-8'))
-                            chat_id = data["chat_id"]
-                            message_text = data["message"]
-                            await send_message(chat_id, message_text, backend_bot, is_notification=True)
-                        except (json.JSONDecodeError, KeyError) as e:
-                            logger.error(f"Error processing message: {e}")
-                        except Exception as e:
-                            logger.error(f"Error sending message: {e}")
-        except aio_pika.exceptions.AMQPError as e:
-            logger.error(f"RabbitMQ error: {e}")
-        except Exception as e:
-            logger.error(f"Critical error: {e}")
-        finally:
-            await asyncio.sleep(5)