Sha256: a389deb6c109a2ed1aa59e7a93d9ccb0bceac956dba632c4d46400630277bc3f

Contents?: true

Size: 1.37 KB

Versions: 44

Compression:

Stored size: 1.37 KB

Contents

require "stud/temporary"


# namespace the Dummy* classes, they are reused names
# use a more specific module name to prevent clashes
module BeatsInputTest
  class Certicate
    attr_reader :ssl_key, :ssl_cert

    def initialize
      @ssl_cert = Stud::Temporary.pathname("ssl_certificate")
      @ssl_key = Stud::Temporary.pathname("ssl_key")

      system("openssl req -x509  -batch -nodes -newkey rsa:2048 -keyout #{ssl_key} -out #{ssl_cert} -subj /CN=localhost > /dev/null 2>&1")
    end

    def p12_key
      p12_key = Stud::Temporary.pathname("p12_key")
      system "openssl pkcs12 -export -passout pass:123 -inkey #{ssl_key} -in #{ssl_cert} -out #{p12_key}"
      p12_key
    end

  end

  class << self
    def certificate
      Certicate.new
    end

    def random_port
      rand(2000..10000)
    end
  end

  class DummyNeverBlockedQueue < Array
    def offer(element, timeout = nil)
      push(element)
    end

    alias_method :take, :shift
  end

  class DummyConnection
    def initialize(events)
      @events = events
    end

    def run
      @events.each do |element|
        yield element[:map], element[:identity_stream]
      end
    end

    def peer
      "localhost:5555"
    end
  end

  class DummyCodec
    def register() end
    def decode(*) end
    def clone() self; end
    def base_codec
      self
    end
    def self.config_name
      "dummy"
    end
  end
end



Version data entries

44 entries across 44 versions & 1 rubygems

Version Path
logstash-input-beats-7.0.2-java spec/support/logstash_test.rb
logstash-input-beats-6.9.3-java spec/support/logstash_test.rb
logstash-input-beats-6.9.2-java spec/support/logstash_test.rb
logstash-input-beats-7.0.1-java spec/support/logstash_test.rb
logstash-input-beats-7.0.0-java spec/support/logstash_test.rb
logstash-input-beats-6.9.1-java spec/support/logstash_test.rb
logstash-input-beats-6.9.0-java spec/support/logstash_test.rb
logstash-input-beats-6.8.4-java spec/support/logstash_test.rb
logstash-input-beats-6.8.3-java spec/support/logstash_test.rb
logstash-input-beats-6.8.2-java spec/support/logstash_test.rb
logstash-input-beats-6.8.1-java spec/support/logstash_test.rb
logstash-input-beats-6.8.0-java spec/support/logstash_test.rb
logstash-input-beats-6.7.2-java spec/support/logstash_test.rb
logstash-input-beats-6.7.1-java spec/support/logstash_test.rb
logstash-input-beats-6.7.0-java spec/support/logstash_test.rb
logstash-input-beats-6.6.4-java spec/support/logstash_test.rb
logstash-input-beats-6.6.3-java spec/support/logstash_test.rb
logstash-input-beats-6.6.2-java spec/support/logstash_test.rb
logstash-input-beats-6.6.1-java spec/support/logstash_test.rb
logstash-input-beats-6.6.0-java spec/support/logstash_test.rb