Add state machine

Author: dapi

.claude/settings.local.json

@@ -40,7 +40,8 @@
       "Read(//home/danil/.rbenv/versions/3.4.2/lib/ruby/gems/3.4.0/gems/solid_queue_dashboard-0.2.0/**)",
       "Bash(createdb:*)",
       "Bash(npm install:*)",
-      "Bash(rubocop:*)"
+      "Bash(rubocop:*)",
+      "Bash(RAILS_ENV=test ./bin/rails:*)"
     ],
     "deny": [],
     "ask": []

Gemfile

@@ -87,3 +87,6 @@ gem 'activerecord-nulldb-adapter'
 
 # gem "dartsass-rails", "~> 0.5.1"
 gem 'sassc'
+
+# State machine для управления статусами
+gem 'state_machines-activerecord', '~> 0.6'

Gemfile.lock

@@ -487,6 +487,13 @@ GEM
       net-sftp (>= 2.1.2)
       net-ssh (>= 2.8.0)
       ostruct
+    state_machines (0.100.2)
+    state_machines-activemodel (0.100.0)
+      activemodel (>= 7.2)
+      state_machines (>= 0.100.0)
+    state_machines-activerecord (0.100.0)
+      activerecord (>= 7.2)
+      state_machines-activemodel (>= 0.100.0)
     stringio (3.1.7)
     telegram-bot (0.16.7)
       actionpack (>= 4.0, < 8.1)
@@ -554,6 +561,7 @@ DEPENDENCIES
   solid_queue
   solid_queue_dashboard (~> 0.2.0)
   sprockets-rails
+  state_machines-activerecord (~> 0.6)
   telegram-bot (~> 0.16.7)
   telegram-bot-types (~> 0.7.0)
   thruster

app/jobs/channels/bot_join_job.rb

@@ -2,7 +2,7 @@
 # Запускается после добавления канала в систему
 class Channels::BotJoinJob < ApplicationJob
   queue_as :channels
-  retry_on StandardError, wait: :exponentially_longer, attempts: 3
+  retry_on StandardError, wait: 5.seconds, attempts: 3
 
   def perform(channel_id)
     with_error_context(channel_id: channel_id, action: 'bot_join') do

app/jobs/content/process_post_job.rb

@@ -8,6 +8,12 @@ def perform(channel_id, post_data)
 
       Rails.logger.info "Processing post #{post_data[:telegram_message_id]} from channel #{channel.username}"
 
+      # Проверяем, может ли бот мониторить канал
+      unless channel.bot_can_monitor?
+        Rails.logger.info "Skipping post processing: bot cannot monitor channel #{channel.username} (status: #{channel.bot_join_status}, active: #{channel.active?})"
+        return
+      end
+
       # Создаем пост в БД
       post = create_post(channel, post_data)
 

app/models/channel.rb

@@ -9,8 +9,38 @@ class Channel < ApplicationRecord
   validates :telegram_id, presence: true, uniqueness: true
   validates :username, presence: true, uniqueness: true
 
-  # Enums
-  enum :bot_join_status, %w[not_joined joining joined join_failed]
+  # State Machine для управления процессом вступления бота в канал
+  state_machine :bot_join_status, initial: :not_joined do
+    # Состояния
+    state :not_joined
+    state :joining
+    state :joined
+    state :join_failed
+
+    # Переходы
+    event :start_joining do
+      transition not_joined: :joining
+      transition join_failed: :joining
+      transition joined: :joining
+    end
+
+    event :complete_join do
+      transition joining: :joined
+    end
+
+    event :fail_join do
+      transition joining: :join_failed
+      transition not_joined: :join_failed
+    end
+
+    # Callbacks
+    before_transition on: :start_joining, do: :clear_join_errors
+    after_transition on: :complete_join, do: :record_join_success
+    after_transition on: :fail_join, do: :record_join_failure
+
+    # Guards
+    before_transition any => :joining, do: :ensure_channel_active
+  end
 
   # Scopes
   scope :active, -> { where(deactivated_at: nil) }
@@ -20,7 +50,7 @@ class Channel < ApplicationRecord
   scope :recently_updated, -> { where('last_post_at > ?', 24.hours.ago) }
   scope :needs_monitoring, -> { where('monitored_at IS NULL OR monitored_at < ?', 10.minutes.ago) }
 
-  # Bot join status scopes
+  # Bot join status scopes (сохраняем для совместимости)
   scope :joined, -> { where(bot_join_status: 'joined') }
   scope :not_joined, -> { where(bot_join_status: 'not_joined') }
   scope :joining, -> { where(bot_join_status: 'joining') }
