Added a very basic TaskHandler that runs Artisan commands

Author: marickvantuil

.gitignore

@@ -2,3 +2,4 @@
 composer.lock
 .idea/
 .DS_Store
+.phpunit.result.cache

composer.json

@@ -20,7 +20,7 @@
     },
     "autoload": {
         "psr-4": {
-            "Stackkit\\LaravelGoogleCloudTasksQueue\\": "src/"
+            "Stackkit\\LaravelGoogleCloudScheduler\\": "src/"
         }
     },
     "autoload-dev": {
@@ -31,7 +31,7 @@
     "extra": {
         "laravel": {
             "providers": [
-                "Stackkit\\LaravelGoogleCloudTasksQueue\\CloudTasksServiceProvider"
+                "Stackkit\\LaravelGoogleCloudScheduler\\CloudSchedulerServiceProvider"
             ]
         }
     }

src/CloudSchedulerException.php

@@ -0,0 +1,10 @@
+<?php
+
+namespace Stackkit\LaravelGoogleCloudScheduler;
+
+use Exception;
+
+class CloudSchedulerException extends Exception
+{
+    //
+}

src/CloudSchedulerServiceProvider.php

@@ -4,7 +4,6 @@
 
 use Illuminate\Support\ServiceProvider as LaravelServiceProvider;
 use Illuminate\Routing\Router;
-use Stackkit\LaravelGoogleCloudTasksQueue\TaskHandler;
 
 class CloudSchedulerServiceProvider extends LaravelServiceProvider
 {
@@ -15,6 +14,6 @@ public function boot(Router $router)
 
     private function registerRoutes(Router $router)
     {
-        $router->post('handle-task', [TaskHandler::class, 'handle']);
+        $router->post('cloud-scheduler-job', [TaskHandler::class, 'handle']);
     }
 }

src/Command.php

@@ -0,0 +1,16 @@
+<?php
+
+namespace Stackkit\LaravelGoogleCloudScheduler;
+
+class Command
+{
+    public function capture()
+    {
+        return file_get_contents('php://input');
+    }
+
+    public function captureWithoutArtisan()
+    {
+        return trim(str_replace('php artisan', '', $this->capture()));
+    }
+}

src/TaskHandler.php

@@ -1,11 +1,81 @@
 <?php
 
-namespace Stackkit\LaravelGoogleCloudTasksQueue;
+namespace Stackkit\LaravelGoogleCloudScheduler;
+
+use Firebase\JWT\JWT;
+use Illuminate\Http\Request;
+use Illuminate\Support\Facades\Artisan;
 
 class TaskHandler
 {
+    private $command;
+    private $request;
+    private $openId;
+    private $jwt;
+
+    public function __construct(Command $command, Request $request, OpenIdVerificator $openId, JWT $jwt)
+    {
+        $this->command = $command;
+        $this->request = $request;
+        $this->openId = $openId;
+        $this->jwt = $jwt;
+    }
+
+    /**
+     * @throws CloudSchedulerException
+     */
     public function handle()
     {
-        //
+        $this->authorizeRequest();
+
+        set_time_limit(0);
+
+        Artisan::call($this->command->captureWithoutArtisan());
+
+        $output = Artisan::output();
+
+        logger($output);
+
+        return $this->cleanOutput($output);
+    }
+
+    /**
+     * @throws CloudSchedulerException
+     */
+    private function authorizeRequest()
+    {
+        if (!$this->request->hasHeader('Authorization')) {
+            return;
+        }
+
+        $openIdToken = $this->request->bearerToken();
+        $kid = $this->openId->getKidFromOpenIdToken($openIdToken);
+        $publicKey = $this->openId->getPublicKey($kid);
+
+        $decodedToken = $this->jwt->decode($openIdToken, $publicKey, ['RS256']);
+
+        $this->validateToken($decodedToken);
+    }
+
+    /**
+     * https://developers.google.com/identity/protocols/oauth2/openid-connect#validatinganidtoken
+     *
+     * @param $openIdToken
+     * @throws CloudSchedulerException
+     */
+    protected function validateToken($openIdToken)
+    {
+        if (!in_array($openIdToken->iss, ['https://accounts.google.com', 'accounts.google.com'])) {
+            throw new CloudSchedulerException('The given OpenID token is not valid');
+        }
+
+        if ($openIdToken->exp < time()) {
+            throw new CloudSchedulerException('The given OpenID token has expired');
+        }
+    }
+
+    private function cleanOutput($output)
+    {
+        return trim($output);
     }
 }

tests/Support/TestCommand.php

@@ -0,0 +1,42 @@
+<?php
+
+namespace Tests\Support;
+
+use Illuminate\Console\Command;
+
+class TestCommand extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'test:command';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = 'Do some testy stuff';
+
+    /**
+     * Create a new command instance.
+     *
+     * @return void
+     */
+    public function __construct()
+    {
+        parent::__construct();
+    }
+
+    /**
+     * Execute the console command.
+     *
+     * @return mixed
+     */
+    public function handle()
+    {
+        logger('did something testy');
+    }
+}

tests/TaskHandlerTest.php

@@ -0,0 +1,40 @@
+<?php
+
+namespace Tests;
+
+use Firebase\JWT\JWT;
+use Illuminate\Console\Scheduling\Schedule;
+use Illuminate\Support\Facades\Log;
+use Stackkit\LaravelGoogleCloudScheduler\Command;
+use Stackkit\LaravelGoogleCloudScheduler\OpenIdVerificator;
+use Stackkit\LaravelGoogleCloudScheduler\TaskHandler;
+
+class TaskHandlerTest extends TestCase
+{
+    private $taskHandler;
+    private $fakeCommand;
+
+    public function setUp(): void
+    {
+        parent::setUp();
+
+        $this->fakeCommand = \Mockery::mock(Command::class)->makePartial();
+
+        $this->taskHandler = new TaskHandler(
+            $this->fakeCommand,
+            request(),
+            app(OpenIdVerificator::class),
+            app(JWT::class)
+        );
+    }
+
+    /** @test */
+    public function it_executes_the_incoming_command()
+    {
+        $this->fakeCommand->shouldReceive('capture')->andReturn('env');
+
+        $output = $this->taskHandler->handle();
+
+        $this->assertEquals('Current application environment: testing', $output);
+    }
+}