ONGR\TranslationsBundle\Service\Export

Complexity

Total Complexity

17

Size/Duplication

Total Lines	141
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

91.49%

Importance

Changes	10
Bugs	4	Features	4

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
C	export()	0	22	7
A	setManagedLocales()	0	4	1
A	getManagedLocales()	0	4	1
B	readStorage()	0	37	6
A	getFilesystem()	0	4	1

<?php

/*
 * This file is part of the ONGR package.
 *
 * (c) NFQ Technologies UAB <info@nfq.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace ONGR\TranslationsBundle\Service;

use ONGR\TranslationsBundle\Document\Message;
use ONGR\TranslationsBundle\Document\Translation;
use ONGR\TranslationsBundle\Storage\StorageInterface;
use ONGR\TranslationsBundle\Translation\Export\ExporterInterface;
use Symfony\Component\Filesystem\Filesystem;

/**
 * Class Export.
 */
class Export
{
    /**
     * @var StorageInterface
     */
    private $storage;

    /**
     * @var ExporterInterface
     */
    private $exporter;

    /**
     * @var LoadersContainer
     */
    private $loadersContainer;

    /**
     * @var array
     */
    private $managedLocales = [];

    /**
     * @var Translation[]
     */
    private $refresh = [];

    /**
     * @param LoadersContainer  $loadersContainer
     * @param StorageInterface  $storage
     * @param ExporterInterface $exporter
     */
    public function __construct(
        LoadersContainer $loadersContainer,
        StorageInterface $storage,
        ExporterInterface $exporter
    ) {
        $this->storage = $storage;
        $this->exporter = $exporter;
        $this->loadersContainer = $loadersContainer;
    }

    /**
     * Exports translations from ES to files.
     *
     * @param array $domains To export.
     */
    public function export($domains = [])
    {
        foreach ($this->readStorage($domains) as $file => $translations) {
            // TODO: refactor after ESB gives easy way to access object!
            $translations = $translations instanceof \Traversable ? iterator_to_array($translations) : $translations;
            if (!file_exists($file)) {
                $this->getFilesystem()->touch($file);
            }
            list($domain, $locale, $extension) = explode('.', $file);
            if ($this->loadersContainer && $this->loadersContainer->has($extension)) {
                $messageCatalogue = $this->loadersContainer->get($extension)->load($file, $locale, $domain);
                $translations = array_merge($messageCatalogue->all($domain), $translations);
            }

            $this->exporter->export($file, $translations);
        }

        if (!empty($this->refresh)) {
            $this->storage->write($this->refresh);
            $this->refresh = [];
        }
    }

    /**
     * Sets managed locales.
     *
     * @param array $managedLocales
     */
    public function setManagedLocales($managedLocales)
    {
        $this->managedLocales = $managedLocales;
    }

    /**
     * @return array
     */
    public function getManagedLocales()
    {
        return $this->managedLocales;
    }

    /**
     * Get translations for export.
     *
     * @param array $domains To read from storage.
     *
     * @return array
     */
    private function readStorage($domains)
    {
        $data = [];
        $translations = $this->storage->read($this->getManagedLocales(), $domains);

        /** @var Translation $translation */
        foreach ($translations as $translation) {
            $messages = $translation->getMessages();
            // TODO: refactor after ESB gives easy way to access object!
            $messages = $messages instanceof \Traversable ? iterator_to_array($messages) : $messages;
            $wasDirty = false;

            foreach ($messages as $key => $message) {
                if ($message->getStatus() === Message::DIRTY) {
                    $path = sprintf(
                        '%s' . DIRECTORY_SEPARATOR . '%s.%s.%s',
                        $translation->getPath(),
                        $translation->getDomain(),
                        $message->getLocale(),
                        $translation->getFormat()
                    );
                    $data[$path][$translation->getKey()] = $message->getMessage();

                    $message->setStatus(Message::FRESH);
                    $messages[$key] = $message;
                    $wasDirty = true;
                }
            }

            if ($wasDirty) {
                $translation->setMessages($messages);
                $this->refresh[] = $translation;
            }
        }

        return $data;
    }

    /**
     * @return Filesystem
     */
    protected function getFilesystem()
    {
        return new Filesystem();
    }
}