f13f3ba446
Removes sentry flooding of unnecessary rubyllm logs of wrong API key. Logs only system api key error since it would be P0. --------- Co-authored-by: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
75 lines
2.4 KiB
Ruby
75 lines
2.4 KiB
Ruby
# Evaluates whether a conversation is complete and can be auto-resolved.
|
|
# Used by InboxPendingConversationsResolutionJob to determine if inactive
|
|
# conversations should be resolved or handed off to human agents.
|
|
#
|
|
# NOTE: This service intentionally does NOT count toward Captain usage limits.
|
|
# The response excludes the :message key that Enterprise::Captain::BaseTaskService
|
|
# checks for usage tracking. This is an internal operational evaluation,
|
|
# not a customer-facing value-add, so we don't charge for it.
|
|
class Captain::ConversationCompletionService < Captain::BaseTaskService
|
|
RESPONSE_SCHEMA = Captain::ConversationCompletionSchema
|
|
|
|
pattr_initialize [:account!, :conversation_display_id!]
|
|
|
|
def perform
|
|
content = format_messages_as_string
|
|
return default_incomplete_response('No messages found') if content.blank?
|
|
|
|
response = make_api_call(
|
|
model: InstallationConfig.find_by(name: 'CAPTAIN_OPEN_AI_MODEL')&.value.presence || GPT_MODEL,
|
|
messages: [
|
|
{ role: 'system', content: prompt_from_file('conversation_completion') },
|
|
{ role: 'user', content: content }
|
|
],
|
|
schema: RESPONSE_SCHEMA
|
|
)
|
|
|
|
return default_incomplete_response(response[:error]) if response[:error].present?
|
|
|
|
parse_response(response[:message])
|
|
end
|
|
|
|
private
|
|
|
|
def prompt_from_file(file_name)
|
|
Rails.root.join('enterprise/lib/captain/prompts', "#{file_name}.liquid").read
|
|
end
|
|
|
|
def format_messages_as_string
|
|
messages = conversation_messages(start_from: 0)
|
|
messages.map do |msg|
|
|
sender_type = msg[:role] == 'user' ? 'Customer' : 'Assistant'
|
|
"#{sender_type}: #{msg[:content]}"
|
|
end.join("\n")
|
|
end
|
|
|
|
def parse_response(message)
|
|
return default_incomplete_response('Invalid response format') unless message.is_a?(Hash)
|
|
|
|
{
|
|
complete: message['complete'] == true,
|
|
reason: message['reason'] || 'No reason provided'
|
|
}
|
|
end
|
|
|
|
def default_incomplete_response(reason)
|
|
{ complete: false, reason: reason }
|
|
end
|
|
|
|
# This is an internal operational evaluation, not a customer-triggered feature,
|
|
# so it should always use the installation key.
|
|
def llm_credential
|
|
@llm_credential ||= system_llm_credential
|
|
end
|
|
|
|
def event_name
|
|
'captain.conversation_completion'
|
|
end
|
|
|
|
def build_follow_up_context?
|
|
false
|
|
end
|
|
end
|
|
|
|
Captain::ConversationCompletionService.prepend_mod_with('Captain::ConversationCompletionService')
|