Maintenence

lib/object_perform_later.rb

@@ -3,28 +3,29 @@ def perform_later(queue, method, *args)
     return self.send(method, *args) unless PerformLater.config.enabled?
 
     worker = PerformLater::Workers::Objects::Worker
-    perform_later_enqueue(worker, queue, method, args)
+    perform_later_enqueue(worker, queue, method, *args)
   end
 
   def perform_later!(queue, method, *args)
     return self.send(method, *args) unless PerformLater.config.enabled?
 
-    return "EXISTS!" if loner_exists(method, args)
+    return "EXISTS!" if loner_exists(method, *args)
 
     worker = PerformLater::Workers::Objects::LoneWorker
-    perform_later_enqueue(worker, queue, method, args)
+    perform_later_enqueue(worker, queue, method, *args)
   end
 
   private 
-    def loner_exists(method, args)
-      digest = PerformLater::PayloadHelper.get_digest(self.name, method, args)
+    def loner_exists(method, *args)
+      digest = PerformLater::PayloadHelper.get_digest(self.name, method, *args)
+
       return true unless Resque.redis.get(digest).blank?
       Resque.redis.set(digest, 'EXISTS')
       return false
     end
 
     def perform_later_enqueue(worker, queue, method, *args)
-      args = PerformLater::ArgsParser.args_to_resque(args)
+      args = PerformLater::ArgsParser.args_to_resque(*args)
       Resque::Job.create(queue, worker, self.name, method, *args)
     end
 end

lib/perform_later/workers/objects/worker.rb

@@ -3,7 +3,7 @@ module Workers
     module Objects
       class Worker
         def self.perform(klass_name, method, *args)
-          args = PerformLater::ArgsParser.args_from_resque(args)
+          args = PerformLater::ArgsParser.args_from_resque(*args)
           klass_name.constantize.send(method, *args)
         end
       end

spec/lib/perform_later/args_parser_spec.rb

@@ -26,8 +26,10 @@
         { something: "eee" }
       ]
       to_resque = subject.args_to_resque(arr).to_json
-      from_resque = subject.args_from_resque(JSON.parse(to_resque))
-
+      puts to_resque
+      a = JSON.parse(to_resque)
+      from_resque = subject.args_from_resque(a)
+
       from_resque.should == arr
     end
 

spec/lib/perform_later/payload_helper_spec.rb

@@ -14,7 +14,6 @@
         }.to_s)
 
       args = PerformLater::ArgsParser.args_to_resque(user)
-      puts args
       subject.get_digest("DummyClass", :some_method, args).should == digest
     end
   end

spec/lib/perform_later/workers/active_record/worker_spec.rb

@@ -0,0 +1,5 @@
+require 'spec_helper'
+
+describe PerformLater::Workers::ActiveRecord::Worker do
+
+end

spec/lib/perform_later/workers/objects/worker_spec.rb

@@ -0,0 +1,15 @@
+require 'spec_helper'
+
+class DummyClass 
+  def self.do_somthing_with_array_of_hashes(arr)
+    arr[0][:foo]
+  end
+end
+
+describe PerformLater::Workers::Objects::Worker do
+  subject { PerformLater::Workers::Objects::Worker }
+
+  it "should pass an array of hashes into the method" do
+
+  end
+end