# encoding: utf-8
require "logstash/devutils/rspec/spec_helper"
require "logstash/inputs/jmx"
require "logstash/codecs/plain"
require 'stud/temporary'

describe LogStash::Inputs::Jmx do

  let(:jmx_config_path) { Stud::Temporary.directory }
  after(:each) do
    FileUtils.remove_dir(jmx_config_path)
  end

  subject { LogStash::Inputs::Jmx.new("path" => jmx_config_path)}

  context "#validate_configuration(conf_hash)" do
    #Reference to error messages
    MISSING_CONFIG_PARAMETER = LogStash::Inputs::Jmx::MISSING_CONFIG_PARAMETER
    BAD_TYPE_CONFIG_PARAMETER = LogStash::Inputs::Jmx::BAD_TYPE_CONFIG_PARAMETER
    BAD_TYPE_QUERY = LogStash::Inputs::Jmx::BAD_TYPE_QUERY
    MISSING_QUERY_PARAMETER = LogStash::Inputs::Jmx::MISSING_QUERY_PARAMETER
    BAD_TYPE_QUERY_PARAMETER = LogStash::Inputs::Jmx::BAD_TYPE_QUERY_PARAMETER

    let(:minimal_config) { {"host"=>"localhost","port"=>1234,"queries" => [] } }

    context "global configuration" do
      it "return [] for valid configuration" do
        #Minimal configuration
        expect(subject.validate_configuration(minimal_config)).to eq([])
        # Re-test with java objects from JrJackson serialization
        if LogStash::Environment.jruby?
          require "java"
          expect(subject.validate_configuration({"host"=>"localhost","port"=>1234,"queries" => java.util.ArrayList.new})).to eq([])
        end
      end

      it "return error message for missing mandatory parameters" do
        expect(subject.validate_configuration({})).to eq([MISSING_CONFIG_PARAMETER % "host", MISSING_CONFIG_PARAMETER % "port", MISSING_CONFIG_PARAMETER % "queries"])
      end

      it "return error message for invalid parameters type" do
        expect(subject.validate_configuration({"host"=>1234,"port"=>1234,"queries" => []})).to eq([BAD_TYPE_CONFIG_PARAMETER % {:param => "host", :expected => String, :actual => Fixnum}])
        expect(subject.validate_configuration({"host"=>"localhost","port"=>"1234","queries" => []})).to eq([BAD_TYPE_CONFIG_PARAMETER % {:param => "port", :expected => Fixnum, :actual => String}])
        expect(subject.validate_configuration({"host"=>"localhost","port"=>1234,"queries" => "my_query"})).to eq([BAD_TYPE_CONFIG_PARAMETER % {:param => "queries", :expected => Enumerable, :actual => String}])
      end
    end

    context "query objects in configuration" do
      it "return [] for valid query message" do
        #Minimal query object
        minimal_config["queries"] = [{"object_name" => "minimal"}]
        expect(subject.validate_configuration(minimal_config)).to eq([])
        #Full query object
        minimal_config["queries"] = [{
          "object_name" => "java.lang:type=Runtime",
          "attributes" => [ "Uptime", "StartTime" ],
          "object_alias" => "Runtime"}]
        expect(subject.validate_configuration(minimal_config)).to eq([])
      end
      it "return error message for invalid query object type" do
        minimal_config["queries"] = [ "1234" ]
        expect(subject.validate_configuration(minimal_config)).to eq([BAD_TYPE_QUERY % { :index => 0, :expected => Hash, :actual => String }])
      end

      it "return error message for missing mandatory query parameter" do
        minimal_config["queries"] = [ {} ]
        expect(subject.validate_configuration(minimal_config)).to eq([MISSING_QUERY_PARAMETER % ["object_name",0] ])
      end

      it "return error message for invalid query parameters type" do
        minimal_config["queries"] = [ { "object_name" => 1234} ]
        expect(subject.validate_configuration(minimal_config)).to eq([BAD_TYPE_QUERY_PARAMETER % {:param => "object_name", :index => 0, :expected => String, :actual => Fixnum} ])

        minimal_config["queries"] = [ { "object_name" => "1234", "object_alias" => 1234} ]
        expect(subject.validate_configuration(minimal_config)).to eq([BAD_TYPE_QUERY_PARAMETER % {:param => "object_alias", :index => 0, :expected => String, :actual => Fixnum} ])

        minimal_config["queries"] = [ { "object_name" => "1234", "attributes" => 1234} ]
        expect(subject.validate_configuration(minimal_config)).to eq([BAD_TYPE_QUERY_PARAMETER % {:param => "attributes", :index => 0, :expected => Enumerable, :actual => Fixnum} ])
      end
    end
  end
end