class SupportMailbox < ApplicationMailbox attr_accessor :channel, :account, :inbox, :conversation, :processed_mail before_processing :find_channel, :load_account, :load_inbox, :decorate_mail def process # prevent loop from chatwoot notification emails return if notification_email_from_chatwoot? ActiveRecord::Base.transaction do find_or_create_contact find_or_create_conversation create_message add_attachments_to_message end end private def find_channel mail.to.each do |email| @channel = Channel::Email.find_by('lower(email) = ? OR lower(forward_to_email) = ?', email.downcase, email.downcase) break if @channel.present? end raise 'Email channel/inbox not found' if @channel.nil? @channel end def load_account @account = @channel.account end def load_inbox @inbox = @channel.inbox end def decorate_mail @processed_mail = MailPresenter.new(mail, @account) end def find_conversation_by_in_reply_to return if in_reply_to.blank? @account.conversations.where("additional_attributes->>'in_reply_to' = ?", in_reply_to).first end def in_reply_to mail['In-Reply-To'].try(:value) end def find_or_create_conversation @conversation = find_conversation_by_in_reply_to || ::Conversation.create!({ account_id: @account.id, inbox_id: @inbox.id, contact_id: @contact.id, contact_inbox_id: @contact_inbox.id, additional_attributes: { in_reply_to: in_reply_to, source: 'email', mail_subject: @processed_mail.subject, initiated_at: { timestamp: Time.now.utc } } }) end def find_or_create_contact @contact = @inbox.contacts.find_by(email: @processed_mail.original_sender) if @contact.present? @contact_inbox = ContactInbox.find_by(inbox: @inbox, contact: @contact) else create_contact end end def create_contact @contact_inbox = ::ContactBuilder.new( source_id: "email:#{processed_mail.message_id}", inbox: @inbox, contact_attributes: { name: identify_contact_name, email: @processed_mail.original_sender, additional_attributes: { source_id: "email:#{processed_mail.message_id}" } } ).perform @contact = @contact_inbox.contact end def identify_contact_name processed_mail.sender_name || processed_mail.from.first.split('@').first end end