first push towards a web interface

Matt George · Matt George · commit a6337efc5dc8 · 2009-11-19T14:11:44.000-06:00
diff --git a/src/resweb/__init__.py b/src/resweb/__init__.py
diff --git a/src/resweb/core/__init__.py b/src/resweb/core/__init__.py
diff --git a/src/resweb/core/middleware.py b/src/resweb/core/middleware.py
@@ -0,0 +1,10 @@
+from django.conf import settings
+from pyres import ResQ
+
+class ResQMiddleware(object):
+    def process_request(self, request):
+        resq = ResQ(settings.RESQ_HOST)
+        request.resq = resq
+    def process_response(self,request, response):
+        del request.resq
+        return response
diff --git a/src/resweb/core/models.py b/src/resweb/core/models.py
@@ -0,0 +1,3 @@
+from django.db import models
+
+# Create your models here.
diff --git a/src/resweb/core/templates/failed.html b/src/resweb/core/templates/failed.html
@@ -0,0 +1 @@
+{% extends "base.html" %}
diff --git a/src/resweb/core/templates/overview.html b/src/resweb/core/templates/overview.html
@@ -0,0 +1,22 @@
+{% extends "base.html" %}
+{%block main%}
+<h1>Queues</h1>
+<table>
+  <tr>
+    <th>Name</th>
+    <th>Pending</th>
+  </tr>
+  {% for queue in queue_list %}
+  <tr>
+    <td><a class="queue" href="/queues/{{queue.name}}/">{{queue.name}}</a></td>
+    <td>{{queue.count}}</td>
+  </tr>
+  {% endfor %}
+  <tr>
+    <td><a class="queue" href="{%url failed%}">failed</a></td>
+    <td>{{failure_count}}</td>
+  </tr>
+</table>
+
+
+{%endblock%}
diff --git a/src/resweb/core/templates/queue_detail.html b/src/resweb/core/templates/queue_detail.html
@@ -0,0 +1,18 @@
+{% extends "base.html" %}
+{%block main%}
+<h1>{{queue.count}} Pending Jobs in '{{queue.name}}'</h1>
+<h2>Showing 0 to 20</h2>
+<table>
+  <tr>
+    <th>Class</th>
+    <th>Args</th>
+  </tr>
+  {% for job in waiting %}
+  <tr>
+    <td>{{job.klass }}</td>
+    <td>{{ job.args }}</td>
+  </tr>
+  {% endfor %}
+ 
+</table>
+{%endblock%}
diff --git a/src/resweb/core/templates/queues.html b/src/resweb/core/templates/queues.html
@@ -0,0 +1 @@
+{% extends "base.html" %}
diff --git a/src/resweb/core/templates/stat.html b/src/resweb/core/templates/stat.html
@@ -0,0 +1 @@
+{% extends "base.html" %}
diff --git a/src/resweb/core/templates/workers.html b/src/resweb/core/templates/workers.html
@@ -0,0 +1 @@
+{% extends "base.html" %}
diff --git a/src/resweb/core/templates/working.html b/src/resweb/core/templates/working.html
@@ -0,0 +1,38 @@
+{% extends "base.html" %}
+{%block main%}
+<% workers = resque.working %>
+<h1><%= workers.size %> of <%= resque.workers.size %> Workers Working</h1>
+<table>
+  <tr>
+    <th>&nbsp;</th>
+    <th>Where</th>
+    <th>Queue</th>
+    <th>Processing</th>
+  </tr>
+  <% if workers.empty? %>
+  <tr>
+    <td colspan="4">Not a one.</td>
+  </tr>
+  <% end %>
+
+  <% for worker in workers.sort_by { |w| w.job['run_at'] ? w.job['run_at'] : '' } %>
+    <% job = worker.job %>
+    <tr>
+      <td><img src="<%=u state = worker.state %>.png" alt="<%= state %>" title="<%= state %>"></td>
+      <% host, pid, queues = worker.to_s.split(':') %>
+      <td><a href="<%=u "/workers/#{worker}" %>"><%= host %>:<%= pid %></a></td>
+      <td>
+        <a class="queue" href="<%=u "/queues/#{job['queue']}" %>"><%= job['queue'] %></a>
+      </td>
+      <td>
+        <% if job['queue'] %>
+          <code><%= job['payload']['class'] %></code>
+          <small><a class="queue time" href="<%=u "/working/#{worker}" %>"><%= job['run_at'] %></a></small>
+        <% else %>
+          Waiting for more
+        <% end %>
+      </td>
+    </tr>
+  <% end %>
+</table>
+{%endblock%}
diff --git a/src/resweb/core/views.py b/src/resweb/core/views.py
@@ -0,0 +1,50 @@
+# Create your views here.
+from django.conf import settings
+
+from resweb.decorators import render_to
+from pyres import ResQ
+from pyres.failure import Failure
+class Queue(object):
+    def __init__(self, name, count):
+        self.name = name
+        self.count = count
+    
+
+@render_to('overview.html')
+def index(request):
+    queue_list = []
+    for q in ResQ.queues(settings.RESQ_HOST):
+        q_item = Queue(q,ResQ(settings.RESQ_HOST).size(q))
+        queue_list.append(q_item)
+    failure_count = Failure.count(ResQ(settings.RESQ_HOST))
+    return locals()
+
+@render_to('working.html')
+def working(request):
+    current = request.resq.working()
+    total_workers = len(request.resq.workers())
+    return {}
+
+def failed(request):
+    return {}
+
+@render_to('queues.html')
+def queues(request):
+    queue_list = []
+    for q in ResQ.queues(settings.RESQ_HOST):
+        q_item = Queue(q,ResQ(settings.RESQ_HOST).size(q))
+        queue_list.append(q_item)
+    failure_count = Failure.count(ResQ(settings.RESQ_HOST))
+    return locals()
+
+@render_to('queue_detail.html')
+def queue_detail(request, queue_id):
+    queue = Queue(queue_id,request.resq.size(queue_id))
+    waiting = request.resq.peek(queue_id,0,20)
+    return locals()
+
+def workers(request):
+    return {}
+
+def stats(request):
+    return {}
diff --git a/src/resweb/decorators.py b/src/resweb/decorators.py
@@ -0,0 +1,28 @@
+from django.shortcuts import render_to_response
+from django.http import HttpResponseRedirect, HttpResponse
+from django.template import RequestContext
+
+def render_to(view, post_to=None):
+    def wrapper(fn):
+        def inner(request, *args, **kwargs):
+            # POSTs may be handled by their own function, which then
+            # redirects back to a GET (or to another path if required)
+            if post_to and request.method == 'POST':
+                result = post_to(request, *args, **kwargs)
+                return HttpResponseRedirect(result or str(request.path))
+            
+            result = fn(request, *args, **kwargs)
+            
+            # If result is some sort of HttpResponse, simply return it
+            if isinstance(result, HttpResponse):
+                return result
+            # ...but if it's a string, redirect to it
+            # (a blank string means 'curent path')
+            elif isinstance(result, str):
+                return HttpResponseRedirect(result or request.path)
+            # ...otherwise, it should be the dict for the view
+            else:
+                return render_to_response(view, result,
+                        context_instance=RequestContext(request))
+        return inner
+    return wrapper
diff --git a/src/resweb/manage.py b/src/resweb/manage.py
@@ -0,0 +1,13 @@
+#!/usr/bin/env python
+import sys
+sys.path.insert(0,'../')
+from django.core.management import execute_manager
+try:
+    import settings # Assumed to be in the same directory.
+except ImportError:
+    import sys
+    sys.stderr.write("Error: Can't find the file 'settings.py' in the directory containing %r. It appears you've customized things.\nYou'll have to run django-admin.py, passing it your settings module.\n(If the file settings.py does indeed exist, it's causing an ImportError somehow.)\n" % __file__)
+    sys.exit(1)
+
+if __name__ == "__main__":
+    execute_manager(settings)
diff --git a/src/resweb/settings.py b/src/resweb/settings.py
@@ -0,0 +1,81 @@
+# Django settings for resweb project.
+import os
+DEBUG = True
+TEMPLATE_DEBUG = DEBUG
+
+ADMINS = (
+    # ('Your Name', 'your_email@domain.com'),
+)
+
+MANAGERS = ADMINS
+
+DATABASE_ENGINE = ''           # 'postgresql_psycopg2', 'postgresql', 'mysql', 'sqlite3' or 'oracle'.
+DATABASE_NAME = ''             # Or path to database file if using sqlite3.
+DATABASE_USER = ''             # Not used with sqlite3.
+DATABASE_PASSWORD = ''         # Not used with sqlite3.
+DATABASE_HOST = ''             # Set to empty string for localhost. Not used with sqlite3.
+DATABASE_PORT = ''             # Set to empty string for default. Not used with sqlite3.
+
+# Local time zone for this installation. Choices can be found here:
+# http://en.wikipedia.org/wiki/List_of_tz_zones_by_name
+# although not all choices may be available on all operating systems.
+# If running in a Windows environment this must be set to the same as your
+# system time zone.
+TIME_ZONE = 'America/Chicago'
+
+# Language code for this installation. All choices can be found here:
+# http://www.i18nguy.com/unicode/language-identifiers.html
+LANGUAGE_CODE = 'en-us'
+
+SITE_ID = 1
+
+# If you set this to False, Django will make some optimizations so as not
+# to load the internationalization machinery.
+USE_I18N = True
+
+# Absolute path to the directory that holds media.
+# Example: "/home/media/media.lawrence.com/"
+MEDIA_ROOT = ''
+
+# URL that handles the media served from MEDIA_ROOT. Make sure to use a
+# trailing slash if there is a path component (optional in other cases).
+# Examples: "http://media.lawrence.com", "http://example.com/media/"
+MEDIA_URL = ''
+
+# URL prefix for admin media -- CSS, JavaScript and images. Make sure to use a
+# trailing slash.
+# Examples: "http://foo.com/media/", "/media/".
+ADMIN_MEDIA_PREFIX = '/media/'
+
+# Make this unique, and don't share it with anybody.
+SECRET_KEY = 'tgcp9th301&#vmr*8(fx*t-ygew_dcg3b+7qn4qluuy=wmk&di'
+
+# List of callables that know how to import templates from various sources.
+TEMPLATE_LOADERS = (
+    'django.template.loaders.filesystem.load_template_source',
+    'django.template.loaders.app_directories.load_template_source',
+#     'django.template.loaders.eggs.load_template_source',
+)
+
+MIDDLEWARE_CLASSES = (
+    'django.middleware.common.CommonMiddleware',
+    'django.contrib.sessions.middleware.SessionMiddleware',
+    'django.contrib.auth.middleware.AuthenticationMiddleware',
+    'resweb.core.middleware.ResQMiddleware',
+)
+
+ROOT_URLCONF = 'resweb.urls'
+
+TEMPLATE_DIRS = (
+    os.path.join(os.path.dirname(__file__), "templates"),
+)
+
+INSTALLED_APPS = (
+    'django.contrib.auth',
+    'django.contrib.contenttypes',
+    'django.contrib.sessions',
+    'django.contrib.sites',
+    'resweb.core'
+)
+
+RESQ_HOST="localhost:6379"
diff --git a/src/resweb/templates/base.html b/src/resweb/templates/base.html
@@ -0,0 +1,37 @@
+<!DOCTYPE html>
+<html>
+<head>
+  <title>PyRes.</title>
+  <link href="<%=u 'style.css' %>" media="screen" rel="stylesheet" type="text/css">
+  <link href="<%=u 'tabs.css' %>" media="screen" rel="stylesheet" type="text/css">
+  <script src="<%=u 'jquery-1.3.2.min.js' %>" type="text/javascript"</script>
+  <script src="<%=u 'jquery.relatize_date.js' %>" type="text/javascript"</script>  
+  <script src="<%=u 'ranger.js' %>" type="text/javascript"></script>
+</head>
+<body>
+  
+<div class="navigation" id="top">
+  <div class="tabs">
+    <div id="logo">
+      PyRes - A Resque offshoot
+    </div>
+    <ul>
+        <li><a href='{%url overview %}'>Overview</a></li>
+        <li><a href='{%url working %}'>Working</a></li>
+        <li><a href='{%url failed %}'>Failed</a></li>
+        <li><a href='{%url queues %}'>Queues</a></li>
+        <li><a href='{%url workers %}'>Workers</a></li>
+        <li><a href='{%url stats %}'>Stats</a></li>
+    </ul>
+  </div>
+  {%block subtabs%}
+  {%endblock%}
+</div>
+
+<div id="main">
+  {%block main%}
+  {%endblock%}
+</div>
+
+</body>
+</html>
diff --git a/src/resweb/urls.py b/src/resweb/urls.py
@@ -0,0 +1,23 @@
+from django.conf.urls.defaults import *
+
+# Uncomment the next two lines to enable the admin:
+# from django.contrib import admin
+# admin.autodiscover()
+
+urlpatterns = patterns('',
+    # Example:
+    # (r'^resweb/', include('resweb.foo.urls')),
+    url(r'^$', 'resweb.core.views.index', name='overview'),
+    url(r'^working/$', 'resweb.core.views.working', name='working'),
+    url(r'^queues/$', 'resweb.core.views.queues', name='queues'),
+    url(r'^queues/(?P<queue_id>\w+)/$', 'resweb.core.views.queue_detail', name='queue_detail'),
+    url(r'^failed/$', 'resweb.core.views.failed', name='failed'),
+    url(r'^workers/$', 'resweb.core.views.workers', name='workers'),
+    url(r'^stats/$', 'resweb.core.views.stats', name='stats'),
+    # Uncomment the admin/doc line below and add 'django.contrib.admindocs' 
+    # to INSTALLED_APPS to enable admin documentation:
+    # (r'^admin/doc/', include('django.contrib.admindocs.urls')),
+
+    # Uncomment the next line to enable the admin:
+    # (r'^admin/', include(admin.site.urls)),
+)

Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+from django.db import models`
	`2`	`+`
	`3`	`+# Create your models here.`