add a get method to batch repo

Author: themsaid

src/Illuminate/Bus/BatchRepository.php

@@ -6,6 +6,15 @@
 
 interface BatchRepository
 {
+    /**
+     * Get available batches.
+     *
+     * @param  mixed  $before
+     * @param  int  $limit
+     * @return [\Illuminate\Bus\Batch]
+     */
+    public function get($before, $limit);
+
     /**
      * Store a new pending batch.
      *

src/Illuminate/Bus/DatabaseBatchRepository.php

@@ -45,6 +45,28 @@ public function __construct(BatchFactory $factory, Connection $connection, strin
         $this->table = $table;
     }
 
+    /**
+     * Get available batches.
+     *
+     * @param  mixed  $before
+     * @param  int  $limit
+     * @return [\Illuminate\Bus\Batch]
+     */
+    public function get($before = null, $limit = 50)
+    {
+        return $this->connection->table($this->table)
+                            ->orderByDesc('id')
+                            ->take($limit)
+                            ->when($before, function ($q) use ($before) {
+                                return $q->where('id', '<', $before);
+                            })
+                            ->get()
+                            ->map(function ($batch) {
+                                return $this->toBatch($batch);
+                            })
+                            ->all();
+    }
+
     /**
      * Retrieve information about an existing batch.
      *
@@ -57,22 +79,9 @@ public function find(string $batchId)
                             ->where('id', $batchId)
                             ->first();
 
-        if (! $batch) {
-            return;
+        if ($batch) {
+            return $this->toBatch($batch);
         }
-
-        return $this->factory->make(
-            $this,
-            $batch->id,
-            (int) $batch->total_jobs,
-            (int) $batch->pending_jobs,
-            (int) $batch->failed_jobs,
-            json_decode($batch->failed_job_ids, true),
-            unserialize($batch->options),
-            CarbonImmutable::createFromTimestamp($batch->created_at),
-            $batch->cancelled_at ? CarbonImmutable::createFromTimestamp($batch->cancelled_at) : $batch->cancelled_at,
-            $batch->finished_at ? CarbonImmutable::createFromTimestamp($batch->finished_at) : $batch->finished_at
-        );
     }
 
     /**
@@ -232,4 +241,26 @@ public function transaction(Closure $callback)
             return $callback();
         });
     }
+
+    /**
+     * Convert the given raw batch to an object.
+     *
+     * @param object $batch
+     * @@return \Illuminate\Bus\Batch
+     */
+    protected function toBatch($batch)
+    {
+        return $this->factory->make(
+            $this,
+            $batch->id,
+            (int) $batch->total_jobs,
+            (int) $batch->pending_jobs,
+            (int) $batch->failed_jobs,
+            json_decode($batch->failed_job_ids, true),
+            unserialize($batch->options),
+            CarbonImmutable::createFromTimestamp($batch->created_at),
+            $batch->cancelled_at ? CarbonImmutable::createFromTimestamp($batch->cancelled_at) : $batch->cancelled_at,
+            $batch->finished_at ? CarbonImmutable::createFromTimestamp($batch->finished_at) : $batch->finished_at
+        );
+    }
 }

src/Illuminate/Support/Testing/Fakes/BatchRepositoryFake.php

@@ -12,6 +12,17 @@
 
 class BatchRepositoryFake implements BatchRepository
 {
+    /**
+     * Get available batches.
+     *
+     * @param  mixed  $before
+     * @param  int  $limit
+     * @return [\Illuminate\Bus\Batch]
+     */
+    public function get($before, $limit)
+    {
+    }
+
     /**
      * Retrieve information about an existing batch.
      *