CreateQueueTables

Complexity

Total Complexity

6

Size/Duplication

Total Lines	53
Duplicated Lines	0 %

Importance

Changes	2
Bugs	1	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	up()	0	29	4
A	down()	0	6	2

<?php

use Illuminate\Database\Migrations\Migration;
use Illuminate\Database\Schema\Blueprint;
use Illuminate\Support\Facades\Schema;

class CreateQueueTables extends Migration
{
    /**
     * Run the migrations.
     *
     * @return void
     */
    public function up()
    {
        if (config('queue.default') == 'database') {
            $connection = config('queue.failed.database');
            if (!Schema::connection($connection)->hasTable(config('queue.failed.table'))) {
                Schema::connection($connection)->create(
                    config('queue.failed.table'),
                    function (Blueprint $table) {
                        $table->bigIncrements('id');
                        $table->text('connection');
                        $table->text('queue');
                        $table->longText('payload');
                        $table->longText('exception');
                        $table->timestamp('failed_at')->useCurrent();
                    }
                );
            }

            if (!Schema::connection($connection)->hasTable(config('queue.connections.database.table'))) {
                Schema::connection($connection)->create(
                    config('queue.connections.database.table'),
                    function (Blueprint $table) {
                        $table->bigIncrements('id');
                        $table->string('queue')->index();
                        $table->longText('payload');
                        $table->unsignedTinyInteger('attempts');
                        $table->unsignedInteger('reserved_at')->nullable();
                        $table->unsignedInteger('available_at');
                        $table->unsignedInteger('created_at');
                    }
                );
            }
        }
    }

    /**
     * Reverse the migrations.
     *
     * @return void
     */
    public function down()
    {
        if (config('queue.default') == 'database') {
            $connection = config('queue.failed.database');
            Schema::connection($connection)->dropIfExists(config('queue.connections.database.table'));
            Schema::connection($connection)->dropIfExists(config('queue.failed.table'));
        }
    }
}