48 lines
1.5 KiB
Ruby
48 lines
1.5 KiB
Ruby
class ContactIdentifyAction
|
|
pattr_initialize [:contact!, :params!]
|
|
|
|
def perform
|
|
ActiveRecord::Base.transaction do
|
|
@contact = merge_contact(existing_identified_contact, @contact) if merge_contacts?(existing_identified_contact, @contact)
|
|
@contact = merge_contact(existing_email_contact, @contact) if merge_contacts?(existing_email_contact, @contact)
|
|
update_contact
|
|
end
|
|
@contact
|
|
end
|
|
|
|
private
|
|
|
|
def account
|
|
@account ||= @contact.account
|
|
end
|
|
|
|
def existing_identified_contact
|
|
return if params[:identifier].blank?
|
|
|
|
@existing_identified_contact ||= Contact.where(account_id: account.id).find_by(identifier: params[:identifier])
|
|
end
|
|
|
|
def existing_email_contact
|
|
return if params[:email].blank?
|
|
|
|
@existing_email_contact ||= Contact.where(account_id: account.id).find_by(email: params[:email])
|
|
end
|
|
|
|
def merge_contacts?(existing_contact, _contact)
|
|
existing_contact && existing_contact.id != @contact.id
|
|
end
|
|
|
|
def update_contact
|
|
custom_attributes = params[:custom_attributes] ? @contact.custom_attributes.merge(params[:custom_attributes]) : @contact.custom_attributes
|
|
@contact.update!(params.slice(:name, :email, :identifier).merge({ custom_attributes: custom_attributes }))
|
|
ContactAvatarJob.perform_later(@contact, params[:avatar_url]) if params[:avatar_url].present?
|
|
end
|
|
|
|
def merge_contact(base_contact, merge_contact)
|
|
ContactMergeAction.new(
|
|
account: account,
|
|
base_contact: base_contact,
|
|
mergee_contact: merge_contact
|
|
).perform
|
|
end
|
|
end
|