Added extendable attributes property to Jobs

src/Models/Job.php

@@ -11,16 +11,17 @@ class Job
     public const STATUS_PROCESSING = 'processing';
     public const STATUS_ERROR = 'error';
     public const STATUS_FINISHED = 'finished';
+    public const ATTR_TAG_KEY = 'tag';
 
     /**
      * @var string
      */
     protected $id;
 
     /**
-     * @var string|null
+     * @var array
      */
-    protected $tag;
+    protected $attributes = array();
 
     /**
      * @var \DateTimeImmutable
@@ -65,7 +66,27 @@ public function getId(): string
      */
     public function getTag(): ?string
     {
-        return $this->tag;
+        return null !== ($tag = $this->attributes[self::ATTR_TAG_KEY]) ? $tag : null;
+    }
+
+    /**
+     * @return array
+     */
+    public function getAttributes(): ?array
+    {
+        return $this->attributes;
+    }
+
+    /**
+     * @param string $key
+     * @param string|null $value
+     *
+     * @return Job
+     */
+    public function setAttribute(string $key, ?string $value): Job
+    {
+        $this->attributes[$key] = $value;
+        return $this;
     }
 
     /**
@@ -75,7 +96,7 @@ public function getTag(): ?string
      */
     public function setTag(?string $tag): Job
     {
-        $this->tag = $tag;
+        $this->attributes[self::ATTR_TAG_KEY] = $tag;
         return $this;
     }
 

src/Resources/JobsResource.php

@@ -51,10 +51,11 @@ public function create(Job $job): Job
                 $task->getPayload() ?? []
             );
         }
-        $response = $this->httpTransport->post($this->httpTransport->getBaseUri() . '/jobs', [
-            'tasks' => $tasks,
-            'tag'   => $job->getTag()
-        ]);
+        $response = $this->httpTransport->post($this->httpTransport->getBaseUri() . '/jobs', array_merge(
+            ['tasks' => $tasks],
+            $job->getAttributes()
+            )
+        );
         return $this->hydrator->hydrateObjectByResponse($job, $response);
     }