# This Builder will create a contact and contact inbox with specified attributes. # If an existing identified contact exisits, it will be returned. # for contact inbox logic it uses the contact inbox builder class ContactInboxWithContactBuilder pattr_initialize [:inbox!, :contact_attributes!, :source_id, :hmac_verified] def perform find_or_create_contact_and_contact_inbox # in case of race conditions where contact is created by another thread # we will try to find the contact and create a contact inbox rescue ActiveRecord::RecordNotUnique find_or_create_contact_and_contact_inbox end def find_or_create_contact_and_contact_inbox @contact_inbox = inbox.contact_inboxes.find_by(source_id: source_id) if source_id.present? return @contact_inbox if @contact_inbox ActiveRecord::Base.transaction(requires_new: true) do build_contact_with_contact_inbox update_contact_avatar(@contact) unless @contact.avatar.attached? @contact_inbox end end private def build_contact_with_contact_inbox @contact = find_contact || create_contact @contact_inbox = create_contact_inbox end def account @account ||= inbox.account end def create_contact_inbox ContactInboxBuilder.new( contact: @contact, inbox: @inbox, source_id: @source_id, hmac_verified: hmac_verified ).perform end def update_contact_avatar(contact) ::Avatar::AvatarFromUrlJob.perform_later(contact, contact_attributes[:avatar_url]) if contact_attributes[:avatar_url] end def create_contact account.contacts.create!( name: contact_attributes[:name] || ::Haikunator.haikunate(1000), phone_number: contact_attributes[:phone_number], email: contact_attributes[:email], identifier: contact_attributes[:identifier], additional_attributes: contact_attributes[:additional_attributes], custom_attributes: contact_attributes[:custom_attributes] ) end def find_contact contact = find_contact_by_identifier(contact_attributes[:identifier]) contact ||= find_contact_by_email(contact_attributes[:email]) contact ||= find_contact_by_phone_number(contact_attributes[:phone_number]) contact end def find_contact_by_identifier(identifier) return if identifier.blank? account.contacts.find_by(identifier: identifier) end def find_contact_by_email(email) return if email.blank? account.contacts.find_by(email: email.downcase) end def find_contact_by_phone_number(phone_number) return if phone_number.blank? account.contacts.find_by(phone_number: phone_number) end end