<?php

use Fuel\Core\DB;
use Fuel\Core\Format;
use Fuel\Core\Request;
use Fuel\Core\Cache;
use Fuel\Core\CacheNotFoundException;
use Fuel\Core\Database_Query_Builder_Select;
use Fuel\Core\FuelException;

class Model_Movie extends Model_Overwrite
{
    protected static $_table_name = 'movie';
    protected static $_primary_key = 'id';
    protected static $_properties = array(
        'id',
        'library_id',
        'season_id',
        'plex_key',
        'type',
        'number',
        'studio',
        'title',
        'originalTitle',
        'summary',
        'rating',
        'year',
        'thumb',
        'art',
        'duration',
        'originallyAvailableAt',
        'addedAt',
        'updatedAt',
        'disable'
    );

    public $metadata = [];
    public $download = '';

    private $_session = null;

    private $_season = null;
    private $_tv_show = null;
    private $_library = null;
    /** @var Model_Server */
    private $_server = null;

    public $trailer = null;

    public function getSeason()
    {
        if(!$this->_season && $this->season_id !== null)
            $this->_season = Model_Season::find_by_pk($this->season_id);

        return $this->_season;
    }

    public function getTvShow()
    {
        if(!$this->_tv_show) {
            $season = $this->getSeason();

            if($season !== null)
                $this->_tv_show = Model_Tvshow::find_by_pk($season->tv_show_id);
        }

        return $this->_tv_show;
    }

    /**
     * @return Model_Library|null
     */
    public function getLibrary()
    {
        if(!$this->_library) {
            if($this->type === 'episode') {
                $tvshow = $this->getTvShow();
                $this->_library = Model_Library::find_by_pk($tvshow->library_id);
            } else if($this->type === 'movie') {
                $this->_library = Model_Library::find_by_pk($this->library_id);
            }
        }

        return $this->_library;
    }

    /**
     * @return Model_Server
     */
    public function getServer()
    {
        if(!$this->_server) {
            $library = $this->getLibrary();
            $this->_server = Model_Server::find_by_pk($library->server_id);
        }

        return $this->_server;
    }

    public function getCover($width = null, $height = null)
    {
        if(!$this->_server)
            $this->getServer();

        $path_cache = null;
        $thumb = null;

        if(!$width && !$height)
            $path_cache = '.cover';
        else
            $path_cache = '.cover_' . $width . '_' . $height;

        try {
            $thumb = Cache::get($this->id . $path_cache);

            if ($thumb)
                return $thumb;
        } catch (CacheNotFoundException $e) {

            if($this->type === 'episode')
                $this->getPicture($this->_season->thumb,$path_cache, $width, $height);
            else if($this->type === 'movie')
                $this->getPicture($this->thumb, $path_cache, $width, $height);

            $thumb = Cache::get($this->id . $path_cache);
            return $thumb;
        }
    }

    private function getPicture($path, $path_cache, $width = null, $height = null)
    {
        if(!$this->_server)
            $this->getServer();

        $curl = null;

        if (!$width && !$height)
            $curl = Request::forge(($this->_server->https === '1' ? 'https' : 'http').'://' . $this->_server->url . ($this->_server->port ? ':' . $this->_server->port : '') . $path . '?X-Plex-Token=' . $this->_server->token, 'curl');
        else
            $curl = Request::forge(($this->_server->https === '1' ? 'https' : 'http').'://' . $this->_server->url . ($this->_server->port ? ':' . $this->_server->port : '') . '/photo/:/transcode?width=' . $width . '&height=' . $height . '&minSize=1&url=' . $path . '&X-Plex-Token=' . $this->_server->token, 'curl');

        if($this->_server->https === '1') {
            $curl->set_options([
                CURLOPT_SSL_VERIFYPEER => false,
                CURLOPT_SSL_VERIFYHOST => false
            ]);
        }

        try {
            $curl->execute();
        } catch (Exception $exception) {
            Cache::set($this->id . $path_cache, null, 24 * 60 * 60);
        }

        if ($curl->response()->status !== 200)
            return false;

        Cache::set($this->id . $path_cache, $curl->response()->body, 24 * 60 * 60);
    }

