var Kismet = require('kismet');
var digest = require('./digest');

var kismet;

var Track = module.exports = function(config, send) {
    kismet = new Kismet(config.host, config.port, config.sourceAddress);

    kismet.on('connect', function() {
        console.log('Kismet connected!');
    });

    kismet.subscribe('bssid', ['bssid', 'manuf', 'channel', 'type'], function(had_error, message) {
        console.log('bssid - ' + message);
    });
    kismet.subscribe('ssid', ['ssid', 'mac', 'cryptset', 'type', 'packets'], function(had_error, message) {
        console.log('ssid - ' + message);
    });
    kismet.subscribe('client', ['bssid', 'mac', 'type', 'signal_dbm', 'manuf'], function(had_error, message) {
        console.log('client - ' + message);
    });

    kismet.on('CAPABILITY', function(fields) {
        console.log('capability:' + fields.protocol);
        console.log(fields.fields.split(','));
    });


    kismet.on('BSSID', function(fields) {
        console.log(
            'Kismet sees bssid : ' + fields.bssid +
            ' type: ' + kismet.types.lookup('network', fields.type) +
            ' manuf: ' + fields.manuf +
            ' channel: ' + fields.channel
        );
    });

    kismet.on('SSID', function(fields) {
        if (fields.packets > 1) {
            console.log(
                'Kismet sees ssid  : ' + fields.mac +
                ' type: ' + kismet.types.lookup('ssid', fields.type) +
                ' ssid: ' + fields.ssid +
                ' pkts: ' + fields.packets +
                ' cryptset: ' + fields.cryptset
            );
        }
    });

    kismet.on('CLIENT', function(fields) {
        if (fields.bssid != fields.mac) {
            console.log(
                'Kismet sees client: ' + fields.bssid +
                ' type: ' + kismet.types.lookup('client', fields.type) +
                ' mac: ' + fields.mac
            );
        }
    });

    /*kismet.on('TIME', function(fields) {
        console.log(new Date(fields.time * 1000))
    });*/

    kismet.on('error', function(error) {
        console.log('Kismet had an error: ' + error.code);
    });

    kismet.on('end', function() {
        console.log('Kismet disconnected');
    });

    /*kismet.on('connect', function() {

        kismet.command('REMOVE TIME');
        //kismet.command('ENABLE CLIENT MAC,manuf,signal_dbm');
        kismet.subscribe('CLIENT', ['MAC', 'manuf', 'signal_dbm']);
        kismet.subscribe('BSSID', ['MAC', 'manuf', 'signal_dbm']);

        kismet.on('rawData', function(data) {
            digest(data, send.queue);
        });

        kismet.on('error', function(err) {
            console.error(err);
        });
    });*/
}

/**
 * Start collecting data
 */
Track.prototype.start = function() {
    kismet.connect();
};

/**
 * Stop collecting data
 */
Track.prototype.stop = function() {
    kismet.disconnect();
};