Improve the decode error message in the Heka file.lua input

Author: trink

heka/CMakeLists.txt

@@ -3,7 +3,7 @@
 # file, You can obtain one at http://mozilla.org/MPL/2.0/.
 
 cmake_minimum_required(VERSION 3.0)
-project(heka VERSION 1.1.14 LANGUAGES C)
+project(heka VERSION 1.1.15 LANGUAGES C)
 set(CPACK_PACKAGE_DESCRIPTION_SUMMARY "Utility modules for Heka sandboxes")
 set(CPACK_DEBIAN_PACKAGE_DEPENDS "${PACKAGE_PREFIX}-cjson (>= 2.1)")
 string(REGEX REPLACE "[()]" "" CPACK_RPM_PACKAGE_REQUIRES ${CPACK_DEBIAN_PACKAGE_DEPENDS})

heka/sandboxes/heka/input/file.lua

@@ -47,15 +47,18 @@ end
 local send_decode_failures  = read_config("send_decode_failures")
 
 local err_msg = {
-    Type    = "error",
+    Type    = "error.decode",
     Payload = nil,
+    Fields  = {
+        data = nil
+    }
 }
 
 function process_message(checkpoint)
     local fh = io.stdin
     if input_filename then
         fh = assert(io.open(input_filename, "rb")) -- closed on plugin shutdown
-        if checkpoint then 
+        if checkpoint then
             fh:seek("set", checkpoint)
         else
             checkpoint = 0
@@ -67,6 +70,7 @@ function process_message(checkpoint)
         local ok, err = pcall(decode, data, default_headers)
         if (not ok or err) and send_decode_failures then
             err_msg.Payload = err
+            err_msg.Fields.data = data
             pcall(inject_message, err_msg)
         end