3 namespace App\Console\Commands;
5 use App\Models\Episode;
6 use App\Models\EpisodePlayer;
10 use Illuminate\Console\Command;
11 use Illuminate\Database\Eloquent\Builder;
12 use Illuminate\Support\Facades\Http;
14 class SyncSpeedGaming extends Command {
17 * The name and signature of the console command.
21 protected $signature = 'sync:speedgaming';
24 * The console command description.
28 protected $description = 'Synchronize SpeedGaming schedule';
31 * Execute the console command.
35 public function handle() {
36 $events = Event::where('external_schedule', 'LIKE', 'sg:%')
37 ->where(function (Builder $query) {
38 $query->whereNull('end');
39 $query->orWhere('end', '<', now());
42 foreach ($events as $event) {
44 $this->line('syncing '.$event->name);
45 $this->syncEvent($event);
46 } catch (\Exception $e) {
47 $this->error('error syncing event '.$event->name.': '.$e->getMessage());
53 private function syncEvent(Event $event) {
54 $sgHandle = substr($event->external_schedule, 3);
55 $from = now()->sub(1, 'day');
56 $to = now()->add(6, 'day');
57 $sgSchedule = HTTP::get('https://speedgaming.org/api/schedule/', [
59 'from' => $from->toIso8601String(),
60 'to' => $to->toIso8601String(),
62 $this->purgeSchedule($event, $from, $to, $sgSchedule);
63 foreach ($sgSchedule as $sgEntry) {
65 $this->syncSchedule($event, $sgEntry);
66 } catch (Exception $e) {
67 $this->error('error syncing episode '.$sgEntry['id'].': '.$e->getMessage());
72 private function purgeSchedule(Event $event, $from, $to, $sgSchedule) {
74 foreach ($sgSchedule as $sgEntry) {
75 $ext_ids[] = 'sg:'.$sgEntry['id'];
77 $to_purge = $event->episodes()
78 ->where('start', '>=', $from)
79 ->where('start', '<=', $to)
80 ->whereNotIn('ext_id', $ext_ids);
81 foreach ($to_purge->get() as $episode) {
82 $episode->players()->delete();
87 private function syncSchedule(Event $event, $sgEntry) {
88 $ext_id = 'sg:'.$sgEntry['id'];
89 $episode = Episode::firstWhere('ext_id', '=', $ext_id);
91 $episode = new Episode();
92 $episode->ext_id = $ext_id;
94 $episode->event()->associate($event);
95 $episode->title = $sgEntry['match1']['title'];
96 $start = Carbon::parse($sgEntry['when']);
97 if ($start->ne($episode->start)) {
98 $episode->start = $start;
100 $episode->estimate = $sgEntry['length'] * 60;
101 $episode->confirmed = $sgEntry['approved'];
102 $episode->comment = $sgEntry['match1']['note'];
104 $this->purgePlayers($episode, $sgEntry);
105 foreach ($sgEntry['match1']['players'] as $sgPlayer) {
107 $this->syncPlayer($episode, $sgPlayer);
108 } catch (Exception $e) {
109 $this->error('error syncing player '.$sgPlayer['id'].': '.$e->getMessage());
114 private function purgePlayers(Episode $episode, $sgEntry) {
116 foreach ($sgEntry['match1']['players'] as $sgPlayer) {
117 $ext_ids[] = 'sg:'.$sgPlayer['id'];
119 $episode->players()->whereNotIn('ext_id', $ext_ids)->delete();
122 private function syncPlayer(Episode $episode, $sgPlayer) {
123 $ext_id = 'sg:'.$sgPlayer['id'];
124 $player = $episode->players()->firstWhere('ext_id', '=', $ext_id);
126 $player = new EpisodePlayer();
127 $player->ext_id = $ext_id;
128 $player->episode()->associate($episode);
130 $user = $this->getUserBySGPlayer($sgPlayer);
132 $player->user()->associate($user);
134 $player->user()->disassociate();
136 if (!empty($sgPlayer['displayName'])) {
137 $player->name_override = $sgPlayer['displayName'];
139 if (!empty($sgPlayer['streamingFrom'])) {
140 $player->stream_override = $sgPlayer['streamingFrom'];
145 private function getUserBySGPlayer($player) {
146 if (!empty($player['discordId'])) {
147 $user = User::find($player['discordId']);
148 if ($user) return $user;
150 if (!empty($player['discordTag'])) {
151 $tag = explode('#', $player['discordTag']);
152 $user = User::firstWhere([
153 ['username', 'LIKE', $tag[0]],
154 ['username', 'LIKE', $tag[1]],
156 if ($user) return $user;