111 lines
2.4 KiB
Ruby
111 lines
2.4 KiB
Ruby
class Twilio::IncomingMessageService
|
|
include ::FileTypeHelper
|
|
|
|
pattr_initialize [:params!]
|
|
|
|
def perform
|
|
set_contact
|
|
set_conversation
|
|
@message = @conversation.messages.create(
|
|
content: params[:Body],
|
|
account_id: @inbox.account_id,
|
|
inbox_id: @inbox.id,
|
|
message_type: :incoming,
|
|
contact_id: @contact.id,
|
|
source_id: params[:SmsSid]
|
|
)
|
|
attach_files
|
|
end
|
|
|
|
private
|
|
|
|
def twilio_inbox
|
|
@twilio_inbox ||= ::Channel::TwilioSms.find_by!(
|
|
account_sid: params[:AccountSid],
|
|
phone_number: params[:To]
|
|
)
|
|
end
|
|
|
|
def inbox
|
|
@inbox ||= twilio_inbox.inbox
|
|
end
|
|
|
|
def account
|
|
@account ||= inbox.account
|
|
end
|
|
|
|
def phone_number
|
|
twilio_inbox.sms? ? params[:From] : params[:From].gsub('whatsapp:', '')
|
|
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,
|
|
additional_attributes: additional_attributes
|
|
}
|
|
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,
|
|
additional_attributes: additional_attributes
|
|
}
|
|
end
|
|
|
|
def additional_attributes
|
|
if twilio_inbox.sms?
|
|
{
|
|
from_zip_code: params[:FromZip],
|
|
from_country: params[:FromCountry],
|
|
from_state: params[:FromState]
|
|
}
|
|
else
|
|
{}
|
|
end
|
|
end
|
|
|
|
def attach_files
|
|
return if params[:MediaUrl0].blank?
|
|
|
|
file_resource = LocalResource.new(params[:MediaUrl0], params[:MediaContentType0])
|
|
|
|
attachment = @message.attachments.new(
|
|
account_id: @message.account_id,
|
|
file_type: file_type(params[:MediaContentType0])
|
|
)
|
|
|
|
attachment.file.attach(
|
|
io: file_resource.file,
|
|
filename: file_resource.tmp_filename,
|
|
content_type: file_resource.encoding
|
|
)
|
|
|
|
@message.save!
|
|
end
|
|
end
|