-
Notifications
You must be signed in to change notification settings - Fork 793
/
MongoDBPagerProvider.php
55 lines (45 loc) · 1.72 KB
/
MongoDBPagerProvider.php
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
<?php
/*
* This file is part of the FOSElasticaBundle package.
*
* (c) FriendsOfSymfony <https://friendsofsymfony.github.com/>
*
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/
namespace FOS\ElasticaBundle\Doctrine;
use Doctrine\Persistence\ManagerRegistry;
use FOS\ElasticaBundle\Provider\PagerfantaPager;
use FOS\ElasticaBundle\Provider\PagerInterface;
use FOS\ElasticaBundle\Provider\PagerProviderInterface;
use Pagerfanta\Doctrine\MongoDBODM\QueryAdapter;
use Pagerfanta\Pagerfanta;
final class MongoDBPagerProvider implements PagerProviderInterface
{
private string $objectClass;
private ManagerRegistry $doctrine;
private array $baseOptions;
private RegisterListenersService $registerListenersService;
public function __construct(
ManagerRegistry $doctrine,
RegisterListenersService $registerListenersService,
string $objectClass,
array $baseOptions
) {
$this->doctrine = $doctrine;
$this->objectClass = $objectClass;
$this->baseOptions = $baseOptions;
$this->registerListenersService = $registerListenersService;
}
public function provide(array $options = []): PagerInterface
{
$options = \array_replace($this->baseOptions, $options);
$manager = $this->doctrine->getManagerForClass($this->objectClass);
$repository = $manager->getRepository($this->objectClass);
$pager = new PagerfantaPager(new Pagerfanta(
new QueryAdapter(\call_user_func([$repository, $options['query_builder_method']]))
));
$this->registerListenersService->register($manager, $pager, $options);
return $pager;
}
}