Copy configuration & migration to your project

Kantai235 · Kantai235 · commit c43fe65a6063 · 2022-04-13T04:06:23.000+08:00
diff --git a/app/Domains/Social/Jobs/Comments/DiscordCommentsJob.php b/app/Domains/Social/Jobs/Comments/DiscordCommentsJob.php
@@ -9,6 +9,7 @@
 use Illuminate\Foundation\Bus\Dispatchable;
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
+use romanzipp\QueueMonitor\Traits\IsMonitored;
 
 /**
  * Class DiscordCommentsJob.
@@ -18,7 +19,8 @@ class DiscordCommentsJob implements ShouldQueue
     use Dispatchable,
         InteractsWithQueue,
         Queueable,
-        SerializesModels;
+        SerializesModels,
+        IsMonitored;
 
     /**
      * @var Platform
diff --git a/app/Domains/Social/Jobs/Comments/FacebookCommentsJob.php b/app/Domains/Social/Jobs/Comments/FacebookCommentsJob.php
@@ -14,6 +14,7 @@
 use Illuminate\Queue\SerializesModels;
 use Illuminate\Support\Facades\Cache;
 use Illuminate\Support\Facades\Http;
+use romanzipp\QueueMonitor\Traits\IsMonitored;
 
 /**
  * Class FacebookCommentsJob.
@@ -23,7 +24,8 @@ class FacebookCommentsJob implements ShouldQueue
     use Dispatchable,
         InteractsWithQueue,
         Queueable,
-        SerializesModels;
+        SerializesModels,
+        IsMonitored;
 
     /**
      * @var Platform
diff --git a/app/Domains/Social/Jobs/Comments/PlurkCommentsJob.php b/app/Domains/Social/Jobs/Comments/PlurkCommentsJob.php
@@ -14,6 +14,7 @@
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
 use Illuminate\Support\Facades\Http;
+use romanzipp\QueueMonitor\Traits\IsMonitored;
 
 /**
  * Class PlurkCommentsJob.
@@ -23,7 +24,8 @@ class PlurkCommentsJob implements ShouldQueue
     use Dispatchable,
         InteractsWithQueue,
         Queueable,
-        SerializesModels;
+        SerializesModels,
+        IsMonitored;
 
     /**
      * @var Platform
diff --git a/app/Domains/Social/Jobs/Comments/TelegramCommentsJob.php b/app/Domains/Social/Jobs/Comments/TelegramCommentsJob.php
@@ -9,6 +9,7 @@
 use Illuminate\Foundation\Bus\Dispatchable;
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
+use romanzipp\QueueMonitor\Traits\IsMonitored;
 
 /**
  * Class TelegramCommentsJob.
@@ -18,7 +19,8 @@ class TelegramCommentsJob implements ShouldQueue
     use Dispatchable,
         InteractsWithQueue,
         Queueable,
-        SerializesModels;
+        SerializesModels,
+        IsMonitored;
 
     /**
      * @var Platform
diff --git a/app/Domains/Social/Jobs/Comments/TumblrCommentsJob.php b/app/Domains/Social/Jobs/Comments/TumblrCommentsJob.php
@@ -9,6 +9,7 @@
 use Illuminate\Foundation\Bus\Dispatchable;
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
+use romanzipp\QueueMonitor\Traits\IsMonitored;
 
 /**
  * Class TumblrCommentsJob.
@@ -18,7 +19,8 @@ class TumblrCommentsJob implements ShouldQueue
     use Dispatchable,
         InteractsWithQueue,
         Queueable,
-        SerializesModels;
+        SerializesModels,
+        IsMonitored;
 
     /**
      * @var Platform
diff --git a/app/Domains/Social/Jobs/Comments/TwitterCommentsJob.php b/app/Domains/Social/Jobs/Comments/TwitterCommentsJob.php
@@ -9,6 +9,7 @@
 use Illuminate\Foundation\Bus\Dispatchable;
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
+use romanzipp\QueueMonitor\Traits\IsMonitored;
 
 /**
  * Class TwitterCommentsJob.
@@ -18,7 +19,8 @@ class TwitterCommentsJob implements ShouldQueue
     use Dispatchable,
         InteractsWithQueue,
         Queueable,
-        SerializesModels;
+        SerializesModels,
+        IsMonitored;
 
     /**
      * @var Platform
diff --git a/app/Domains/Social/Jobs/Publish/DiscordPublishJob.php b/app/Domains/Social/Jobs/Publish/DiscordPublishJob.php
@@ -13,6 +13,7 @@
 use Illuminate\Queue\SerializesModels;
 use Illuminate\Support\Facades\Http;
 use Illuminate\Support\Str;
+use romanzipp\QueueMonitor\Traits\IsMonitored;
 
 /**
  * Class DiscordPublishJob.
@@ -24,7 +25,8 @@ class DiscordPublishJob implements ShouldQueue
     use Dispatchable,
         InteractsWithQueue,
         Queueable,
-        SerializesModels;
+        SerializesModels,
+        IsMonitored;
 
     /**
      * @var Cards
diff --git a/app/Domains/Social/Jobs/Publish/FacebookPublishJob.php b/app/Domains/Social/Jobs/Publish/FacebookPublishJob.php
@@ -15,6 +15,7 @@
 use Illuminate\Queue\SerializesModels;
 use Illuminate\Support\Facades\Cache;
 use Illuminate\Support\Facades\Http;
+use romanzipp\QueueMonitor\Traits\IsMonitored;
 
 /**
  * Class FacebookPublishJob.
@@ -24,7 +25,8 @@ class FacebookPublishJob implements ShouldQueue
     use Dispatchable,
         InteractsWithQueue,
         Queueable,
-        SerializesModels;
+        SerializesModels,
+        IsMonitored;
 
     /**
      * @var Cards
diff --git a/app/Domains/Social/Jobs/Publish/PlurkPublishJob.php b/app/Domains/Social/Jobs/Publish/PlurkPublishJob.php
@@ -17,6 +17,7 @@
 use Illuminate\Support\Facades\Http;
 use Illuminate\Support\Facades\Storage;
 use Illuminate\Support\Str;
+use romanzipp\QueueMonitor\Traits\IsMonitored;
 
 /**
  * Class PlurkPublishJob.
@@ -28,7 +29,8 @@ class PlurkPublishJob implements ShouldQueue
     use Dispatchable,
         InteractsWithQueue,
         Queueable,
-        SerializesModels;
+        SerializesModels,
+        IsMonitored;
 
     /**
      * @var Cards
diff --git a/app/Domains/Social/Jobs/Publish/TelegramPublishJob.php b/app/Domains/Social/Jobs/Publish/TelegramPublishJob.php
@@ -13,6 +13,7 @@
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
 use Illuminate\Support\Facades\Http;
+use romanzipp\QueueMonitor\Traits\IsMonitored;
 
 /**
  * Class TelegramPublishJob.
@@ -22,7 +23,8 @@ class TelegramPublishJob implements ShouldQueue
     use Dispatchable,
         InteractsWithQueue,
         Queueable,
-        SerializesModels;
+        SerializesModels,
+        IsMonitored;
 
     /**
      * @var Cards
diff --git a/app/Domains/Social/Jobs/Publish/TumblrPublishJob.php b/app/Domains/Social/Jobs/Publish/TumblrPublishJob.php
@@ -15,6 +15,7 @@
 use Illuminate\Queue\InteractsWithQueue;
 use Illuminate\Queue\SerializesModels;
 use Illuminate\Support\Facades\Http;
+use romanzipp\QueueMonitor\Traits\IsMonitored;
 
 /**
  * Class TumblrPublishJob.
@@ -26,7 +27,8 @@ class TumblrPublishJob implements ShouldQueue
     use Dispatchable,
         InteractsWithQueue,
         Queueable,
-        SerializesModels;
+        SerializesModels,
+        IsMonitored;
 
     /**
      * @var Cards
diff --git a/app/Domains/Social/Jobs/Publish/TwitterPublishJob.php b/app/Domains/Social/Jobs/Publish/TwitterPublishJob.php
@@ -17,6 +17,7 @@
 use Illuminate\Support\Facades\Http;
 use Illuminate\Support\Facades\Storage;
 use Illuminate\Support\Str;
+use romanzipp\QueueMonitor\Traits\IsMonitored;
 
 /**
  * Class TwitterPublishJob.
@@ -28,7 +29,8 @@ class TwitterPublishJob implements ShouldQueue
     use Dispatchable,
         InteractsWithQueue,
         Queueable,
-        SerializesModels;
+        SerializesModels,
+        IsMonitored;
 
     /**
      * @var Cards
diff --git a/config/queue-monitor.php b/config/queue-monitor.php
@@ -0,0 +1,55 @@
+<?php
+
+return [
+    /*
+     * Set the table to be used for monitoring data.
+     */
+    'table' => 'queue_monitor',
+    'connection' => null,
+
+    /*
+     * Set the model used for monitoring.
+     * If using a custom model, be sure to implement the
+     *   romanzipp\QueueMonitor\Models\Contracts\MonitorContract
+     * interface or extend the base model.
+     */
+    'model' => \romanzipp\QueueMonitor\Models\Monitor::class,
+
+    /*
+     * Specify the max character length to use for storing exception backtraces.
+     */
+    'db_max_length_exception' => 4294967295,
+    'db_max_length_exception_message' => 65535,
+
+    /*
+     * The optional UI settings.
+     */
+    'ui' => [
+        /*
+         * Set the monitored jobs count to be displayed per page.
+         */
+        'per_page' => 35,
+
+        /*
+         *  Show custom data stored on model
+         */
+        'show_custom_data' => false,
+
+        /**
+         * Allow the deletion of single monitor items.
+         */
+        'allow_deletion' => true,
+
+        /**
+         * Allow purging all monitor entries.
+         */
+        'allow_purge' => true,
+
+        'show_metrics' => true,
+
+        /**
+         * Time frame used to calculate metrics values (in days).
+         */
+        'metrics_time_frame' => 14,
+    ],
+];
diff --git a/database/migrations/2018_02_05_000000_create_queue_monitor_table.php b/database/migrations/2018_02_05_000000_create_queue_monitor_table.php
@@ -0,0 +1,58 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+/**
+ * Class CreateQueueMonitorTable.
+ *
+ * @extends Migration
+ */
+class CreateQueueMonitorTable extends Migration
+{
+    /**
+     * Run the migrations.
+     *
+     * @return void
+     */
+    public function up(): void
+    {
+        Schema::create(config('queue-monitor.table'), function (Blueprint $table) {
+            $table->increments('id');
+
+            $table->string('job_id')->index();
+            $table->string('name')->nullable();
+            $table->string('queue')->nullable();
+
+            $table->timestamp('started_at')->nullable()->index();
+            $table->string('started_at_exact')->nullable();
+
+            $table->timestamp('finished_at')->nullable();
+            $table->string('finished_at_exact')->nullable();
+
+            $table->float('time_elapsed', 12, 6)->nullable()->index();
+
+            $table->boolean('failed')->default(false)->index();
+
+            $table->integer('attempt')->default(0);
+            $table->integer('progress')->nullable();
+
+            $table->longText('exception')->nullable();
+            $table->text('exception_message')->nullable();
+            $table->text('exception_class')->nullable();
+
+            $table->longText('data')->nullable();
+        });
+    }
+
+    /**
+     * Reverse the migrations.
+     *
+     * @return void
+     */
+    public function down(): void
+    {
+        Schema::drop(config('queue-monitor.table'));
+    }
+}
diff --git a/resources/views/frontend/includes/nav.blade.php b/resources/views/frontend/includes/nav.blade.php
@@ -179,10 +179,15 @@ class="nav-link dropdown-toggle"
                                 :href="route('admin.dashboard')"
                                 :text="__('Administration')"
                                 class="dropdown-item" />
-                            {{-- OPCache --}}
+                            {{-- OPCache 監控 --}}
                             <x-utils.link
                                 :href="route('frontend.monitor.opcache.index')"
-                                :text="__('OPCache')"
+                                :text="__('OPCache Monitor')"
+                                class="dropdown-item" />
+                            {{-- Queue 監控 --}}
+                            <x-utils.link
+                                :href="route('frontend.monitor.queue-monitor::index')"
+                                :text="__('Queue Monitor')"
                                 class="dropdown-item" />
                         @endif
 
diff --git a/resources/views/frontend/opcache.blade.php b/resources/views/frontend/opcache.blade.php
diff --git a/resources/views/vendor/queue-monitor/jobs.blade.php b/resources/views/vendor/queue-monitor/jobs.blade.php
diff --git a/resources/views/vendor/queue-monitor/partials/metrics-card.blade.php b/resources/views/vendor/queue-monitor/partials/metrics-card.blade.php
diff --git a/routes/frontend/home.php b/routes/frontend/home.php
