pipe.js

'use strict';
const fs = require('fs');
const util = require('../util');
let client;

function reader() {
    fs.createReadStream(exports.config.pipe)
        .on('data', (data) => {
            client.say(exports.config.channel, data);
        })
        .on('end', () => {
            reader();
        });
}

exports.begin = function (_client) {
    client = _client;
    reader();
};

exports.stop = function () {
    util.log('Pipes Stopping');
};

exports.defaults = {
    channel: '#thedailywtf',
    pipe: './fifo'
};
exports.config = {};