Ensure that the job we pull from the queue is a non-empty hash.

1 files changed, 17 insertions, 1 deletions

diff --git a/lib/custodian.rb b/lib/custodian.rb
index 821bf6d..6c0ec81 100644
--- a/lib/custodian.rb
+++ b/lib/custodian.rb
@@ -111,10 +111,26 @@ class Custodian
 
 
       #
-      #  Parse the JSON of the job body.
+      #  Get the job body
       #
       json = job.body
+      raise ArgumentError, "Body doesn't look like JSON" unless( json =~ /[{}]/ )
+
+
+      #
+      # Decode the JSON body - it should return a non-empty hash.
+      #
       hash = JSON.parse( json )
+
+      #
+      # Ensure we got a non-empty hash.
+      #
+      raise ArgumentError, "JSON didn't decode to a hash" unless hash.kind_of?(Hash)
+      raise ArgumentError, "JSON hash is empty" if (hash.empty?)
+
+      #
+      # Are we being verbose?
+      #
       hash['verbose'] = 1 if ( ENV['VERBOSE'] )