feat: add dispatch() to dispatch jobs

Author: mychidarko

src/functions.php

@@ -1 +1,64 @@
 <?php
+
+/**
+ * Return queue object
+ *
+ * @return \Leaf\Queue
+ */
+function queue()
+{
+    if (!(\Leaf\Config::getStatic('queue'))) {
+        \Leaf\Config::singleton('queue', function () {
+            return new \Leaf\Queue();
+        });
+    }
+
+    return \Leaf\Config::get('queue');
+}
+
+/**
+ * Dispatch a job, batch or a group of jobs
+ *
+ * @param array|mixed $dispatchable The job, batch or group of jobs to dispatch
+ * @param array $data The data to pass to the job
+ */
+function dispatch($dispatchable, $data = [])
+{
+    if (is_array($dispatchable)) {
+        foreach ($dispatchable as $item) {
+            dispatch($item, $data);
+        }
+
+        return;
+    }
+
+    /** @var \Leaf\Queue\Dispatchable */
+    $jobOrBatch = new $dispatchable();
+    $queueModuleConfig = MvcConfig('queue') ?? [];
+    $jobConnection = $jobOrBatch->connection();
+
+    $defaultConnection = $queueModuleConfig['connections'][$queueModuleConfig['default'] ?? 'database'];
+
+    if (!empty($data)) {
+        $jobOrBatch->with($data);
+    }
+
+    // if (\Leaf\Config::getStatic('queue')) {
+    //     return queue()->push([
+    //         'class' => $jobOrBatch,
+    //         'config' => $jobOrBatch->getConfig(),
+    //         'status' => 'pending',
+    //         'retry_count' => 0,
+    //     ]);
+    // }
+
+    // can optimize by saving a cached version of this instance
+    queue()->connect($queueModuleConfig['connections'][$jobConnection] ?? $defaultConnection);
+
+    return queue()->push([
+        'class' => $jobOrBatch::class,
+        'config' => json_encode($jobOrBatch->getConfig()),
+        'status' => 'pending',
+        'retry_count' => 0,
+    ]);
+}