Directus\SDK\ClientFactory

Complexity

Total Complexity

25

Size/Duplication

Total Lines	338
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	15

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	create()	0	15	3
B	createLocalClient()	0	92	6
A	getFiles()	0	14	2
D	getEmitter()	0	112	13
A	createRemoteClient()	0	4	1

<?php

/**
 * Directus – <http://getdirectus.com>
 *
 * @link      The canonical repository – <https://github.com/directus/directus>
 * @copyright Copyright 2006-2016 RANGER Studio, LLC – <http://rangerstudio.com>
 * @license   GNU General Public License (v3) – <http://www.gnu.org/copyleft/gpl.html>
 */

namespace Directus\SDK;

use Directus\Database\Connection;
use Directus\Database\TableGateway\BaseTableGateway;
use Directus\Database\TableGateway\DirectusSettingsTableGateway;
use Directus\Filesystem\Files;
use Directus\Filesystem\Filesystem;
use Directus\Filesystem\FilesystemFactory;
use Directus\Hook\Emitter;
use Directus\Util\ArrayUtils;
use Directus\Database\TableSchema;

/**
 * Client
 *
 * @author Welling Guzmán <welling@rngr.org>
 */
class ClientFactory
{
    /**
     * @var ClientFactory
     */
    protected static $instance = null;

    /**
     * @var Container
     */
    protected $container;

    /**
     * @var array
     */
    protected $config = [];

    protected $settings = [];

    protected $emitter;

    protected $files;

    /**
     * @var array
     */
    protected $defaultConfig = [
        'environment' => 'development',
        'database' => [
            'driver' => 'pdo_mysql'
        ],
        'status' => [
            'column_name' => 'active',
            'deleted_value' => 0,
            'active_value' => 1,
            'draft_value' => 2,
            'mapping' => [
                0 => [
                    'name' => 'Delete',
                    'color' => '#C1272D',
                    'sort' => 3
                ],
                1 => [
                    'name' => 'Active',
                    'color' => '#5B5B5B',
                    'sort' => 1
                ],
                2 => [
                    'name' => 'Draft',
                    'color' => '#BBBBBB',
                    'sort' => 2
                ]
            ]
        ],
        'filesystem' => [
            'adapter' => 'local',
            // By default media directory are located at the same level of directus root
            // To make them a level up outsite the root directory
            // use this instead
            // Ex: 'root' => realpath(BASE_PATH.'/../storage/uploads'),
            // Note: BASE_PATH constant doesn't end with trailing slash
            'root' => '/storage/uploads',
            // This is the url where all the media will be pointing to
            // here all assets will be (yourdomain)/storage/uploads
            // same with thumbnails (yourdomain)/storage/uploads/thumbs
            'root_url' => '/storage/uploads',
            'root_thumb_url' => '/storage/uploads/thumbs',
            //   'key'    => 's3-key',
            //   'secret' => 's3-key',
            //   'region' => 's3-region',
            //   'version' => 's3-version',
            //   'bucket' => 's3-bucket'
        ],
    ];

    /**
     * @param $userToken
     * @param array $options
     *
     * @return ClientLocal|ClientRemote
     */
    public static function create($userToken, $options = [])
    {
        if (static::$instance == null) {
            static::$instance = new static;
        }

        if (!is_array($userToken)) {
            $newClient = static::$instance->createRemoteClient($userToken, $options);
        } else {
            $options = $userToken;
            $newClient = static::$instance->createLocalClient($options);
        }

        return $newClient;
    }

