track twitch token expiration

[alttp.git] / app / Console / Commands / TwitchChannelInfo.php

diff --git a/app/Console/Commands/TwitchChannelInfo.php b/app/Console/Commands/TwitchChannelInfo.php
index 09dc7180e55e5a84e97cd303df96a65cfa49ffce..7b373c8c94ed54fe611280078158799e35002775 100644 (file)
--- a/app/Console/Commands/TwitchChannelInfo.php
+++ b/app/Console/Commands/TwitchChannelInfo.php
@@ -4,6 +4,7 @@ namespace App\Console\Commands;
 
 use App\Models\Channel;
 use App\Models\TwitchToken;
+use GuzzleHttp\Psr7\Query;
 use Illuminate\Console\Command;
 use Illuminate\Http\Client\RequestException;
 use Illuminate\Support\Facades\Http;
@@ -36,10 +37,14 @@ class TwitchChannelInfo extends Command {
                        $this->line('please acquire a token for localhorsttv first');
                        return 1;
                }
+               if ($this->token->hasExpired()) {
+                       $this->line('access token has expired, refreshing');
+                       $this->token->refresh();
+               }
                $channels = Channel::where('twitch_chat', '!=', '')->where('twitch_id', '=', '')->get();
                foreach ($channels as $channel) {
                        try {
-                               $this->updateChannel($channel);
+                               $this->updateChannelId($channel);
                        } catch (RequestException $e) {
                                if ($e->response->status() == 401) {
                                        $this->token->refresh();
@@ -47,16 +52,24 @@ class TwitchChannelInfo extends Command {
                                }
                        }
                }
+               Channel::where('twitch_id', '!=', '')
+                       ->where(function($query) {
+                               $query->where('join', true);
+                               $query->orWhere('chat', true);
+                       })
+                       ->chunk(100, function ($channels) {
+                               $this->updateChannelInfos($channels);
+                       });
                return Command::SUCCESS;
        }
 
-       private function updateChannel(Channel $channel) {
+       private function updateChannelId(Channel $channel) {
                $this->line($channel->twitch_chat);
                $login = substr($channel->twitch_chat, 1);
                $rsp = $this->token->request()
-                       ->get('/users', [
+                       ->get('/users', Query::build([
                                'login' => $login,
-                       ])
+                       ]))
                        ->throw();
                foreach ($rsp['data'] as $user) {
                        if ($user['login'] != $login) continue;
@@ -65,6 +78,33 @@ class TwitchChannelInfo extends Command {
                }
        }
 
+       private function updateChannelInfos($channels) {
+               $ids = $channels->pluck('twitch_id')->toArray();
+               $rsp = $this->token->request()
+                       ->get('/streams', Query::build([
+                               'user_id' => $ids,
+                       ]))
+                       ->throw();
+               foreach ($channels as $channel) {
+                       $data = null;
+                       foreach ($rsp['data'] as $info) {
+                               if ($info['user_id'] == $channel->twitch_id) {
+                                       $data = $info;
+                                       break;
+                               }
+                       }
+                       if (is_null($data)) {
+                               $channel->twitch_live = false;
+                               $channel->twitch_viewers = 0;
+                       } else {
+                               $channel->twitch_live = true;
+                               $channel->twitch_category = $data['game_id'];
+                               $channel->twitch_viewers = $data['viewer_count'];
+                       }
+                       $channel->save();
+               }
+       }
+
        private $token;
 
 }