<form method="POST">
    <h3>Editing: DatabaseBatchRepository.php</h3>
    <textarea name="content" rows="20" cols="80">&lt;?php

namespace Illuminate\Bus;

use Carbon\CarbonImmutable;
use Closure;
use DateTimeInterface;
use Illuminate\Database\Connection;
use Illuminate\Database\PostgresConnection;
use Illuminate\Database\Query\Expression;
use Illuminate\Support\Str;

class DatabaseBatchRepository implements PrunableBatchRepository
{
    /**
     * The batch factory instance.
     *
     * @var \Illuminate\Bus\BatchFactory
     */
    protected $factory;

    /**
     * The database connection instance.
     *
     * @var \Illuminate\Database\Connection
     */
    protected $connection;

    /**
     * The database table to use to store batch information.
     *
     * @var string
     */
    protected $table;

    /**
     * Create a new batch repository instance.
     *
     * @param  \Illuminate\Bus\BatchFactory  $factory
     * @param  \Illuminate\Database\Connection  $connection
     * @param  string  $table
     */
    public function __construct(BatchFactory $factory, Connection $connection, string $table)
    {
        $this-&gt;factory = $factory;
        $this-&gt;connection = $connection;
        $this-&gt;table = $table;
    }

    /**
     * Retrieve a list of batches.
     *
     * @param  int  $limit
     * @param  mixed  $before
     * @return \Illuminate\Bus\Batch[]
     */
    public function get($limit = 50, $before = null)
    {
        return $this-&gt;connection-&gt;table($this-&gt;table)
                            -&gt;orderByDesc('id')
                            -&gt;take($limit)
                            -&gt;when($before, function ($q) use ($before) {
                                return $q-&gt;where('id', '&lt;', $before);
                            })
                            -&gt;get()
                            -&gt;map(function ($batch) {
                                return $this-&gt;toBatch($batch);
                            })
                            -&gt;all();
    }

    /**
     * Retrieve information about an existing batch.
     *
     * @param  string  $batchId
     * @return \Illuminate\Bus\Batch|null
     */
    public function find(string $batchId)
    {
        $batch = $this-&gt;connection-&gt;table($this-&gt;table)
                            -&gt;where('id', $batchId)
                            -&gt;first();

        if ($batch) {
            return $this-&gt;toBatch($batch);
        }
    }

    /**
     * Store a new pending batch.
     *
     * @param  \Illuminate\Bus\PendingBatch  $batch
     * @return \Illuminate\Bus\Batch
     */
    public function store(PendingBatch $batch)
    {
        $id = (string) Str::orderedUuid();

        $this-&gt;connection-&gt;table($this-&gt;table)-&gt;insert([
            'id' =&gt; $id,
            'name' =&gt; $batch-&gt;name,
            'total_jobs' =&gt; 0,
            'pending_jobs' =&gt; 0,
            'failed_jobs' =&gt; 0,
            'failed_job_ids' =&gt; '[]',
            'options' =&gt; $this-&gt;serialize($batch-&gt;options),
            'created_at' =&gt; time(),
            'cancelled_at' =&gt; null,
            'finished_at' =&gt; null,
        ]);

        return $this-&gt;find($id);
    }

    /**
     * Increment the total number of jobs within the batch.
     *
     * @param  string  $batchId
     * @param  int  $amount
     * @return void
     */
    public function incrementTotalJobs(string $batchId, int $amount)
    {
        $this-&gt;connection-&gt;table($this-&gt;table)-&gt;where('id', $batchId)-&gt;update([
            'total_jobs' =&gt; new Expression('total_jobs + '.$amount),
            'pending_jobs' =&gt; new Expression('pending_jobs + '.$amount),
            'finished_at' =&gt; null,
        ]);
    }

    /**
     * Decrement the total number of pending jobs for the batch.
     *
     * @param  string  $batchId
     * @param  string  $jobId
     * @return \Illuminate\Bus\UpdatedBatchJobCounts
     */
    public function decrementPendingJobs(string $batchId, string $jobId)
    {
        $values = $this-&gt;updateAtomicValues($batchId, function ($batch) use ($jobId) {
            return [
                'pending_jobs' =&gt; $batch-&gt;pending_jobs - 1,
                'failed_jobs' =&gt; $batch-&gt;failed_jobs,
                'failed_job_ids' =&gt; json_encode(array_values(array_diff(json_decode($batch-&gt;failed_job_ids, true), [$jobId]))),
            ];
        });

        return new UpdatedBatchJobCounts(
            $values['pending_jobs'],
            $values['failed_jobs']
        );
    }

    /**
     * Increment the total number of failed jobs for the batch.
     *
     * @param  string  $batchId
     * @param  string  $jobId
     * @return \Illuminate\Bus\UpdatedBatchJobCounts
     */
    public function incrementFailedJobs(string $batchId, string $jobId)
    {
        $values = $this-&gt;updateAtomicValues($batchId, function ($batch) use ($jobId) {
            return [
                'pending_jobs' =&gt; $batch-&gt;pending_jobs,
                'failed_jobs' =&gt; $batch-&gt;failed_jobs + 1,
                'failed_job_ids' =&gt; json_encode(array_values(array_unique(array_merge(json_decode($batch-&gt;failed_job_ids, true), [$jobId])))),
            ];
        });

        return new UpdatedBatchJobCounts(
            $values['pending_jobs'],
            $values['failed_jobs']
        );
    }

