<?php

namespace App\Services;

use App\Http\Resources\MovieDetail;
use App\Services\TmdbClient as ServicesTmdbClient;
use App\Supports\Traits\CleanItems;
use App\Supports\Traits\Helpers;
use Carbon\Carbon;
use Illuminate\Support\Facades\Cache;
use Illuminate\Support\Facades\Redis;
use Symfony\Component\Cache\Adapter\RedisAdapter;
use Symfony\Component\Cache\Adapter\RedisTagAwareAdapter;
use Tmdb\Client;
use Tmdb\Event\BeforeRequestEvent;
use Tmdb\Event\Listener\Request\AcceptJsonRequestListener;
use Tmdb\Event\Listener\Request\ApiTokenRequestListener;
use Tmdb\Event\Listener\Request\ContentTypeJsonRequestListener;
use Tmdb\Event\Listener\Request\UserAgentRequestListener;
use Tmdb\Event\RequestEvent;
use Tmdb\Token\Api\ApiToken;
use Tmdb\Token\Api\BearerToken;
use Tmdb\Event\Listener\Psr6CachedRequestListener;
use Tmdb\Event\Listener\Request\LanguageFilterRequestListener;
use Tmdb\Event\Listener\Request\RegionFilterRequestListener;

class TmdbClient
{
    use CleanItems, Helpers;
    private static $instance;
    private $ttl = 3600*24;
    private $use_cache = false;
    /** @var Client $client **/
    public $client;
    private static $api_keys = ['aba8176c9250ba755ca1783de87528a2', '5c6763d6500cc611d442a5414e951c05'];


    public function __construct($tmdb_key = null, $use_cache = false, $cache_time = 3600)
    {
        // 5c6763d6500cc611d442a5414e951c05
        $this->ttl = $cache_time;
        $this->use_cache = $use_cache;

        $api_key_key = array_rand(self::$api_keys);
        if(!defined("TMDB_API_KEY")){
            define('TMDB_API_KEY', self::$api_keys[$api_key_key]);
        }

        $token = defined('TMDB_BEARER_TOKEN') && TMDB_BEARER_TOKEN !== 'TMDB_BEARER_TOKEN' ?
        new BearerToken(TMDB_BEARER_TOKEN) :
        new ApiToken(TMDB_API_KEY);

        $ed = new \Symfony\Component\EventDispatcher\EventDispatcher();

        $client = new Client(
            [
                /** @var ApiToken|BearerToken */
                'api_token' => $token,
                'event_dispatcher' => [
                    'adapter' => $ed
                ],
                // We make use of PSR-17 and PSR-18 auto discovery to automatically guess these, but preferably set these explicitly.
                'http' => [
                    'client' => null,
                    'request_factory' => null,
                    'response_factory' => null,
                    'stream_factory' => null,
                    'uri_factory' => null,
                ]
            ]
        );

        /**
         * Required event listeners and events to be registered with the PSR-14 Event Dispatcher.
         */
        // $cache = new FilesystemAdapter('php-tmdb', 86400, '/home/cache');
        $redisConnection = RedisAdapter::createConnection('redis:///var/lib/redis/redis.sock/15');
        $cache = new RedisTagAwareAdapter($redisConnection, 3600*24);
        // $requestListener = new RequestListener($client->getHttpClient(), $ed);
        $requestListener = new Psr6CachedRequestListener(
            $client->getHttpClient(),
            $ed,
            $cache,
            $client->getHttpClient()->getPsr17StreamFactory(),
            []
        );
        $ed->addListener(RequestEvent::class, $requestListener);

        $apiTokenListener = new ApiTokenRequestListener($client->getToken());
        $ed->addListener(BeforeRequestEvent::class, $apiTokenListener);

        $acceptJsonListener = new AcceptJsonRequestListener();
        $ed->addListener(BeforeRequestEvent::class, $acceptJsonListener);

        $jsonContentTypeListener = new ContentTypeJsonRequestListener();
        $ed->addListener(BeforeRequestEvent::class, $jsonContentTypeListener);

        $userAgentListener = new UserAgentRequestListener();
        $ed->addListener(BeforeRequestEvent::class, $userAgentListener);

        // $regionFilerListener = new RegionFilterRequestListener();
        // $ed->addListener(BeforeRequestEvent::class, $regionFilerListener);

        // $languageFilerListener = new LanguageFilterRequestListener();
        // $ed->addListener(BeforeRequestEvent::class, $languageFilerListener);

        $this->client = $client;
        // self::$client = $client;


    }
    /**
     * @return  Client
     */
    public static function getClient() {
        // Check is $_instance has been set
        if(!isset(self::$instance))
        {
            // Creates sets object to instance
            self::$instance = new TmdbClient();
        }

        // Returns the instance
        return self::$instance::$client;
    }

