1
|
|
|
<?php |
2
|
|
|
|
3
|
|
|
namespace Spatie\EventProjector\Console\Concerns; |
4
|
|
|
|
5
|
|
|
use Illuminate\Support\Collection; |
6
|
|
|
use Illuminate\Support\Facades\DB; |
7
|
|
|
use Spatie\EventProjector\Models\StoredEvent; |
8
|
|
|
use Spatie\EventProjector\Projectors\Projector; |
9
|
|
|
use Spatie\EventProjector\Models\ProjectorStatus; |
10
|
|
|
|
11
|
|
|
trait ReplaysEvents |
12
|
|
|
{ |
13
|
|
|
public function replay(Collection $projectors) |
14
|
|
|
{ |
15
|
|
|
$afterEventId = $this->determineAfterEventId($projectors); |
16
|
|
|
|
17
|
|
|
if ($afterEventId === StoredEvent::getMaxId()) { |
18
|
|
|
$this->warn('There are no events to replay.'); |
|
|
|
|
19
|
|
|
} |
20
|
|
|
|
21
|
|
|
$replayCount = StoredEvent::after($afterEventId)->count(); |
22
|
|
|
|
23
|
|
|
if ($replayCount === 0) { |
24
|
|
|
$this->warn('There are no events to replay'); |
|
|
|
|
25
|
|
|
|
26
|
|
|
return; |
27
|
|
|
} |
28
|
|
|
|
29
|
|
|
$afterEventId === 0 |
30
|
|
|
? $this->comment('Replaying all events...') |
|
|
|
|
31
|
|
|
: $this->comment("Replaying events after stored event id {$afterEventId}..."); |
|
|
|
|
32
|
|
|
$this->emptyLine(); |
33
|
|
|
|
34
|
|
|
$bar = $this->output->createProgressBar(StoredEvent::after($afterEventId)->count()); |
|
|
|
|
35
|
|
|
$onEventReplayed = function () use ($bar) { |
36
|
|
|
$bar->advance(); |
37
|
|
|
}; |
38
|
|
|
|
39
|
|
|
$this->Projectionist->replay($projectors, $afterEventId, $onEventReplayed); |
|
|
|
|
40
|
|
|
|
41
|
|
|
$bar->finish(); |
42
|
|
|
|
43
|
|
|
$this->emptyLine(2); |
44
|
|
|
$this->comment('All done!'); |
|
|
|
|
45
|
|
|
} |
46
|
|
|
|
47
|
|
|
protected function determineAfterEventId(Collection $projectors): int |
48
|
|
|
{ |
49
|
|
|
$projectorsWithoutStatus = collect($projectors) |
50
|
|
|
->filter(function (Projector $projector) { |
51
|
|
|
return ! ProjectorStatus::query() |
|
|
|
|
52
|
|
|
->where('projector_name', $projector->getName()) |
53
|
|
|
->exists(); |
54
|
|
|
}); |
55
|
|
|
|
56
|
|
|
if ($projectorsWithoutStatus->isNotEmpty()) { |
57
|
|
|
return 0; |
58
|
|
|
} |
59
|
|
|
|
60
|
|
|
$allProjectorStatusesCount = DB::table('projector_statuses') |
61
|
|
|
->whereIn('projector_name', $projectors->map->getName()->toArray()) |
62
|
|
|
->count(); |
63
|
|
|
|
64
|
|
|
$allUpToDateProjectorStatusesCount = DB::table('projector_statuses') |
65
|
|
|
->whereIn('projector_name', $projectors->map->getName()->toArray()) |
66
|
|
|
->where('has_received_all_events', true) |
67
|
|
|
->count(); |
68
|
|
|
|
69
|
|
|
if ($allProjectorStatusesCount === $allUpToDateProjectorStatusesCount) { |
70
|
|
|
return StoredEvent::getMaxId(); |
71
|
|
|
} |
72
|
|
|
|
73
|
|
|
return DB::table('projector_statuses') |
74
|
|
|
->whereIn('projector_name', $projectors->map->getName()->toArray()) |
75
|
|
|
->where('has_received_all_events', false) |
76
|
|
|
->min('last_processed_event_id') ?? 0; |
77
|
|
|
} |
78
|
|
|
|
79
|
|
|
protected function emptyLine(int $amount = 1) |
80
|
|
|
{ |
81
|
|
|
foreach (range(1, $amount) as $i) { |
82
|
|
|
$this->line(''); |
|
|
|
|
83
|
|
|
} |
84
|
|
|
} |
85
|
|
|
} |
86
|
|
|
|
This check looks for methods that are used by a trait but not required by it.
To illustrate, let’s look at the following code example
The trait
Idable
provides a methodequalsId
that in turn relies on the methodgetId()
. If this method does not exist on a class mixing in this trait, the method will fail.Adding the
getId()
as an abstract method to the trait will make sure it is available.