var di = require('di');
var injector = new di.Injector();

var config = injector.get(require('./src/DillerConfig'));
config.configureLogging('mqtt');

/**
 * @type {function(function(PgTx, DillerDao, Diller))} tx
 */
var tx = injector.get(require('./src/DillerTx'));

/**
 * @type DillerMqttClient
 */
var dillerMqttClient = injector.get(require('./src/mqtt/DillerMqttClient'));
dillerMqttClient.run('mqtt');

dillerMqttClient.on('message', function (topic, message, payload) {
  tx(function (pg, dao, diller) {
    return diller.onMessage(topic, message, payload);
  });
});