    public function getThumb($width = null, $height = null)
    {
        $path_cache = null;
        $thumb = null;

        if(!$width && !$height)
            $path_cache = '.preview';
        else
            $path_cache = '.preview_' . $width . '_' . $height;

        try {
            $thumb = Cache::get($this->id . $path_cache);

            if ($thumb)
                return $thumb;
        } catch (CacheNotFoundException $e) {
            $this->getPicture($this->thumb, $path_cache, $width, $height);

            $thumb = Cache::get($this->id . $path_cache);
            return $thumb;
        }
    }

    public function getArt($width = null, $height = null)
    {
        $path_cache = null;
        $art = null;

        if(!$width && !$height)
            $path_cache = '.art';
        else
            $path_cache = '.art_' . $width . '_' . $height;

        try {
            $art = Cache::get($this->id . $path_cache);

            if ($art)
                return $art;
        } catch (CacheNotFoundException $e) {
            $this->getPicture($this->art, $path_cache, $width, $height);

            $art = Cache::get($this->id . $path_cache);
            return $art;
        }
    }

    /**
     * @return array|mixed
     * @throws FuelException
     */
    public function getMetaData()
    {
        try {
            $this->metadata = Cache::get($this->id . '.metadata');
            if ($this->metadata)
                return $this->metadata;
        } catch (CacheNotFoundException $e) {
            if(!$this->_server)
                $this->getServer();

            $curl = Request::forge(($this->_server->https === '1' ? 'https' : 'http').'://' . $this->_server->url . ($this->_server->port ? ':' . $this->_server->port : '') . $this->plex_key . '?X-Plex-Token=' . $this->_server->token, 'curl');

            if($this->_server->https === '1') {
                $curl->set_options([
                    CURLOPT_SSL_VERIFYPEER => false,
                    CURLOPT_SSL_VERIFYHOST => false
                ]);
            }

            $curl->execute();

            $array = Format::forge($curl->response()->body, 'xml')->to_array();

            //MEDIA
            $this->metadata['Media'] = $array['Video']['Media'];
            //GENRE
            $this->metadata['Genre'] = isset($array['Video']['Genre']) ? $array['Video']['Genre'] : null;
            //DIRECTOR
            $this->metadata['Director'] = isset($array['Video']['Director']) ? $array['Video']['Director'] : null;
            //WRITER
            $this->metadata['Writer'] = isset($array['Video']['Writer']) ? $array['Video']['Writer'] : null;
            //ROLES
            $this->metadata['Role'] = isset($array['Video']['Role']) ? $array['Video']['Role'] : null;

            $this->metadata['Stream'] = [];
            $this->metadata['Stream']['Video'] = [];
            $this->metadata['Stream']['Audio'] = [];
            $this->metadata['Stream']['SubTitle'] = [];

            if(isset($array['Video']['Media']['Part']['Stream'])) {
                foreach ($array['Video']['Media']['Part']['Stream'] as $stream) {
                    if($stream['@attributes']['streamType'] === '1')
                        $this->metadata['Stream']['Video'][] = $stream['@attributes'];
                    else if($stream['@attributes']['streamType'] === '2')
                        $this->metadata['Stream']['Audio'][] = $stream['@attributes'];
                    else if($stream['@attributes']['streamType'] === '3')
                        $this->metadata['Stream']['SubTitle'][] = $stream['@attributes'];
                }
            }

            Cache::set($this->id . '.metadata', $this->metadata, 7 * 24 * 60 * 60);
            return $this->metadata;
        } catch (Exception $exception) {
            throw new FuelException($exception->getMessage(),$exception->getCode());
        }
    }

    public function getReleaseDate()
    {
        if(!$this->originallyAvailableAt)
            return null;

        $date = new DateTime($this->originallyAvailableAt);

        return $date->format('d F Y');
    }

    public function getDuration()
    {
        $init = $this->duration;

        $hours = floor($init / (3600 * 1000));
        $minutes = floor(($init / (60 * 1000)) % 60);

        return ($hours > 0 ? $hours . ' h ' : '') . $minutes . ' min';
    }

    public function getDurationMovie()
    {
        $init = $this->duration;

        $hours = floor($init / (3600 * 1000));
        $minutes = floor(($init / (60 * 1000)) % 60);
        $secondes = floor(($init - ($hours * 3600 * 1000) - ($minutes * 60 * 1000)) / 1000);

        return ($hours > 0 ? $hours . ':' : '') . ($minutes > 0 ? $minutes . ':' : '0:') . $secondes;
    }

