Concurrent ruby

.gitignore

@@ -3,4 +3,5 @@
 .tox
 ./idea
 .idea/
-.DS_Store
+.DS_Store
+**/test_pos.txt

fluentd/plugins/ci/pipelines.yml

@@ -0,0 +1,32 @@
+resources:
+  - name: source_repo
+    type: GitRepo
+    configuration:
+      gitProvider: github_integration
+      path: jfrog/log-analytics
+      branches:
+        include: concurrent_ruby
+
+
+pipelines:
+  - name: siem_plugin_test
+    steps:
+      - name: siem_plugin_test_step
+        type: Bash
+        configuration:
+          inputResources:
+            - name: source_repo
+              trigger: true
+          runtime:
+            type: image
+            image:
+              custom:
+                name: ruby
+                tag: '3.0.2'
+                autoPull: true
+        execution:
+          onExecute:
+            - cd $res_source_repo_resourcePath/fluentd/plugins/input/fluent-plugin-jfrog-siem
+            - bundle --version
+            - bundle install
+            - rspec

fluentd/plugins/input/fluent-plugin-jfrog-siem/.rspec

@@ -0,0 +1 @@
+--require spec_helper

fluentd/plugins/input/fluent-plugin-jfrog-siem/Gemfile.lock

@@ -0,0 +1,90 @@
+PATH
+  remote: .
+  specs:
+    fluent-plugin-jfrog-siem (1.0.0)
+      concurrent-ruby (~> 1.1.8)
+      concurrent-ruby-edge
+      fluentd (>= 0.14.10, < 2)
+
+GEM
+  remote: https://rubygems.org/
+  specs:
+    concurrent-ruby (1.1.8)
+    concurrent-ruby-edge (0.6.0)
+      concurrent-ruby (~> 1.1.6)
+    cool.io (1.7.1)
+    diff-lcs (1.4.4)
+    domain_name (0.5.20190701)
+      unf (>= 0.0.5, < 1.0.0)
+    fluentd (1.13.1)
+      bundler
+      cool.io (>= 1.4.5, < 2.0.0)
+      http_parser.rb (>= 0.5.1, < 0.7.0)
+      msgpack (>= 1.3.1, < 2.0.0)
+      serverengine (>= 2.2.2, < 3.0.0)
+      sigdump (~> 0.2.2)
+      strptime (>= 0.2.2, < 1.0.0)
+      tzinfo (>= 1.0, < 3.0)
+      tzinfo-data (~> 1.0)
+      webrick (>= 1.4.2, < 1.8.0)
+      yajl-ruby (~> 1.0)
+    http-accept (1.7.0)
+    http-cookie (1.0.3)
+      domain_name (~> 0.5)
+    http_parser.rb (0.6.0)
+    mime-types (3.3.1)
+      mime-types-data (~> 3.2015)
+    mime-types-data (3.2021.0225)
+    msgpack (1.4.2)
+    netrc (0.11.0)
+    power_assert (2.0.0)
+    rake (12.3.3)
+    rest-client (2.1.0)
+      http-accept (>= 1.7.0, < 2.0)
+      http-cookie (>= 1.0.2, < 2.0)
+      mime-types (>= 1.16, < 4.0)
+      netrc (~> 0.8)
+    rspec (3.10.0)
+      rspec-core (~> 3.10.0)
+      rspec-expectations (~> 3.10.0)
+      rspec-mocks (~> 3.10.0)
+    rspec-core (3.10.1)
+      rspec-support (~> 3.10.0)
+    rspec-expectations (3.10.1)
+      diff-lcs (>= 1.2.0, < 2.0)
+      rspec-support (~> 3.10.0)
+    rspec-mocks (3.10.2)
+      diff-lcs (>= 1.2.0, < 2.0)
+      rspec-support (~> 3.10.0)
+    rspec-support (3.10.2)
+    serverengine (2.2.4)
+      sigdump (~> 0.2.2)
+    sigdump (0.2.4)
+    strptime (0.2.5)
+    test-unit (3.4.2)
+      power_assert
+    tzinfo (2.0.4)
+      concurrent-ruby (~> 1.0)
+    tzinfo-data (1.2021.1)
+      tzinfo (>= 1.0.0)
+    unf (0.1.4)
+      unf_ext
+    unf_ext (0.0.7.7)
+    webrick (1.7.0)
+    yajl-ruby (1.4.1)
+
+PLATFORMS
+  x86_64-darwin-20
+
+DEPENDENCIES
+  bundler (~> 2.0)
+  concurrent-ruby (~> 1.1.8)
+  concurrent-ruby-edge
+  fluent-plugin-jfrog-siem!
+  rake (~> 12.0)
+  rest-client (~> 2.0)
+  rspec (~> 3.10.0)
+  test-unit (~> 3.0)
+
+BUNDLED WITH
+   2.2.3

fluentd/plugins/input/fluent-plugin-jfrog-siem/Rakefile

@@ -4,7 +4,7 @@ Bundler::GemHelper.install_tasks
 require "rake/testtask"
 
 Rake::TestTask.new(:test) do |t|
-  t.libs.push("lib", "test")
+  t.libs.push("lib", "test", 'lib/fluent/plugin')
   t.test_files = FileList["test/**/test_*.rb"]
   t.verbose = true
   t.warning = false

fluentd/plugins/input/fluent-plugin-jfrog-siem/fluent-plugin-jfrog-siem.gemspec

@@ -3,7 +3,7 @@ $LOAD_PATH.unshift(lib) unless $LOAD_PATH.include?(lib)
 
 Gem::Specification.new do |spec|
   spec.name    = "fluent-plugin-jfrog-siem"
-  spec.version = "1.0.0"
+  spec.version = "2.0.0"
   spec.authors = ["John Peterson", "Mahitha Byreddy"]
   spec.email   = ["johnp@jfrog.com", "mahithab@jfrog.com"]
 
@@ -24,7 +24,12 @@ Gem::Specification.new do |spec|
   spec.add_development_dependency "rake", "~> 12.0"
   spec.add_development_dependency "test-unit", "~> 3.0"
   spec.add_development_dependency "rest-client", "~> 2.0"
-  spec.add_development_dependency "thread", "~> 0.2.2"
-  spec.add_runtime_dependency "thread", "~> 0.2.2"
+  spec.add_development_dependency "concurrent-ruby", "~> 1.1.8"
+  spec.add_development_dependency "concurrent-ruby-edge", '>= 0'
+  spec.add_development_dependency 'rspec', '~> 3.10.0'
+
+  spec.add_runtime_dependency "rest-client", "~> 2.0"
+  spec.add_runtime_dependency "concurrent-ruby", "~> 1.1.8"
+  spec.add_runtime_dependency "concurrent-ruby-edge", '>= 0'
   spec.add_runtime_dependency "fluentd", [">= 0.14.10", "< 2"]
 end