pipe_spec.rb in logstash-output-pipe-1.1.0

- old
+ new

@@ -1,34 +1,68 @@
-require "logstash/devutils/rspec/spec_helper"
+# encoding: utf-8
+require_relative "../spec_helper"
+require "logstash/plugin"
+require "logstash/event"
+
+describe LogStash::Outputs::Pipe do
+
+  let(:format) { "%{message}" }
+  let(:cmd)    { "cmd" }
+
+  it "should register without errors" do
+    plugin = LogStash::Plugin.lookup("output", "pipe").new({"command" => cmd})
+    expect { plugin.register }.to_not raise_error
+  end
+
+  describe "#send" do
+
+    subject { LogStash::Outputs::Pipe.new("command" => cmd) }
+
+    let(:properties) { { "message" => "This is a message!"} }
+    let(:event)      { LogStash::Event.new(properties) }
+
+    let(:pipe)       { double("pipe") }
+    before(:each) do
+      allow(PipeWrapper).to receive(:new).and_return(pipe)
+      subject.register
+    end
+
+    it "sends the generated event to the pipe" do
+      expect(pipe).to receive(:puts).with(event.to_json)
+      subject.receive(event)
+    end
+
+  end
+end