<?php

namespace App\Console\Commands;

use App\Models\Channel;
use App\Models\Episode;
use App\Models\EpisodePlayer;
use App\Models\Event;
use App\Models\Organization;
use App\Models\User;
use Carbon\Carbon;
use Illuminate\Console\Command;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Support\Facades\Http;
use Illuminate\Support\Str;

class SyncZSR extends Command {

	/**
	 * The name and signature of the console command.
	 *
	 * @var string
	 */
	protected $signature = 'sync:zsr';

	/**
	 * The console command description.
	 *
	 * @var string
	 */
	protected $description = 'Synchronize Zelda Speedruns schedule';

	/**
	 * Execute the console command.
	 *
	 * @return int
	 */
	public function handle() {
		$this->org = Organization::where('name', '=', 'zsr')->firstOrFail();

		$events = Event::where('external_schedule', 'LIKE', 'zsr:%')
			->where(function (Builder $query) {
				$query->whereNull('end');
				$query->orWhere('end', '<', now());
			})
			->get();

		$from = now()->sub(1, 'day');
		$to = now()->add(14, 'day');
		$schedule = Http::get('https://www.googleapis.com/calendar/v3/calendars/zsrstaff%40gmail.com/events', [
			'alt' => 'json',
			'key' => config('google.api_key'),
			'timeMax' => $to->toIso8601String(),
			'timeMin' => $from->toIso8601String(),
		])->json();

		foreach ($events as $event) {
			try {
				$this->line('syncing '.$event->name);
				$this->syncEvent($event, $schedule['items']);
			} catch (\Exception $e) {
				$this->error('error syncing event '.$event->name.': '.$e->getMessage());
			}
		}

		return Command::SUCCESS;
	}

	private function syncEvent(Event $event, $schedule) {
		$tag = substr($event->external_schedule, 4);
		foreach ($schedule as $entry) {
			if (!Str::startsWith($entry['summary'], $tag)) continue;
			$this->syncSchedule($event, $entry);
		}

	}

	private function syncSchedule(Event $event, $entry) {
		$ext_id = 'zsr:'.$entry['id'];
		$episode = Episode::firstWhere('ext_id', '=', $ext_id);
		if (!$episode) {
			$episode = new Episode();
			$episode->ext_id = $ext_id;
		}
		$episode->event()->associate($event);
		if (strlen($entry['summary']) > (strlen($event->external_schedule) - 4)) {
			$episode->title = substr($entry['summary'], strlen($event->external_schedule) - 4);
		} else {
			$episode->title = $entry['summary'];
		}
		$start = Carbon::parse($entry['start']['dateTime'])->setTimezone('UTC');
		if (!$episode->start || $start->ne($episode->start)) {
			$episode->start = $start;
		}
		$end = Carbon::parse($entry['end']['dateTime'])->setTimezone('UTC');
		$episode->estimate = $start->diffInSeconds($end);
		$episode->confirmed = true;
		if (preg_match('/^(.*) - (.*?) vs\.? (.*?) vs\.? (.*?) vs\.? (.*?)$/u', $episode->title, $matches)) {
			$episode->title = $matches[1];
			$episode->save();
			$this->syncPlayer($episode, $matches[2]);
			$this->syncPlayer($episode, $matches[3]);
			$this->syncPlayer($episode, $matches[4]);
			$this->syncPlayer($episode, $matches[5]);
		} else if (preg_match('/^(.*) - (.*?) vs\.? (.*?) vs\.? (.*?)$/u', $episode->title, $matches)) {
			$episode->title = $matches[1];
			$episode->save();
			$this->syncPlayer($episode, $matches[2]);
			$this->syncPlayer($episode, $matches[3]);
			$this->syncPlayer($episode, $matches[4]);
		} else if (preg_match('/^(.*) - (.*?) vs\.? (.*?)$/u', $episode->title, $matches)) {
			$episode->title = $matches[1];
			$episode->save();
			$this->syncPlayer($episode, $matches[2]);
			$this->syncPlayer($episode, $matches[3]);
		} else {
			$episode->save();
		}
		if (preg_match('/Restream: https?:\/\/(www\.)?twitch\.tv\/(\w+)/u', $entry['description'], $matches)) {
			$channel = $this->syncChannel($episode, $matches[2]);
			if ($channel) {
				$episode->channels()->syncWithoutDetaching([$channel->id]);
			}
		}
	}

	private function syncChannel(Episode $episode, $zsrChannel) {
		$ext_id = 'zsr:'.$zsrChannel;
		$channel = $this->org->channels()->firstWhere('ext_id', '=', $ext_id);
		if (!$channel) {
			$channel = new Channel();
			$channel->ext_id = $ext_id;
			$channel->organization()->associate($this->org);
			$channel->languages = ['en'];
			$channel->short_name = '';
		}
		$channel->title = $zsrChannel;
		$channel->stream_link = 'https://twitch.tv/'.strtolower($zsrChannel);
		$channel->save();
		return $channel;
	}

	private function syncPlayer(Episode $episode, $zsrPlayer) {
		$ext_id = 'zsr:'.$zsrPlayer;
		$player = $episode->players()->firstWhere('ext_id', '=', $ext_id);
		if (!$player) {
			$player = new EpisodePlayer();
			$player->ext_id = $ext_id;
			$player->episode()->associate($episode);
		}
		$user = $this->getUserByZSRPlayer($zsrPlayer);
		if ($user) {
			$player->user()->associate($user);
		} else {
			$player->user()->disassociate();
		}
		$player->name_override = $zsrPlayer;
		$player->save();
		return $player;
	}

	private function getUserByZSRPlayer($player) {
		$user = User::firstWhere('discord_nickname', '=', $player);
		if ($user) {
			return $user;
		}
		$user = User::firstWhere('username', '=', strtolower($player));
		if ($user) {
			return $user;
		}
		return null;
	}

	private $org;

}