specs and travis

.gitignore

@@ -0,0 +1,68 @@
+# bundler state
+/.bundle
+/vendor/bundle/
+/vendor/ruby/
+/ruby/
+app.god
+
+# minimal Rails specific artifacts
+db/*.sqlite3
+/log/development.log
+/log/production.log
+/log/test.log
+/tmp/*
+*.gem
+*.~
+
+# various artifacts
+**.war
+*.rbc
+*.sassc
+.byebug_history
+.redcar/
+.capistrano/
+.sass-cache
+/config/god/sidekiq.rb
+/config/puma.rb
+/coverage.data
+/coverage/
+/doc/api/
+/doc/app/
+/doc/yard
+/doc/features.html
+/doc/specs.html
+/spec/tmp/*
+/cache
+/capybara*
+/capybara-*.html
+/gems
+/specifications
+rerun.txt
+pickle-email-*.html
+
+# If you find yourself ignoring temporary files generated by your text editor
+# or operating system, you probably want to add a global ignore instead:
+#   git config --global core.excludesfile ~/.gitignore_global
+#
+# Here are some files you may want to ignore globally:
+
+# scm revert files
+**.orig
+
+# Mac finder artifacts
+.DS_Store
+
+# Netbeans project directory
+/nbproject
+
+# RubyMine project files
+.idea
+
+# Textmate project files
+/*.tmproj
+
+# vim artifacts
+**.swp
+
+# documentation
+.yardoc

.rspec

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

.ruby-gemset

@@ -0,0 +1 @@
+karafka-sidekiq-backend

.ruby-version

@@ -0,0 +1 @@
+2.4.1

.travis.yml

@@ -0,0 +1,16 @@
+language: ruby
+sudo: false
+rvm:
+  - 2.3.0
+  - 2.3.1
+  - 2.3.2
+  - 2.3.3
+  - 2.3.4
+  - 2.4.0
+  - 2.4.1
+  - jruby-9.1.12.0
+script: bundle exec rspec spec/
+env:
+  global:
+    - JRUBY_OPTS='--debug'
+install: bundle install --jobs=3 --retry=3

Gemfile

@@ -2,5 +2,11 @@
 
 source 'https://rubygems.org'
 
-# Specify your gem's dependencies in capistrano-karafka.gemspec
 gemspec
+
+group :development, :test do
+  gem 'karafka', github: 'karafka/karafka', branch: '#147'
+  gem 'timecop'
+  gem 'rspec'
+  gem 'simplecov'
+end

Gemfile.lock

@@ -0,0 +1,147 @@
+GIT
+  remote: git://github.com/karafka/karafka.git
+  revision: 0df386aba9f72bcd4a451e5145e8074551a7109b
+  branch: #147
+  specs:
+    karafka (0.6.0.rc2)
+      activesupport (>= 5.0)
+      celluloid
+      dry-configurable (~> 0.7)
+      dry-validation (~> 0.11)
+      envlogic (~> 1.0)
+      multi_json (>= 1.12)
+      rake (>= 11.3)
+      require_all (>= 1.4)
+      ruby-kafka (>= 0.4)
+      thor (~> 0.19)
+      waterdrop (>= 0.4)
+
+PATH
+  remote: .
+  specs:
+    karafka-sidekiq-backend (1.0.0)
+      karafka (>= 0.5)
+      sidekiq (>= 4.2)
+
+GEM
+  remote: https://rubygems.org/
+  specs:
+    activesupport (5.1.3)
+      concurrent-ruby (~> 1.0, >= 1.0.2)
+      i18n (~> 0.7)
+      minitest (~> 5.1)
+      tzinfo (~> 1.1)
+    celluloid (0.17.3)
+      celluloid-essentials
+      celluloid-extras
+      celluloid-fsm
+      celluloid-pool
+      celluloid-supervision
+      timers (>= 4.1.1)
+    celluloid-essentials (0.20.5)
+      timers (>= 4.1.1)
+    celluloid-extras (0.20.5)
+      timers (>= 4.1.1)
+    celluloid-fsm (0.20.5)
+      timers (>= 4.1.1)
+    celluloid-pool (0.20.5)
+      timers (>= 4.1.1)
+    celluloid-supervision (0.20.6)
+      timers (>= 4.1.1)
+    concurrent-ruby (1.0.5)
+    connection_pool (2.2.1)
+    diff-lcs (1.3)
+    docile (1.1.5)
+    dry-configurable (0.7.0)
+      concurrent-ruby (~> 1.0)
+    dry-container (0.6.0)
+      concurrent-ruby (~> 1.0)
+      dry-configurable (~> 0.1, >= 0.1.3)
+    dry-core (0.3.3)
+      concurrent-ruby (~> 1.0)
+    dry-equalizer (0.2.0)
+    dry-logic (0.4.1)
+      dry-container (~> 0.2, >= 0.2.6)
+      dry-core (~> 0.2)
+      dry-equalizer (~> 0.2)
+    dry-types (0.11.1)
+      concurrent-ruby (~> 1.0)
+      dry-configurable (~> 0.1)
+      dry-container (~> 0.3)
+      dry-core (~> 0.2, >= 0.2.1)
+      dry-equalizer (~> 0.2)
+      dry-logic (~> 0.4, >= 0.4.0)
+      inflecto (~> 0.0.0, >= 0.0.2)
+    dry-validation (0.11.0)
+      concurrent-ruby (~> 1.0)
+      dry-configurable (~> 0.1, >= 0.1.3)
+      dry-core (~> 0.2, >= 0.2.1)
+      dry-equalizer (~> 0.2)
+      dry-logic (~> 0.4, >= 0.4.0)
+      dry-types (~> 0.11.0)
+    envlogic (1.0.4)
+      activesupport
+    hitimes (1.2.6)
+    i18n (0.8.6)
+    inflecto (0.0.2)
+    json (2.1.0)
+    minitest (5.10.3)
+    multi_json (1.12.1)
+    null-logger (0.1.4)
+    rack (2.0.3)
+    rack-protection (2.0.0)
+      rack
+    rake (12.0.0)
+    redis (3.3.3)
+    require_all (1.4.0)
+    rspec (3.6.0)
+      rspec-core (~> 3.6.0)
+      rspec-expectations (~> 3.6.0)
+      rspec-mocks (~> 3.6.0)
+    rspec-core (3.6.0)
+      rspec-support (~> 3.6.0)
+    rspec-expectations (3.6.0)
+      diff-lcs (>= 1.2.0, < 2.0)
+      rspec-support (~> 3.6.0)
+    rspec-mocks (3.6.0)
+      diff-lcs (>= 1.2.0, < 2.0)
+      rspec-support (~> 3.6.0)
+    rspec-support (3.6.0)
+    ruby-kafka (0.4.1)
+    sidekiq (5.0.4)
+      concurrent-ruby (~> 1.0)
+      connection_pool (~> 2.2, >= 2.2.0)
+      rack-protection (>= 1.5.0)
+      redis (~> 3.3, >= 3.3.3)
+    simplecov (0.15.0)
+      docile (~> 1.1.0)
+      json (>= 1.8, < 3)
+      simplecov-html (~> 0.10.0)
+    simplecov-html (0.10.2)
+    thor (0.20.0)
+    thread_safe (0.3.6)
+    timecop (0.9.1)
+    timers (4.1.2)
+      hitimes
+    tzinfo (1.2.3)
+      thread_safe (~> 0.1)
+    waterdrop (0.4.0)
+      bundler
+      connection_pool
+      dry-configurable (~> 0.6)
+      null-logger
+      rake
+      ruby-kafka (~> 0.4)
+
+PLATFORMS
+  ruby
+
+DEPENDENCIES
+  karafka!
+  karafka-sidekiq-backend!
+  rspec
+  simplecov
+  timecop
+
+BUNDLED WITH
+   1.15.4

karafka-sidekiq-backend.gemspec

@@ -4,8 +4,6 @@ lib = File.expand_path('../lib', __FILE__)
 $LOAD_PATH.unshift(lib) unless $LOAD_PATH.include?(lib)
 require 'karafka/backends/sidekiq'
 
-p Karafka::Backends::Sidekiq::VERSION
-
 Gem::Specification.new do |spec|
   spec.name        = 'karafka-sidekiq-backend'
   spec.version     = Karafka::Backends::Sidekiq::VERSION

spec/backends/sidekiq_spec.rb → spec/lib/backends/sidekiq_spec.rb

@@ -4,7 +4,7 @@
   subject(:controller) { controller_class.new }
 
   let(:controller_class) { Class.new(Karafka::BaseController) }
-  let(:interchanger) { Karafka::Params::Interchanger }
+  let(:interchanger) { Karafka::Interchanger }
   let(:params_batch) { [OpenStruct.new(value: rand.to_s)] }
   let(:interchanged_data) { params_batch }
   let(:topic) do

spec/params/interchanger_spec.rb → spec/lib/interchanger_spec.rb

@@ -1,6 +1,6 @@
 # frozen_string_literal: true
 
-RSpec.describe Karafka::Params::Interchanger do
+RSpec.describe Karafka::Interchanger do
   subject(:interchanger_class) { described_class }
 
   let(:params) { double }