ops-GithubBot/server.js

const fastify = require('fastify')();
const irc = require('irc-upd');

const settings = require('./settings');

const client = new irc.Client('irc.orpheus.network', settings.username, {
  channels: []
});

client.addListener('registered', () => {
  if (settings.nickserv) {
    client.say('nickserv', `IDENTIFY ${settings.nickserv}`);
    client.join(settings.channels.join(','));
  }
});

let messages = []
function handle_issue(body) {
  // Format:
  // Gazelle - itismadness opened issue #59 - Test Issue... | https://github.com/OPSnet/Gazelle/issues/59
  let message = `${body.repository.name} - ${body.sender.login} ${body.action} issue #${body.issue.number}`;
  message += ` - ${body.issue.title} | ${body.issue.html_url}`;
  
  // TODO: handle comments

  messages.push(message);
}

function handle_commits(body) {
  let ref = body.ref.split('/');
  let branch = ref[ref.length-1];
  if (branch !== body.repository.master_branch) {
    return;
  }
  for (let commit of body.commits) {
    let id = commit.id.substr(0, 7);
    let message = `${body.repository.name} - ${commit.author.name} just pushed commit ${id} to ${branch}`;
    message += ` - ${commit.message} | ${commit.url}`;
    messages.push(message);
  }
}

fastify.get('/', async (req, reply) => {
  return { hello: 'world' }
});

fastify.post('/', async (req, reply) => {
  let body = req.body;
  
  let event = req.headers['x-github-event'];
  messages = [];
  if (event === 'issues') {
    handle_issue(body);
  }
  else if (event === 'push') {
    handle_commits(body);
  }
  else {
    console.log(JSON.stringify(body, null, 2));
    console.log(req.headers);
    let message = `New Github Event ${event} by ${body.sender.login}`;
    messages.push(message);
  }

  for (channel of settings.channels) {
    for (let message of messages) {
      client.say('#test', message);
    }
  }
  messages = [];
  return { message: 'posted' };
});

const start = async () => {
  fastify.listen(13452, '0.0.0.0', (err, address) => {
    if (err) {
      fastify.log.error(err);
      process.exit(1);
    }
    fastify.log.info(`server listening on ${address}`);
  });
};

start();