Symfony Profiler

<?php declare(strict_types=1);
namespace Shopware\Core\Content\Sitemap\Service;
use League\Flysystem\FilesystemInterface;
use Psr\Cache\CacheItemPoolInterface;
use Shopware\Core\Content\Sitemap\Event\SitemapGeneratedEvent;
use Shopware\Core\Content\Sitemap\Exception\AlreadyLockedException;
use Shopware\Core\Content\Sitemap\Provider\UrlProviderInterface;
use Shopware\Core\Content\Sitemap\Struct\SitemapGenerationResult;
use Shopware\Core\Content\Sitemap\Struct\Url;
use Shopware\Core\Content\Sitemap\Struct\UrlResult;
use Shopware\Core\Framework\Log\Package;
use Shopware\Core\System\SalesChannel\Aggregate\SalesChannelDomain\SalesChannelDomainCollection;
use Shopware\Core\System\SalesChannel\SalesChannelContext;
use Shopware\Core\System\SystemConfig\Exception\InvalidDomainException;
use Symfony\Contracts\EventDispatcher\EventDispatcherInterface;
#[Package('sales-channel')]
class SitemapExporter implements SitemapExporterInterface
{
/**
* @deprecated tag:v6.5.0 - The interface will be remove, use AbstractUrlProvider instead
*
* @var UrlProviderInterface[]
*/
private $urlProvider;
private CacheItemPoolInterface $cache;
private int $batchSize;
private FilesystemInterface $filesystem;
private SitemapHandleFactoryInterface $sitemapHandleFactory;
private array $sitemapHandles;
private EventDispatcherInterface $dispatcher;
/**
* @internal
*/
public function __construct(
iterable $urlProvider,
CacheItemPoolInterface $cache,
int $batchSize,
FilesystemInterface $filesystem,
SitemapHandleFactoryInterface $sitemapHandleFactory,
EventDispatcherInterface $dispatcher
) {
$this->urlProvider = $urlProvider;
$this->cache = $cache;
$this->batchSize = $batchSize;
$this->filesystem = $filesystem;
$this->sitemapHandleFactory = $sitemapHandleFactory;
$this->dispatcher = $dispatcher;
}
/**
* {@inheritdoc}
*/
public function generate(SalesChannelContext $context, bool $force = false, ?string $lastProvider = null, ?int $offset = null): SitemapGenerationResult
{
$this->lock($context, $force);
try {
$this->initSitemapHandles($context);
foreach ($this->urlProvider as $urlProvider) {
do {
$result = $urlProvider->getUrls($context, $this->batchSize, $offset);
$this->processSiteMapHandles($result);
$needRun = $result->getNextOffset() !== null;
$offset = $result->getNextOffset();
} while ($needRun);
}
$this->finishSitemapHandles();
} finally {
$this->unlock($context);
}
$this->dispatcher->dispatch(new SitemapGeneratedEvent($context));
return new SitemapGenerationResult(
true,
$lastProvider,
null,
$context->getSalesChannel()->getId(),
$context->getLanguageId()
);
}
private function lock(SalesChannelContext $salesChannelContext, bool $force): void
{
$key = $this->generateCacheKeyForSalesChannel($salesChannelContext);
$item = $this->cache->getItem($key);
if ($item->isHit() && !$force) {
throw new AlreadyLockedException($salesChannelContext);
}
$item->set(true);
$this->cache->save($item);
}
private function unlock(SalesChannelContext $salesChannelContext): void
{
$this->cache->deleteItem($this->generateCacheKeyForSalesChannel($salesChannelContext));
}
private function generateCacheKeyForSalesChannel(SalesChannelContext $salesChannelContext): string
{
return sprintf('sitemap-exporter-running-%s-%s', $salesChannelContext->getSalesChannel()->getId(), $salesChannelContext->getLanguageId());
}
private function initSitemapHandles(SalesChannelContext $context): void
{
$languageId = $context->getLanguageId();
$domainsEntity = $context->getSalesChannel()->getDomains();
$sitemapDomains = [];
if ($domainsEntity instanceof SalesChannelDomainCollection) {
foreach ($domainsEntity as $domain) {
if ($domain->getLanguageId() === $languageId) {
$urlParts = \parse_url($domain->getUrl());
if ($urlParts === false) {
continue;
}
$arrayKey = ($urlParts['host'] ?? '') . ($urlParts['path'] ?? '');
if (\array_key_exists($arrayKey, $sitemapDomains) && $sitemapDomains[$arrayKey]['scheme'] === 'https') {
// NEXT-21735 - does not execute on every test run
continue;
}
$sitemapDomains[$arrayKey] = [
'url' => $domain->getUrl(),
'scheme' => $urlParts['scheme'] ?? '',
];
}
}
}
$sitemapHandles = [];
foreach ($sitemapDomains as $sitemapDomain) {
$sitemapHandles[$sitemapDomain['url']] = $this->sitemapHandleFactory->create($this->filesystem, $context, $sitemapDomain['url']);
}
if (empty($sitemapHandles)) {
throw new InvalidDomainException('Empty domain');
}
$this->sitemapHandles = $sitemapHandles;
}
private function processSiteMapHandles(UrlResult $result): void
{
/** @var SitemapHandle $sitemapHandle */
foreach ($this->sitemapHandles as $host => $sitemapHandle) {
/** @var Url[] $urls */
$urls = [];
foreach ($result->getUrls() as $url) {
$newUrl = clone $url;
$newUrl->setLoc(empty($newUrl->getLoc()) ? $host : $host . '/' . $newUrl->getLoc());
$urls[] = $newUrl;
}
$sitemapHandle->write($urls);
}
}
private function finishSitemapHandles(): void
{
/** @var SitemapHandle $sitemapHandle */
foreach ($this->sitemapHandles as $index => $sitemapHandle) {
if ($index === array_key_first($this->sitemapHandles)) {
$sitemapHandle->finish();
continue;
}
$sitemapHandle->finish(false);
}
}
}

vendor/shopware/core/Content/Sitemap/Service/SitemapExporter.php line 72