Mustache'd /queues page

Author: defunkt

lib/resque/server/templates/queues.mustache

@@ -0,0 +1,73 @@
+{{#queue?}}
+  <h1>Pending jobs on <span class='hl'>{{queue}}</span></h1>
+
+  <form method="POST" action="{{remove_queue_url}}" class='remove-queue'>
+    <input type='submit' name='' value='Remove Queue' />
+  </form>
+
+  <p class='sub'>
+    Showing {{start}}
+    to
+    {{end}}
+    of
+    <b>{{size}}</b>
+    jobs
+  </p>
+
+  <table class='jobs'>
+    <tr>
+      <th>Class</th>
+      <th>Args</th>
+    </tr>
+
+    {{#jobs}}
+    <tr>
+      <td class='class'>{{class}}</td>
+      <td class='args'>{{args}}</td>
+    </tr>
+    {{/jobs}}
+
+    {{#no_jobs}}
+    <tr>
+      <td class='no-data' colspan='2'>
+        There are no pending jobs in this queue
+      </td>
+    </tr>
+    {{/no_jobs}}
+  </table>
+
+  {{> next_more}}
+{{/queue?}}
+
+{{#queues?}}
+  <h1 class='wi'>Queues</h1>
+
+  <p class='intro'>
+    The list below contains all the registered queues with the number
+    of jobs currently in the queue. Select a queue from above to view
+    all jobs currently pending on the queue.
+  </p>
+
+  <table class='queues'>
+    <tr>
+      <th>Name</th>
+      <th>Jobs</th>
+    </tr>
+
+    {{#queues}}
+      <tr>
+        <td class='queue'>
+          <a class="queue" href="{{queue_url}}">{{queue}}</a>
+        </td>
+        <td class='size'>{{size}}</td>
+      </tr>
+    {{/queues}}
+
+    <tr class="{{failure_class}}">
+      <td class='queue failed'>
+        <a class="queue" href="{{failed_url}}">failed</a>
+      </td>
+      <td class='size'>{{failed_count}}</td>
+    </tr>
+  </table>
+{{/queues?}}

lib/resque/server/views/queues.erb

@@ -0,0 +1,69 @@
+module Resque
+  module Views
+    class Queues < Layout
+      def subtabs
+        Resque.queues
+      end
+
+      def queues?
+        !queue?
+      end
+
+      def queues
+        Resque.queues.sort_by { |q| q.to_s }.map do |queue|
+          { :queue => queue }
+        end
+      end
+
+      def queue?
+        queue && { :queue => queue }
+      end
+
+      def queue
+        params[:id]
+      end
+
+      def queue_url
+        u "queues/#{self[:queue]}"
+      end
+
+      def remove_queue_url
+        u "/queues/#{queue}"
+      end
+
+      def start
+        params[:start].to_i
+      end
+
+      def end
+        start + 20
+      end
+
+      def size
+        Resque.size(queue || self[:queue])
+      end
+
+      def jobs
+        Resque.peek(queue, start, 20).map do |job|
+          job.merge('args' => job['args'].inspect)
+        end
+      end
+
+      def no_jobs
+        jobs.empty?
+      end
+
+      def failure_class
+        failed_count.zero? ? :failed : :failure
+      end
+
+      def failed_count
+        Resque::Failure.count
+      end
+
+      def failed_url
+        url :failed
+      end
+    end
+  end
+end