52a55827c3
* chore: lint files * chore: suppress warning * chore: disable suggest extensions * chore: do not stage changes in pre-commit * chore: remove git add from FE lint and `-a` flag from rubocop on husky
65 lines
1.9 KiB
Ruby
65 lines
1.9 KiB
Ruby
class Integrations::BotProcessorService
|
|
# TODO: In CSML processor service, the argument is agent bot, update initializers accordingly.
|
|
pattr_initialize [:event_name!, :hook!, :event_data!]
|
|
|
|
def perform
|
|
message = event_data[:message]
|
|
return unless should_run_processor?(message)
|
|
|
|
process_content(message)
|
|
rescue StandardError => e
|
|
ChatwootExceptionTracker.new(e, account: (hook&.account || agent_bot&.account)).capture_exception
|
|
end
|
|
|
|
private
|
|
|
|
def should_run_processor?(message)
|
|
return false if message.private?
|
|
return false unless processable_message?(message)
|
|
return false unless conversation.pending?
|
|
|
|
true
|
|
end
|
|
|
|
def conversation
|
|
message = event_data[:message]
|
|
@conversation ||= message.conversation
|
|
end
|
|
|
|
def process_content(message)
|
|
content = message_content(message)
|
|
response = get_response(conversation.contact_inbox.source_id, content) if content.present?
|
|
process_response(message, response) if response.present?
|
|
end
|
|
|
|
def message_content(message)
|
|
# TODO: might needs to change this to a way that we fetch the updated value from event data instead
|
|
# cause the message.updated event could be that that the message was deleted
|
|
|
|
return message.content_attributes['submitted_values']&.first&.dig('value') if event_name == 'message.updated'
|
|
|
|
message.content
|
|
end
|
|
|
|
def processable_message?(message)
|
|
# TODO: change from reportable and create a dedicated method for this?
|
|
return false unless message.reportable?
|
|
return false if message.outgoing? && !processable_outgoing_message?(message)
|
|
|
|
true
|
|
end
|
|
|
|
def processable_outgoing_message?(message)
|
|
event_name == 'message.updated' && ['input_select'].include?(message.content_type)
|
|
end
|
|
|
|
def process_action(message, action)
|
|
case action
|
|
when 'handoff'
|
|
message.conversation.bot_handoff!
|
|
when 'resolve'
|
|
message.conversation.resolved!
|
|
end
|
|
end
|
|
end
|