2022-02-03 23:22:13 +00:00
|
|
|
class Sms::IncomingMessageService
|
|
|
|
include ::FileTypeHelper
|
|
|
|
|
|
|
|
pattr_initialize [:inbox!, :params!]
|
|
|
|
|
|
|
|
def perform
|
|
|
|
set_contact
|
|
|
|
set_conversation
|
|
|
|
@message = @conversation.messages.create(
|
|
|
|
content: params[:text],
|
|
|
|
account_id: @inbox.account_id,
|
|
|
|
inbox_id: @inbox.id,
|
|
|
|
message_type: :incoming,
|
|
|
|
sender: @contact,
|
|
|
|
source_id: params[:id]
|
|
|
|
)
|
2022-03-02 09:39:56 +00:00
|
|
|
attach_files
|
|
|
|
@message.save!
|
2022-02-03 23:22:13 +00:00
|
|
|
end
|
|
|
|
|
|
|
|
private
|
|
|
|
|
|
|
|
def account
|
|
|
|
@account ||= @inbox.account
|
|
|
|
end
|
|
|
|
|
2022-03-02 09:39:56 +00:00
|
|
|
def channel
|
|
|
|
@channel ||= @inbox.channel
|
|
|
|
end
|
|
|
|
|
2022-02-03 23:22:13 +00:00
|
|
|
def phone_number
|
|
|
|
params[:from]
|
|
|
|
end
|
|
|
|
|
|
|
|
def formatted_phone_number
|
|
|
|
TelephoneNumber.parse(phone_number).international_number
|
|
|
|
end
|
|
|
|
|
|
|
|
def set_contact
|
|
|
|
contact_inbox = ::ContactBuilder.new(
|
|
|
|
source_id: params[:from],
|
|
|
|
inbox: @inbox,
|
|
|
|
contact_attributes: contact_attributes
|
|
|
|
).perform
|
|
|
|
|
|
|
|
@contact_inbox = contact_inbox
|
|
|
|
@contact = contact_inbox.contact
|
|
|
|
end
|
|
|
|
|
|
|
|
def conversation_params
|
|
|
|
{
|
|
|
|
account_id: @inbox.account_id,
|
|
|
|
inbox_id: @inbox.id,
|
|
|
|
contact_id: @contact.id,
|
|
|
|
contact_inbox_id: @contact_inbox.id
|
|
|
|
}
|
|
|
|
end
|
|
|
|
|
|
|
|
def set_conversation
|
|
|
|
@conversation = @contact_inbox.conversations.first
|
|
|
|
return if @conversation
|
|
|
|
|
|
|
|
@conversation = ::Conversation.create!(conversation_params)
|
|
|
|
end
|
|
|
|
|
|
|
|
def contact_attributes
|
|
|
|
{
|
|
|
|
name: formatted_phone_number,
|
|
|
|
phone_number: phone_number
|
|
|
|
}
|
|
|
|
end
|
2022-03-02 09:39:56 +00:00
|
|
|
|
|
|
|
def attach_files
|
|
|
|
return if params[:media].blank?
|
|
|
|
|
|
|
|
params[:media].each do |media_url|
|
|
|
|
# we don't need to process this files since chatwoot doesn't support it
|
|
|
|
next if media_url.end_with? '.smil'
|
|
|
|
|
|
|
|
attachment_file = Down.download(
|
|
|
|
media_url,
|
|
|
|
http_basic_authentication: [channel.provider_config['api_key'], channel.provider_config['api_secret']]
|
|
|
|
)
|
|
|
|
|
|
|
|
@message.attachments.new(
|
|
|
|
account_id: @message.account_id,
|
|
|
|
file_type: file_type(attachment_file.content_type),
|
|
|
|
file: {
|
|
|
|
io: attachment_file,
|
|
|
|
filename: attachment_file,
|
|
|
|
content_type: attachment_file.content_type
|
|
|
|
}
|
|
|
|
)
|
|
|
|
end
|
|
|
|
end
|
2022-02-03 23:22:13 +00:00
|
|
|
end
|