feat(sidekiq): sidekiq-scheduler

Author: marsz

Gemfile

@@ -37,7 +37,7 @@ gem 'turbolinks', '~> 5'
 # background jobs
 gem 'sidekiq'
 gem 'sidekiq-limit_fetch'
-gem 'sidetiq'
+gem 'sidekiq-scheduler'
 gem 'sinatra', '~> 2.0.0.beta2'
 
 # file upload

Gemfile.lock

@@ -111,23 +111,6 @@ GEM
       activemodel (>= 4.0.0)
       activesupport (>= 4.0.0)
       mime-types (>= 1.16)
-    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)
     coffee-rails (4.2.2)
       coffee-script (>= 2.2.0)
       railties (>= 4.0.0)
@@ -156,6 +139,8 @@ GEM
       dotenv (= 2.2.1)
       railties (>= 3.2, < 5.2)
     erubi (1.6.1)
+    et-orbi (1.0.5)
+      tzinfo
     excon (0.59.0)
     execjs (2.7.0)
     factory_girl (4.8.0)
@@ -186,12 +171,10 @@ GEM
       activesupport (>= 4.2.0)
     hashdiff (0.3.6)
     hashie (3.5.6)
-    hitimes (1.2.6)
     http-cookie (1.0.3)
       domain_name (~> 0.5)
     http_logger (0.5.1)
     i18n (0.8.6)
-    ice_cube (0.14.0)
     ipaddress (0.8.3)
     jbuilder (2.7.0)
       activesupport (>= 4.2.0)
@@ -377,6 +360,8 @@ GEM
     ruby-progressbar (1.8.3)
     ruby_dep (1.5.0)
     rubyzip (1.2.1)
+    rufus-scheduler (3.4.2)
+      et-orbi (~> 1.0)
     safe_yaml (1.0.4)
     sass (3.5.1)
       sass-listen (~> 4.0.0)
@@ -402,10 +387,11 @@ GEM
       redis (~> 3.3, >= 3.3.3)
     sidekiq-limit_fetch (3.4.0)
       sidekiq (>= 4)
-    sidetiq (0.7.2)
-      celluloid (>= 0.17.3)
-      ice_cube (~> 0.14.0)
-      sidekiq (>= 4.1.0)
+    sidekiq-scheduler (2.1.7)
+      redis (~> 3)
+      rufus-scheduler (~> 3.2)
+      sidekiq (>= 3)
+      tilt (>= 1.4.0)
     simple_form (3.5.0)
       actionpack (> 4, < 5.2)
       activemodel (> 4, < 5.2)
@@ -441,8 +427,6 @@ GEM
     thread_safe (0.3.6)
     tilt (2.0.8)
     timecop (0.9.1)
-    timers (4.1.2)
-      hitimes
     turbolinks (5.0.1)
       turbolinks-source (~> 5)
     turbolinks-source (5.0.3)
@@ -534,7 +518,7 @@ DEPENDENCIES
   settingslogic
   sidekiq
   sidekiq-limit_fetch
-  sidetiq
+  sidekiq-scheduler
   simple_form
   sinatra (~> 2.0.0.beta2)
   sitemap_generator

app/schedulers/base_scheduler.rb

@@ -0,0 +1,9 @@
+require 'sidekiq-scheduler'
+
+class BaseScheduler
+  include Sidekiq::Worker
+
+  def perform
+    raise NotImplementedError, 'perform'
+  end
+end

app/schedulers/example_scheduler.rb

@@ -0,0 +1,7 @@
+class ExampleScheduler < BaseScheduler
+
+  def perform(*args)
+    metadata = args.last
+    puts metadata.inspect
+  end
+end

config/initializers/sidekiq_scheudler.rb

@@ -0,0 +1,8 @@
+require 'sidekiq/scheduler'
+
+Sidekiq.configure_server do |config|
+  config.on(:startup) do
+    Sidekiq.schedule = YAML.load_file(Rails.root.join('config', 'sidekiq_scheduler.yml'))
+    Sidekiq::Scheduler.reload_schedule!
+  end
+end

config/routes.rb

@@ -1,4 +1,5 @@
 require 'sidekiq/web'
+require 'sidekiq-scheduler/web'
 
 Rails.application.routes.draw do
   devise_for :users

config/sidekiq_scheduler.yml

@@ -0,0 +1,19 @@
+example1:
+  # https://github.com/jmettraux/rufus-scheduler
+  every: '1h'
+  class: 'ExampleScheduler'
+  description: 'Example 1'
+  queue: 'default'
+  enabled: true
+  include_metadata: true
+  dynamic: true
+  dynamic_every: '60s'
+example2:
+  every: '1d'
+  class: 'ExampleScheduler'
+  description: 'Example 2'
+  queue: 'default'
+  enabled: true
+  include_metadata: true
+  dynamic: true
+  dynamic_every: '60s'