r Properly re-encode json

dusterio · Nov 3, 2016 · a81d562 · a81d562
1 parent 72a79db
commit a81d562
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/Sqs/Queue.php b/src/Sqs/Queue.php
@@ -85,9 +85,11 @@ private function modifyPayload($payload, $class)
     {
         if (! is_array($payload)) $payload = json_decode($payload, true);
 
+        $body = json_decode($payload['Body'], true);
+
         $body = [
             'job' => $class . '@handle',
-            'data' => json_decode($payload['Body'])
+            'data' => isset($body['data']) ? $body['data'] : $body
         ];
 
         $payload['Body'] = json_encode($body);