    public function getStreamUrl($user_settings)
    {
        try {
            if (!$this->_server)
                $this->getServer();

            $maxVideoBitrate = isset($user_settings->maxdownloadspeed) ? $user_settings->maxdownloadspeed : 10000;
            $subtitleSize = isset($user_settings->subtitle) ? $user_settings->subtitle : 100;
            $language = isset($user_settings->language) ? $user_settings->language : false;

            $request = $this->_server->https === '1' ? 'https' : 'http';
            $request .= '://' . $this->_server->url . ($this->_server->port ? ':' . $this->_server->port : '');
            //$request .= '/video/:/transcode/universal/start.mpd?hasMDE=1'; // DASH
            $request .= '/video/:/transcode/universal/start.m3u8'; // HLS
            $request .= '?identifier=[PlexShare_V0.0.1]';
            $request .= '&path=http%3A%2F%2F127.0.0.1%3A32400' . urlencode($this->plex_key);
            $request .= '&mediaIndex=0';
            $request .= '&partIndex=0';
            //$request .= '&protocol=dash';
            $request .= '&protocol=hls';
            $request .= '&offset=0';
            $request .= '&fastSeek=1';
            $request .= '&directStream=1';
            $request .= '&directPlay=0';
            $request .= '&videoQuality=100';
            $request .= '&maxVideoBitrate=' . $maxVideoBitrate;
            $request .= '&subtitleSize=' . $subtitleSize;
            $request .= '&audioBoost=100';
            $request .= '&videoResolution=1920x1080';
            $request .= '&Accept-Language=' . $language;
            $request .= '&X-Plex-Platform=Chrome';
            $request .= '&X-Plex-Token=' . $this->_server->token;

            $curl = Request::forge($request, 'curl');

            if($this->_server->https === '1') {
                $curl->set_options([
                    CURLOPT_SSL_VERIFYPEER => false,
                    CURLOPT_SSL_VERIFYHOST => false
                ]);
            }

            $curl->execute();

            if ($curl->response()->status !== 200)
                throw new FuelException('Error to create a session on plex!');

            preg_match('/session\/[a-z0-9\-]+\/base\/index\.m3u8/', $curl->response()->body, $matches);

            if (count($matches) <= 0)
                throw new FuelException('No session found!');

            $split = preg_split('/\//', $matches[0]);

            if (count($split) <= 0)
                throw new FuelException('No session found!');

            $this->_session = $split[1];

            return '/movie/' . $this->id . '/video/:/transcode/universal/session/' . $this->_session . '/base/index.m3u8';
            //return ($this->_server->https === '1' ? 'https' : 'http') . '://' . $this->_server->url . ($this->_server->port ? ':' . $this->_server->port : '') . '/video/:/transcode/universal/session/' . $this->_session . '/base/index.m3u8';
        } catch (Exception $exception) {
            if($exception->getCode() === 403)
                throw new FuelException('Cannot connect to the server.<br/>The token must be outdated!', $exception->getCode());
            else
                throw new FuelException($exception->getMessage(), $exception->getCode());
        }
    }

    public function getDownloadLink()
    {
        try {
            $this->download = Cache::get($this->id . '.download');
            return $this->download;
        } catch (CacheNotFoundException $e) {
            if(!$this->_server)
                $this->getServer();

            $this->getMetaData();

            if((!isset($this->metadata['Media']) && !isset($this->metadata['Media'][0]))
                || (!isset($this->metadata['Media']['Part']) && !isset($this->metadata['Media'][0]['Part']))
                || (!isset($this->metadata['Media']['Part']['@attributes']) && !isset($this->metadata['Media'][0]['Part']['@attributes']))
                || (!isset($this->metadata['Media']['Part']['@attributes']['key'])  && !isset($this->metadata['Media'][0]['Part']['@attributes']['key'])) ) {
                Cache::set($this->id . '.download', null,24 * 60 * 60);
                return null;
            }

            $key = '';

            if(isset($this->metadata['Media'][0]))
                $key = $this->metadata['Media'][0]['Part']['@attributes']['key'];
            else
                $key = $this->metadata['Media']['Part']['@attributes']['key'];

            $curl = ($this->_server->https === '1' ? 'https' : 'http').'://' . $this->_server->url . ($this->_server->port ? ':' . $this->_server->port : '') . $key . '?X-Plex-Token=' . $this->_server->token;

            $this->download = $curl;

            Cache::set($this->id . '.download', $curl, 24 * 60 * 60);
            return $this->download;
        } catch (Exception $exception) {
            throw new FuelException($exception->getMessage(),$exception->getCode());
        }
    }

