126 lines
3.1 KiB
Ruby
126 lines
3.1 KiB
Ruby
class Api::V1::Widget::MessagesController < Api::V1::Widget::BaseController
|
|
before_action :set_web_widget
|
|
before_action :set_contact
|
|
before_action :set_conversation, only: [:create]
|
|
before_action :set_message, only: [:update]
|
|
|
|
def index
|
|
@messages = conversation.nil? ? [] : message_finder.perform
|
|
end
|
|
|
|
def create
|
|
@message = conversation.messages.new(message_params)
|
|
build_attachment
|
|
@message.save!
|
|
end
|
|
|
|
def update
|
|
@message.update!(input_submitted_email: contact_email)
|
|
update_contact(contact_email)
|
|
rescue StandardError => e
|
|
render json: { error: @contact.errors, message: e.message }.to_json, status: 500
|
|
end
|
|
|
|
private
|
|
|
|
def build_attachment
|
|
return if params[:message][:attachment].blank?
|
|
|
|
@message.attachment = Attachment.new(
|
|
account_id: @message.account_id,
|
|
file_type: helpers.file_type(params[:message][:attachment][:file]&.content_type)
|
|
)
|
|
@message.attachment.file.attach(params[:message][:attachment][:file])
|
|
end
|
|
|
|
def set_conversation
|
|
@conversation = ::Conversation.create!(conversation_params) if conversation.nil?
|
|
end
|
|
|
|
def message_params
|
|
{
|
|
account_id: conversation.account_id,
|
|
contact_id: @contact.id,
|
|
content: permitted_params[:message][:content],
|
|
inbox_id: conversation.inbox_id,
|
|
message_type: :incoming
|
|
}
|
|
end
|
|
|
|
def conversation_params
|
|
{
|
|
account_id: inbox.account_id,
|
|
inbox_id: inbox.id,
|
|
contact_id: @contact.id,
|
|
contact_inbox_id: @contact_inbox.id,
|
|
additional_attributes: {
|
|
browser: browser_params,
|
|
referer: permitted_params[:message][:referer_url],
|
|
initiated_at: timestamp_params
|
|
}
|
|
}
|
|
end
|
|
|
|
def browser_params
|
|
{
|
|
browser_name: browser.name,
|
|
browser_version: browser.full_version,
|
|
device_name: browser.device.name,
|
|
platform_name: browser.platform.name,
|
|
platform_version: browser.platform.version
|
|
}
|
|
end
|
|
|
|
def timestamp_params
|
|
{
|
|
timestamp: permitted_params[:message][:timestamp]
|
|
}
|
|
end
|
|
|
|
def inbox
|
|
@inbox ||= ::Inbox.find_by(id: auth_token_params[:inbox_id])
|
|
end
|
|
|
|
def message_finder_params
|
|
{
|
|
filter_internal_messages: true,
|
|
before: permitted_params[:before]
|
|
}
|
|
end
|
|
|
|
def message_finder
|
|
@message_finder ||= MessageFinder.new(conversation, message_finder_params)
|
|
end
|
|
|
|
def update_contact(email)
|
|
contact_with_email = @account.contacts.find_by(email: email)
|
|
if contact_with_email
|
|
@contact = ::ContactMergeAction.new(
|
|
account: @account,
|
|
base_contact: contact_with_email,
|
|
mergee_contact: @contact
|
|
).perform
|
|
else
|
|
@contact.update!(
|
|
email: email,
|
|
name: contact_name
|
|
)
|
|
end
|
|
end
|
|
|
|
def contact_email
|
|
permitted_params[:contact][:email].downcase
|
|
end
|
|
|
|
def contact_name
|
|
contact_email.split('@')[0]
|
|
end
|
|
|
|
def permitted_params
|
|
params.permit(:id, :before, :website_token, contact: [:email], message: [:content, :referer_url, :timestamp])
|
|
end
|
|
|
|
def set_message
|
|
@message = @web_widget.inbox.messages.find(permitted_params[:id])
|
|
end
|
|
end
|