discourse-ai/app/jobs/regular/create_ai_chat_reply.rb

# frozen_string_literal: true

module ::Jobs
  class CreateAiChatReply < ::Jobs::Base
    sidekiq_options retry: false

    def execute(args)
      channel = ::Chat::Channel.find_by(id: args[:channel_id])
      return if channel.blank?

      message = ::Chat::Message.find_by(id: args[:message_id])
      return if message.blank?

      agentClass =
        DiscourseAi::Agents::Agent.find_by(id: args[:agent_id], user: message.user)
      return if agentClass.blank?

      user = User.find_by(id: agentClass.user_id)
      bot = DiscourseAi::Agents::Bot.as(user, agent: agentClass.new)

      DiscourseAi::AiBot::Playground.new(bot).reply_to_chat_message(
        message,
        channel,
        args[:context_post_ids],
      )
    end
  end
end