Code Coverage
 
Lines
Functions and Methods
Classes and Traits
Total
79.31%
23 / 29
60.00%
6 / 10
 CRAP
0.00%
0 / 1
GroupedDataLayer
79.31%
23 / 29
60.00%
6 / 10
 16.99
0.00%
0 / 1
 __construct
100.00%
1 / 1
100.00%
1 / 1
 1
 isSupported
75.00%
6 / 8
0.00%
0 / 1
 4.25
 getFilterColumns
75.00%
3 / 4
0.00%
0 / 1
 2.06
 getOrderByColumns
75.00%
3 / 4
0.00%
0 / 1
 2.06
 all
100.00%
2 / 2
100.00%
1 / 1
 1
 find
100.00%
2 / 2
100.00%
1 / 1
 1
 persistNew
100.00%
2 / 2
100.00%
1 / 1
 1
 persistExisting
100.00%
2 / 2
100.00%
1 / 1
 1
 removeExisting
100.00%
2 / 2
100.00%
1 / 1
 1
 upsert
0.00%
0 / 2
0.00%
0 / 1
 2
1<?php
2namespace Apie\Core\Datalayers;
3
4use Apie\Core\BoundedContext\BoundedContextId;
5use Apie\Core\Datalayers\Grouped\DataLayerByBoundedContext;
6use Apie\Core\Datalayers\Lists\EntityListInterface;
7use Apie\Core\Entities\EntityInterface;
8use Apie\Core\Identifiers\IdentifierInterface;
9use Apie\Core\Lists\StringSet;
10use ReflectionClass;
11
12final class GroupedDataLayer implements ApieDatalayerWithFilters, ApieDatalayer, ApieDatalayerWithSupport
13{
14    public function __construct(private readonly DataLayerByBoundedContext $hashmap)
15    {
16    }
17
18    public function isSupported(EntityInterface|ReflectionClass|IdentifierInterface $instance, BoundedContextId $boundedContextId): bool
19    {
20        if ($instance instanceof EntityInterface) {
21            $instance = $instance->getId()->getReferenceFor();
22        } elseif ($instance instanceof IdentifierInterface) {
23            $instance = $instance->getReferenceFor();
24        }
25        $datalayer = $this->hashmap->pickDataLayerFor($instance, $boundedContextId);
26        if ($datalayer instanceof ApieDatalayerWithSupport) {
27            return $datalayer->isSupported($instance, $boundedContextId);
28        }
29        return true;
30    }
31
32    public function getFilterColumns(ReflectionClass $class, BoundedContextId $boundedContextId): ?StringSet
33    {
34        $datalayer = $this->hashmap->pickDataLayerFor($class, $boundedContextId);
35        if ($datalayer instanceof ApieDatalayerWithFilters) {
36            return $datalayer->getFilterColumns($class, $boundedContextId);
37        }
38        return null;
39    }
40
41    public function getOrderByColumns(ReflectionClass $class, BoundedContextId $boundedContextId): ?StringSet
42    {
43        $datalayer = $this->hashmap->pickDataLayerFor($class, $boundedContextId);
44        if ($datalayer instanceof ApieDatalayerWithFilters) {
45            return $datalayer->getOrderByColumns($class, $boundedContextId);
46        }
47        return null;
48    }
49
50    public function all(ReflectionClass $class, ?BoundedContextId $boundedContextId = null): EntityListInterface
51    {
52        return $this->hashmap->pickDataLayerFor($class, $boundedContextId)
53            ->all($class, $boundedContextId);
54    }
55
56    public function find(IdentifierInterface $identifier, ?BoundedContextId $boundedContextId = null): EntityInterface
57    {
58        return $this->hashmap->pickDataLayerFor($identifier::getReferenceFor(), $boundedContextId)
59            ->find($identifier, $boundedContextId);
60    }
61
62    public function persistNew(EntityInterface $entity, ?BoundedContextId $boundedContextId = null): EntityInterface
63    {
64        return $this->hashmap->pickDataLayerFor($entity->getId()::getReferenceFor(), $boundedContextId)
65            ->persistNew($entity, $boundedContextId);
66    }
67
68    public function persistExisting(EntityInterface $entity, ?BoundedContextId $boundedContextId = null): EntityInterface
69    {
70        return $this->hashmap->pickDataLayerFor($entity->getId()::getReferenceFor(), $boundedContextId)
71            ->persistExisting($entity, $boundedContextId);
72    }
73    
74    public function removeExisting(EntityInterface $entity, ?BoundedContextId $boundedContextId = null): void
75    {
76        $this->hashmap->pickDataLayerFor($entity->getId()::getReferenceFor(), $boundedContextId)
77            ->removeExisting($entity, $boundedContextId);
78    }
79
80    public function upsert(EntityInterface $entity, ?BoundedContextId $boundedContextId): EntityInterface
81    {
82        return $this->hashmap->pickDataLayerFor($entity->getId()::getReferenceFor(), $boundedContextId)
83            ->upsert($entity, $boundedContextId);
84    }
85}