from flup.server.fcgi import WSGIServer
import logging
import json
+import os
import subprocess
import sys
import traceback
+HERE = os.path.abspath(os.path.dirname(__file__))
+ZWRITE = os.path.join(HERE, 'bin', 'zsend')
LOG_FILENAME = 'logs/zcommit.log'
# Set up a specific logger with our desired output level
handler = logging.FileHandler(LOG_FILENAME)
logger.addHandler(handler)
-def zephyr(klass, instance, zsig, msg):
+def zephyr(sender, klass, instance, zsig, msg):
# TODO: spoof the sender
logger.info("""About to send zephyr:
+sender: %(sender)s
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,
+msg: %(msg)s""" % {'sender' : sender,
+ 'klass' : klass,
+ 'instance' : instance,
+ 'zsig' : zsig,
+ 'msg' : msg})
+ cmd = [ZWRITE, '-S', sender, '-c', klass, '-i', instance,
'-s', zsig, '-d', '-m', msg]
- subprocess.check_call(cmd)
+ subprocess.check_call([str(p) for p in cmd])
class Application(object):
@cherrypy.expose
def index(self):
logger.debug('Hello world app reached')
- return 'Hello world!'
+ return """
+<p> <i>Welcome to zcommit.</i> </p>
+
+<p> zcommit allows you to send zephyr notifications by sending an HTTP
+POST request to a URL. Currently zcommit supports POST-backs from
+github. If you would like it to support another form of POST-back,
+please let us know (zcommit@mit.edu). </p>
+
+<h1> URL structure </h1>
+
+The URL you post to is structured as follows:
+<tt>http://zcommit.mit.edu/$type/$key1/$value1/$key2/$value2/...</tt>.
+So for example, the URL
+<tt>http://zcommit.mit.edu/github/class/zcommit/instance/commit</tt>
+is parsed as having type <tt>github</tt>, class <tt>zcommit</tt>, and
+instance <tt>commit</tt>. Using this information, zcommit figures out
+how to form a useful message which is then sends as a zephyr.
+
+<h1> Types </h1>
+
+<h2> Github </h2>
+
+Set your POST-back URL to
+<tt>http://zcommit.mit.edu/github/class/$classname</tt>, followed by
+any of the following optional key/value parameters:
+
+<ul>
+<li> <tt>/instance/$instance</tt> </li>
+<li> <tt>/zsig/$zsig</tt> (sets the prefix of the zsig; the postfix is always the branch name) </li>
+<li> <tt>/sender/$sender</tt> </li>
+</ul>
+"""
class Github(object):
@cherrypy.expose
zsig = payload['ref']
if 'zsig' in opts:
zsig = '%s: %s' % (opts['zsig'], zsig)
+ sender = opts.get('sender', 'daemon.zcommit')
logger.debug('Set zsig')
for c in reversed(payload['commits']):
inst = opts.get('instance', c['id'][:8])
+ actions = []
+ if c.get('added'):
+ actions.append('Added: %s\n' % '\n '.join(c['added']))
+ if c.get('removed'):
+ actions.append('Removed: %s\n' % '\n '.join(c['removed']))
+ if c.get('modified'):
+ actions.append('Modified: %s\n' % '\n '.join(c['modified']))
+ if not actions:
+ actions.append('Did not add/remove/modify any nonempty files.')
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
+ 'actions' : '--\n'.join(actions),
+ 'url' : c['url']}
+
+ msg = """%(name)s <%(email)s> (%(timestamp)s)
+%(url)s
+> %(message)s
--
-%(added)s""" % info
- zephyr(opts['class'], inst, zsig, msg)
+%(actions)s""" % info
+ zephyr(sender, opts['class'], inst, zsig, msg)
msg = 'Thanks for posting!'
else:
msg = ('If you had sent a POST request to this URL, would have sent'