PlexShare/fuel/app/classes/model/library.php

<?php


use Fuel\Core\FuelException;

class Model_Library extends Model_Overwrite
{
    protected static $_table_name = 'library';
    protected static $_primary_key = 'id';
    protected static $_properties = array(
        'id',
        'plex_key',
        'server_id',
        'name',
        'type',
        'updatedAt',
        'createdAt',
        'scannedAt',
        'disable'
    );

    private $_server = null;

    public function getServer()
    {
        if(!$this->_server)
            $this->_server = Model_Server::find_by_pk($this->server_id);

        return $this->_server;
    }

    public function getLastUpdate()
    {
        $dateString = date('Y/m/d H:i:s', time());
        $now = new DateTime($dateString);

        $dateString = date('Y-m-d H:i:s', $this->updatedAt);
        $time = new DateTime($dateString);

        $diff = date_diff($now, $time);

        $days = $diff->days . 'd ';
        $hours = $diff->h . 'h ';
        $minutes = $diff->i . 'min ';
        $seconds = $diff->s . 's';

        return $days.$hours.$minutes.$seconds;
    }

    /**
     * List all libraries and register it in database
     * @param $server
     * @return bool | array
     * @throws FuelException
     */
    public static function BrowseLibraries($server)
    {
        try {
            $libraries_id_array = [];

            $curl = Request::forge(($server->https ? 'https' : 'http') . '://' . $server->url . ($server->port ? ':' . $server->port : '') . '/library/sections?X-Plex-Token=' . $server->token, 'curl');

            if($server->https) {
                $curl->set_options([
                    CURLOPT_SSL_VERIFYPEER => false,
                    CURLOPT_SSL_VERIFYHOST => false
                ]);
            }

            $curl->execute();

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

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

            if (!isset($list_libraries['Directory']))
                return false;

            $list_libraries = $list_libraries['Directory'];

            foreach ($list_libraries as $index => $library) {
                $library = !isset($list_libraries['@attributes']) ? $library : $list_libraries;

                $new_library = Model_Library::find_by_pk($library['@attributes']['uuid']) ?: Model_Library::forge();

                if ((isset($new_library->disable) && $new_library->disable) || ($library['@attributes']['type'] !== 'show' && $library['@attributes']['type'] !== 'movie'))
                    continue;

                $libraries_id_array[] = ['id' => $library['@attributes']['uuid'], 'name' => $library['@attributes']['title']];

                $new_library->set(array(
                    'id' => $library['@attributes']['uuid'],
                    'plex_key' => $library['@attributes']['key'],
                    'server_id' => $server->id,
                    'name' => $library['@attributes']['title'],
                    'type' => $library['@attributes']['type'],
                    'updatedAt' => time(),
                    'createdAt' => $library['@attributes']['createdAt'],
                    'scannedAt' => $library['@attributes']['scannedAt']
                ));

                $new_library->save();

                //self::getSectionsContent($server, $new_library);

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

            return $libraries_id_array;
        } catch (Exception $exception) {
            throw new FuelException($exception->getMessage(),$exception->getCode());
        }
    }

    /**
     * @param $server
     * @param $library
     * @return bool
     * @throws FuelException
     */
    public static function getLibraryContents($server, $library)
    {
        $curl = Request::forge(($server->https ? 'https' : 'http').'://' . $server->url . ($server->port? ':' . $server->port : '') . '/library/sections/' . $library->plex_key . '/all?X-Plex-Token=' . $server->token, 'curl');

        if($server->https) {
            $curl->set_options([
                CURLOPT_SSL_VERIFYPEER => false,
                CURLOPT_SSL_VERIFYHOST => false
            ]);
        }

        $curl->execute();

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

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

        if(isset($section_content['Directory']))
            return ['tvshows' => Model_Tvshow::BrowseTvShow($server, $section_content['Directory'], $library)];
        else if(isset($section_content['Video']))
            return ['movies' => Model_Movie::BrowseMovies($server, $section_content['Video'], $library)];
    }
}