Lines 94.23% 49 / 52
Functions and Methods 70.00% 7 / 10
Classes and Traits 0.00% 0 / 1
Name Lines Functions and Methods CRAP Classes and Traits
ReservedDataDeleteByCron 94.23% 49 / 52 70.00% 7 / 10 17.06 0.00% 0 / 1
 __construct 100.00% 5 / 5 100.00% 1 / 1 1
 getCount 100.00% 1 / 1 100.00% 1 / 1 1
 setLimit 100.00% 2 / 2 100.00% 1 / 1 1
 startProcessing 100.00% 6 / 6 100.00% 1 / 1 1
 log 66.66% 2 / 3 0.00% 0 / 1 2.15
 deleteExpiredReservations 100.00% 3 / 3 100.00% 1 / 1 2
 getExpirationTimeByScopePreference 100.00% 3 / 3 100.00% 1 / 1 1
 deleteProcessesByScope 90.00% 9 / 10 0.00% 0 / 1 3.01
 getProcessListByScope 100.00% 14 / 14 100.00% 1 / 1 2
 writeDeleteProcess 80.00% 4 / 5 0.00% 0 / 1 3.07
1<?php
2
3/**
4 * @copyright BerlinOnline Stadtportal GmbH & Co. KG
5 **/
6
7namespace BO\Zmsbackend\Helper;
8
9/**
10 * @codeCoverageIgnore
11 */
12
13use BO\Zmsbackend\Process\Service\Process as ProcessRepository;
14use BO\Zmsbackend\Scope\Service\Scope as ScopeRepository;
15use BO\Zmsentities\Collection\ScopeList;
16use BO\Zmsentities\Process;
17use BO\Zmsentities\Scope;
18
19class ReservedDataDeleteByCron
20{
21    /** @var \DateTimeInterface */
22    protected $nowTime;
23
24    /** @var bool */
25    protected $verbose = false;
26
27    /** @var int */
28    protected $limit = 500;
29
30    /** @var bool */
31    protected $isDryRun = false;
32
33    /** @var int[] */
34    protected $countByScopeId = [];
35
36    /** @var ScopeRepository */
37    protected $scopeRepository;
38
39    protected $processRepository;
40
41    public function __construct(\DateTimeInterface $now, bool $verbose = false, bool $isDryRun = false)
42    {
43        $this->nowTime  = $now;
44        $this->verbose  = $verbose;
45        $this->isDryRun = $isDryRun;
46
47        $this->scopeRepository = new ScopeRepository();
48        $this->processRepository = new ProcessRepository();
49    }
50
51    /**
52     * @return int[]
53     */
54    public function getCount(): array
55    {
56        return $this->countByScopeId;
57    }
58
59    public function setLimit(int $limit): ReservedDataDeleteByCron
60    {
61        $this->limit = $limit;
62
63        return $this;
64    }
65
66    public function startProcessing(): void
67    {
68        $this->log("INFO: Deleting expired reservations older than scopes reservation duration");
69
70        $scopeList = $this->scopeRepository->readList();
71        $this->countByScopeId = array_fill_keys($scopeList->getIds(), 0);
72        $this->deleteExpiredReservations($scopeList);
73        $filteredCount = array_filter($this->getCount());
74
75        $this->log(PHP_EOL . "SUMMARY: Processed reservations: " . var_export($filteredCount, true));
76    }
77
78    protected function log(string $message): bool
79    {
80        if ($this->verbose) {
81            \App::$log->info($message);
82        }
83        return $this->verbose;
84    }
85
86    protected function deleteExpiredReservations(ScopeList $scopeList): void
87    {
88        foreach ($scopeList as $scope) {
89            $countedProcesses = $this->deleteProcessesByScope($scope);
90            $this->countByScopeId[$scope->id] += $countedProcesses;
91        }
92    }
93
94    protected function getExpirationTimeByScopePreference(int $reservationDuration): \DateTimeInterface
95    {
96        $expirationTime = clone $this->nowTime;
97        $expiredTimestamp = ($this->nowTime->getTimestamp() - ($reservationDuration * 60));
98
99        return $expirationTime->setTimestamp($expiredTimestamp);
100    }
101
102    protected function deleteProcessesByScope(Scope $scope): int
103    {
104        $processCount = 0;
105        $processList  = $this->getProcessListByScope($scope);
106
107        foreach ($processList as $process) {
108            if ($process->status === 'reserved') {
109                $age = ($this->nowTime->getTimestamp() - $process->createTimestamp);
110                $this->log("INFO: found process($process->id) with a reservation age of $age seconds");
111                $this->writeDeleteProcess($process);
112            } else {
113                $this->log("INFO: Keep process $process->id with status $process->status");
114            }
115
116            $processCount++;
117        }
118
119        return $processCount;
120    }
121
122    protected function getProcessListByScope(Scope $scope): iterable
123    {
124        $reservationDuration = $scope->toProperty()->preferences->appointment->reservationDuration->get();
125        $expirationTime = $this->getExpirationTimeByScopePreference((int) $reservationDuration);
126        $processList = $this->processRepository
127            ->readExpiredReservationsList($expirationTime, $scope->id, $this->limit)
128            ->sortByCustomKey('createTimestamp');
129
130        if ($processList->count() === 0) {
131            return [];
132        }
133
134        $this->log(
135            "\nNow: " . $this->nowTime->format('H:i:s') .
136            "\nTime of expiration: " . $expirationTime->format('H:i:s') . " | scope " . $scope->id .
137            " | $reservationDuration minutes reservation time (" . $processList->count() . " found)" .
138            "\n-------------------------------------------------------------------"
139        );
140
141        return $processList;
142    }
143
144    /**
145     * @return void
146     */
147    protected function writeDeleteProcess(Process $process)
148    {
149        if ($this->isDryRun) {
150            return;
151        }
152
153        if ($this->processRepository->writeDeletedEntity($process->id)) {
154            $this->log("INFO: ($process->id) removed successfully\n");
155        } else {
156            $this->log("WARN: Could not remove process '$process->id'!\n");
157        }
158    }
159}