mirror of
https://github.com/discourse/discourse-ai.git
synced 2025-07-01 12:02:16 +00:00
478f31de47
* FEATURE: add inferred concepts system This commit adds a new inferred concepts system that: - Creates a model for storing concept labels that can be applied to topics - Provides AI personas for finding new concepts and matching existing ones - Adds jobs for generating concepts from popular topics - Includes a scheduled job that automatically processes engaging topics * FEATURE: Extend inferred concepts to include posts * Adds support for concepts to be inferred from and applied to posts * Replaces daily task with one that handles both topics and posts * Adds database migration for posts_inferred_concepts join table * Updates PersonaContext to include inferred concepts Co-authored-by: Roman Rizzi <rizziromanalejandro@gmail.com> Co-authored-by: Keegan George <kgeorge13@gmail.com>
56 lines
1.5 KiB
Ruby
56 lines
1.5 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
module DiscourseAi
|
|
module Discord::Bot
|
|
class PersonaReplier < Base
|
|
def initialize(body)
|
|
@persona =
|
|
AiPersona
|
|
.all_personas(enabled_only: false)
|
|
.find { |p| p.id == SiteSetting.ai_discord_search_persona.to_i }
|
|
.new
|
|
@bot =
|
|
DiscourseAi::Personas::Bot.as(
|
|
Discourse.system_user,
|
|
persona: @persona,
|
|
model: LlmModel.find(@persona.class.default_llm_id),
|
|
)
|
|
super(body)
|
|
end
|
|
|
|
def handle_interaction!
|
|
last_update_sent_at = Time.now - 1
|
|
reply = +""
|
|
full_reply =
|
|
@bot.reply(
|
|
{ conversation_context: [{ type: :user, content: @query }], skip_tool_details: true },
|
|
) do |partial, _something|
|
|
reply << partial
|
|
next if reply.blank?
|
|
|
|
if @reply_response.nil?
|
|
create_reply(wrap_links(reply.dup))
|
|
elsif @last_update_response.nil?
|
|
update_reply(wrap_links(reply.dup))
|
|
elsif Time.now - last_update_sent_at > 1
|
|
update_reply(wrap_links(reply.dup))
|
|
last_update_sent_at = Time.now
|
|
end
|
|
end
|
|
|
|
discord_reply = wrap_links(full_reply.last.first)
|
|
|
|
if @reply_response.nil?
|
|
create_reply(discord_reply)
|
|
else
|
|
update_reply(discord_reply)
|
|
end
|
|
end
|
|
|
|
def wrap_links(text)
|
|
text.gsub(%r{(?<url>https?://[^\s]+)}, "<\\k<url>>")
|
|
end
|
|
end
|
|
end
|
|
end
|