    /**
     * Creates a new local client instance
     *
     * @param array $options
     *
     * @return ClientLocal
     */
    public function createLocalClient(array $options)
    {
        $this->container = $container = new Container();

        $options = ArrayUtils::defaults($this->defaultConfig, $options);
        $container->set('config', $options);

        $dbConfig = ArrayUtils::get($options, 'database', []);

        $config = ArrayUtils::omit($options, 'database');
        // match the actual directus status mapping config key
        $config['statusMapping'] = $config['status']['mapping'];
        unset($config['status']['mapping']);

        if (!defined('STATUS_DELETED_NUM')) {
            define('STATUS_DELETED_NUM', ArrayUtils::get($config, 'status.deleted_value', 0));
        }

        if (!defined('STATUS_ACTIVE_NUM')) {
            define('STATUS_ACTIVE_NUM', ArrayUtils::get($config, 'status.active_value', 1));
        }

        if (!defined('STATUS_DRAFT_NUM')) {
            define('STATUS_DRAFT_NUM', ArrayUtils::get($config, 'status.draft_value', 2));
        }

        if (!defined('STATUS_COLUMN_NAME')) {
            define('STATUS_COLUMN_NAME', ArrayUtils::get($config, 'status.column_name', 'active'));
        }

        if (!defined('DIRECTUS_ENV')) {
            define('DIRECTUS_ENV', ArrayUtils::get($config, 'environment', 'development'));
        }

        $connection = new Connection($dbConfig);
        $connection->connect();
        $container->set('connection', $connection);

        $acl = new \Directus\Permissions\Acl();
        $acl->setUserId(1);
        $acl->setGroupId(1);
        $acl->setGroupPrivileges([
            '*' => [
                'id' => 1,
                'table_name' => '*',
                'group_id' => 1,
                'read_field_blacklist' => [],
                'write_field_blacklist' => [],
                'nav_listed' => 1,
                'status_id' => 0,
                'allow_view' => 2,
                'allow_add' => 1,
                'allow_edit' => 2,
                'allow_delete' => 2,
                'allow_alter' => 1
            ]
        ]);
        $container->set('acl', $acl);

        $schema = new \Directus\Database\Schemas\Sources\MySQLSchema($connection);
        $container->set('schemaSource', $schema);
        $schema = new \Directus\Database\SchemaManager($schema);
        $container->set('schemaManager', $schema);
        TableSchema::setSchemaManagerInstance($schema);
        TableSchema::setAclInstance($acl);
        TableSchema::setConnectionInstance($connection);
        TableSchema::setConfig($config);

        $container->singleton('emitter', function() {
            return $this->getEmitter();
        });
        $container->set('settings', function(Container $container) {
            $adapter = $container->get('connection');
            $acl = $container->get('acl');
            $Settings = new DirectusSettingsTableGateway($adapter, $acl);

            return $Settings->fetchCollection('files', [
                'thumbnail_size', 'thumbnail_quality', 'thumbnail_crop_enabled'
            ]);
        });
        $container->singleton('files', function() {
            return $this->getFiles();
        });

        BaseTableGateway::setHookEmitter($container->get('emitter'));
        BaseTableGateway::setContainer($container);

        $client = new ClientLocal($connection);
        $client->setContainer($container);

        return $client;
    }

    public function getFiles()
    {
        static $files = null;
        if ($files == null) {
            $config = $this->container->get('config');
            $filesystemConfig = ArrayUtils::get($config, 'filesystem', []);
            $filesystem = new Filesystem(FilesystemFactory::createAdapter($filesystemConfig));

It seems like \Directus\Filesystem\FilesystemFactory::createAdapter($filesystemConfig) can be null; however, __construct() does not accept null, maybe add an additional type check?

            $settings = $this->container->get('settings');
            $emitter = $this->container->get('emitter');
            $files = new Files($filesystem, $filesystemConfig, $settings, $emitter);
        }

        return $files;
    }

