Merge pull request #11 from myLocalInfluence/feat/add-attributes-in-r…

…aw-body

feat: Add Uuid Attribute

composer.json

@@ -22,7 +22,8 @@
     "illuminate/queue": "5.7.* | 5.8.* | ^6.0 | ^7.0 | ^8.0",
     "illuminate/bus": "5.7.* | 5.8.* | ^6.0 | ^7.0 | ^8.0",
     "google/cloud-pubsub": "^1.1",
-    "ext-json": "*"
+    "ext-json": "*",
+    "ramsey/uuid": "^4.1"
   },
   "require-dev": {
     "phpspec/phpspec": "^5.1|^6.1"

src/PubSub/Job.php

@@ -2,10 +2,11 @@
 
 namespace Myli\PlainJobs\PubSub;
 
-use Illuminate\Queue\Jobs\Job as IlluminateJob;
 use Google\Cloud\PubSub\Message;
 use Illuminate\Container\Container;
 use Illuminate\Contracts\Queue\Job as JobContract;
+use Illuminate\Queue\Jobs\Job as IlluminateJob;
+use Ramsey\Uuid\Uuid;
 
 class Job extends IlluminateJob implements JobContract
 {
@@ -72,12 +73,13 @@ public function getJobId()
     public function getRawBody()
     {
         $fullData = [
-            'data' => json_decode(base64_decode($this->job->data()), true),
-            'attributes' => $this->job->attributes()
+            'data'       => json_decode(base64_decode($this->job->data()), true) ?? [],
+            'attributes' => $this->job->attributes() ?? []
         ];
         $newArray = [
             'job'  => $this->classHandler . '@handle',
             'data' => $fullData,
+            'uuid' => Uuid::uuid4()
         ];
 
         return json_encode($newArray);
@@ -108,7 +110,8 @@ public function attempts()
     /**
      * Release the job back into the queue.
      *
-     * @param  int $delay
+     * @param int $delay
+     *
      * @return void
      */
     public function release($delay = 0)