plugin-api 2.0

.travis.yml

@@ -1,7 +1,11 @@
 sudo: false
+jdk:
+  - oraclejdk8
 language: ruby
 cache: bundler
 rvm:
-  - jruby-1.7.23
-script: 
+  - jruby-1.7.25
+before_install:
+  - git clone -b feature/event_interface https://github.com/elastic/logstash
+script:
   - bundle exec rspec spec

Gemfile

@@ -1,2 +1,8 @@
 source 'https://rubygems.org'
-gemspec
+gemspec
+
+# this is temporary for the feature/plugin-api-2_0 branch and is meant for travis testing
+gem "logstash-core", :path => "./logstash/logstash-core"
+gem "logstash-core-plugin-api", :path => "./logstash/logstash-core-plugin-api"
+gem "logstash-core-event-java", :path => "./logstash/logstash-core-event-java"
+gem "logstash-devutils", :github => "elastic/logstash-devutils", :branch => "feature/plugin-api-2_0"

lib/logstash/filters/clone.rb

@@ -19,10 +19,9 @@ def register
 
   public
   def filter(event)
-
     @clones.each do |type|
       clone = event.clone
-      clone["type"] = type
+      clone.set("type", type)
       filter_matched(clone)
       @logger.debug("Cloned event", :clone => clone, :event => event)
 

logstash-filter-clone.gemspec

@@ -20,7 +20,7 @@ Gem::Specification.new do |s|
   s.metadata = { "logstash_plugin" => "true", "logstash_group" => "filter" }
 
   # Gem dependencies
-  s.add_runtime_dependency "logstash-core-plugin-api", "~> 1.0"
+  s.add_runtime_dependency "logstash-core-plugin-api", "~> 2.0"
 
   s.add_development_dependency 'logstash-devutils'
 end

spec/filters/clone_spec.rb

@@ -20,11 +20,11 @@
       insist { subject.length } == 4
       subject.each_with_index do |s,i|
         if i == 0 # last one should be 'original'
-          insist { s["type"] } == "original"
+          insist { s.get("type") } == "original"
         else
-          insist { s["type"]} == "clone"
+          insist { s.get("type")} == "clone"
         end
-        insist { s["message"] } == "hello world"
+        insist { s.get("message") } == "hello world"
       end
     end
   end
@@ -44,21 +44,21 @@
       insist { subject }.is_a? Array
       insist { subject.length } == 3
 
-      insist { subject[0]["type"] } == "nginx-access"
+      insist { subject[0].get("type") } == "nginx-access"
       #Initial event remains unchanged
-      insist { subject[0]["tags"] }.include? "TESTLOG"
-      reject { subject[0]["tags"] }.include? "RABBIT"
-      reject { subject[0]["tags"] }.include? "NO_ES"
+      insist { subject[0].get("tags") }.include? "TESTLOG"
+      reject { subject[0].get("tags") }.include? "RABBIT"
+      reject { subject[0].get("tags") }.include? "NO_ES"
       #All clones go through filter_matched
-      insist { subject[1]["type"] } == "nginx-access-clone1"
-      reject { subject[1]["tags"] }.include? "TESTLOG"
-      insist { subject[1]["tags"] }.include? "RABBIT"
-      insist { subject[1]["tags"] }.include? "NO_ES"
+      insist { subject[1].get("type") } == "nginx-access-clone1"
+      reject { subject[1].get("tags") }.include? "TESTLOG"
+      insist { subject[1].get("tags") }.include? "RABBIT"
+      insist { subject[1].get("tags") }.include? "NO_ES"
 
-      insist { subject[2]["type"] } == "nginx-access-clone2"
-      reject { subject[2]["tags"] }.include? "TESTLOG"
-      insist { subject[2]["tags"] }.include? "RABBIT"
-      insist { subject[2]["tags"] }.include? "NO_ES"
+      insist { subject[2].get("type") } == "nginx-access-clone2"
+      reject { subject[2].get("tags") }.include? "TESTLOG"
+      insist { subject[2].get("tags") }.include? "RABBIT"
+      insist { subject[2].get("tags") }.include? "NO_ES"
     end
   end
 
@@ -73,8 +73,8 @@
     CONFIG
 
     sample("type" => "bug-1225", "message" => "unused", "number" => 5) do
-      insist { subject[0]["number"] } == 5
-      insist { subject[1]["number"] } == 5
+      insist { subject[0].get("number") } == 5
+      insist { subject[1].get("number") } == 5
     end
   end