add horizon controls

Author: kevindees

README.md

@@ -39,3 +39,32 @@ Outputs,
 ```
 Clearing Redis queues:emails
 ```
+
+## Horizon Basic Clear
+
+The horizon feature here is not fool proof so you will want to check on the results after the fact.
+
+To clear all failed jobs from redis in horizon.
+
+```shell
+php artisan horizon:data failed_jobs -C
+```
+
+To clear all jobs from redis in horizon.
+
+```shell
+php artisan horizon:data jobs -C
+```
+
+To clear all jobs from redis in horizon.
+
+```shell
+php artisan horizon:data recent_jobs -C
+```
+
+To clear an tag or something else from redis in horizon.
+
+```shell
+php artisan horizon:data App\\Import:66 -C
+php artisan horizon:data failed:App\Import:65 -C
+```

src/HorizonDataCommand.php

@@ -0,0 +1,83 @@
+<?php
+/**
+ * Created by PhpStorm.
+ * User: kevindees
+ * Date: 2018-12-19
+ * Time: 15:43
+ */
+
+namespace QueueRedis;
+
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\Redis;
+
+
+class HorizonDataCommand extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'horizon:data 
+                            {type : The data you wish to target: failed_jobs, recent_jobs, tag }
+                            {--C|clear : Clear the data}';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'Flush horizon data';
+
+    protected $type;
+    protected $clear;
+
+    /**
+     * Create a new command instance.
+     *
+     * @return void
+     */
+    public function __construct()
+    {
+        parent::__construct();
+    }
+
+    /**
+     * Execute the console command.
+     *
+     * @return mixed
+     */
+    public function handle()
+    {
+        $this->type = $this->argument('type');
+        $this->clear = $this->option('clear');
+
+        if($this->clear) {
+            $this->clear();
+        }
+    }
+
+    protected function clear() {
+
+        switch ($this->type) {
+            case 'failed_jobs' :
+                $this->info('Clearing all horizon recent failed and failed jobs');
+                Redis::connection()->del('horizon:failed:*');
+                Redis::connection()->del('horizon:recent_failed_jobs');
+                Redis::connection()->del('horizon:failed_jobs');
+                break;
+            case 'recent_jobs' :
+                $this->info('Clearing all horizon recent jobs');
+                Redis::connection()->del('horizon:recent_jobs');
+                break;
+            default :
+                if(!empty($this->type)) {
+                    $tag = $this->type;
+                    $this->info('Clearing: horizon:' . $tag);
+                    Redis::connection()->del('horizon:' . escapeshellarg($tag));
+                }
+                break;
+        }
+    }
+}

src/QueueRedisServiceProvider.php

@@ -25,6 +25,7 @@ public function boot()
         if ($this->app->runningInConsole()) {
             $this->commands([
                 QueueRedisCommand::class,
+                HorizonDataCommand::class,
             ]);
         }
     }