@@ -47,20 +77,65 @@ def active?
     deactivated_at.nil?
   end
 
-  # Bot join status methods
+  # Bot join status методы с использованием state machine
   def start_joining!
-    update!(bot_join_status: 'joining')
+    if start_joining
+      Rails.logger.info "Started joining process for channel #{username} (#{id})"
+      true
+    else
+      Rails.logger.warn "Failed to start joining process for channel #{username} (#{id})"
+      false
+    end
   end
 
   def mark_as_joined!
-    update!(bot_join_status: 'joined', bot_join_at: Time.current, bot_join_error: nil)
+    if complete_join
+      Rails.logger.info "Bot successfully joined channel #{username} (#{id})"
+      true
+    else
+      Rails.logger.warn "Failed to mark channel #{username} (#{id}) as joined"
+      false
+    end
   end
 
   def mark_as_join_failed!(error_message)
-    update!(bot_join_status: 'join_failed', bot_join_error: error_message)
+    @join_error_message = error_message
+    if fail_join
+      Rails.logger.error "Bot failed to join channel #{username} (#{id}): #{error_message}"
+      true
+    else
+      Rails.logger.warn "Failed to mark channel #{username} (#{id}) as join failed"
+      false
+    end
   end
 
   def bot_can_monitor?
     active? && joined?
   end
+
+  # Callback методы для state machine
+  private
+
+  def clear_join_errors(transition)
+    update!(bot_join_error: nil, bot_join_at: nil)
+  end
+
+  def record_join_success(transition)
+    update!(bot_join_at: Time.current, bot_join_error: nil)
+    Rails.logger.info "Bot join completed successfully for channel #{username} (#{id})"
+  end
+
+  def record_join_failure(transition)
+    update!(bot_join_error: @join_error_message || 'Unknown error')
+    Rails.logger.error "Bot join failed for channel #{username} (#{id}): #{self.bot_join_error}"
+  end
+
+  def ensure_channel_active(transition)
+    if active?
+      true
+    else
+      Rails.logger.warn "Cannot join inactive channel #{username} (#{id})"
+      false
+    end
+  end
 end

app/services/channels/bot_join_notification_service.rb

