Use after hook

lib/resque_ext/resque.rb

@@ -1,22 +1,5 @@
 module Resque
   class << self
-    def enqueue_to(queue, klass, *args)
-      # Perform before_enqueue hooks. Don't perform enqueue if any hook returns false
-      before_hooks = Plugin.before_enqueue_hooks(klass).collect do |hook|
-        klass.send(hook, *args)
-      end
-      return nil if before_hooks.any? { |result| result == false }
-
-      result = Job.create(queue, klass, *args)
-      return nil if result == "EXISTED"
-
-      Plugin.after_enqueue_hooks(klass).each do |hook|
-        klass.send(hook, *args)
-      end
-
-      true
-    end
-
     def enqueued?(klass, *args)
       enqueued_in?(queue_from_class(klass), klass, *args)
     end

lib/resque_solo/unique_job.rb

@@ -45,6 +45,14 @@ def ttl
         def lock_after_execution_period
           @lock_after_execution_period ||= 0
         end
+
+        # We want this to run first in before_enqueue_hooks (which are alpha sorted), so name appropriately
+        def before_enqueue_001_solo_job(*args)
+          queue_name = self.instance_variable_get(:@queue)
+          item = { class: self.to_s, args: args }
+          !ResqueSolo::Queue.queued?(queue_name, item)
+        end
+
       end
     end
   end

resque_solo.gemspec

@@ -20,5 +20,7 @@ Gem::Specification.new do |spec|
   spec.add_development_dependency "bundler", "~> 1.6"
   spec.add_development_dependency "fakeredis", "~> 0.4"
   spec.add_development_dependency "minitest", "~> 5.8"
+  spec.add_development_dependency "minitest-reporters", "~> 1.1"
   spec.add_development_dependency "rake", "~> 11.2"
+  spec.add_development_dependency "m", "~> 1.5"
 end

test/resque_test.rb

@@ -12,7 +12,8 @@ class ResqueTest < MiniTest::Spec
   it "enqueues normal jobs" do
     Resque.enqueue FakeJob, "x"
     Resque.enqueue FakeJob, "x"
-    assert_equal 2, Resque.size(:normal)
+    queue_name = FakeJob.instance_variable_get(:@queue)
+    assert_equal 2, Resque.size(queue_name)
   end
 
   it "is not able to report if a non-unique job was enqueued" do
@@ -26,19 +27,25 @@ class ResqueTest < MiniTest::Spec
   describe "#enqueue_to" do
     describe "non-unique job" do
       it "should return true if job was enqueued" do
-        assert Resque.enqueue_to(:normal, FakeJob)
-        assert Resque.enqueue_to(:normal, FakeJob)
+        queue_name = FakeJob.instance_variable_get(:@queue)
+        assert Resque.enqueue_to(queue_name, FakeJob)
+        assert Resque.enqueue_to(queue_name, FakeJob)
       end
     end
 
     describe "unique job" do
+      before do
+        @queue_name = FakeUniqueJob.instance_variable_get(:@queue)
+      end
+
       it "should return true if job was enqueued" do
-        assert Resque.enqueue_to(:normal, FakeUniqueJob)
+        assert Resque.enqueue_to(@queue_name, FakeUniqueJob)
       end
 
       it "should return nil if job already existed" do
-        Resque.enqueue_to(:normal, FakeUniqueJob)
-        assert_nil Resque.enqueue_to(:normal, FakeUniqueJob)
+        Resque.enqueue_to(@queue_name, FakeUniqueJob)
+        assert Resque.enqueued?(FakeUniqueJob)
+        assert_nil Resque.enqueue_to(@queue_name, FakeUniqueJob)
       end
     end
   end

test/test_helper.rb

@@ -4,11 +4,14 @@
 end
 
 require "minitest/autorun"
+require "minitest/reporters"
 require "resque_solo"
 require "fake_jobs"
-require "fakeredis"
+require "fakeredis/minitest"
 begin
   require "pry-byebug"
 rescue LoadError
   # ignore
 end
+
+Minitest::Reporters.use! [Minitest::Reporters::DefaultReporter.new({ color: true })]