fall back to any SG channel on lang not found

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

diff --git a/app/Console/Commands/SyncSpeedGaming.php b/app/Console/Commands/SyncSpeedGaming.php
index 4d2cb9cb27cb9a4a9195f21c93f3851238a6f9c2..c2fa36820af063ed59cc6f62482f4e2e129ae49e 100644 (file)
--- a/app/Console/Commands/SyncSpeedGaming.php
+++ b/app/Console/Commands/SyncSpeedGaming.php
@@ -3,7 +3,9 @@
 namespace App\Console\Commands;
 
 use App\Models\Channel;
+use App\Models\DiscordBotCommand;
 use App\Models\Episode;
+use App\Models\EpisodeCrew;
 use App\Models\EpisodePlayer;
 use App\Models\Event;
 use App\Models\Organization;
@@ -85,6 +87,8 @@ class SyncSpeedGaming extends Command {
                        ->where('start', '<=', $to)
                        ->whereNotIn('ext_id', $ext_ids);
                foreach ($to_purge->get() as $episode) {
+                       $episode->channels()->detach();
+                       $episode->crew()->delete();
                        $episode->players()->delete();
                }
                $to_purge->delete();
@@ -123,6 +127,42 @@ class SyncSpeedGaming extends Command {
                        $episode->channels()->syncWithoutDetaching($channelIds);
                }
 
+               $this->purgeCrew($episode, $sgEntry['broadcasters'], 'brd');
+               foreach ($sgEntry['broadcasters'] as $sgCrew) {
+                       try {
+                               $this->syncCrew($episode, $sgCrew, 'brd', 'setup');
+                       } catch (Exception $e) {
+                               $this->error('error syncing broadcaster '.$sgCrew['id'].': '.$e->getMessage());
+                       }
+               }
+
+               $this->purgeCrew($episode, $sgEntry['commentators'], 'comm');
+               foreach ($sgEntry['commentators'] as $sgCrew) {
+                       try {
+                               $this->syncCrew($episode, $sgCrew, 'comm', 'commentary');
+                       } catch (Exception $e) {
+                               $this->error('error syncing commentator '.$sgCrew['id'].': '.$e->getMessage());
+                       }
+               }
+
+               $this->purgeCrew($episode, $sgEntry['helpers'], 'help');
+               foreach ($sgEntry['helpers'] as $sgCrew) {
+                       try {
+                               $this->syncCrew($episode, $sgCrew, 'help', 'setup');
+                       } catch (Exception $e) {
+                               $this->error('error syncing helper '.$sgCrew['id'].': '.$e->getMessage());
+                       }
+               }
+
+               $this->purgeCrew($episode, $sgEntry['trackers'], 'track');
+               foreach ($sgEntry['trackers'] as $sgCrew) {
+                       try {
+                               $this->syncCrew($episode, $sgCrew, 'track', 'tracking');
+                       } catch (Exception $e) {
+                               $this->error('error syncing tracker '.$sgCrew['id'].': '.$e->getMessage());
+                       }
+               }
+
                $this->purgePlayers($episode, $sgEntry);
                foreach ($sgEntry['match1']['players'] as $sgPlayer) {
                        try {
@@ -138,10 +178,13 @@ class SyncSpeedGaming extends Command {
                foreach ($sgEntry['channels'] as $sgChannel) {
                        $ext_ids[] = 'sg:'.$sgChannel['id'];
                }
-               $episode->channels()
-                 ->where('ext_id', 'LIKE', 'sg:%')
-                 ->whereNotIn('ext_id', $ext_ids)
-                 ->detach();
+               $channels = $episode->channels()
+                       ->where('ext_id', 'LIKE', 'sg:%')
+                       ->whereNotIn('ext_id', $ext_ids)
+                       ->get();
+               if (!$channels->isEmpty()) {
+                       $episode->channels()->detach($channels->pluck('id'));
+               }
        }
 
        private function syncChannel(Episode $episode, $sgChannel) {
@@ -160,6 +203,47 @@ class SyncSpeedGaming extends Command {
                return $channel;
        }
 
+       private function purgeCrew(Episode $episode, $sgCrews, $prefix) {
+               $ext_ids = [];
+               foreach ($sgCrews as $sgCrew) {
+                       $ext_ids[] = 'sg:'.$prefix.':'.$sgCrew['id'];
+               }
+               $episode->crew()->where('ext_id', 'LIKE', 'sg:'.$prefix.':%')->whereNotIn('ext_id', $ext_ids)->delete();
+       }
+
+       private function syncCrew(Episode $episode, $sgCrew, $prefix, $role) {
+               $ext_id = 'sg:'.$prefix.':'.$sgCrew['id'];
+               $crew = $episode->crew()->firstWhere('ext_id', '=', $ext_id);
+               if (!$crew) {
+                       $crew = new EpisodeCrew();
+                       $crew->ext_id = $ext_id;
+                       $crew->episode()->associate($episode);
+               }
+               $user = $this->getUserBySGPlayer($sgCrew);
+               if ($user) {
+                       $crew->user()->associate($user);
+               } else {
+                       $crew->user()->disassociate();
+               }
+               if ($role == 'commentary') {
+                       $channel = $this->getChannelByCrew($episode, $sgCrew);
+                       if ($channel) {
+                               $crew->channel()->associate($channel);
+                       } else {
+                               $crew->channel()->disassociate();
+                       }
+               }
+               $crew->role = $role;
+               $crew->confirmed = $sgCrew['approved'] ?: false;
+               if (!empty($sgCrew['displayName'])) {
+                       $crew->name_override = $sgCrew['displayName'];
+               }
+               if (!empty($sgCrew['publicStream'])) {
+                       $crew->stream_override = 'https://twitch.tv/'.strtolower($sgCrew['publicStream']);
+               }
+               $crew->save();
+       }
+
        private function purgePlayers(Episode $episode, $sgEntry) {
                $ext_ids = [];
                foreach ($sgEntry['match1']['players'] as $sgPlayer) {
@@ -186,21 +270,46 @@ class SyncSpeedGaming extends Command {
                        $player->name_override = $sgPlayer['displayName'];
                }
                if (!empty($sgPlayer['streamingFrom'])) {
-                       $player->stream_override = strtolower($sgPlayer['streamingFrom']);
+                       $player->stream_override = 'https://twitch.tv/'.strtolower($sgPlayer['streamingFrom']);
                }
                $player->save();
        }
 
+       private function getChannelByCrew(Episode $episode, $sgCrew) {
+               $channel = $episode->channels()
+                 ->where('ext_id', 'LIKE', 'sg:%')
+                 ->whereJsonContains('languages', $sgCrew['language'])
+                 ->first();
+               if ($channel) {
+                       return $channel;
+               }
+               return $episode->channels()
+                 ->where('ext_id', 'LIKE', 'sg:%')
+                 ->first();
+       }
+
        private function getUserBySGPlayer($player) {
                if (!empty($player['discordId'])) {
                        $user = User::find($player['discordId']);
-                       if ($user) return $user;
+                       if ($user) {
+                               if (empty($user->stream_link)) {
+                                       if (!empty($sgPlayer['publicStream'])) {
+                                               $user->stream_link = 'https://twitch.tv/'.strtolower($sgPlayer['publicStream']);
+                                               $user->save();
+                                       } else if (!empty($sgPlayer['streamingFrom'])) {
+                                               $user->stream_link = 'https://twitch.tv/'.strtolower($sgPlayer['streamingFrom']);
+                                               $user->save();
+                                       }
+                               }
+                               return $user;
+                       }
+                       DiscordBotCommand::syncUser($player['discordId']);
                }
                if (!empty($player['discordTag'])) {
                        $tag = explode('#', $player['discordTag']);
                        $user = User::firstWhere([
                                ['username', 'LIKE', $tag[0]],
-                               ['username', 'LIKE', $tag[1]],
+                               ['discriminator', '=', $tag[1]],
                        ]);
                        if ($user) return $user;
                }