add operation

Author: alisissa

src/Feature.php

@@ -2,60 +2,11 @@
 
 namespace Lucid\Foundation;
 
-use ReflectionClass;
-use Illuminate\Http\Request;
-use Illuminate\Support\Collection;
-use App\Domains\Queue\DefaultQueue;
 use Illuminate\Foundation\Bus\DispatchesJobs;
 
 abstract class Feature
 {
     use MarshalTrait;
     use DispatchesJobs;
-
-    /**
-     * beautifier function to be called instead of the
-     * laravel function dispatchFromArray.
-     * When the $arguments is an instance of Request
-     * it will call dispatchFrom instead.
-     *
-     * @param string                         $job
-     * @param array|\Illuminate\Http\Request $arguments
-     * @param array                          $extra
-     *
-     * @return mixed
-     */
-    public function run($job, $arguments = [], $extra = [])
-    {
-        if ($arguments instanceof Request) {
-            $result = $this->dispatch($this->marshal($job, $arguments, $extra));
-        } else {
-            if (!is_object($job)) {
-                $job = $this->marshal($job, new Collection(), $arguments);
-            }
-
-            $result = $this->dispatch($job, $arguments);
-        }
-
-        return $result;
-    }
-
-    /**
-     * Run the given job in the given queue.
-     *
-     * @param string     $job
-     * @param array      $arguments
-     * @param Queue|null $queue
-     *
-     * @return mixed
-     */
-    public function runInQueue($job, array $arguments = [], $queue = 'default')
-    {
-        // instantiate and queue the job
-        $reflection = new ReflectionClass($job);
-        $jobInstance = $reflection->newInstanceArgs($arguments);
-        $jobInstance->onQueue((string) $queue);
-
-        return $this->dispatch($jobInstance);
-    }
+    use JobDispatcherTrait;
 }

src/JobDispatcherTrait.php

@@ -0,0 +1,58 @@
+<?php
+
+namespace Lucid\Foundation;
+
+use ReflectionClass;
+use Illuminate\Http\Request;
+use Illuminate\Support\Collection;
+use App\Domains\Queue\DefaultQueue;
+use Illuminate\Foundation\Bus\DispatchesJobs;
+
+trait JobDispatcherTrait
+{
+    /**
+     * beautifier function to be called instead of the
+     * laravel function dispatchFromArray.
+     * When the $arguments is an instance of Request
+     * it will call dispatchFrom instead.
+     *
+     * @param string                         $job
+     * @param array|\Illuminate\Http\Request $arguments
+     * @param array                          $extra
+     *
+     * @return mixed
+     */
+    public function run($job, $arguments = [], $extra = [])
+    {
+        if ($arguments instanceof Request) {
+            $result = $this->dispatch($this->marshal($job, $arguments, $extra));
+        } else {
+            if (!is_object($job)) {
+                $job = $this->marshal($job, new Collection(), $arguments);
+            }
+
+            $result = $this->dispatch($job, $arguments);
+        }
+
+        return $result;
+    }
+
+    /**
+     * Run the given job in the given queue.
+     *
+     * @param string     $job
+     * @param array      $arguments
+     * @param Queue|null $queue
+     *
+     * @return mixed
+     */
+    public function runInQueue($job, array $arguments = [], $queue = 'default')
+    {
+        // instantiate and queue the job
+        $reflection = new ReflectionClass($job);
+        $jobInstance = $reflection->newInstanceArgs($arguments);
+        $jobInstance->onQueue((string) $queue);
+
+        return $this->dispatch($jobInstance);
+    }
+}

src/Operation.php

@@ -0,0 +1,12 @@
+<?php
+
+namespace Lucid\Foundation;
+
+use Illuminate\Foundation\Bus\DispatchesJobs;
+
+abstract class Operation
+{
+    use MarshalTrait;
+    use DispatchesJobs;
+    use JobDispatcherTrait;
+}

src/QueueableOperation.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace Lucid\Foundation;
+
+use Illuminate\Queue\SerializesModels;
+use Illuminate\Queue\InteractsWithQueue;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Bus\Queueable;
+
+/**
+ * An abstract Operation that can be managed with a queue
+ * when extended the operation will be queued by default.
+ */
+class QueueableOperation extends Operation implements ShouldQueue
+{
+    use SerializesModels;
+    use InteractsWithQueue;
+    use Queueable;
+}