    /**
     * @param $server
     * @param $movies
     * @param null $library
     * @param null $season
     * @return bool
     * @throws Exception
     * @throws FuelException
     * @throws HttpNotFoundException
     * @throws \FuelException
     */
    public static function BrowseMovies($server, $movies, $library = null, $season = null)
    {
        $movies_id_array = [];

        foreach ($movies as $XMLmovie) {
            $XMLmovie = !isset($movies['@attributes']) ? $XMLmovie : $movies;

            $library_id = isset($library->id) ? $library->id : null;
            $season_id = isset($season->id) ? $season->id : null;

            $movie = Model_Movie::find(function ($query) use ($XMLmovie, $library_id, $season_id){
                /** @var Database_Query_Builder_Select $query */
                return $query
                    ->select('*')
                    ->where('plex_key', $XMLmovie['@attributes']['key'])
                    ->and_where_open()
                    ->where('season_id', $season_id)
                    ->and_where('library_id', $library_id)
                    ->and_where_close()
                    ;
            });

            $movie = $movie !== null ? $movie[0] : Model_Movie::forge();

            if($library === null && $season === null)
                throw new FuelException('Missing Parameters for the movie');

            $movie->set([
                'library_id'            => $library ? $library->id : null,
                'season_id'             => $season ? $season->id : null,
                'plex_key'              => $XMLmovie['@attributes']['key'],
                'type'                  => $XMLmovie['@attributes']['type'],
                'number'                => isset($XMLmovie['@attributes']['index']) ? $XMLmovie['@attributes']['index'] : null,
                'studio'                => isset($XMLmovie['@attributes']['studio']) ? $XMLmovie['@attributes']['studio'] : null,
                'title'                 => $XMLmovie['@attributes']['title'],
                'originalTitle'         => isset($XMLmovie['@attributes']['originalTitle']) ? $XMLmovie['@attributes']['originalTitle'] : null,
                'summary'               => $XMLmovie['@attributes']['summary'],
                'rating'                => isset($XMLmovie['@attributes']['rating']) ? $XMLmovie['@attributes']['rating'] : null,
                'year'                  => isset($XMLmovie['@attributes']['year']) ? $XMLmovie['@attributes']['year'] : null,
                'thumb'                 => isset($XMLmovie['@attributes']['thumb']) ? $XMLmovie['@attributes']['thumb'] : null,
                'art'                   => isset($XMLmovie['@attributes']['art']) ? $XMLmovie['@attributes']['art'] : null,
                'duration'              => isset($XMLmovie['@attributes']['duration']) ? $XMLmovie['@attributes']['duration'] : null,
                'originallyAvailableAt' => isset($XMLmovie['@attributes']['originallyAvailableAt']) ? $XMLmovie['@attributes']['originallyAvailableAt'] : null,
                'addedAt'               => $XMLmovie['@attributes']['addedAt'],
                'updatedAt'             => $XMLmovie['@attributes']['updatedAt']
            ]);

            $movie->save();

            $movies_id_array[]= ['id' => $movie->id, 'name' => $movie->title];

            if(isset($movies['@attributes']))
                break;
        }

        return $movies_id_array;
    }

    public static function getList()
    {
        return self::find(function ($query) {
            /** @var Database_Query_Builder_Select $query */
            return $query
                ->select('*')
                ->where('type', 'movie')
                ->group_by('originalTitle', 'title', 'year')
                ->order_by(DB::expr("str_to_date(`originallyAvailableAt`, '%Y-%m-%d')"), 'DESC')
                ;
        });
    }

    public function getTrailer()
    {
        try {
            $this->trailer = Cache::get($this->id.'.trailer');
            return $this->trailer;
        } catch (CacheNotFoundException $e)
        {
            $trailer = new Model_Trailer($this->id, $this->originalTitle ?: $this->title, $this->year, $this->type);
            $this->trailer = $trailer->getTrailer();

            Cache::set($this->id . '.trailer', $this->trailer, 24 * 60 * 60);
            return $this->trailer;
        }
    }
}