    protected function getEmitter()
    {
        static $emitter = null;
        if ($emitter) {
            return $emitter;
        }

        $emitter = new Emitter();
        $acl = $this->container->get('acl');
        $adapter = $this->container->get('connection');

        $emitter->addAction('table.insert.directus_groups', function ($data) use ($acl, $adapter) {
            $privilegesTable = new DirectDirectusPrivilegesTableGateway($adapter, $acl);

            $privilegesTable->insertPrivilege([
                'group_id' => $data['id'],
                'allow_view' => 1,
                'allow_add' => 0,
                'allow_edit' => 1,
                'allow_delete' => 0,
                'allow_alter' => 0,
                'table_name' => 'directus_users',
                'read_field_blacklist' => 'token',
                'write_field_blacklist' => 'group,token'
            ]);
        });

        $emitter->addFilter('table.insert:before', function($payload) {
            // $tableName, $data
            if (func_num_args() == 2) {
                $tableName = func_get_arg(0);
                $data = func_get_arg(1);
            } else {
                $tableName = $payload->tableName;
                $data = $payload->data;
            }

            if ($tableName == 'directus_files') {
                unset($data['data']);
                $data['user'] = 1;
            }

            return func_num_args() == 2 ? $data : $payload;
        });

        // Add file url and thumb url
        $config = $this->container->get('config');
        $files = $this->container->get('files');
        $emitter->addFilter('table.select', function($payload) use ($config, $files) {
            if (func_num_args() == 2) {
                $result = func_get_arg(0);
                $selectState = func_get_arg(1);
            } else {
                $selectState = $payload->selectState;
                $result = $payload->result;
            }

            if ($selectState['table'] == 'directus_files') {
                $fileRows = $result->toArray();
                foreach ($fileRows as &$row) {
                    $fileURL = ArrayUtils::get($config, 'filesystem.root_url', '');
                    $thumbnailURL = ArrayUtils::get($config, 'filesystem.root_thumb_url', '');
                    $thumbnailFilenameParts = explode('.', $row['name']);
                    $thumbnailExtension = array_pop($thumbnailFilenameParts);

                    $row['url'] = $fileURL . '/' . $row['name'];
                    if (in_array($thumbnailExtension, ['tif', 'tiff', 'psd', 'pdf'])) {
                        $thumbnailExtension = 'jpg';
                    }

                    $thumbnailFilename = $row['id'] . '.' . $thumbnailExtension;
                    $row['thumbnail_url'] = $thumbnailURL . '/' . $thumbnailFilename;

                    // filename-ext-100-100-true.jpg
                    // @TODO: This should be another hook listener
                    $row['thumbnail_url'] = null;
                    $filename = implode('.', $thumbnailFilenameParts);
                    if ($row['type'] == 'embed/vimeo') {
                        $oldThumbnailFilename = $row['name'] . '-vimeo-220-124-true.jpg';
                    } else {
                        $oldThumbnailFilename = $filename . '-' . $thumbnailExtension . '-160-160-true.jpg';
                    }

                    // 314551321-vimeo-220-124-true.jpg
                    // hotfix: there's not thumbnail for this file
                    if ($files->exists('thumbs/' . $oldThumbnailFilename)) {
                        $row['thumbnail_url'] = $thumbnailURL . '/' . $oldThumbnailFilename;
                    }

                    if ($files->exists('thumbs/' . $thumbnailFilename)) {
                        $row['thumbnail_url'] = $thumbnailURL . '/' . $thumbnailFilename;
                    }

                    /*
                    $embedManager = Bootstrap::get('embedManager');
                    $provider = $embedManager->getByType($row['type']);
                    $row['html'] = null;
                    if ($provider) {
                        $row['html'] = $provider->getCode($row);
                    }
                    */
                }

                $filesArrayObject = new \ArrayObject($fileRows);
                $result->initialize($filesArrayObject->getIterator());
            }

            return (func_num_args() == 2) ? $result : $payload;
        });

        return $emitter;
    }

    /**
     * Create a new remote client instance
     *
     * @param $userToken
     * @param array $options
     *
     * @return ClientRemote
     */
    public function createRemoteClient($userToken, array $options = [])
    {
        return new ClientRemote($userToken, $options);
    }
}