Bot joins channel

Author: dapi

CLAUDE.md

@@ -123,3 +123,5 @@ Bugsnag, по-возмоности указывая контекст котор
 
 План имплементации всегда имеет такой-же номер как и спецификаций по которой он
 создан и имеет ссылку на неё.
+
+После выполнения плана имплементации отмечай выполненные пункты как выполненные.

app/jobs/channels/bot_join_job.rb

@@ -0,0 +1,81 @@
+# Фоновая задача для вступления бота в Telegram канал
+# Запускается после добавления канала в систему
+class Channels::BotJoinJob < ApplicationJob
+  queue_as :channels
+  retry_on StandardError, wait: :exponentially_longer, attempts: 3
+
+  def perform(channel_id)
+    with_error_context(channel_id: channel_id, action: 'bot_join') do
+      channel = Channel.find(channel_id)
+
+      Rails.logger.info "Starting bot join process for channel #{channel.username}"
+
+      # Обновляем статус на joining
+      channel.start_joining!
+
+      # Пытаемся вступить в канал
+      success = attempt_to_join_channel(channel)
+
+      if success
+        channel.mark_as_joined!
+        notify_admins_success(channel)
+        Rails.logger.info "Bot successfully joined channel #{channel.username}"
+      else
+        error_message = extract_error_message(success)
+        channel.mark_as_join_failed!(error_message)
+        notify_admins_failure(channel, error_message)
+        Rails.logger.error "Bot failed to join channel #{channel.username}: #{error_message}"
+      end
+    end
+  end
+
+  private
+
+  def attempt_to_join_channel(channel)
+    begin
+      # Инициализируем клиент
+      bot = Telegram.bots[:default]
+
+      # Для публичных каналов бот может просто начать следить
+      # через webhook без дополнительного вступления
+      chat_id = channel.telegram_id
+
+      # Проверяем доступность канала
+      chat_info = bot.get_chat(chat_id: chat_id)
+
+      if chat_info['ok']
+        Rails.logger.info "Channel #{channel.username} is accessible to bot"
+        true
+      else
+        error_code = chat_info['error_code'] || 'unknown'
+        error_description = chat_info['description'] || 'Unknown error'
+
+        Rails.logger.warn "Cannot access channel #{channel.username}: #{error_code} - #{error_description}"
+        { error_code: error_code, error_description: error_description }
+      end
+
+    rescue Telegram::Bot::Error => e
+      Rails.logger.error "Telegram API error for channel #{channel.username}: #{e.message}"
+      { error_code: 'telegram_api_error', error_description: e.message }
+    rescue StandardError => e
+      Rails.logger.error "Unexpected error for channel #{channel.username}: #{e.message}"
+      { error_code: 'unexpected_error', error_description: e.message }
+    end
+  end
+
+  def extract_error_message(result)
+    return 'Unknown error' if result == true
+    return result[:error_description] if result.is_a?(Hash) && result[:error_description]
+    'Failed to join channel'
+  end
+
+  def notify_admins_success(channel)
+    # TODO: Implement admin notifications in stage 4
+    Rails.logger.info "Bot successfully joined channel: #{channel.username} (#{channel.title})"
+  end
+
+  def notify_admins_failure(channel, error_message)
+    # TODO: Implement admin notifications in stage 4
+    Rails.logger.error "Bot failed to join channel #{channel.username}: #{error_message}"
+  end
+end

app/jobs/channels/fetch_posts_job.rb

@@ -9,6 +9,14 @@ class Channel < ApplicationRecord
   validates :telegram_id, presence: true, uniqueness: true
   validates :username, presence: true, uniqueness: true
 
+  # Enums
+  enum bot_join_status: {
+    not_joined: 0,
+    joining: 1,
+    joined: 2,
+    join_failed: 3
+  }
+
   # Scopes
   scope :active, -> { where(deactivated_at: nil) }
   scope :inactive, -> { where.not(deactivated_at: nil) }
@@ -17,6 +25,12 @@ 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
+  scope :joined, -> { where(bot_join_status: 'joined') }
+  scope :not_joined, -> { where(bot_join_status: 'not_joined') }
+  scope :joining, -> { where(bot_join_status: 'joining') }
+  scope :join_failed, -> { where(bot_join_status: 'join_failed') }
+
   # Methods
   def mark_as_monitored!
     touch(:monitored_at)
@@ -37,4 +51,21 @@ def activate!
   def active?
     deactivated_at.nil?
   end
+
+  # Bot join status methods
+  def start_joining!
+    update!(bot_join_status: 'joining')
+  end
+
+  def mark_as_joined!
+    update!(bot_join_status: 'joined', bot_join_at: Time.current, bot_join_error: nil)
+  end
+
+  def mark_as_join_failed!(error_message)
+    update!(bot_join_status: 'join_failed', bot_join_error: error_message)
+  end
+
+  def bot_can_monitor?
+    active? && joined?
+  end
 end

app/jobs/channels/monitor_job.rb

@@ -141,13 +141,21 @@ def add_channel_to_database(channel_username)
             message: I18n.t('telegram_bot.channels.add.error', error: channel.errors.full_messages.join(', '))
           }
         end
+
+        # Запускаем задачу для вступления бота в канал
+        Channels::BotJoinJob.perform_later(channel.id)
       else
         # Обновляем информацию о канале
         channel.update(
           title: channel_info[:title],
           description: channel_info[:description],
           subscribers_count: channel_info[:member_count]
         )
+
+        # Если канал еще не вступал, запускаем задачу для вступления
+        if channel.not_joined?
+          Channels::BotJoinJob.perform_later(channel.id)
+        end
       end
 
       {

app/models/channel.rb

@@ -0,0 +1,9 @@
+class AddBotJoinFieldsToChannels < ActiveRecord::Migration[8.0]
+  def change
+    add_column :channels, :bot_join_status, :string, default: 'not_joined', null: false
+    add_column :channels, :bot_join_error, :text
+    add_column :channels, :bot_join_at, :datetime
+
+    add_index :channels, :bot_join_status
+  end
+end