Merge pull request #35 from Kovah/dev

v0.0.7

Author: Kovah

.gitignore

@@ -4,6 +4,7 @@
 /storage/*.key
 /vendor
 /.idea
+/.tmp
 /.vscode
 /.vagrant
 Homestead.json

app/Console/CheckLinksCommand.php

@@ -0,0 +1,189 @@
+<?php
+
+namespace App\Console\Commands;
+
+use App\Models\Link;
+use GuzzleHttp\Client;
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\Cache;
+
+/**
+ * Class CheckLinksCommand
+ *
+ * @package App\Console\Commands
+ */
+class CheckLinksCommand extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'links:check';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'Checks links for availablility';
+
+    /**
+     * Check a maximum of 100 links at once
+     *
+     * @var int
+     */
+    protected $limit = 100;
+
+    /** @var int */
+    protected $offset;
+
+    /** @var int */
+    protected $total;
+
+    /** @var int */
+    protected $checked_link_count;
+
+    /** @var Client */
+    protected $client;
+
+    /** @var string */
+    protected $cache_key_offset = 'command_links:check_offset';
+
+    /** @var string */
+    protected $cache_key_skip_timestamp = 'command_links:check_skip_timestamp';
+
+    /** @var string */
+    protected $cache_key_checked_count = 'command_links:check_checked_count';
+
+    /**
+     * RegisterUser constructor.
+     */
+    public function __construct()
+    {
+        $this->client = new Client();
+
+        parent::__construct();
+    }
+
+    /**
+     * Execute the console command.
+     *
+     * @return void
+     */
+    public function handle(): void
+    {
+        // Check if the command should skip the execution
+        $skip_timestamp = Cache::get($this->cache_key_skip_timestamp);
+        $this->offset = Cache::get($this->cache_key_offset, 0);
+        $this->checked_link_count = Cache::get($this->cache_key_checked_count, 0);
+
+        if (now()->timestamp < $skip_timestamp) {
+            return;
+        }
+
+        $links = $this->getLinks();
+
+        // Cancel if there are no links to check
+        if ($links->isEmpty()) {
+            Cache::forget($this->cache_key_offset);
+            Cache::forget($this->cache_key_skip_timestamp);
+
+            $this->comment('No links found, aborting...');
+            return;
+        }
+
+        // Check all provided links
+        $this->comment('Checking ' . $links->count() . ' links now.');
+
+        $links->each(function ($link) {
+            $this->checkLink($link);
+
+            // Prevent spam-ish behaviour by limiting outgoing HTTP requests
+            sleep(1);
+        });
+
+        // Check if there are more links to check
+        $checked_count = $this->checked_link_count + $links->count();
+        Cache::forever($this->cache_key_checked_count, $checked_count);
+
+        if ($this->total > $checked_count) {
+
+            // If yes, simply save the offset to the cache.
+            // The next link check will pick it up and continue the check
+            $next_offset = $this->offset + $this->limit;
+            Cache::forever($this->cache_key_offset, $next_offset);
+
+            $this->comment('Saving offset for next link check.');
+
+        } else {
+
+            // If not, all links have been successfully checked.
+            // Save a cache flag that prevents link checks for the next days.
+            $next_check = now()->addDays(5)->timestamp;
+            Cache::forever($this->cache_key_skip_timestamp, $next_check);
+
+            $this->comment('All existing links checked, next link check scheduled for ' . now()->addDays(5)->toDateTimeString());
+
+        }
+    }
+
+    /**
+     * Get links but limit the results to a fixed number of links
+     * If there is an offset saved, use this instead of beginning from the first entry
+     *
+     * @return mixed
+     */
+    protected function getLinks()
+    {
+        // Get the total amount of remaining links
+        $this->total = Link::count();
+
+        // Get a porton of the remaining links based on the limit
+        return Link::orderBy('id', 'ASC')->offset($this->offset)->limit($this->limit)->get();
+    }
+
+    /**
+     * Check the URL of an link and set the status accordingly
+     *
+     * @param Link $link
+     * @return void
+     * @throws \GuzzleHttp\Exception\GuzzleException
+     */
+    protected function checkLink(Link $link): void
+    {
+        $this->comment('Checking link ' . $link->url);
+
+        $options = [
+            'http_errors' => false, // Do not throw exceptions for 4xx and 5xx errors
+            'timeout' => 5, // wait a maximum of 5 seconds for the request to finish
+        ];
+
+        try {
+            $res = $this->client->request('GET', $link->url, $options);
+            $status_code = $res->getStatusCode();
+        } catch (\Exception $e) {
+            // Just abort now, may be a temporary issue
+            $this->warn('› Unknown error while trying to check the URL, trying again later.');
+            return;
+        }
+
+        // Check if the status code is not 200
+        if ($status_code !== 200) {
+            // If the link target is a redirect, set the status 2 (moved)
+            // else set the status to 3 (broken)
+            if ($status_code === 301 || $status_code === 302) {
+                $link->status = 2;
+                $this->warn('› Link moved to another URL!');
+            } else {
+                $link->status = 3;
+                $this->error('› Link seems to be broken!');
+            }
+
+            $link->save();
+
+        } else {
+            $this->info('› Link looks okay.');
+        }
+    }
+}

