bot.js

var process_token = process.env.token;
if (!process_token) {
    console.log('Error: Specify token in environment');
    process.exit(1);
}

var Botkit = require('./lib/Botkit.js');
var os = require('os');
var schedule = require('node-schedule');

var controller = Botkit.slackbot({
    debug: false
});

var bot = controller.spawn({
    token: process_token
}).startRTM();

var flag_owner = 'alefas';

function user_list(cb) {
    bot.api.users.list({token: process_token}, function (err, json) {
        cb(json.members)
    });
}

function im_list(cb) {
    bot.api.im.list({token: process_token}, function (err, json) {
        cb(json.ims);
    });
}


function user_id(username, cb) {
    //todo: cache
    user_list(function (userlist) {
        userlist.forEach(function (element, i, arr) {
            if (element.name == username) {
                cb(element.id);
            }
        });
    });
}

function im_id(userid, cb) {
    im_list(function (imlist) {
        var found = false;
        imlist.forEach(function (element, index, array) {
            if (element.user == userid) {
                cb(element.id);
                found = true;
            }
        });
        if (!found) {
            bot.api.im.open({token: process_token, user: userid}, function (err, json) {
                if (!err) {
                    cb(json.channel.id)
                }
            })
        }
    });
}


//todo: move to DB
var scala_team_users = [
    'alefas',
    'nikolay.tropin',
    'alexandra.vesloguzova',
    'andrew.kozlov',
    'dmitry.naydanov',
    'kate.ustyuzhanina',
    'mikhail.mutcianko',
    'pavel.fatin',
    'roman.shein'
];

function broadcast_to_team(message) {
    scala_team_users.forEach(function (user, i, arr) {
        user_id(user, function (userid) {
            im_id(userid, function(imid) {
                controller.startConversation(bot, {
                    text: 'Test',
                    user: userid,
                    channel: imid
                }, function (err, convo) {
                    convo.say(message);
                });
            })
        });
    })
}

function schedule_team_reminder (days, hour, minute, message) {
    var rule = new schedule.RecurrenceRule();
    rule.dayOfWeek = days;
    rule.hour = hour;
    rule.minute = minute;

    schedule.scheduleJob(rule, function () {
        broadcast_to_team(message)
    })
}

schedule_team_reminder([1, 2, 4, 5], 15, 59, "Daily meeting!");
schedule_team_reminder([3], 13, 57, "Weekly seminar!");