REfactor cahnnel creation

Author: dapi

app/services/telegram/channel_service.rb

@@ -1,7 +1,7 @@
 # Сервис для работы с Telegram каналами
 module Telegram
   class ChannelService
-    def initialize(bot)
+    def initialize(bot = Telegram.bot)
       @bot = bot
     end
 
@@ -97,38 +97,28 @@ def get_channel_info(username)
       end
     end
 
-    # Добавляет канал в подписки пользователя
-    # @param user [TelegramUser] - пользователь
-    # @param channel_username [String] - username канала
-    # @return [Hash] - результат операции { success: true/false, message: String, channel: Channel }
-    def add_channel_for_user(user, channel_username)
+    # Добавляет или обновляет канал в базе данных по username
+    # @param channel_username [String] - username канала (может быть в разных форматах)
+    # @return [Hash] - результат операции { success: true/false, channel: Channel, message: String }
+    def add_channel_to_database(channel_username)
       # Парсим username
       username = parse_channel_username(channel_username)
 
       unless username
         return {
           success: false,
+          channel: nil,
           message: I18n.t('telegram_bot.channels.add.invalid_format')
         }
       end
 
-      # Проверяем лимит каналов для бесплатных пользователей
-      limit_checker = Limits::LimitChecker.new(user)
-      unless limit_checker.can_add_channel?
-        return {
-          success: false,
-          message: I18n.t('telegram_bot.channels.add.limit_reached',
-                         limit: ApplicationConfig.free_channels_limit,
-                         current: limit_checker.current_channels_count)
-        }
-      end
-
       # Получаем информацию о канале
       channel_info = get_channel_info(username)
 
       unless channel_info
         return {
           success: false,
+          channel: nil,
           message: I18n.t('telegram_bot.channels.add.not_found', channel: "@#{username}")
         }
       end
@@ -147,6 +137,7 @@ def add_channel_for_user(user, channel_username)
         unless channel.save
           return {
             success: false,
+            channel: nil,
             message: I18n.t('telegram_bot.channels.add.error', error: channel.errors.full_messages.join(', '))
           }
         end
@@ -159,6 +150,70 @@ def add_channel_for_user(user, channel_username)
         )
       end
 
+      {
+        success: true,
+        channel: channel,
+        message: nil
+      }
+    rescue StandardError => e
+      Bugsnag.notify(e) { |b| b.metadata = { channel_username: channel_username, action: 'add_channel_to_database' } }
+
+      ErrorNotificationService.notify_service_error(e,
+        service: self.class,
+        method: 'add_channel_to_database',
+        metadata: {
+          channel_username: channel_username,
+          error_class: e.class.name,
+          error_message: e.message
+        }
+      )
+      Rails.logger.error "Error adding channel to database: #{e.message}"
+
+      {
+        success: false,
+        channel: nil,
+        message: I18n.t('telegram_bot.channels.add.error', error: e.message)
+      }
+    end
+
+    # Добавляет канал в подписки пользователя
+    # @param user [TelegramUser] - пользователь
+    # @param channel_username [String] - username канала
+    # @return [Hash] - результат операции { success: true/false, message: String, channel: Channel }
+    def add_channel_for_user(user, channel_username)
+      # Парсим username
+      username = parse_channel_username(channel_username)
+
+      unless username
+        return {
+          success: false,
+          message: I18n.t('telegram_bot.channels.add.invalid_format')
+        }
+      end
+
+      # Проверяем лимит каналов для бесплатных пользователей
+      limit_checker = Limits::LimitChecker.new(user)
+      unless limit_checker.can_add_channel?
+        return {
+          success: false,
+          message: I18n.t('telegram_bot.channels.add.limit_reached',
+                         limit: ApplicationConfig.free_channels_limit,
+                         current: limit_checker.current_channels_count)
+        }
+      end
+
+      # Добавляем или обновляем канал в базе данных
+      channel_result = add_channel_to_database(channel_username)
+
+      unless channel_result[:success]
+        return {
+          success: false,
+          message: channel_result[:message]
+        }
+      end
+
+      channel = channel_result[:channel]
+
       # Проверяем, не подписан ли уже пользователь
       subscription = user.subscriptions.find_by(channel: channel)
 

db/seeds.rb

@@ -7,3 +7,5 @@
 #   ["Action", "Comedy", "Drama", "Horror"].each do |genre_name|
 #     MovieGenre.find_or_create_by!(name: genre_name)
 #   end
+
+Telegram::ChannelService.new.add_channel_to_database '@problemhunt'

