probot/server.js

const process = require('process');
const http = require('http');
const createHandler = require('github-webhook-handler');
const GitHubApi = require('github');
const debug = require('debug')('PRobot');
const Configuration = require('./lib/configuration');
const Dispatcher = require('./lib/dispatcher');

const PORT = process.env.PORT || 3000;
const webhook = createHandler({path: '/', secret: process.env.WEBHOOK_SECRET || 'development'});

debug('Starting');

const github = new GitHubApi({debug: false});

github.authenticate({
  type: 'token',
  token: process.env.GITHUB_TOKEN
});

http.createServer((req, res) => {
  webhook(req, res, err => {
    if (err) {
      console.error(err);
      res.statusCode = 500;
      res.end('Something has gone terribly wrong.');
    } else {
      res.statusCode = 404;
      res.end('no such location');
    }
  });
}).listen(PORT);

webhook.on('*', event => {
  debug('webhook', event);

  if (event.payload.repository) {
    const dispatcher = new Dispatcher(github, event);
    return Configuration.load(github, event.payload.repository).then(
      config => dispatcher.call(config)
    );
  }
});

// Check for and accept any repository invitations
function checkForInvites() {
  debug('Checking for repository invites');
  github.users.getRepoInvites({}).then(invites => {
    invites.forEach(invite => {
      debug('Accepting repository invite', invite.full_name);
      github.users.acceptRepoInvite(invite);
    });
  });

  debug('Checking for organization invites');
  github.orgs.getOrganizationMemberships({state: 'pending'}).then(invites => {
    invites.forEach(invite => {
      debug('Accepting organization invite', invite.organization.login);
      github.users.editOrganizationMembership({
        org: invite.organization.login,
        state: 'active'
      });
    });
  });
}
checkForInvites();
setInterval(checkForInvites, Number(process.env.INVITE_CHECK_INTERVAL || 60) * 1000);

console.log('Listening on http://localhost:' + PORT);