Spaces:
No application file
No application file
File size: 3,407 Bytes
d2897cd |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 |
<?php
declare(strict_types=1);
namespace Mautic\MarketplaceBundle\Service;
use Mautic\CoreBundle\Release\ThisRelease;
use Mautic\MarketplaceBundle\Api\Connection;
use Mautic\MarketplaceBundle\Collection\PackageCollection;
use Mautic\MarketplaceBundle\DTO\AllowlistEntry;
class PluginCollector
{
/**
* @var AllowlistEntry[]
*/
private array $allowlistedPackages = [];
private int $total = 0;
public function __construct(
private Connection $connection,
private Allowlist $allowlist
) {
}
public function collectPackages(int $page, int $limit, string $query = ''): PackageCollection
{
$allowlist = $this->allowlist->getAllowList();
if (!empty($allowlist)) {
$this->allowlistedPackages = $this->filterAllowlistedPackagesForCurrentMauticVersion($allowlist->entries);
$payload = $this->getAllowlistedPackages($page, $limit);
} else {
$payload = $this->connection->getPlugins($page, $limit, $query);
}
$this->total = (int) $payload['total'];
return PackageCollection::fromArray($payload['results']);
}
public function getTotal(): int
{
return $this->total;
}
/**
* @param AllowlistEntry[] $entries
*
* @return AllowlistEntry[]
*/
private function filterAllowlistedPackagesForCurrentMauticVersion(array $entries): array
{
$mauticVersion = ThisRelease::getMetadata()->getVersion();
return array_filter($entries, function (AllowlistEntry $entry) use ($mauticVersion): bool {
if (
!empty($entry->minimumMauticVersion)
&& !version_compare($mauticVersion, $entry->minimumMauticVersion, '>=')
) {
return false;
}
if (
!empty($entry->maximumMauticVersion)
&& !version_compare($mauticVersion, $entry->maximumMauticVersion, '<=')
) {
return false;
}
return true;
});
}
/**
* During the Marketplace beta period, we only want to show packages that are explicitly
* allowlisted. This function only gets allowlisted packages from Packagist. Their API doesn't
* support querying multiple packages at once, so we simply do a foreach loop.
*
* @return array<string,mixed>
*/
private function getAllowlistedPackages(int $page, int $limit): array
{
$total = count($this->allowlistedPackages);
$results = [];
if (0 === $total) {
return [
'total' => 0,
'results' => [],
];
}
/** @var array<int, AllowlistEntry[]> $chunks */
$chunks = array_chunk($this->allowlistedPackages, $limit);
// Array keys start at 0 but page numbers start at 1
$pageChunk = $page - 1;
foreach ($chunks[$pageChunk] as $entry) {
if (count($results) >= $limit) {
continue;
}
$payload = $this->connection->getPlugins(1, 1, $entry->package);
if (isset($payload['results'][0])) {
$results[] = $payload['results'][0] + $entry->toArray();
}
}
return [
'total' => $total,
'results' => $results,
];
}
}
|