docs/Implementation/Refactoring_ChannelService_Method_Extraction.md

@@ -0,0 +1,94 @@
+# Рефакторинг ChannelService: Выделение метода add_channel_to_database
+
+## Обзор
+
+Был выполнен рефакторинг сервиса `Telegram::ChannelService` с целью выделения логики добавления канала в базу данных в отдельный метод `add_channel_to_database`.
+
+## Цели рефакторинга
+
+1. **Single Responsibility Principle**: Разделение ответственности между методами
+2. **Reusability**: Создание метода, который можно использовать в других частях приложения
+3. **Testability**: Упрощение тестирования отдельных компонентов
+4. **Maintainability**: Улучшение читаемости и поддержки кода
+
+## Изменения
+
+### 1. Новый метод `add_channel_to_database`
+
+**Локация**: `app/services/telegram/channel_service.rb:103-177`
+
+**Сигнатура**:
+```ruby
+def add_channel_to_database(channel_username)
+```
+
+**Ответственность**:
+- Парсинг username канала
+- Получение информации о канале через Telegram API
+- Создание или обновление канала в базе данных
+- Обработка ошибок базы данных
+
+**Возвращаемое значение**:
+```ruby
+{
+  success: true/false,
+  channel: Channel/nil,
+  message: String/nil
+}
+```
+
+### 2. Обновленный метод `add_channel_for_user`
+
+**Изменения**:
+- Удалена логика работы с базой данных
+- Добавлен вызов нового метода `add_channel_to_database`
+- Упрощена структура метода
+- Сохранена логика работы с подписками
+
+### 3. Тесты
+
+**Локация**: `test/services/telegram/channel_service_test.rb:222-249`
+
+Добавлен тест `test_add_channel_to_database_creates_new_channel_with_username` который проверяет:
+- Успешное создание нового канала
+- Корректность сохраненных данных
+- Правильную работу с моками Telegram API
+
+## Архитектурные преимущества
+
+### 1. Разделение ответственности
+- `add_channel_to_database` - работа с данными канала
+- `add_channel_for_user` - бизнес-логика подписок
+
+### 2. Возможность переиспользования
+Метод `add_channel_to_database` может быть использован в:
+- Административных функциях
+- Фоновых задачах обновления каналов
+- API endpoints для массового добавления каналов
+
+### 3. Улучшенная обработка ошибок
+- Каждая операция имеет свою собственную обработку ошибок
+- Более детальное логирование ошибок
+- Консистентные сообщения об ошибках
+
+## Потенциальные улучшения
+
+1. **Валидация на уровне сервиса**: Можно добавить дополнительную валидацию перед созданием канала
+2. **Кеширование информации о каналах**: Для уменьшения количества запросов к Telegram API
+3. **Батчная обработка**: Возможность добавления нескольких каналов за раз
+
+## Backward Compatibility
+
+Рефакторинг полностью сохраняет обратную совместимость. Публичный интерфейс сервиса `add_channel_for_user` остался без изменений.
+
+## Тестирование
+
+Все существующие тесты продолжают проходить. Новый тест покрывает основной сценарий использования метода `add_channel_to_database`.
+
+```
+21 runs, 70 assertions, 0 failures, 0 errors, 0 skips
+```
+
+## Заключение
+
+Рефакторинг успешно завершен. Код стал более модульным, тестируемым и соответствующим принципам SOLID. Новый метод можно безопасно использовать в других частях приложения.

test/services/telegram/channel_service_test.rb

@@ -216,4 +216,35 @@ class Telegram::ChannelServiceTest < ActiveSupport::TestCase
       end
     end
   end
+
+  # Тесты add_channel_to_database
+
+  test 'add_channel_to_database creates new channel with username' do
+    # Мокаем get_channel_info чтобы возвращать тестовые данные
+    mock_channel_info = {
+      id: 12345,
+      username: 'testchannel',
+      title: 'Test Channel',
+      description: 'Test Description',
+      member_count: 1000
+    }
+
+    @service.stubs(:get_channel_info).returns(mock_channel_info)
+
+    result = @service.add_channel_to_database('@testchannel')
+
+    assert result[:success]
+    assert_not_nil result[:channel]
+    assert_nil result[:message]
+
+    channel = result[:channel]
+    assert_equal 12345, channel.telegram_id
+    assert_equal 'testchannel', channel.username
+    assert_equal 'Test Channel', channel.title
+    assert_equal 'Test Description', channel.description
+    assert_equal 1000, channel.subscribers_count
+
+    # Возвращаем оригинальный метод
+    @service.unstub(:get_channel_info)
+  end
 end