Implemented [delayed_jobs] zafu method to list current jobs in the qu…

…eue.

bricks/worker/lib/bricks/worker.rb

@@ -0,0 +1,37 @@
+module Bricks
+  module Worker
+    class Job < ActiveRecord::Base
+      include RubyLess
+      set_table_name :delayed_jobs
+
+      safe_method :run_at => Time, :created_at => Time
+      safe_method :info   => String
+
+      def info
+        obj = YAML.load(self[:handler])
+        if obj.respond_to?(:info)
+          obj.info
+        else
+          obj.inspect
+        end
+      end
+    end # Job
+
+    module ViewMethods
+      include RubyLess
+
+      safe_method :delayed_jobs => [Job]
+
+      def delayed_jobs
+        Bricks::Worker::Job.find(:all,
+          # FIXME: find a way to add site_id to delayed_jobs...
+          #:conditions => ['site_id = ?', current_site.id],
+          :order => 'run_at ASC'
+        )
+      end
+    end # ViewMethods
+  end # Worker
+end
+
+# Make sure the class is loaded before first YAML.load
+Zena::SiteWorker

bricks/worker/zena/init.rb

@@ -7,3 +7,4 @@
   Delayed::Job.const_set("MAX_RUN_TIME", 5.minutes)
 end
 
+Zena::Use.module Bricks::Worker

bricks/worker/zena/test/sites/zena/delayed_jobs.yml

@@ -0,0 +1,16 @@
+zena_index:
+  run_at: 2011-03-21 10:41
+  handler: |
+    --- !ruby/struct:Zena::SiteWorker
+    site_id: 705790410
+    action: :rebuild_index
+    page: 1
+
+ocean_vhash:
+  run_at: 2011-03-21 10:05
+  handler: |
+    --- !ruby/struct:Zena::SiteWorker
+    site_id: 740511775
+    action: :rebuild_vhash
+    page: 1
+

bricks/worker/zena/test/zafu/worker.yml

@@ -0,0 +1,8 @@
+# test_file: ../../../../test/integration/zafu_compiler_test.rb
+default:
+  context:
+    node: 'status'
+    visitor: 'anon'
+  src: "<r:delayed_jobs do='each' join=', '>[<r:run_at format='%Y-%m-%d %H:%M'/> <r:info/>]</r:delayed_jobs>"
+  tem: "/delayed_jobs/"
+  res: "[2011-03-21 10:05 -], [2011-03-21 10:41 rebuild_index, page 1/1]"

config/bricks.yml

@@ -4,7 +4,7 @@ test:
   tags:        ON
   captcha:     ON
   sphinx:      OFF
-  worker:      OFF
+  worker:      ON
 
 development:
   asset_port: 7999

lib/zena/site_worker.rb

@@ -44,5 +44,15 @@ def get_nodes
     def page_count
       (Node.count(:conditions => ['site_id = ?', site_id]) / CHUNK_SIZE) + 1
     end
+
+    # Return a textual description of the operation.
+    def info
+      if site_id == current_site.id
+        "#{action}, #{_('page')} #{page}/#{page_count}"
+      else
+        # Do not show jobs from other sites
+        "-"
+      end
+    end
   end
 end # Zena

test/integration/zafu_compiler_test.rb

@@ -21,6 +21,7 @@ class ZafuCompilerTest < Zena::Controller::TestCase
     'search',
     'site',
     'tags',      # bricks/tags/zena/test/zafu
+    'worker',    # bricks/worker/zena/test/zafu
     'urls',
     'user',
     'version',