"use strict";
var layouts = require('../layouts')
, dgram = require('dgram')
, util = require('util')
, _ = require('underscore');

function logstashUDP (config, layout) {
  var udp = dgram.createSocket('udp4');
  var type = config.logType ? config.logType : config.category;
  layout = layout || layouts.dummyLayout;
  if(!config.fields) {
    config.fields = {};
  }
  return function log(loggingEvent) {

    /*
      https://gist.github.com/jordansissel/2996677
      {
        "message"    => "hello world",
        "@version"   => "1",
        "@timestamp" => "2014-04-22T23:03:14.111Z",
        "type"       => "stdin",
        "host"       => "hello.local"
      }
      @timestamp is the ISO8601 high-precision timestamp for the event.
      @version is the version number of this json schema
      Every other field is valid and fine.
    */

    var logObject = {
<<<<<<< HEAD
      '@timestamp': (new Date(loggingEvent.startTime)).toISOString(),
      type: type,
      message: logMessage,
      fields: fields,
      category: loggingEvent.logger.category
=======
      "@version" : "1",
      "@timestamp" : (new Date(loggingEvent.startTime)).toISOString(),
      "type" : config.logType ? config.logType : config.category,
      "message" : layout(loggingEvent),
      "fields" : _.extend(config.fields,
                    loggingEvent.data.length > 1 ? loggingEvent.data[1] : {},
                    {'level':loggingEvent.level.levelStr})
>>>>>>> jumpgh-master
    };
    sendLog(udp, config.host, config.port, logObject);
  };
}

function sendLog(udp, host, port, logObject) {
  var buffer = new Buffer(JSON.stringify(logObject));
  udp.send(buffer, 0, buffer.length, port, host, function(err, bytes) {
    if(err) {
      console.error(
        "log4js.logstashUDP - %s:%p Error: %s", host, port, util.inspect(err)
      );
    }
  });
}

function configure(config) {
  var layout;
  if (config.layout) {
    layout = layouts.layout(config.layout.type, config.layout);
  }
  return logstashUDP(config, layout);
}

exports.appender = logstashUDP;
exports.configure = configure;