ReliqArts\Docweaver\Service\Documentation\Publisher

Complexity

Total Complexity

11

Size/Duplication

Total Lines	140
Duplicated Lines	35 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

<?php
final class Publisher extends BasePublisher implements PublisherContract
{
    /**
     * Documentation resource directory.
     *
     * @var string
     */
    private string $documentationDirectory;

This code did not parse for me. Apparently, there is an error somewhere around this line:

Syntax error, unexpected T_STRING, expecting T_FUNCTION or T_CONST

    /**
     * @var ProductPublisher
     */
    private ProductPublisher $productPublisher;

    /**
     * @var ProductFactory
     */
    private ProductFactory $productFactory;

    /**
     * Working directory.
     *
     * @var string
     */
    private string $workingDirectory;

    /**
     * Create a new DocumentationPublisher.
     *
     * @throws BadImplementation
     */
    public function __construct(
        Filesystem $filesystem,
        Logger $logger,
        ConfigProvider $configProvider,
        ProductPublisher $productPublisher,
        ProductFactory $productFactory
    ) {
        parent::__construct($filesystem, $logger);

        $this->productPublisher = $productPublisher;
        $this->productFactory = $productFactory;
        $this->documentationDirectory = $configProvider->getDocumentationDirectory();
        $this->workingDirectory = base_path($this->documentationDirectory);

        if (!$this->readyResourceDirectory($this->workingDirectory)) {
            throw new BadImplementation(sprintf('Could not ready document resource directory `%s`. Please ensure file system is writable.', $this->documentationDirectory));
        }
    }

    /**
     * @throws Exception
     */
    public function publish(string $productName, string $source = '', Command &$callingCommand = null): Result
    {
        $result = new Result();
        $commonName = strtolower($productName);
        $productDirectory = sprintf('%s/%s', $this->workingDirectory, $commonName);

        $this->setExecutionStartTime();
        if (!$this->readyResourceDirectory($productDirectory)) {
            return $result->setError(sprintf('Product directory %s is not writable.', $productDirectory))
                ->setExtra((object)['executionTime' => $this->getExecutionTime()]);
        }

        $product = $this->productFactory->create($productDirectory);
        $result = $this->productPublisher->publish($product, $source);

        foreach ($result->getMessages() as $message) {
            $this->tell($message);
        }

        $data = $result->getExtra() ?? (object)[];
        $data->executionTime = $this->getExecutionTime();

        return $result->setExtra($data);
    }

    /**
     * @throws Exception
     */
    public function update(string $productName, Command &$callingCommand = null): Result
    {
        $this->callingCommand = $callingCommand;
        $result = new Result();
        $commonName = strtolower($productName);
        $productDirectory = sprintf('%s/%s', $this->workingDirectory, $commonName);

        $this->setExecutionStartTime();
        if (!$this->readyResourceDirectory($productDirectory)) {
            return $result->setError(sprintf('Product directory %s is not writable.', $productDirectory))
                ->setExtra((object)['executionTime' => $this->getExecutionTime()]);
        }

        $product = $this->productFactory->create($productDirectory);
        $result = $this->productPublisher->update($product);

        foreach ($result->getMessages() as $message) {
            $this->tell($message);
        }

        $data = $result->getExtra() ?? (object)[];
        $data->executionTime = $this->getExecutionTime();

        return $result->setExtra($data);
    }

    /**
     * @throws Exception
     */
    public function updateAll(Command &$callingCommand = null): Result
    {
        $this->callingCommand = $callingCommand;
        $result = new Result();
        $productDirectories = $this->filesystem->directories($this->workingDirectory);
        $products = [];
        $productsUpdated = [];

        $this->setExecutionStartTime();

        foreach ($productDirectories as $productDirectory) {
            $productName = basename($productDirectory);

            $this->tell(sprintf('Updating %s...', $productName), self::TELL_DIRECTION_FLAT);

            $productResult = $this->update($productName, $callingCommand);
            $products[] = $productName;

            if ($productResult->isSuccess()) {
                $productsUpdated[] = $productName;
            }
        }

        return $result->setExtra((object)[
            'products' => $products,
            'productsUpdated' => $productsUpdated,
            'executionTime' => $this->getExecutionTime(),
        ]);
    }
}