Add outputs/elasticsearch_http tests

spec/outputs/elasticsearch_http.rb

@@ -0,0 +1,89 @@
+require "test_utils"
+require "logstash/outputs/elasticsearch_http"
+require "insist"
+require "stud/try"
+require "spoon"
+
+describe LogStash::Outputs::ElasticSearchHTTP do
+  extend LogStash::RSpec
+
+  describe "ship lots of events" do
+    # Generate a random index name
+    index = 10.times.collect { rand(10).to_s }.join("")
+
+    # Write a random number of events
+    event_count = 10000 + rand(500)
+
+    puts "Index: #{index}"
+
+    config <<-CONFIG
+      input {
+        generator {
+          message => "hello world"
+          count => #{event_count}
+          type => "generator"
+        }
+      }
+      output {
+        elasticsearch_http {
+          host => "127.0.0.1"
+          port => 9200
+          index => "#{index}"
+          index_type => "testing"
+          flush_size => 20
+        }
+      }
+    CONFIG
+
+    agent do
+      Stud::try(5.times) do
+        puts "Checking ES for results"
+        ftw = FTW::Agent.new
+        data = ""
+        response = ftw.get!("http://127.0.0.1:9200/#{index}/_count?q=*")
+        response.read_body { |chunk| data << chunk }
+        count = JSON.parse(data)["count"]
+        insist { count } == event_count
+      end
+    end
+  end
+end
+
+
+    #before :all do
+      #puts "Downloading elasticsearch if necessary"
+      #system("make vendor-elasticsearch")
+      #puts "Spawning ElasticSearch"
+      #classpath = Dir.glob("vendor/jar/elasticsearch-*/lib/*.jar").join(":")
+      #options = {
+        #"foreground" => "yes",
+        #"index.store.type" => "memory"
+      #}
+#
+      #es_opts = options.collect { |k,v| "-Des.#{k}=#{v}" }.join(" ")
+      #runclass = "org.elasticsearch.bootstrap.ElasticSearch"
+      #@es_proc = Spoon.spawnp("sh", "-c", "exec java -cp #{classpath} -Delasticsearch #{es_opts} #{runclass}")
+      #reject { @es_proc }.nil?
+
+      # Wait for it to be healthy?
+      #require "ftw/agent"
+      #ftw = FTW::Agent.new
+      #success = false
+      #Stud.try(10.times) do
+        #puts "Waiting for elasticsearch to come up..."
+        #response = ftw.get!("http://127.0.0.1:9200/")
+        #response.read_body { |chunk| }
+        #if response.status != 200
+          #raise "failed"
+        #end
+        #success = true
+      #end
+      #raise "elasticsearch never came online?" if !success
+    #end # before :all
+
+    #after :all do
+      #puts "Killing elasticsearch (pid: #{@es_proc})"
+      #Process::kill("KILL", @es_proc)
+      #puts "Waiting for elasticsearch to die"
+      #Process::wait(@es_proc)
+    #end