class Aip

# File plugins/aip.rb, line 49
def self.admin_denial_message
  AiPlanSession.admin_denial_message
end

# File plugins/aip.rb, line 21
def self.build_execute_plan(question, asker:, channel:, network: nil, channel_obj: nil, user: nil,
                            yaml_default: nil)
  AiChatCore.build_execute_plan(
    question.to_s,
    asker: asker,
    channel: channel,
    network: network,
    channel_obj: channel_obj,
    user: user,
    yaml_default: yaml_default
  )
end

# File plugins/aip.rb, line 38
def self.format_plan_reply(preview:, body:, model:, total_tokens:, duration_s:, usage_percents: nil)
  AipReport.format_plan_reply(
    preview: preview,
    body: body,
    model: model,
    total_tokens: total_tokens,
    duration_s: duration_s,
    usage_percents: usage_percents
  )
end

# File plugins/aip.rb, line 34
def self.request_preview(question)
  AiChatCore.request_preview(question)
end

# File plugins/aip.rb, line 53
def execute(m, prompt)
  plan = self.class.build_execute_plan(
    prompt.to_s,
    asker: m.user.nick,
    channel: m.channel&.name,
    network: bot.config.server,
    channel_obj: m.channel,
    user: m.user,
    yaml_default: bot.config.shared[:ai_model]
  )

  if plan[:immediate_reply]
    themed_flood_safe_reply(m, plan[:immediate_reply])
    return
  end
  return unless plan[:async]

  themed_flood_safe_reply(m, plan[:async_ack]) if plan[:async_ack]

  AsyncJob.run(label: "aip") do
    outcome = if plan[:continuation]
                AiChatCore.process_plan_answer(
                  response: plan[:response],
                  channel: plan[:channel],
                  asker: plan[:asker],
                  network: plan[:network],
                  yaml_default: bot.config.shared[:ai_model],
                  usage_fetch: method(:usage_fetch)
                )
              else
                AiChatCore.process_plan_request(
                  question: plan[:question],
                  channel: plan[:channel],
                  asker: plan[:asker],
                  network: plan[:network],
                  yaml_default: bot.config.shared[:ai_model],
                  usage_fetch: method(:usage_fetch)
                )
              end
    themed_flood_safe_reply(m, outcome[:reply])
  rescue StandardError
    themed_flood_safe_reply(m, AipReport.format_error("AI plan request failed"))
  end
end

# File plugins/aip.rb, line 98
def usage_fetch
  nil
end