FilterService::createFilteredBinary() - Code Metrics - Inspection of "Generate WebP in liip:imagine:cache:resolve CLI co..." - liip/LiipImagineBundle - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — 2.x (#1347)

by Peter

created 2021-06-11 11:00 UTC

FilterService::createFilteredBinary() A

↳ Parent: FilterService

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	17
rs	9.7
c	0
b	0
f	0
cc	2
nc	2
nop	2

<?php

/*
 * This file is part of the `liip/LiipImagineBundle` project.
 *
 * (c) https://github.com/liip/LiipImagineBundle/graphs/contributors
 *
 * For the full copyright and license information, please view the LICENSE.md
 * file that was distributed with this source code.
 */

namespace Liip\ImagineBundle\Service;

use Liip\ImagineBundle\Binary\BinaryInterface;
use Liip\ImagineBundle\Exception\Imagine\Filter\NonExistingFilterException;
use Liip\ImagineBundle\Imagine\Cache\CacheManager;
use Liip\ImagineBundle\Imagine\Data\DataManager;
use Liip\ImagineBundle\Imagine\Filter\FilterManager;
use Psr\Log\LoggerInterface;
use Psr\Log\NullLogger;

class FilterService
{
    /**
     * @var DataManager
     */
    private $dataManager;

    /**
     * @var FilterManager
     */
    private $filterManager;

    /**
     * @var CacheManager
     */
    private $cacheManager;

    /**
     * @var LoggerInterface
     */
    private $logger;

    /**
     * @var bool
     */
    private $webpGenerate;

    /**
     * @var mixed[]
     */
    private $webpOptions;

    public function __construct(
        DataManager $dataManager,
        FilterManager $filterManager,
        CacheManager $cacheManager,
        bool $webpGenerate,
        array $webpOptions,
        ?LoggerInterface $logger = null
    ) {
        $this->dataManager = $dataManager;
        $this->filterManager = $filterManager;
        $this->cacheManager = $cacheManager;
        $this->webpGenerate = $webpGenerate;
        $this->webpOptions = $webpOptions;
        $this->logger = $logger ?: new NullLogger();
    }

    /**
     * @param string $path
     * @param string $filter
     *
     * @return bool Returns true if the cache is busted
     */
    public function bustCache($path, $filter)
    {
        $busted = false;

        foreach ($this->iterateFilterPathContainers($path) as $filterPathContainer) {
            if ($this->cacheManager->isStored($filterPathContainer->getTarget(), $filter)) {
                $this->cacheManager->remove($filterPathContainer->getTarget(), $filter);

                $busted = true;
            }
        }

        return $busted;
    }

    /**
     * @param bool $forced Force warm up cache
     *
     * @return bool Returns true if the cache is warmed up
     */
    public function warmsUpCache(
        string $path,
        string $filter,
        ?string $resolver = null,
        bool $forced = false
    ): bool {
        $warmedUp = false;

        foreach ($this->iterateFilterPathContainers($path) as $filterPathContainer) {
            if ($this->warmsUpCacheFilterPathContainer($filterPathContainer, $filter, $resolver, $forced)) {
                $warmedUp = true;
            }
        }

        return $warmedUp;
    }

    /**
     * @param string      $path
     * @param string      $filter
     * @param string|null $resolver
     *
     * @return string
     */
    public function getUrlOfFilteredImage($path, $filter, $resolver = null, bool $webpSupported = false)
    {
        foreach ($this->iterateFilterPathContainers($path) as $filterPathContainer) {
            $this->warmsUpCacheFilterPathContainer($filterPathContainer, $filter, $resolver);
        }

        return $this->resolveFilterPathContainer(new FilterPathContainer($path), $filter, $resolver, $webpSupported);
    }

    /**
     * @param string      $path
     * @param string      $filter
     * @param string|null $resolver
     *
     * @return string
     */
    public function getUrlOfFilteredImageWithRuntimeFilters(
        $path,
        $filter,
        array $runtimeFilters = [],
        $resolver = null,
        bool $webpSupported = false
    ) {
        $runtimePath = $this->cacheManager->getRuntimePath($path, $runtimeFilters);
        $runtimeOptions = [
            'filters' => $runtimeFilters,
        ];

        foreach ($this->iterateFilterPathContainers($path, $runtimePath, $runtimeOptions) as $filterPathContainer) {
            $this->warmsUpCacheFilterPathContainer($filterPathContainer, $filter, $resolver);
        }

        return $this->resolveFilterPathContainer(
            new FilterPathContainer($path, $runtimePath, $runtimeOptions),
            $filter,
            $resolver,
            $webpSupported
        );
    }

    /**
     * @param string  $source
     * @param string  $target
     * @param mixed[] $options
     *
     * @return FilterPathContainer[]
     */
    private function iterateFilterPathContainers(string $source, string $target = '', array $options = []): array
    {
        $basePathContainer = new FilterPathContainer($source, $target, $options);
        $filterPathContainers = [$basePathContainer];

        if ($this->webpGenerate) {
            $filterPathContainers[] = $basePathContainer->createWebp($this->webpOptions);
        }

        return $filterPathContainers;
    }

    private function resolveFilterPathContainer(
        FilterPathContainer $filterPathContainer,
        string $filter,
        ?string $resolver = null,
        bool $webpSupported = false
    ): string {
        $path = $filterPathContainer->getTarget();

        if ($webpSupported) {
            $path = $filterPathContainer->createWebp($this->webpOptions)->getTarget();
        }

        return $this->cacheManager->resolve($path, $filter, $resolver);
    }

    /**
     * @param bool $forced Force warm up cache
     *
     * @return bool Returns true if the cache is warmed up
     */
    private function warmsUpCacheFilterPathContainer(
        FilterPathContainer $filterPathContainer,
        string $filter,
        ?string $resolver = null,
        bool $forced = false
    ): bool {
        if ($forced || !$this->cacheManager->isStored($filterPathContainer->getTarget(), $filter, $resolver)) {
            $this->cacheManager->store(
                $this->createFilteredBinary($filterPathContainer, $filter),
                $filterPathContainer->getTarget(),
                $filter,
                $resolver
            );

            return true;
        }

        return false;
    }

    /**
     * @throws NonExistingFilterException
     */
    private function createFilteredBinary(FilterPathContainer $filterPathContainer, string $filter): BinaryInterface
    {
        $binary = $this->dataManager->find($filter, $filterPathContainer->getSource());

        try {
            return $this->filterManager->applyFilter($binary, $filter, $filterPathContainer->getOptions());
        } catch (NonExistingFilterException $e) {
            $this->logger->debug(sprintf(
                'Could not locate filter "%s" for path "%s". Message was "%s"',
                $filter,
                $filterPathContainer->getSource(),
                $e->getMessage()
            ));

            throw $e;
        }
    }
}


1			<?php
2
3			/*
4			* This file is part of the `liip/LiipImagineBundle` project.
5			*
6			* (c) https://github.com/liip/LiipImagineBundle/graphs/contributors
7			*
8			* For the full copyright and license information, please view the LICENSE.md
9			* file that was distributed with this source code.
10			*/
11
12			namespace Liip\ImagineBundle\Service;
13
14			use Liip\ImagineBundle\Binary\BinaryInterface;
15			use Liip\ImagineBundle\Exception\Imagine\Filter\NonExistingFilterException;
16			use Liip\ImagineBundle\Imagine\Cache\CacheManager;
17			use Liip\ImagineBundle\Imagine\Data\DataManager;
18			use Liip\ImagineBundle\Imagine\Filter\FilterManager;
19			use Psr\Log\LoggerInterface;
20			use Psr\Log\NullLogger;
21
22			class FilterService
23			{
24			/**
25			* @var DataManager
26			*/
27			private $dataManager;
28
29			/**
30			* @var FilterManager
31			*/
32			private $filterManager;
33
34			/**
35			* @var CacheManager
36			*/
37			private $cacheManager;
38
39			/**
40			* @var LoggerInterface
41			*/
42			private $logger;
43
44			/**
45			* @var bool
46			*/
47			private $webpGenerate;
48
49			/**
50			* @var mixed[]
51			*/
52			private $webpOptions;
53
54			public function __construct(
55			DataManager $dataManager,
56			FilterManager $filterManager,
57			CacheManager $cacheManager,
58			bool $webpGenerate,
59			array $webpOptions,
60			?LoggerInterface $logger = null
61			) {
62			$this->dataManager = $dataManager;
63			$this->filterManager = $filterManager;
64			$this->cacheManager = $cacheManager;
65			$this->webpGenerate = $webpGenerate;
66			$this->webpOptions = $webpOptions;
67			$this->logger = $logger ?: new NullLogger();
68			}
69
70			/**
71			* @param string $path
72			* @param string $filter
73			*
74			* @return bool Returns true if the cache is busted
75			*/
76			public function bustCache($path, $filter)
77			{
78			$busted = false;
79
80			foreach ($this->iterateFilterPathContainers($path) as $filterPathContainer) {
81			if ($this->cacheManager->isStored($filterPathContainer->getTarget(), $filter)) {
82			$this->cacheManager->remove($filterPathContainer->getTarget(), $filter);
83
84			$busted = true;
85			}
86			}
87
88			return $busted;
89			}
90
91			/**
92			* @param bool $forced Force warm up cache
93			*
94			* @return bool Returns true if the cache is warmed up
95			*/
96			public function warmsUpCache(
97			string $path,
98			string $filter,
99			?string $resolver = null,
100			bool $forced = false
101			): bool {
102			$warmedUp = false;
103
104			foreach ($this->iterateFilterPathContainers($path) as $filterPathContainer) {
105			if ($this->warmsUpCacheFilterPathContainer($filterPathContainer, $filter, $resolver, $forced)) {
106			$warmedUp = true;
107			}
108			}
109
110			return $warmedUp;
111			}
112
113			/**
114			* @param string $path
115			* @param string $filter
116			* @param string\|null $resolver
117			*
118			* @return string
119			*/
120			public function getUrlOfFilteredImage($path, $filter, $resolver = null, bool $webpSupported = false)
121			{
122			foreach ($this->iterateFilterPathContainers($path) as $filterPathContainer) {
123			$this->warmsUpCacheFilterPathContainer($filterPathContainer, $filter, $resolver);
124			}
125
126			return $this->resolveFilterPathContainer(new FilterPathContainer($path), $filter, $resolver, $webpSupported);
127			}
128
129			/**
130			* @param string $path
131			* @param string $filter
132			* @param string\|null $resolver
133			*
134			* @return string
135			*/
136			public function getUrlOfFilteredImageWithRuntimeFilters(
137			$path,
138			$filter,
139			array $runtimeFilters = [],
140			$resolver = null,
141			bool $webpSupported = false
142			) {
143			$runtimePath = $this->cacheManager->getRuntimePath($path, $runtimeFilters);
144			$runtimeOptions = [
145			'filters' => $runtimeFilters,
146			];
147
148			foreach ($this->iterateFilterPathContainers($path, $runtimePath, $runtimeOptions) as $filterPathContainer) {
149			$this->warmsUpCacheFilterPathContainer($filterPathContainer, $filter, $resolver);
150			}
151
152			return $this->resolveFilterPathContainer(
153			new FilterPathContainer($path, $runtimePath, $runtimeOptions),
154			$filter,
155			$resolver,
156			$webpSupported
157			);
158			}
159
160			/**
161			* @param string $source
162			* @param string $target
163			* @param mixed[] $options
164			*
165			* @return FilterPathContainer[]
166			*/
167			private function iterateFilterPathContainers(string $source, string $target = '', array $options = []): array
168			{
169			$basePathContainer = new FilterPathContainer($source, $target, $options);
170			$filterPathContainers = [$basePathContainer];
171
172			if ($this->webpGenerate) {
173			$filterPathContainers[] = $basePathContainer->createWebp($this->webpOptions);
174			}
175
176			return $filterPathContainers;
177			}
178
179			private function resolveFilterPathContainer(
180			FilterPathContainer $filterPathContainer,
181			string $filter,
182			?string $resolver = null,
183			bool $webpSupported = false
184			): string {
185			$path = $filterPathContainer->getTarget();
186
187			if ($webpSupported) {
188			$path = $filterPathContainer->createWebp($this->webpOptions)->getTarget();
189			}
190
191			return $this->cacheManager->resolve($path, $filter, $resolver);
192			}
193
194			/**
195			* @param bool $forced Force warm up cache
196			*
197			* @return bool Returns true if the cache is warmed up
198			*/
199			private function warmsUpCacheFilterPathContainer(
200			FilterPathContainer $filterPathContainer,
201			string $filter,
202			?string $resolver = null,
203			bool $forced = false
204			): bool {
205			if ($forced \|\| !$this->cacheManager->isStored($filterPathContainer->getTarget(), $filter, $resolver)) {
206			$this->cacheManager->store(
207			$this->createFilteredBinary($filterPathContainer, $filter),
208			$filterPathContainer->getTarget(),
209			$filter,
210			$resolver
211			);
212
213			return true;
214			}
215
216			return false;
217			}
218
219			/**
220			* @throws NonExistingFilterException
221			*/
222			private function createFilteredBinary(FilterPathContainer $filterPathContainer, string $filter): BinaryInterface
223			{
224			$binary = $this->dataManager->find($filter, $filterPathContainer->getSource());
225
226			try {
227			return $this->filterManager->applyFilter($binary, $filter, $filterPathContainer->getOptions());
228			} catch (NonExistingFilterException $e) {
229			$this->logger->debug(sprintf(
230			'Could not locate filter "%s" for path "%s". Message was "%s"',
231			$filter,
232			$filterPathContainer->getSource(),
233			$e->getMessage()
234			));
235
236			throw $e;
237			}
238			}
239			}
240

liip / LiipImagineBundle

Pull Request — 2.x (#1347)

FilterService::createFilteredBinary() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like