clean trash

Author: wiltort

src/api/admin.py

@@ -384,137 +384,3 @@ def _maybe_restart_bot(self, bot):
                 logger.info(f"Запланирован перезапуск бота {bot.name} после изменения обработчиков")
             except Exception as e:
                 logger.error(f"Ошибка планирования перезапуска бота {bot.id}: {e}")
-
-
-class BotControlViewSet(viewsets.ViewSet):
-    """
-    ViewSet для массового управления ботами
-    """
-    permission_classes = [permissions.IsAuthenticated]
-    
-    @action(detail=False, methods=['post'])
-    def bulk_start(self, request):
-        """
-        Массовый запуск ботов
-        POST /api/control/bulk_start/
-        """
-        serializer = BotControlSerializer(data=request.data)
-        
-        if not serializer.is_valid():
-            return Response(serializer.errors, status=status.HTTP_400_BAD_REQUEST)
-        
-        bot_ids = serializer.validated_data['bot_ids']
-        results = []
-        
-        for bot_id in bot_ids:
-            try:
-                bot = TelegramBot.objects.get(id=bot_id)
-                
-                if not bot.is_active:
-                    results.append({'bot_id': bot_id, 'status': 'skipped', 'reason': 'not_active'})
-                    continue
-                
-                if bot.is_running:
-                    results.append({'bot_id': bot_id, 'status': 'skipped', 'reason': 'already_running'})
-                    continue
-                
-                task_id = BotService.start_bot(bot_id)
-                results.append({'bot_id': bot_id, 'status': 'started', 'task_id': task_id})
-                
-            except TelegramBot.DoesNotExist:
-                results.append({'bot_id': bot_id, 'status': 'error', 'reason': 'not_found'})
-            except Exception as e:
-                results.append({'bot_id': bot_id, 'status': 'error', 'reason': str(e)})
-        
-        return Response({'results': results})
-    
-    @action(detail=False, methods=['post'])
-    def bulk_stop(self, request):
-        """
-        Массовая остановка ботов
-        POST /api/control/bulk_stop/
-        """
-        serializer = BotControlSerializer(data=request.data)
-        
-        if not serializer.is_valid():
-            return Response(serializer.errors, status=status.HTTP_400_BAD_REQUEST)
-        
-        bot_ids = serializer.validated_data['bot_ids']
-        results = []
-        
-        for bot_id in bot_ids:
-            try:
-                bot = TelegramBot.objects.get(id=bot_id)
-                
-                if not bot.is_running:
-                    results.append({'bot_id': bot_id, 'status': 'skipped', 'reason': 'not_running'})
-                    continue
-                
-                task_id = BotService.stop_bot(bot_id)
-                results.append({'bot_id': bot_id, 'status': 'stopped', 'task_id': task_id})
-                
-            except TelegramBot.DoesNotExist:
-                results.append({'bot_id': bot_id, 'status': 'error', 'reason': 'not_found'})
-            except Exception as e:
-                results.append({'bot_id': bot_id, 'status': 'error', 'reason': str(e)})
-        
-        return Response({'results': results})
-
-class HealthCheckViewSet(viewsets.ViewSet):
-    """
-    ViewSet для проверки здоровья системы
-    """
-    permission_classes = [permissions.AllowAny]
-    
-    @action(detail=False, methods=['get'])
-    def health(self, request):
-        """
-        Проверка здоровья приложения
-        GET /api/health/
-        """
-        from django.db import connection
-        from django.core.cache import cache
-        import redis
-        
-        checks = {
-            'database': False,
-            'cache': False,
-            'celery': False,
-            'overall': False
-        }
-        
-        # Проверка базы данных
-        try:
-            with connection.cursor() as cursor:
-                cursor.execute("SELECT 1")
-            checks['database'] = True
-        except Exception as e:
-            logger.error(f"Database health check failed: {e}")
-        
-        # Проверка кеша (Redis)
-        try:
-            cache.set('health_check', 'ok', 10)
-            checks['cache'] = cache.get('health_check') == 'ok'
-        except Exception as e:
-            logger.error(f"Cache health check failed: {e}")
-        
-        # Проверка Celery (опционально)
-        try:
-            # Простая проверка подключения к Redis
-            import redis
-            r = redis.Redis.from_url(settings.CELERY_BROKER_URL)
-            r.ping()
-            checks['celery'] = True
-        except Exception as e:
-            logger.error(f"Celery health check failed: {e}")
-        
-        # Общий статус
-        checks['overall'] = all([checks['database'], checks['cache']])
-        
-        status_code = status.HTTP_200_OK if checks['overall'] else status.HTTP_503_SERVICE_UNAVAILABLE
-        
-        return Response({
-            'status': 'healthy' if checks['overall'] else 'unhealthy',
-            'checks': checks,
-            'timestamp': timezone.now().isoformat()
-        }, status=status_code)