lumberjack_spec.rb in logstash-input-lumberjack-0.1.4

- old
+ new
@@ -1,56 +1,112 @@
-require "logstash/devutils/rspec/spec_helper"
+# encoding: utf-8
+require "spec_helper"
+require "stud/temporary"
+require 'logstash/inputs/lumberjack'
+require "logstash/codecs/plain"
+require "logstash/codecs/multiline"
+
+describe LogStash::Inputs::Lumberjack do
+
+  let(:ssl_cert) { Stud::Temporary.pathname("ssl_certificate") }
+  let(:ssl_key)  { Stud::Temporary.pathname("ssl_key") }
+
+  let(:queue)  { Queue.new }
+  let(:config)   { { "port" => 0, "ssl_certificate" => ssl_cert, "ssl_key" => ssl_key, "type" => "example" } }
+
+
+  before do
+    system("openssl req -x509  -batch -nodes -newkey rsa:2048 -keyout #{ssl_key} -out #{ssl_cert} -subj /CN=localhost > /dev/null 2>&1")
+  end
+
+  context "#register" do
+
+    it "raise no exception" do
+      plugin = LogStash::Inputs::Lumberjack.new(config)
+      expect { plugin.register}.not_to raise_error
+    end
+  end
+
+  describe "#processing of events" do
+
+    context "#codecs" do
+
+      let(:config) do
+        { "port" => 6969, "ssl_certificate" => ssl_cert, "ssl_key" => ssl_key,
+          "type" => "example", "codec" => codec }
+      end
+
+      let(:codec) { LogStash::Codecs::Multiline.new("pattern" => '\n', "what" => "previous") }
+      subject!(:lumberjack) { LogStash::Inputs::Lumberjack.new(config) }
+      let(:connection) { double("connection") }
+      let(:lines) { {"line" => "one\ntwo\n  two.2\nthree\n"} }
+
+      before(:each) do
+        allow(connection).to receive(:run).and_yield(lines)
+        lumberjack.register
+      end
+
+      it "clone the codec per connection" do
+        expect_any_instance_of(Lumberjack::Server).to receive(:accept).and_return(connection)
+        expect(lumberjack.codec).to receive(:clone).once
+        expect(lumberjack).to receive(:invoke).and_throw(:msg)
+        lumberjack.run(queue)
+      end
+
+    end
+  end
+end