triggers_proccess_messages.rb

# perceba que agora o metodo está no plural
def process_messages messages

  # vou ter um hash de: client_id: mensagens
  messages_by_client = messages.group_by do |message|
    message["client_id"]
  end

  messages_by_client.each do |client_id, messages|
    # como as mensagens estão agrupadas por cliente, preciso pegar apenas os triggers
    # do cliente de qualquer mensagem
    triggers = find_triggers_for_client messages.first

    messages.each do |message|
      process_message message, triggers
    end
  end
end

def process_message message, triggers
  # Aqui eu não preciso mais filtrar os triggers pelo cliente
  triggers = filter_triggers_in_batch message, triggers

  triggers = triggers.select do |trigger|
    # verifica se passa nos ultimos filtros
    trigger.pass_filters? message
  end.each do |trigger|
    # executa as ações
    publish_to_actions_queue trigger, message
  end
end