a274a1702a
- Fixed send_attachment and send_email_transcript - Fixed duplicate activity messages - Fixed Order of execution Fixes: #5584
49 lines
1.2 KiB
Ruby
49 lines
1.2 KiB
Ruby
class Macros::ExecutionService < ActionService
|
|
def initialize(macro, conversation, user)
|
|
super(conversation)
|
|
@macro = macro
|
|
@account = macro.account
|
|
Current.user = user
|
|
end
|
|
|
|
def perform
|
|
@macro.actions.each do |action|
|
|
action = action.with_indifferent_access
|
|
begin
|
|
send(action[:action_name], action[:action_params])
|
|
rescue StandardError => e
|
|
ChatwootExceptionTracker.new(e, account: @account).capture_exception
|
|
end
|
|
end
|
|
ensure
|
|
Current.reset
|
|
end
|
|
|
|
private
|
|
|
|
def send_message(message)
|
|
return if conversation_a_tweet?
|
|
|
|
params = { content: message[0], private: false }
|
|
|
|
# Added reload here to ensure conversation us persistent with the latest updates
|
|
mb = Messages::MessageBuilder.new(nil, @conversation.reload, params)
|
|
mb.perform
|
|
end
|
|
|
|
def send_attachment(blob_ids)
|
|
return if conversation_a_tweet?
|
|
|
|
return unless @macro.files.attached?
|
|
|
|
blobs = ActiveStorage::Blob.where(id: blob_ids)
|
|
|
|
return if blobs.blank?
|
|
|
|
params = { content: nil, private: false, attachments: blobs }
|
|
|
|
# Added reload here to ensure conversation us persistent with the latest updates
|
|
mb = Messages::MessageBuilder.new(nil, @conversation.reload, params)
|
|
mb.perform
|
|
end
|
|
end
|