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 } mb = Messages::MessageBuilder.new(nil, @conversation, 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 } mb = Messages::MessageBuilder.new(nil, @conversation, params) mb.perform end end