Contents

require "test_utils"
require "logstash/filters/clone"

describe LogStash::Filters::Clone do
  extend LogStash::RSpec

  describe "all defaults" do
    type "original"
    config <<-CONFIG
      filter {
        clone {
          type => "original"
          clones => ["clone", "clone", "clone"]
        }
      }
    CONFIG

    sample("message" => "hello world", "type" => "original") do
      insist { subject }.is_a? Array
      insist { subject.length } == 4
      subject.each_with_index do |s,i|
        if i == 0 # last one should be 'original'
          insist { s["type"] } == "original"
        else
          insist { s["type"]} == "clone"
        end
        insist { s["message"] } == "hello world"
      end
    end
  end

  describe "Complex use" do
    config <<-CONFIG
      filter {
        clone {
          type => "nginx-access"
          tags => ['TESTLOG']
          clones => ["nginx-access-clone1", "nginx-access-clone2"]
          add_tag => ['RABBIT','NO_ES']
          remove_tag => ["TESTLOG"]
        }
      }
    CONFIG

    sample("type" => "nginx-access", "tags" => ["TESTLOG"], "message" => "hello world") do
      insist { subject }.is_a? Array
      insist { subject.length } == 3

      insist { subject[0]["type"] } == "nginx-access"
      #Initial event remains unchanged
      insist { subject[0]["tags"] }.include? "TESTLOG"
      reject { subject[0]["tags"] }.include? "RABBIT"
      reject { subject[0]["tags"] }.include? "NO_ES"
      #All clones go through filter_matched
      insist { subject[1]["type"] } == "nginx-access-clone1"
      reject { subject[1]["tags"] }.include? "TESTLOG"
      insist { subject[1]["tags"] }.include? "RABBIT"
      insist { subject[1]["tags"] }.include? "NO_ES"

      insist { subject[2]["type"] } == "nginx-access-clone2"
      reject { subject[2]["tags"] }.include? "TESTLOG"
      insist { subject[2]["tags"] }.include? "RABBIT"
      insist { subject[2]["tags"] }.include? "NO_ES"

    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
logstash-lib-1.3.2	spec/filters/clone.rb