require "logstash/devutils/rspec/spec_helper"
require "logstash/filters/clone"

describe LogStash::Filters::Clone do

  describe "all defaults" do
    type "original"
    config <<-CONFIG
      filter {
        clone {
          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 {
          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

  describe "Bug LOGSTASH-1225" do
    ### LOGSTASH-1225: Cannot clone events containing numbers.
    config <<-CONFIG
      filter {
        clone {
          clones => [ 'clone1' ]
        }
      }
    CONFIG

    sample("type" => "bug-1225", "message" => "unused", "number" => 5) do
      insist { subject[0]["number"] } == 5
      insist { subject[1]["number"] } == 5
    end
  end


end