decoder.lua

local cjson = require('cjson')

local fields = {
  Type = "cisco",
  Timestamp = nil,
  Payload = "to be filled in...",
  Logger = "logstreamer"
}

function process_message()
  local raw_payload = read_message("raw")
  local ok,json = pcall(cjson.decode, raw_payload)

  if not ok then
    if raw_payload == nil then
      return -1, "could not parse nil payload"
    else
      return -1, "could not parse " .. raw_payload
    end
  end

  fields.Payload = raw_payload
  fields.Type = "filelog." .. json["type"]
  inject_message(fields)

  return 0
end