andreaseger · September 6, 2011 14:17 · Sep 6, 2011
diff --git a/config-initializers-resque.rb b/config-initializers-resque.rb
@@ -0,0 +1,10 @@
+rails_root = ENV['RAILS_ROOT'] || File.dirname(__FILE__) + '/../..'
+rails_env = ENV['RAILS_ENV'] || 'development'
+
+resque_config = YAML.load_file(rails_root + '/config/resque.yml')
+Resque.redis = resque_config[rails_env]
+
+#secure the admin view of resque
+Resque::Server.use(Rack::Auth::Basic) do |user, password|
+    password == "secret"
+end
diff --git a/config-resque.yml b/config-resque.yml
@@ -0,0 +1,3 @@
+development: localhost:6379:6
+test: localhost:6379:12
+production: localhost:6379:3
diff --git a/lib-carrierwave_resque_job.rb b/lib-carrierwave_resque_job.rb
@@ -0,0 +1,30 @@
+module CarrierWave
+  module Resque
+    module Job
+      module ActiveRecordInterface
+        def delay_carrierwave
+          @delay_carrierwave ||= true
+        end
+
+        def delay_carrierwave=(delay)
+          @delay_carrierwave = delay
+        end
+      end
+      def self.included(base)
+        base.extend ClassMethods
+      end
+      module ClassMethods
+        def self.extended(base)
+          base.send(:include, InstanceMethods)
+          base.alias_method_chain :process!, :delay
+          ::ActiveRecord::Base.send(:include, CarrierWave::Resque::Job::ActiveRecordInterface)
+        end
+        module InstanceMethods
+          def process_with_delay!(new_file)
+            process_without_delay!(new_file) unless model.delay_carrierwave
+          end
+        end
+      end
+    end
+  end
+end
diff --git a/lib-tasks-resque.rake b/lib-tasks-resque.rake
@@ -0,0 +1,4 @@
+require "resque/tasks"
+
+#to load the rails env in every worker
+task "resque:setup" => :environment
diff --git a/more_stuff.rb b/more_stuff.rb
@@ -0,0 +1,6 @@
+## at some point do this(id is my picture_id)
+Resque.enqueue(ImageProcessor, id)
+
+#mount the nice user interface(add this to config/routes.rb)
+mount Resque::Server.new, :at => '/resque'
+
diff --git a/worker-image_processor.rb b/worker-image_processor.rb
@@ -0,0 +1,19 @@
+class ImageProcessor
+  @queue = :image_proccesor_queue
+  def self.perform(picture_id)
+    picture = Picture.find(picture_id)
+    `convert public#{picture.image_url} -resize 64x64\\> public#{picture.image_url(:thumb)}`
+  end
+end
+
+### or better but didn't work or me
+
+class ImageProcessor
+  @queue = :image_proccesor_queue
+  def self.perform(picture_id)
+    picture = Picture.find(picture_id)
+    picture.image.versions.each_pair do |key,value|
+      value.process_without_delay!
+    end
+  end
+end