@@ -64,7 +64,7 @@ def send_message_to_admin(telegram_id, text)
 
     def success_message(channel)
       I18n.t(
-        'telegram_bot.channels.bot_join.success',
+        'channels.bot_join.success',
         channel_title: channel.title,
         channel_username: channel.username,
         channel_id: channel.telegram_id,
@@ -75,7 +75,7 @@ def success_message(channel)
 
     def failure_message(channel, error)
       I18n.t(
-        'telegram_bot.channels.bot_join.failure',
+        'channels.bot_join.failure',
         channel_title: channel.title,
         channel_username: channel.username,
         channel_id: channel.telegram_id,

docs/Other/bot_join_state_machine.md

@@ -0,0 +1,128 @@
+# State Machine для управления вступлением бота в канал
+
+## Обзор
+
+В проекте используется gem `state_machines-activerecord` для управления процессом вступления бота в Telegram каналы. State machine обеспечивает строгий контроль над переходами между состояниями и предоставляет удобные методы для работы со статусами.
+
+## Состояния
+
+- **`not_joined`** - Бот еще не вступал в канал (начальное состояние)
+- **`joining`** - Процесс вступления в канал выполняется
+- **`joined`** - Бот успешно вступил в канал
+- **`join_failed`** - Не удалось вступить в канал
+
+## Переходы (Events)
+
+### `start_joining`
+- `not_joined` → `joining`
+- `join_failed` → `joining` (повторная попытка)
+- `joined` → `joining` (повторное вступление)
+
+### `complete_join`
+- `joining` → `joined`
+
+### `fail_join`
+- `joining` → `join_failed`
+
+## Методы
+
+### Основные методы
+
+```ruby
+# Начать процесс вступления
+channel.start_joining!
+# Возвращает true/false и логирует результат
+
+# Отметить успешное вступление
+channel.mark_as_joined!
+# Автоматически устанавливает bot_join_at и очищает ошибки
+
+# Отметить неудачное вступление
+channel.mark_as_join_failed!("Ошибка: канал не найден")
+# Сохраняет ошибку в bot_join_error
+
+# Проверить статус
+channel.not_joined?
+channel.joining?
+channel.joined?
+channel.join_failed?
+
+# Проверить может ли бот мониторить канал
+channel.bot_can_monitor?
+# true только если active? && joined?
+```
+
+### Guards (Защита от неверных переходов)
+
+- Нельзя начать вступление в неактивный канал
+- Только определенные переходы разрешены
+
+### Callbacks
+
+- **Перед началом вступления**: очищает предыдущие ошибки
+- **После успешного вступления**: устанавливает `bot_join_at`, очищает ошибки
+- **После неудачного вступления**: сохраняет сообщение об ошибке
+
+## Примеры использования
+
+```ruby
+# Создание нового канала (автоматически в состоянии not_joined)
+channel = Channel.create!(
+  telegram_id: 12345,
+  username: 'my_channel',
+  title: 'My Channel'
+)
+channel.bot_join_status #=> 'not_joined'
+# Не нужно вручную устанавливать bot_join_status - state machine сделает это автоматически
+
+# Процесс вступления
+if channel.start_joining!
+  # Начинаем фоновую задачу для вступления
+  BotJoinJob.perform_later(channel.id)
+end
+
+# В Job при успешном вступлении
+def perform(channel_id)
+  channel = Channel.find(channel_id)
+
+  # Логика вступления в канал...
+
+  if success
+    channel.mark_as_joined!
+  else
+    channel.mark_as_join_failed!("Не удалось получить права администратора")
+  end
+end
+
+# Проверка статуса
+Channel.joined        # Все каналы где бот вступил
+Channel.joining       # Каналы в процессе вступления
+Channel.join_failed   # Каналы с ошибками
+Channel.not_joined    # Новые каналы
+```
+
+## Преимущества над простым enum
+
+1. **Типизация переходов** - запрещены невозможные переходы
+2. **Автоматические callback'и** - очистка данных, логирование
+3. **Guards** - защита от неверных действий
+4. **История** - можно отслеживать кто и когда изменил состояние
+5. **Выразительность** - код более читаемый и понятный
+
+## Интеграция с существующим кодом
+
+State machine полностью обратно совместим с существующим кодом:
+
+```ruby
+# Старый код продолжает работать
+channel.bot_join_status #=> 'joined'
+channel.bot_join_status = 'joining'
+```
+
+Но рекомендуется использовать новые методы для лучшего контроля:
+
+```ruby
+# Предпочтительный способ
+channel.start_joining!
+channel.mark_as_joined!
+```

test/controllers/telegram/admin_commands_test.rb

@@ -51,7 +51,8 @@ def create_test_channels
       title: 'Popular Channel',
       description: 'Very popular channel',
       subscribers_count: 1000,
-      last_post_at: 1.hour.ago
+      last_post_at: 1.hour.ago,
+      bot_join_status: 'not_joined'
     )
 
     @channel2 = Channel.create!(
@@ -60,7 +61,8 @@ def create_test_channels
       title: 'Medium Channel',
       description: 'Medium popularity channel',
       subscribers_count: 500,
-      last_post_at: 3.hours.ago
+      last_post_at: 3.hours.ago,
+      bot_join_status: 'not_joined'
     )
 
     @channel3 = Channel.create!(
@@ -71,7 +73,8 @@ def create_test_channels
       subscribers_count: 200,
       last_post_at: 2.days.ago,
       deactivated_at: 1.day.ago,
-      deactivation_reason: 'test_deactivation'
+      deactivation_reason: 'test_deactivation',
+      bot_join_status: 'not_joined'
     )
 
     @channel4 = Channel.create!(
@@ -80,7 +83,8 @@ def create_test_channels
       title: 'Old Channel',
       description: 'Channel with old posts',
       subscribers_count: 300,
-      last_post_at: 10.days.ago
+      last_post_at: 10.days.ago,
+      bot_join_status: 'not_joined'
     )
   end
 
@@ -273,7 +277,8 @@ def create_test_subscriptions
       title: 'Demo Channel',
       description: 'Demo channel for testing',
       subscribers_count: 100,
-      last_post_at: 1.hour.ago
+      last_post_at: 1.hour.ago,
+      bot_join_status: 'not_joined'
     )
 
     update = create_user_update(user_id: admin_user.id, username: admin_user.username,
@@ -305,7 +310,8 @@ def create_test_subscriptions
         title: "Channel #{i}",
         description: "Test channel #{i}",
         subscribers_count: 100 + i,
-        last_post_at: i.hours.ago
+        last_post_at: i.hours.ago,
+        bot_join_status: 'not_joined'
       )
       channels << channel
 
@@ -392,7 +398,7 @@ def create_test_subscriptions
     text = message_content[:text]
 
     # Проверяем что информация о последнем посте отображается
-    assert_includes text, I18n.t('telegram_bot.channels.list.last_post')
+    assert_includes text, I18n.t('telegram_bot.channels.admin_list.last_post')
   end
 
   test 'channels command handles errors gracefully' do