    public function getMovie(int $id)
    {
        try {
            $call = fn() => $this->formatTmdbMovie($this->client->getMoviesApi()->getMovie($id, ['append_to_response'=>'credits,videos,keywords,recommendations']));

            if ($this->use_cache)
            return Cache::remember('movie:'.$id, $this->ttl, $call);

            return $call();
        } catch (\Throwable $th) {
            return abort(404, 'Not Found');
        }

    }
    public function getShow(int $id)
    {

        try {
            $call = fn() => $this->formatTmdbShow($this->client->getTvApi()->getTvshow($id, ['append_to_response'=>'credits,videos,recommendations,keywords']));
            if ($this->use_cache)
            return Cache::remember('show:'.$id, $this->ttl, $call);

            return $call();
        } catch (\Throwable $th) {
            return abort(404, 'Not Found');
        }

    }
    public function getSeason(int $id, int $season_number)
    {
        $call = fn() => $this->client->getTvSeasonApi()->getSeason($id, $season_number, ['append_to_response'=>'credits,videos,keywords']);
        if ($this->use_cache)
        return Cache::remember('show'.$id.'_'.$season_number, $this->ttl, $call);

        return $call();

    }
    public function getEpisode(int $id, int $season_number, int $episode_number)
    {
        $call = fn() => $this->client->getTvEpisodeApi()->getEpisode($id, $season_number, $episode_number, ['append_to_response'=>'credits,videos']);
        if ($this->use_cache)
        return Cache::remember('episode'.$id.'_'.$season_number.'_'.$episode_number, $this->ttl, $call);

        return $call();

    }

    public function getUpcomingMovies($page = 1)
    {
        $call = fn() => $this->client->getMoviesApi()->getUpcoming();
        if ($this->use_cache)
        return Cache::remember('upcomingtmdb'.$page, $this->ttl, $call);

        return $call();

    }
    public function getPopularMovies($page = 1)
    {
        $call = fn() => $this->client->getMoviesApi()->getPopular();
        if ($this->use_cache)
        return Cache::remember('populartmdb'.$page, $this->ttl, $call);

        return $call();

    }
    public function getPopularShows($page = 1)
    {
        $call = fn() => $this->client->getTvApi()->getPopular();
        if ($this->use_cache)
        return Cache::remember('populartvtmdb'.$page, $this->ttl, $call);

        return $call();

    }
    public function getAiringShows($page = 1)
    {
        $call = fn() => $this->client->getTvApi()->getOnTheAir();
        if ($this->use_cache)
        return Cache::remember('airingtmdb'.$page, $this->ttl, $call);

        return $call();

    }
    public function getComingSoonMovies($page = 1)
    {
        $from = Carbon::now()
                    ->subDay()
                    ->format('Y-m-d');
                $to = Carbon::now()
                    ->addMonth()
                    ->format('Y-m-d');
        $call = fn() => $this->client->getMoviesApi()->getUpcoming(['sort_by' => 'popularity.desc',
        'with_release_type' => '2|3',
        'primary_release_date.gte' => $from,
        'primary_release_date.lte' => $to,
        'region' => 'US',
        'language' => 'en',
        'include_adult' => 'false',
        'page' => $page,]);
        if ($this->use_cache)
        return Cache::remember('comingsoontmdb'.$page, $this->ttl, $call);

        return $call();

    }
    public function getNowPlayingMovies($page = 1)
    {
        $call = fn() => $this->client->getMoviesApi()->getNowPlaying();
        if ($this->use_cache)
        return Cache::remember('nowplayingtmdb'.$page, $this->ttl, $call);

        return $call();

    }
    public function getCountryMovies($country = 'us', $page = 1)
    {
        // dd($country);
        $call = fn() => $this->client->getDiscoverApi()->discoverMovies(['language' => 'en-US', 'page' => $page, 'region' => $country, 'watch_region' => $country]);
        if ($this->use_cache)
        // return Cache::remember('country'.$country.$page, $this->ttl, $call);

        return $call();

    }
    public function getTopRatedMovies($page = 1)
    {
        // dd($country);
        // dd($page);


        $call = fn() => $this->client->getMoviesApi()->getTopRated(['language' => 'en-US', 'page' => $page]);
        if ($this->use_cache)
        return Cache::remember('toprated'.$page, $this->ttl, $call);

        return $call();

    }

    public function getSearch(string $query, int $page = 1)
    {
        $kw = str_replace('-', ' ',$query);
		$kw = urlencode($kw);

        $call = fn() => $this->client->getSearchApi()->searchMulti($kw, ['page' => $page]);
        if ($this->use_cache)
        return Cache::remember('search'.$kw.'_'.$page, $this->ttl, $call);

        return $call();
    }

    public function getPerson($id)
    {
        $call = fn() => self::filterTmdbPersonData($this->client->getPeopleApi()->getPerson($id, ['language' => 'en-US', 'append_to_response' => 'movie_credits,tv_credits']));
        if ($this->use_cache)
        return Cache::remember('person_movie_credits_'.$id, $this->ttl, $call);

        return $call();

    }

}