dbot/modules/radio/radio.js

/**
 * Module Name: Radio
 * Description: Various icecast functionality.
 */

var _ = require('underscore')._,
    icecast = require('icecast-stack');

var radio = function(dbot) {
    this.listening = false;
    this.data = false;
    this.stream = false;
    this.internalAPI = {
        'startRadio': function() {
            var stream = icecast.createReadStream(this.config.stream);
            this.stream = stream;

            stream.on('connect', function() {
                this.listening = true;
            }.bind(this));

            stream.on('response', function(res) {
                this.data = res.headers;
                _.each(this.config.announce, function(a) {
                    dbot.say(a.server, a.name, dbot.t('now_online', {
                        'name': res.headers['icy-name'],
                        'desc': res.headers['icy-description'],
                        'url': res.headers['icy-url']
                    }));
                });
            }.bind(this));

            stream.on('metadata', function(metadata) {
                var title = icecast.parseMetadata(metadata).StreamTitle;
                _.each(this.config.announce, function(a) {
                    dbot.say(a.server, a.name, dbot.t('now_playing', {
                        'name': this.data['icy-name'],
                        'song': title,
                        'url': this.data['icy-url']
                    }));
                }, this);
            }.bind(this));

            stream.on('end', function() {
                this.stream.end();
                this.listening = false;
            }.bind(this));
        }.bind(this),

        'getRadio': function() {
            dbot.api.timers.addTimer(20000, function() {
                if(this.listening == false) {
                    this.internalAPI.startRadio();
                }
            }.bind(this));
        }.bind(this)
    };
    this.onLoad = function() {
        this.internalAPI.getRadio();
    }.bind(this);
    this.onDestroy = function() {
        this.stream.abort();
    }.bind(this);
};

exports.fetch = function(dbot) {
    return new radio(dbot);
};