merged in master

README.md

@@ -2,13 +2,37 @@
 
 Drip is continuous integration for npm.
 
+## Running
+
+Starting the entire application:
+
+    node script/init.js
+
+Starting just a worker:
+
+    node script/worker.js
+
 ## Requirements
 
 drip has the following requirements:
 
 * redis (for resque, and scheduling and working of builds)
 * mongodb (for storage of build statistics)
 
+## Compiling
+
+    coffee -c **/*.coffee
+
+## Testing
+
+    npm test
+
+## Running
+
+Be sure to have the following environment variables set:
+
+    MONGO_URL, REDIS_URL
+
 ## Authors
 
 drip was written by [Christopher Meiklejohn](mailto:christopher.meiklejohn@gmail.com), [Simon Højberg](http://twitter.com/shojberg), and Barnaby Claydon for the [2011 Node Knockout](http://nodeknockout.com).

config/app.coffee

@@ -0,0 +1,27 @@
+express = exports.express = require 'express'
+app     = exports.app     = express.createServer()
+
+app.configure ->
+  app.set 'views', __dirname + '/../views'
+  app.use express.static __dirname + '/../public'
+  app.use express.bodyParser()
+  app.use express.methodOverride()
+  app.use express.cookieParser()
+  app.use express.logger()
+  app.use app.router
+  app.set 'view engine', 'jade'
+
+credentials   = require './credentials'
+routes        = require './routes'
+mongoose      = require './mongoose'
+environments  = require './environments'
+
+exports.start = (port) ->
+  app.listen port, ->
+    console.log 'Ready'
+
+    if process.getuid() == 0
+      require('fs').stat __filename, (err, stats) ->
+        process.setuid stats.uid
+
+    console.log 'Listening on ' + app.address().port

config/app.js

@@ -0,0 +1,30 @@
+(function() {
+  var app, credentials, environments, express, mongoose, routes;
+  express = exports.express = require('express');
+  app = exports.app = express.createServer();
+  app.configure(function() {
+    app.set('views', __dirname + '/../views');
+    app.use(express.static(__dirname + '/../public'));
+    app.use(express.bodyParser());
+    app.use(express.methodOverride());
+    app.use(express.cookieParser());
+    app.use(express.logger());
+    app.use(app.router);
+    return app.set('view engine', 'jade');
+  });
+  credentials = require('./credentials');
+  routes = require('./routes');
+  mongoose = require('./mongoose');
+  environments = require('./environments');
+  exports.start = function(port) {
+    return app.listen(port, function() {
+      console.log('Ready');
+      if (process.getuid() === 0) {
+        require('fs').stat(__filename, function(err, stats) {
+          return process.setuid(stats.uid);
+        });
+      }
+      return console.log('Listening on ' + app.address().port);
+    });
+  };
+}).call(this);

config/credentials.coffee

@@ -0,0 +1,15 @@
+app  = require('../config/app').app
+http = require('http')
+url  = require('url')
+
+mongo_url = process.env.MONGO_URL
+redis_url = process.env.REDIS_URL
+redis_uri = url.parse(redis_url)
+
+app.set 'credentials'
+  redis:
+    host: redis_uri.hostname
+    port: redis_uri.port
+    pass: redis_uri.auth.split(':')[1]
+  mongo:
+    url:  mongo_url

config/credentials.js

@@ -1,12 +1,19 @@
-var app = require('../server').app;
-
-app.set('credentials', {
-  redis: { 
-    host: process.env.REDIS_HOST,
-    port: process.env.REDIS_PORT,
-    pass: process.env.REDIS_PASS
-  }, 
-  mongo: { 
-    url:  process.env.MONGO_URL
-  }
-});
+(function() {
+  var app, http, mongo_url, redis_uri, redis_url, url;
+  app = require('../config/app').app;
+  http = require('http');
+  url = require('url');
+  mongo_url = process.env.MONGO_URL;
+  redis_url = process.env.REDIS_URL;
+  redis_uri = url.parse(redis_url);
+  app.set('credentials', {
+    redis: {
+      host: redis_uri.hostname,
+      port: redis_uri.port,
+      pass: redis_uri.auth.split(':')[1]
+    },
+    mongo: {
+      url: mongo_url
+    }
+  });
+}).call(this);

config/environments.coffee

@@ -0,0 +1,13 @@
+app     = require('../config/app').app
+express = require('../config/app').express
+
+app.configure 'test', 'development', ->
+  app.use express.errorHandler
+    dumpExceptions: true
+    showStack: true
+
+app.configure 'production', ->
+  app.use express.errorHandler
+
+app.configure 'development', 'production', ->
+  sockets = require '../lib/sockets'

config/environments.js

@@ -1,10 +1,18 @@
-var app     = require('../server').app,
-    express = require('../server').express;
-
-app.configure('test', 'development', function() {
-  app.use(express.errorHandler({ dumpExceptions: true, showStack: true })); 
-});
-
-app.configure('production', function() {
-  app.use(express.errorHandler()); 
-});
+(function() {
+  var app, express;
+  app = require('../config/app').app;
+  express = require('../config/app').express;
+  app.configure('test', 'development', function() {
+    return app.use(express.errorHandler({
+      dumpExceptions: true,
+      showStack: true
+    }));
+  });
+  app.configure('production', function() {
+    return app.use(express.errorHandler);
+  });
+  app.configure('development', 'production', function() {
+    var sockets;
+    return sockets = require('../lib/sockets');
+  });
+}).call(this);

config/mongoose.coffee

@@ -0,0 +1,7 @@
+mongoose = require 'mongoose'
+app      = require('../config/app').app
+creds    = app.set('credentials').mongo
+
+exports.Connection = mongoose.connect creds.url, (err) ->
+  if err
+    throw err

config/mongoose.js

@@ -1,8 +1,11 @@
-var mongoose = require('mongoose'),
-    app      = require('../server').app,
-    url      = app.set('credentials').mongo.url;
-
-module.exports = mongoose.connect(url, function(err) { 
-  if (err) throw err;
-  console.log('Connected to Mongo');
-});
+(function() {
+  var app, creds, mongoose;
+  mongoose = require('mongoose');
+  app = require('../config/app').app;
+  creds = app.set('credentials').mongo;
+  exports.Connection = mongoose.connect(creds.url, function(err) {
+    if (err) {
+      throw err;
+    }
+  });
+}).call(this);

config/redis.coffee

@@ -0,0 +1,14 @@
+redis   = require('redis')
+app     = require('../config/app').app
+creds   = app.set('credentials').redis
+
+client = redis.createClient(creds.port, creds.host)
+
+client.auth app.set('credentials').redis.pass, (err) ->
+  if err
+    throw err
+
+client.on 'error', (err) ->
+  console.log 'Redis connection error: ' + err
+
+exports.Connection = client

config/redis.js

@@ -1,22 +1,16 @@
-var redis = require('redis'),
-    app   = require('../server').app;
-
-var client = redis.createClient(
-  app.set('credentials').redis.port,
-  app.set('credentials').redis.host
-);
-
-client.auth(app.set('credentials').redis.pass, function(err) {
-  if(err) throw err;
-  console.log("Redis authenticated!");
-});
-
-client.on("error", function (err) {
-  console.log("Redis connection error: " + err);
-});
-
-client.on("connect", function (err) {
-  console.log('Connected to Redis');
-});
-
-module.exports = client;
+(function() {
+  var app, client, creds, redis;
+  redis = require('redis');
+  app = require('../config/app').app;
+  creds = app.set('credentials').redis;
+  client = redis.createClient(creds.port, creds.host);
+  client.auth(app.set('credentials').redis.pass, function(err) {
+    if (err) {
+      throw err;
+    }
+  });
+  client.on('error', function(err) {
+    return console.log('Redis connection error: ' + err);
+  });
+  exports.Connection = client;
+}).call(this);

config/resque.coffee

@@ -0,0 +1,8 @@
+resque  = require 'coffee-resque'
+app     = require('../config/app').app
+creds   = app.set('credentials').redis
+
+exports.Connection = resque.connect
+  host: creds.host
+  port: creds.port
+  password: creds.pass

config/resque.js

@@ -1,10 +1,11 @@
-var resque  = require('coffee-resque'),
-    app     = require('../server').app;
-
-module.exports = resque.connect({ 
-  host: app.set('credentials').redis.host,
-  port: app.set('credentials').redis.port,
-  password: app.set('credentials').redis.pass
-});
-
-console.log('Connected to Redis');
+(function() {
+  var app, creds, resque;
+  resque = require('coffee-resque');
+  app = require('../config/app').app;
+  creds = app.set('credentials').redis;
+  exports.Connection = resque.connect({
+    host: creds.host,
+    port: creds.port,
+    password: creds.pass
+  });
+}).call(this);

config/routes.coffee

@@ -0,0 +1,20 @@
+app = require('../config/app').app
+
+Index        = require '../controllers/index'
+Repositories = require '../controllers/repositories'
+Builds       = require '../controllers/builds'
+Receiver     = require '../controllers/receiver'
+
+app.get   '/', Index.index
+app.post  '/', Receiver.receive
+
+app.get   '/repositories',                  Repositories.list
+app.post  '/repositories',                  Repositories.create
+app.get   '/repositories/:ownerName',       Repositories.list
+app.get   '/repositories/:ownerName/:name', Repositories.show
+app.del   '/repositories/:ownerName/:name', Repositories.destroy
+
+app.get   '/repositories/:ownerName/:name/builds',      Builds.list
+app.get   '/repositories/:ownerName/:name/builds/:id',  Builds.show
+
+app.post  '/receive', Receiver.receive

config/routes.js

@@ -1,20 +1,18 @@
-var app = require('../server').app;
-
-var Index        = require('../controllers/index');
-    Repositories = require('../controllers/repositories');
-    Builds       = require('../controllers/builds');
-    Receiver     = require('../controllers/receiver');
-
-app.get('/', Index.index);
-app.post('/', Receiver.receive);
-
-app.get('/repositories', Repositories.list);
-app.post('/repositories', Repositories.create);
-app.get('/repositories/:ownerName', Repositories.list);
-app.get('/repositories/:ownerName/:name', Repositories.show);
-app.del('/repositories/:ownerName/:name', Repositories.destroy);
-
-app.get('/repositories/:ownerName/:name/builds', Builds.list);
-app.get('/repositories/:ownerName/:name/builds/:id', Builds.show);
-
-app.post('/receive', Receiver.receive);
+(function() {
+  var Builds, Index, Receiver, Repositories, app;
+  app = require('../config/app').app;
+  Index = require('../controllers/index');
+  Repositories = require('../controllers/repositories');
+  Builds = require('../controllers/builds');
+  Receiver = require('../controllers/receiver');
+  app.get('/', Index.index);
+  app.post('/', Receiver.receive);
+  app.get('/repositories', Repositories.list);
+  app.post('/repositories', Repositories.create);
+  app.get('/repositories/:ownerName', Repositories.list);
+  app.get('/repositories/:ownerName/:name', Repositories.show);
+  app.del('/repositories/:ownerName/:name', Repositories.destroy);
+  app.get('/repositories/:ownerName/:name/builds', Builds.list);
+  app.get('/repositories/:ownerName/:name/builds/:id', Builds.show);
+  app.post('/receive', Receiver.receive);
+}).call(this);