index.js

'use strict';

// add timestamps in front of log messages
require('console-stamp')(console, 'yyyy/mm/dd HH:MM:ss');
const config = require('./config/config');
const IP_MAP = require('./cml_ip_map.json');
const Promise = require('bluebird');
const table2json = require('tabletojson');
const request = require('request-promise');
const iconv = require('iconv-lite');
const loginFacebook = Promise.promisify(require('facebook-chat-api'));
const fs = Promise.promisifyAll(require('fs'));
const log = require('./log.json');

const option = {
    method: 'POST',
    uri: 'http://cert.ntu.edu.tw/Module/Index/ip.php',
    encoding: null,
    form: {
        ip1: 140,
        ip2: 112,
        ip3: 29,
        isset: 'ok'
    }
};

let msg = {};

request(option)
    .then(buffer => {
        const decoded = iconv.decode(new Buffer(buffer), 'big5');
        const table = table2json.convert(decoded)[1];
        const banned = checkIP(table);

        if (!banned.length) {
            console.log("All IP are fine, flush log.");
            fs.writeFileSync(`${__dirname}/log.json`, '[]');
            process.exit(0);
        }

        msg.body = JSON.stringify(banned, null, '\t').replace(/[\{\},\[\]\t"]/g, '');

        if (JSON.stringify(log) == JSON.stringify(banned)) {
            console.log('Already warned.');
            process.exit(0);
        } else {
            fs.writeFileSync(`${__dirname}/log.json`, JSON.stringify(banned));
        }

        return loginFacebook(config.account);
    })
    .then(api => api.sendMessage(msg, config.notify_channel_id))
    .then(() => console.log(msg.body))
    .catch(err => console.error(err));


function checkIP(list) {
    return list
        .filter(item => !!IP_MAP[item['違規IP']] )
        .map(item => Object.assign(item, { '主機': IP_MAP[item['違規IP']] }));
}