✨ Add login/refresh token commands

app/Commands/TraktLogin.php

@@ -0,0 +1,55 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Commands;
+
+use App\Services\Trakt;
+
+class TraktLogin extends Command
+{
+    protected $signature = 'trakt:login';
+    protected $description = 'Login and get new token.';
+
+    public function handle(Trakt $trakt): int
+    {
+        $data = [
+            'client_id' => env('TRAKT_APP_ID'),
+        ];
+
+        $resp = $trakt->requestNoAuth()->post('/oauth/device/code', $data);
+        if (!$resp->ok()) {
+            $this->line('Failed to get device code: ' . $resp->status());
+            $this->line($resp->body());
+            return static::FAILURE;
+        }
+
+        $body = $resp->json();
+        $this->line("Visit {$body['verification_url']} and enter the code {$body['user_code']}");
+        if (!$this->confirm('Ready to continue?')) {
+            return static::FAILURE;
+        }
+
+        $this->line("TRAKT_DEVICE_RESP='" . json_encode($body) . "'");
+
+        $data = [
+            'client_id' => env('TRAKT_APP_ID'),
+            'client_secret' => env('TRAKT_APP_SECRET'),
+            'code' => $body['device_code'],
+        ];
+
+        $resp = $trakt->requestNoAuth()->post('/oauth/device/token', $data);
+
+        if (!$resp->ok()) {
+            $this->line('Failed to get new token');
+            return static::FAILURE;
+        }
+
+        $body = $resp->json();
+        $this->line("TRAKT_OAUTH_RESP='" . json_encode($body) . "'");
+        $this->line('TRAKT_OAUTH_TOKEN=' . $body['access_token']);
+
+        return static::SUCCESS;
+
+    }
+}

app/Commands/TraktRefreshLogin.php

@@ -0,0 +1,45 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Commands;
+
+use App\Services\Trakt;
+
+class TraktRefreshLogin extends Command
+{
+    protected $signature = 'trakt:refresh';
+    protected $description = 'Refresh access token.';
+
+    public function handle(Trakt $trakt): int
+    {
+        $oauth_resp = json_decode(env('TRAKT_OAUTH_RESP'), true);
+        if (empty($oauth_resp)) {
+            $this->line("Failed to get OAuth response");
+            return static::FAILURE;
+        }
+
+        $data = [
+            'refresh_token' => $oauth_resp['refresh_token'],
+            'client_id' => env('TRAKT_APP_ID'),
+            'client_secret' => env('TRAKT_APP_SECRET'),
+            'redirect_uri' => env('TRAKT_REDIRECT_URI'),
+            'grant_type' => 'refresh_token',
+        ];
+
+        $resp = $trakt->request()->post('/oauth/token', $data);
+
+        if (!$resp->ok()) {
+            $this->line('Failed to get new token');
+            return static::FAILURE;
+        }
+
+        // $this->line(json_encode($resp->body()));
+        // $body = $json->body();
+        $body = $resp->json();
+        $this->line("TRAKT_OAUTH_RESP='" . json_encode($body) . "'");
+        $this->line('TRAKT_OAUTH_TOKEN=' . $body['access_token']);
+
+        return static::SUCCESS;
+    }
+}

app/Services/Trakt.php

@@ -26,6 +26,11 @@ class Trakt
         return Http::withHeaders($this->headers + $headers)->baseUrl('https://api.trakt.tv');
     }
 
+    public function requestNoAuth(array $headers = []): PendingRequest
+    {
+        return Http::withHeaders(['trakt-api-version' => 2] + $headers)->baseUrl('https://api.trakt.tv');
+    }
+
     public function syncHistory(WatchData $data, OutputInterface $output = null): Response
     {
         $output?->writeln(sprintf('Submitting %s to trakt with headers %s', json_encode($data->structuredData), json_encode($this->headers)));