basic resweb powered by ity

Author: Matt George

src/resweb/server.py

@@ -23,18 +23,26 @@ def index(request):
 
 @get("/working/")
 def working(request):
-    workers = Worker.working(request.resq._server)
+    workers = Worker.working(resq._server)
     template = env.get_template('working.html')
     dic = {
-        'all_workers':Worker.all(settings.RESQ_HOST),
+        'all_workers':Worker.all(HOST),
         'workers':workers,
         'resq': resq
     }
     return str(template.render(dic))
 
 @get("/queues/")
 def queues(request):
-    return ""
+    queues = ResQ.queues(HOST)
+    failure_count = Failure.count(ResQ(HOST))
+    template = env.get_template('queues.html')
+    dic = {
+        'queues':queues,
+        'failure_count':failure_count,
+        'resq': resq
+    }
+    return str(template.render(dic))
 
 @get('/queues/(?P<queue_id>\w+)/')
 def queue(request, queue_id):
@@ -44,16 +52,25 @@ def queue(request, queue_id):
     template = env.get_template('queue_detail.html')
     return str(template.render(context))
 
-@get(r'/failed/$')
+@get('/failed/')
 def failed(request):
-    return ""
+    context = {
+        'resq': resq
+    }
+    template = env.get_template('failed.html')
+    return str(template.render(context))
 
-@get(r'/workers/$')
+@get('/workers/')
 def workers(request):
-    return ""
+    context = {
+        'workers': Worker.all(HOST)
+    }
+    template = env.get_template('workers.html')
+    return str(template.render(context))
 
-@get(r'/stats/$')
+@get('/stats/')
 def stats(request):
-    return ""
+    template = env.get_template('stats.html')
+    return str(template.render({}))
 
 run_itty()

src/resweb/templates/base.html

@@ -16,7 +16,7 @@
         <li><a href='/failed/'>Failed</a></li>
         <li><a href='/queues/'>Queues</a></li>
         <li><a href='/workers/'>Workers</a></li>
-        <li><a href='/stats'>Stats</a></li>
+        <li><a href='/stats/'>Stats</a></li>
     </ul>
   </div>
   {%block subtabs%}

src/resweb/templates/failed.html

@@ -1 +1,4 @@
-{% extends "base.html" %}
+{% extends "base.html" %}
+{% block main%}
+Coming Soon
+{% endblock%}

src/resweb/templates/queues.html

@@ -1 +1,22 @@
 {% extends "base.html" %}
+{%block main%}
+<h1>Queues</h1>
+<table>
+  <tr>
+    <th>Name</th>
+    <th>Pending</th>
+  </tr>
+  {% for queue in queues %}
+  <tr>
+    <td><a class="queue" href="/queues/{{queue}}/">{{queue}}</a></td>
+    <td>{{ resq.size(queue)}}</td>
+  </tr>
+  {% endfor %}
+  <tr>
+    <td><a class="queue" href="/failed/">failed</a></td>
+    <td>{{failure_count}}</td>
+  </tr>
+</table>
+
+
+{%endblock%}

src/resweb/templates/stat.html

@@ -0,0 +1,4 @@
+{% extends "base.html" %}
+{% block main%}
+Coming Soon
+{% endblock%}

src/resweb/templates/stats.html

@@ -1 +1,32 @@
-{% extends "base.html" %}
+{% extends "base.html" %}
+{% block main%}
+<h1>{{ workers|length }} Workers</h1>
+<table>
+  <tr>
+    <th>&nbsp;</th>
+    <th>Where</th>
+    <th>Queues</th>
+    <th>Processing</th>
+  </tr>
+  {% for worker in workers %}
+  <tr>
+    <td><img src="{{worker.state}}.png" alt="{{worker.state}}" title="{{worker.state}}"></td>
+    {% set host,pid,queues = str(worker).split(':') %}
+    
+    <td><a href="/workers/{{worker}}">{{host}}:{{pid}}</a></td>
+    <td></td>
+
+    <td>
+      {% set data = worker.processing %}
+      
+      {% if data.hasattr('queue') %}
+        <code>{{data['payload']['class']}}</code>
+        <small><a class="queue time" href="/working/{{worker}}" %>">{{data['run_at']}}</a></small>
+      {% else %}
+        Waiting for more
+      {% endif %}
+    </td>
+  </tr>
+  {% endfor %}
+</table>
+{% endblock%}

src/resweb/templates/workers.html

@@ -1,6 +1,6 @@
 {% extends "base.html" %}
 {%block main%}
-<h1>{{len(workers)}} of {{all_workers}} Workers Working</h1>
+<h1>{{ workers|length }} of {{all_workers|length}} Workers Working</h1>
 <table>
   <tr>
     <th>&nbsp;</th>