app.js

'use strict';

require('./env');
var log = require('./getLogger')('app');
var Botkit = require('botkit');
var schedule = require('node-schedule');
var botLib = require('./lib/bot');
var startWebServer = require('./lib/web/start');
var cfenv = require('cfenv');

var appEnv = cfenv.getAppEnv();

// Database setup
var models = require('./models');
models.sequelize.sync(
  // Set to true to reset db on load
  {force: false}
);

if (!process.env.SLACK_TOKEN) {
  log.error('SLACK_TOKEN not set in environment.');
  process.exit(1);
}

var bkLogger = require('./getLogger')('botkit');
function bkLog(level) {
  var args = [ ];
  for(var i = 1; i < arguments.length; i++) {
    args.push(arguments[i]);
  }

  // Remap botkit log levels
  if(level === 'debug') {
    return;
  }
  else if(level === 'info') {
    level = 'verbose';
  } else if(level === 'notice') {
    level = 'info';
  }

  var fn, thisObj;
  if(bkLogger[level]) {
    fn = bkLogger[level];
    thisObj = bkLogger;
  } else {
    fn = console.log;
    thisObj = console;
    args.unshift('[' + level + ']');
  }

  fn.apply(thisObj, args);
}

var controller = Botkit.slackbot({
  debug: false,
  logger: { log: bkLog },
  webserver: {
    static_dir: __dirname + '/lib/web/static'
  }
});

// Initialize the bot
controller.spawn({
  token: process.env.SLACK_TOKEN,
  retry: 5
}).startRTM(function(err, bot) {
  if (err) {
    log.error(err);
    throw new Error(err);
  } else {
    log.info('Connected to RTM');
    bot.identifyBot(function(err,identity) {
      // identity contains...
      // {name, id, team_id}
      log.info('Bot name: ' + identity.name);

      // Set up cron job to check every minute for channels that need a standup report
      schedule.scheduleJob('* * * * 1-5', botLib.getReportRunner(bot));
      schedule.scheduleJob('* * * * 1-5', botLib.getReminderRunner(bot));

      // TODO: method to set standup frequency
      // TODO: add usage messages
      botLib.giveHelp(controller, identity.name);

      // Set yourself OOO for some time.  Put this above getStandupInfo
      // because getStandupInfo catches anything that starts with "#channel",
      // so catch the more precise
      botLib.setOutOfOffice(controller);

      botLib.getStandupInfo(controller);

      // TODO: remind people to do standup?
      botLib.setReminder(controller);

      // Message for when the bot is added to a channel
      botLib.joinChannel(controller, identity.name);

      // Create a standup in a channel
      botLib.createStandup(controller);

      // Add or change a standup message for today in a DM with the bot
      botLib.getUserStandupInfo(controller);

      // DM a user when they ask to be interviewed or
      // they react to a reminder DM
      botLib.startInterview(controller);
      botLib.startDmEmoji(controller, identity.id);

      // Remove a standup
      botLib.removeStandup(controller);

      // Set a standup audience to a user group
      botLib.setAudience(controller);

      // Configure in-channel updates
      botLib.setInChannelUpdate(controller);

      // Get a weekly user report
      botLib.userReport(controller);

      // Respond to all other direct messages
      botLib.unhandledDM(controller);

      log.verbose('All bot functions initialized');
    });

    startWebServer(controller);
  }
});