sidekiq for endow funds report

.travis.yml

@@ -5,3 +5,5 @@ bundler_args: --without production
 script:
   - bundle exec rake db:test:prepare
   - bundle exec rspec spec/
+services:
+  - redis-server

Capfile

@@ -6,6 +6,7 @@ require 'capistrano/deploy'
 require 'capistrano/bundler'
 require 'capistrano/rails/assets'
 require 'capistrano/passenger'
+require 'capistrano/sidekiq'
 require 'dlss/capistrano'
 
 # Load custom tasks from `lib/capistrano/tasks` if you have any defined

Gemfile

@@ -34,6 +34,8 @@ gem 'faraday'
 gem 'config'
 # Use okcomputer to set up checks to monitor
 gem 'okcomputer'
+# Use sidekiq for background jobs
+gem 'sidekiq'
 
 group :production do
   gem 'activerecord-oracle_enhanced-adapter'
@@ -47,6 +49,7 @@ group :deployment do
   gem 'capistrano-bundler'
   gem 'capistrano-rails'
   gem 'capistrano-passenger'
+  gem 'capistrano-sidekiq'
   gem 'dlss-capistrano'
 end
 

Gemfile.lock

@@ -78,6 +78,9 @@ GEM
       capistrano-bundler (~> 1.1)
     capistrano-releaseboard (0.0.1)
       faraday
+    capistrano-sidekiq (0.10.0)
+      capistrano
+      sidekiq (>= 3.4)
     capybara (2.8.0)
       addressable
       mime-types (>= 1.16)
@@ -91,6 +94,7 @@ GEM
     config (1.3.0)
       activesupport (>= 3.0)
       deep_merge (~> 1.1.1)
+    connection_pool (2.2.1)
     coveralls (0.8.15)
       json (>= 1.8, < 3)
       simplecov (~> 0.12.0)
@@ -150,6 +154,8 @@ GEM
     pkg-config (1.1.7)
     powerpack (0.1.1)
     rack (1.6.4)
+    rack-protection (1.5.3)
+      rack
     rack-test (0.6.3)
       rack (>= 1.0)
     rails (4.2.7.1)
@@ -180,6 +186,7 @@ GEM
     rake (11.2.2)
     rdoc (4.2.2)
       json (~> 1.4)
+    redis (3.3.2)
     ref (2.0.0)
     rspec-core (3.5.2)
       rspec-support (~> 3.5.0)
@@ -219,6 +226,11 @@ GEM
     sdoc (0.4.1)
       json (~> 1.7, >= 1.7.7)
       rdoc (~> 4.0)
+    sidekiq (4.2.7)
+      concurrent-ruby (~> 1.0)
+      connection_pool (~> 2.2, >= 2.2.0)
+      rack-protection (>= 1.5.0)
+      redis (~> 3.2, >= 3.2.1)
     simplecov (0.12.0)
       docile (~> 1.1.0)
       json (>= 1.8, < 3)
@@ -270,6 +282,7 @@ DEPENDENCIES
   capistrano-bundler
   capistrano-passenger
   capistrano-rails
+  capistrano-sidekiq
   capybara
   composite_primary_keys (= 8.1.4)
   config
@@ -287,10 +300,11 @@ DEPENDENCIES
   sass-rails (~> 5.0)
   scss_lint
   sdoc (~> 0.4.0)
+  sidekiq
   sqlite3
   sul_styles
   therubyracer
   web-console (~> 2.0)
 
 BUNDLED WITH
-   1.12.5
+   1.13.6

app/controllers/concerns/endow_funds_params.rb

@@ -11,7 +11,7 @@ def submit_endow_funds(batch_params)
     email(batch_params, report_params)
     fund_str(batch_params, report_params)
     date_range(batch_params, report_params)
-    request_conn('endow_rpt.cgi', report_params)
+    EndowFundsJob.perform_later('endow_rpt.cgi', report_params)
   end
 
   private

app/jobs/endow_funds_job.rb

@@ -0,0 +1,10 @@
+# asychronous processing for endowed funds symphony call
+class EndowFundsJob < ActiveJob::Base
+  include EndowFundsParams
+  include SymphonyCgi
+  queue_as :default
+
+  def perform(*args)
+    request_conn(args[0], args[1])
+  end
+end

config/application.rb

@@ -33,5 +33,6 @@ class Application < Rails::Application
     config.active_record.raise_in_transactional_callbacks = true
     config.autoload_paths += %W(#{config.root}/lib)
     config.sass.load_paths << File.expand_path('../../vendor/assets/stylesheets/')
+    config.active_job.queue_adapter = :sidekiq
   end
 end

config/routes.rb

@@ -1,5 +1,8 @@
 Rails.application.routes.draw do
 
+  require 'sidekiq/web'
+  mount Sidekiq::Web => '/sidekiq'
+
   get 'home/index'
 
   get 'webauth/login' => 'authentication#login', as: :login

spec/jobs/endow_funds_job_spec.rb

@@ -0,0 +1,25 @@
+require 'rails_helper'
+
+RSpec.describe EndowFundsJob, type: :job do
+  include ActiveJob::TestHelper
+
+  subject(:job) { EndowFundsJob.perform_later('endow_rpt.cgi', email: 'test@stanford.edu') }
+
+  it 'queues the job' do
+    expect { job }.to change(ActiveJob::Base.queue_adapter.enqueued_jobs, :size).by(1)
+  end
+
+  it 'is in the default queue' do
+    expect(EndowFundsJob.new.queue_name).to eq('default')
+  end
+
+  it 'executes perform' do
+    # how to test request_conn(args[0], args[1])?
+    perform_enqueued_jobs { job }
+  end
+
+  after do
+    clear_enqueued_jobs
+    clear_performed_jobs
+  end
+end