2021-11-08 07:12:07 -05:00
|
|
|
# frozen_string_literal: true
|
|
|
|
|
|
|
|
module Issues
|
|
|
|
class SetCrmContactsService < ::BaseProjectService
|
|
|
|
MAX_ADDITIONAL_CONTACTS = 6
|
|
|
|
|
2021-11-19 13:12:50 -05:00
|
|
|
# Replacing contacts by email is not currently supported
|
2021-11-08 07:12:07 -05:00
|
|
|
def execute(issue)
|
|
|
|
@issue = issue
|
|
|
|
@errors = []
|
|
|
|
|
|
|
|
return error_no_permissions unless allowed?
|
|
|
|
return error_invalid_params unless valid_params?
|
|
|
|
|
2021-11-19 13:12:50 -05:00
|
|
|
@existing_ids = issue.issue_customer_relations_contacts.map(&:contact_id)
|
|
|
|
determine_changes if params[:replace_ids].present?
|
2021-11-08 07:12:07 -05:00
|
|
|
return error_too_many if too_many?
|
|
|
|
|
2021-11-19 13:12:50 -05:00
|
|
|
add if params[:add_ids].present?
|
|
|
|
remove if params[:remove_ids].present?
|
|
|
|
|
|
|
|
add_by_email if params[:add_emails].present?
|
|
|
|
remove_by_email if params[:remove_emails].present?
|
2021-11-08 07:12:07 -05:00
|
|
|
|
|
|
|
if issue.valid?
|
2021-11-23 13:12:49 -05:00
|
|
|
GraphqlTriggers.issue_crm_contacts_updated(issue)
|
2021-11-08 07:12:07 -05:00
|
|
|
ServiceResponse.success(payload: issue)
|
|
|
|
else
|
|
|
|
# The default error isn't very helpful: "Issue customer relations contacts is invalid"
|
|
|
|
issue.errors.delete(:issue_customer_relations_contacts)
|
|
|
|
issue.errors.add(:issue_customer_relations_contacts, errors.to_sentence)
|
2021-11-19 13:12:50 -05:00
|
|
|
ServiceResponse.error(payload: issue, message: issue.errors.full_messages.to_sentence)
|
2021-11-08 07:12:07 -05:00
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
private
|
|
|
|
|
2021-11-19 13:12:50 -05:00
|
|
|
attr_accessor :issue, :errors, :existing_ids
|
|
|
|
|
2021-11-08 07:12:07 -05:00
|
|
|
def determine_changes
|
2021-11-19 13:12:50 -05:00
|
|
|
params[:add_ids] = params[:replace_ids] - existing_ids
|
|
|
|
params[:remove_ids] = existing_ids - params[:replace_ids]
|
|
|
|
end
|
|
|
|
|
|
|
|
def add
|
|
|
|
add_by_id(params[:add_ids])
|
|
|
|
end
|
|
|
|
|
|
|
|
def add_by_email
|
|
|
|
contact_ids = ::CustomerRelations::Contact.find_ids_by_emails(project_group.id, params[:add_emails])
|
|
|
|
add_by_id(contact_ids)
|
2021-11-08 07:12:07 -05:00
|
|
|
end
|
|
|
|
|
2021-11-19 13:12:50 -05:00
|
|
|
def add_by_id(contact_ids)
|
|
|
|
contact_ids -= existing_ids
|
|
|
|
contact_ids.uniq.each do |contact_id|
|
2021-11-08 07:12:07 -05:00
|
|
|
issue_contact = issue.issue_customer_relations_contacts.create(contact_id: contact_id)
|
|
|
|
|
|
|
|
unless issue_contact.persisted?
|
|
|
|
# The validation ensures that the id exists and the user has permission
|
|
|
|
errors << "#{contact_id}: The resource that you are attempting to access does not exist or you don't have permission to perform this action"
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2021-11-19 13:12:50 -05:00
|
|
|
def remove
|
|
|
|
remove_by_id(params[:remove_ids])
|
|
|
|
end
|
|
|
|
|
|
|
|
def remove_by_email
|
|
|
|
contact_ids = ::CustomerRelations::IssueContact.find_contact_ids_by_emails(issue.id, params[:remove_emails])
|
|
|
|
remove_by_id(contact_ids)
|
|
|
|
end
|
|
|
|
|
|
|
|
def remove_by_id(contact_ids)
|
|
|
|
contact_ids &= existing_ids
|
2021-11-08 07:12:07 -05:00
|
|
|
issue.issue_customer_relations_contacts
|
2021-11-19 13:12:50 -05:00
|
|
|
.where(contact_id: contact_ids) # rubocop: disable CodeReuse/ActiveRecord
|
2021-11-08 07:12:07 -05:00
|
|
|
.delete_all
|
|
|
|
end
|
|
|
|
|
|
|
|
def allowed?
|
|
|
|
current_user&.can?(:set_issue_crm_contacts, issue)
|
|
|
|
end
|
|
|
|
|
|
|
|
def valid_params?
|
|
|
|
set_present? ^ add_or_remove_present?
|
|
|
|
end
|
|
|
|
|
|
|
|
def set_present?
|
2021-11-19 13:12:50 -05:00
|
|
|
params[:replace_ids].present?
|
2021-11-08 07:12:07 -05:00
|
|
|
end
|
|
|
|
|
|
|
|
def add_or_remove_present?
|
2021-11-19 13:12:50 -05:00
|
|
|
add_present? || remove_present?
|
|
|
|
end
|
|
|
|
|
|
|
|
def add_present?
|
|
|
|
params[:add_ids].present? || params[:add_emails].present?
|
|
|
|
end
|
|
|
|
|
|
|
|
def remove_present?
|
|
|
|
params[:remove_ids].present? || params[:remove_emails].present?
|
2021-11-08 07:12:07 -05:00
|
|
|
end
|
|
|
|
|
|
|
|
def too_many?
|
2021-11-19 13:12:50 -05:00
|
|
|
too_many_ids? || too_many_emails?
|
|
|
|
end
|
|
|
|
|
|
|
|
def too_many_ids?
|
|
|
|
params[:add_ids] && params[:add_ids].length > MAX_ADDITIONAL_CONTACTS
|
|
|
|
end
|
|
|
|
|
|
|
|
def too_many_emails?
|
|
|
|
params[:add_emails] && params[:add_emails].length > MAX_ADDITIONAL_CONTACTS
|
2021-11-08 07:12:07 -05:00
|
|
|
end
|
|
|
|
|
|
|
|
def error_no_permissions
|
2021-11-19 13:12:50 -05:00
|
|
|
ServiceResponse.error(message: _('You have insufficient permissions to set customer relations contacts for this issue'))
|
2021-11-08 07:12:07 -05:00
|
|
|
end
|
|
|
|
|
|
|
|
def error_invalid_params
|
2021-11-19 13:12:50 -05:00
|
|
|
ServiceResponse.error(message: _('You cannot combine replace_ids with add_ids or remove_ids'))
|
2021-11-08 07:12:07 -05:00
|
|
|
end
|
|
|
|
|
|
|
|
def error_too_many
|
2021-11-19 13:12:50 -05:00
|
|
|
ServiceResponse.error(payload: issue, message: _("You can only add up to %{max_contacts} contacts at one time" % { max_contacts: MAX_ADDITIONAL_CONTACTS }))
|
2021-11-08 07:12:07 -05:00
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|