app/Console/Kernel.php

@@ -2,10 +2,16 @@
 
 namespace App\Console;
 
-use App\Console\Commands\RegisterUser;
+use App\Console\Commands\CheckLinksCommand;
+use App\Console\Commands\RegisterUserCommand;
 use Illuminate\Console\Scheduling\Schedule;
 use Illuminate\Foundation\Console\Kernel as ConsoleKernel;
 
+/**
+ * Class Kernel
+ *
+ * @package App\Console
+ */
 class Kernel extends ConsoleKernel
 {
     /**
@@ -14,7 +20,8 @@ class Kernel extends ConsoleKernel
      * @var array
      */
     protected $commands = [
-        RegisterUser::class
+        RegisterUserCommand::class,
+        CheckLinksCommand::class,
     ];
 
     /**
@@ -25,8 +32,7 @@ class Kernel extends ConsoleKernel
      */
     protected function schedule(Schedule $schedule)
     {
-        // $schedule->command('inspire')
-        //          ->hourly();
+         $schedule->command('links:check')->hourly();
     }
 
     /**

app/Console/RegisterUser.php renamed to app/Console/RegisterUserCommand.php

@@ -14,14 +14,14 @@
  *
  * @package App\Console\Commands
  */
-class RegisterUser extends Command
+class RegisterUserCommand extends Command
 {
     /**
      * The name and signature of the console command.
      *
      * @var string
      */
-    protected $signature = 'registeruser {name : Username} {email : User email address}';
+    protected $signature = 'registeruser {name? : Username} {email? : User email address}';
 
     /**
      * The console command description.
@@ -30,6 +30,11 @@ class RegisterUser extends Command
      */
     protected $description = 'Register a new user';
 
+    private $user_roles = [
+        'admin',
+        'user',
+    ];
+
     /**
      * RegisterUser constructor.
      */
@@ -49,29 +54,31 @@ public function handle()
         $email = $this->argument('email');
 
         if (empty($name)) {
-            $this->warn('Name is missing!');
-            return;
+            $name = $this->ask('Please enter the user name:');
         }
 
         if (empty($email)) {
-            $this->warn('Email address is missing!');
-            return;
+            $email = $this->ask('Please enter the user email address:');
         }
 
-        $password = $this->secret('Please enter a password for ' . $name);
-
         // Check if the user exists
         if (User::where('email', $email)->first()) {
             $this->error('An user with the email address "' . $email . '" already exists!');
             return;
         }
 
+        $password = $this->secret('Please enter a password for ' . $name);
+
+        $role = $this->choice('Please choose the user role:', $this->user_roles, 'user');
+
         $new_user = User::create([
             'name' => $name,
             'email' => $email,
             'password' => Hash::make($password),
         ]);
 
+        $new_user->assignRole($role);
+
         $this->info('User ' . $name . ' registered.');
         return;
     }

app/Helper/functions.php

@@ -1,5 +1,7 @@
 <?php
 
+use App\Models\Setting;
+
 /**
  * Shorthand for the current user settings
  *
@@ -19,6 +21,21 @@ function usersettings(string $key = '')
     return auth()->user()->settings();
 }
 
+/**
+ * Retrieve system settings
+ *
+ * @param string $key
+ * @return mixed
+ */
+function systemsettings(string $key = '')
+{
+    if ($key === '') {
+        return Setting::systemOnly()->get();
+    }
+
+    return Setting::systemOnly()->where('key', $key)->pluck('value')->first() ?: null;
+}
+
 /**
  * Output a correctly formatted date with the correct timezone
  *

app/Http/Controllers/API/CronController.php

@@ -0,0 +1,33 @@
+<?php
+
+namespace App\Http\Controllers\API;
+
+use App\Http\Controllers\Controller;
+use Illuminate\Http\Request;
+use Illuminate\Support\Facades\Artisan;
+
+/**
+ * Class CronController
+ *
+ * @package App\Http\Controllers
+ */
+class CronController extends Controller
+{
+    /**
+     * @param Request     $request
+     * @param null|string $cron_token
+     * @return \Illuminate\Contracts\Routing\ResponseFactory|\Illuminate\Http\Response
+     */
+    public function run(Request $request, $cron_token)
+    {
+        // Verify the cron token
+        if (!$cron_token || $cron_token !== systemsettings('cron_token')) {
+            abort(403);
+        }
+
+        // Run all cron tasks
+        Artisan::call('schedule:run');
+
+        return response('Cron successfully executed');
+    }
+}