From 08b967d5ac2471b2fcd498ee52c0512a219cfe74 Mon Sep 17 00:00:00 2001
From: Greg Brockman <gdb@mit.edu>
Date: Tue, 23 Mar 2010 04:04:04 -0400
Subject: [PATCH] Made initial zephyring work

---
 zcommit.py | 54 ++++++++++++++++++++++++++++++++++++++++++------------
 1 file changed, 42 insertions(+), 12 deletions(-)

diff --git a/zcommit.py b/zcommit.py
index 59f1678..15a2236 100755
--- a/zcommit.py
+++ b/zcommit.py
@@ -2,11 +2,30 @@
 
 import cherrypy
 from flup.server.fcgi import WSGIServer
+import logging
+import json
 import subprocess
 import sys
+import traceback
+
+LOG_FILENAME = 'logs/zcommit.log'
+
+# Set up a specific logger with our desired output level
+logger = logging.getLogger(__name__)
+logger.setLevel(logging.DEBUG)
+
+# Add the log message handler to the logger
+handler = logging.FileHandler(LOG_FILENAME)
+logger.addHandler(handler)
 
 def zephyr(klass, instance, zsig, msg):
     # TODO: spoof the sender
+    logger.info("""About to send zephyr:
+class: %(klass)s
+instance: %(instance)s
+zsig: %(zsig)s
+msg: %(msg)s""" % {'klass' : klass, 'instance' : instance,
+                 'zsig' : zsig, 'msg' : msg})
     cmd = ['zwrite', '-c', klass, '-i', instance,
            '-s', zsig, '-d', '-m', msg]
     subprocess.check_call(cmd)
@@ -14,42 +33,53 @@ def zephyr(klass, instance, zsig, msg):
 class Application(object):
     @cherrypy.expose
     def index(self):
+        logger.debug('Hello world app reached')
         return 'Hello world!'
 
-    @cherrypy.expose
-    def default(self, *args, **kwargs):
-        return 'hello'
-
     class Github(object):
         @cherrypy.expose
         def default(self, *args, **query):
+            try:
+                return self._default(*args, **query)
+            except Exception, e:
+                logger.error('Caught exception %s:\n%s' % (e, traceback.format_exc()))
+                raise
+
+        def _default(self, *args, **query):
+            logger.info('A %s request with args: %r and query: %r' %
+                        (cherrypy.request.method, args, query))
             opts = {}
             if len(args) % 2:
                 raise cherrypy.HTTPError(400, 'Invalid submission URL')
+            logger.debug('Passed validation')
             for i in xrange(0, len(args), 2):
                 opts[args[i]] = args[i + 1]
-
+            logger.debug('Set opts')
             if 'class' not in opts:
                 raise cherrypy.HTTPError(400, 'Must specify a zephyr class name')
-
+            logger.debug('Specified a class')
             if cherrypy.request.method == 'POST':
+                logger.debug('About to load data')
                 payload = json.loads(query['payload'])
-
+                logger.debug('Loaded payload data')
                 zsig = payload['ref']
                 if 'zsig' in opts:
                     zsig = '%s: %s' % (opts['zsig'], zsig)
-                else:
-                    zsig = 'zcommit bot'
-
+                logger.debug('Set zsig')
                 for c in reversed(payload['commits']):
                     inst = opts.get('instance', c['id'][:8])
-                    c['added_as_str'] = '\n'.join(c['added'])
+                    info = {'name' : c['author']['name'],
+                            'email' : c['author']['email'],
+                            'message' : c['message'],
+                            'timestamp' : c['timestamp'],
+                            'added' :  '\n'.join(c['added'])}
                     msg = """%(name)s <%(email)s>
 %(message)s
 %(timestamp)s
 --
-%(added)s""" % c
+%(added)s""" % info
                     zephyr(opts['class'], inst, zsig, msg)
+                msg = 'Thanks for posting!'
             else:
                 msg = ('If you had sent a POST request to this URL, would have sent'
                        ' a zepyhr to -c %s' % opts['class'])
-- 
2.45.1