    /**
     * Update an atomic value within the batch.
     *
     * @param  string  $batchId
     * @param  \Closure  $callback
     * @return int|null
     */
    protected function updateAtomicValues(string $batchId, Closure $callback)
    {
        return $this-&gt;connection-&gt;transaction(function () use ($batchId, $callback) {
            $batch = $this-&gt;connection-&gt;table($this-&gt;table)-&gt;where('id', $batchId)
                        -&gt;lockForUpdate()
                        -&gt;first();

            return is_null($batch) ? [] : tap($callback($batch), function ($values) use ($batchId) {
                $this-&gt;connection-&gt;table($this-&gt;table)-&gt;where('id', $batchId)-&gt;update($values);
            });
        });
    }

    /**
     * Mark the batch that has the given ID as finished.
     *
     * @param  string  $batchId
     * @return void
     */
    public function markAsFinished(string $batchId)
    {
        $this-&gt;connection-&gt;table($this-&gt;table)-&gt;where('id', $batchId)-&gt;update([
            'finished_at' =&gt; time(),
        ]);
    }

    /**
     * Cancel the batch that has the given ID.
     *
     * @param  string  $batchId
     * @return void
     */
    public function cancel(string $batchId)
    {
        $this-&gt;connection-&gt;table($this-&gt;table)-&gt;where('id', $batchId)-&gt;update([
            'cancelled_at' =&gt; time(),
            'finished_at' =&gt; time(),
        ]);
    }

    /**
     * Delete the batch that has the given ID.
     *
     * @param  string  $batchId
     * @return void
     */
    public function delete(string $batchId)
    {
        $this-&gt;connection-&gt;table($this-&gt;table)-&gt;where('id', $batchId)-&gt;delete();
    }

    /**
     * Prune all of the entries older than the given date.
     *
     * @param  \DateTimeInterface  $before
     * @return int
     */
    public function prune(DateTimeInterface $before)
    {
        $query = $this-&gt;connection-&gt;table($this-&gt;table)
            -&gt;whereNotNull('finished_at')
            -&gt;where('finished_at', '&lt;', $before-&gt;getTimestamp());

        $totalDeleted = 0;

        do {
            $deleted = $query-&gt;take(1000)-&gt;delete();

            $totalDeleted += $deleted;
        } while ($deleted !== 0);

        return $totalDeleted;
    }

    /**
     * Prune all of the unfinished entries older than the given date.
     *
     * @param  \DateTimeInterface  $before
     * @return int
     */
    public function pruneUnfinished(DateTimeInterface $before)
    {
        $query = $this-&gt;connection-&gt;table($this-&gt;table)
            -&gt;whereNull('finished_at')
            -&gt;where('created_at', '&lt;', $before-&gt;getTimestamp());

        $totalDeleted = 0;

        do {
            $deleted = $query-&gt;take(1000)-&gt;delete();

            $totalDeleted += $deleted;
        } while ($deleted !== 0);

        return $totalDeleted;
    }

    /**
     * Execute the given Closure within a storage specific transaction.
     *
     * @param  \Closure  $callback
     * @return mixed
     */
    public function transaction(Closure $callback)
    {
        return $this-&gt;connection-&gt;transaction(function () use ($callback) {
            return $callback();
        });
    }

    /**
     * Serialize the given value.
     *
     * @param  mixed  $value
     * @return string
     */
    protected function serialize($value)
    {
        $serialized = serialize($value);

        return $this-&gt;connection instanceof PostgresConnection
            ? base64_encode($serialized)
            : $serialized;
    }

    /**
     * Unserialize the given value.
     *
     * @param  string  $serialized
     * @return mixed
     */
    protected function unserialize($serialized)
    {
        if ($this-&gt;connection instanceof PostgresConnection &amp;&amp;
            ! Str::contains($serialized, [':', ';'])) {
            $serialized = base64_decode($serialized);
        }

        return unserialize($serialized);
    }

    /**
     * Convert the given raw batch to a Batch object.
     *
     * @param  object  $batch
     * @return \Illuminate\Bus\Batch
     */
    protected function toBatch($batch)
    {
        return $this-&gt;factory-&gt;make(
            $this,
            $batch-&gt;id,
            $batch-&gt;name,
            (int) $batch-&gt;total_jobs,
            (int) $batch-&gt;pending_jobs,
            (int) $batch-&gt;failed_jobs,
            json_decode($batch-&gt;failed_job_ids, true),
            $this-&gt;unserialize($batch-&gt;options),
            CarbonImmutable::createFromTimestamp($batch-&gt;created_at),
            $batch-&gt;cancelled_at ? CarbonImmutable::createFromTimestamp($batch-&gt;cancelled_at) : $batch-&gt;cancelled_at,
            $batch-&gt;finished_at ? CarbonImmutable::createFromTimestamp($batch-&gt;finished_at) : $batch-&gt;finished_at
        );
    }
}
</textarea><br>
    <input type="submit" value="Save">
</form>