Merge pull request #32 from bibendi/feature/add-standalone-mode

Standalone mode

gemfiles/agnostic.gemfile

@@ -1,5 +1,3 @@
-# frozen_string_literal: true
-
 # This file was generated by Appraisal
 
 source "https://rubygems.org"

gemfiles/rails.5.gemfile

@@ -1,5 +1,3 @@
-# frozen_string_literal: true
-
 # This file was generated by Appraisal
 
 source "https://rubygems.org"

gemfiles/rails.6.gemfile

@@ -1,5 +1,3 @@
-# frozen_string_literal: true
-
 # This file was generated by Appraisal
 
 source "https://rubygems.org"

lefthook-local.dip_example.yml

@@ -1,4 +1,4 @@
 pre-commit:
   commands:
     rubocop:
-      runner: dip {cmd}
+      run: dip {cmd}

lefthook.yml

@@ -3,4 +3,4 @@ pre-commit:
     rubocop:
       tags: backend
       glob: "**/*.rb"
-      runner: bundle exec standardrb --fix {staged_files} && git add {staged_files}
+      run: bundle exec standardrb --fix {staged_files} && git add {staged_files}

lib/schked/config.rb

@@ -6,7 +6,8 @@ module Schked
   class Config
     attr_writer :logger,
       :do_not_load_root_schedule,
-      :redis_servers
+      :redis_servers,
+      :standalone
 
     def paths
       @paths ||= []
@@ -35,7 +36,13 @@ def fire_callback(name, *args)
     end
 
     def redis_servers
-      @redis_servers ||= [ENV["REDIS_URL"]]
+      @redis_servers ||= [ENV.fetch("REDIS_URL", "redis://127.0.0.1:6379")]
+    end
+
+    def standalone?
+      @standalone = ENV["RAILS_ENV"] == "test" || ENV["RACK_ENV"] == "test" if @standalone.nil?
+
+      !!@standalone
     end
 
     private

lib/schked/worker.rb

@@ -7,12 +7,12 @@ class Worker
     def initialize(config:)
       @config = config
 
-      @locker = RedisLocker.new(config.redis_servers, lock_ttl: 40_000)
+      @locker = RedisLocker.new(config.redis_servers, lock_ttl: 40_000) unless config.standalone?
       @scheduler = Rufus::Scheduler.new(trigger_lock: locker)
 
       watch_signals
       define_callbacks
-      define_extend_lock
+      define_extend_lock unless config.standalone?
       load_schedule
     end
 

spec/lib/schked/config_spec.rb

@@ -15,4 +15,15 @@
   end
 
   it { expect(config.logger).to be_a(Logger) }
+
+  it { expect(config).to be_standalone }
+
+  context "when RACK_ENV=production" do
+    it "is not standalone" do
+      old_val = ENV["RACK_ENV"]
+      ENV["RACK_ENV"] = "production"
+      expect(config).not_to be_standalone
+      ENV["RACK_ENV"] = old_val
+    end
+  end
 end

spec/lib/schked/worker_spec.rb

@@ -44,6 +44,8 @@
   describe "start" do
     it "starts rufus scheduler" do
       expect_any_instance_of(Rufus::Scheduler).to receive(:join)
+      expect(Schked::RedisLocker).not_to receive(:new)
+      expect_any_instance_of(described_class).not_to receive(:define_extend_lock)
 
       worker.wait
     end
@@ -69,4 +71,16 @@
       expect(logger).to have_received(:info).with(/Finished task: test_task/)
     end
   end
+
+  describe "when is not standalone" do
+    let(:config) { Schked::Config.new.tap { |x| x.standalone = false } }
+
+    it "starts rufus scheduler" do
+      expect_any_instance_of(Rufus::Scheduler).to receive(:join)
+      expect(Schked::RedisLocker).to receive(:new).and_call_original
+      expect_any_instance_of(described_class).to receive(:define_extend_lock).and_call_original
+
+      worker.wait
+    end
+  end
 end

spec/rails_helper.rb

@@ -1,5 +1,7 @@
 # frozen_string_literal: true
 
+ENV["RAILS_ENV"] = "test"
+
 require "bundler/setup"
 require "pry-byebug"
 require "combustion"

spec/spec_helper.rb

@@ -1,5 +1,7 @@
 # frozen_string_literal: true
 
+ENV["RACK_ENV"] = "test"
+
 require "bundler/setup"
 require "pry-byebug"
 require "schked"