This commit is contained in:
Yuri Kuznetsov
2022-11-12 18:36:08 +02:00
parent cc5125230e
commit 4bc24352c6
4 changed files with 14 additions and 3 deletions
@@ -77,11 +77,17 @@ class Subscribers implements Cleanup
private function processEntityType(string $entityType): void
{
/** @var ?array<string, mixed> $data */
$data = $this->metadata->get(['streamDefs', $entityType, 'subscribersCleanup']);
if (!($data['enabled'] ?? false)) {
return;
}
/** @var string $dateField */
$dateField = $this->metadata->get(['streamDefs', $entityType, 'subscribersCleanup', 'dateField']) ??
'createdAt';
$dateField = $data['dateField'] ?? 'createdAt';
/** @var ?string[] $statusList */
$statusList = $this->metadata->get(['streamDefs', $entityType, 'subscribersCleanup', 'statusList']);
$statusList = $data['statusList'] ?? null;
/** @var ?string $statusField */
$statusField = $this->metadata->get(['scopes', $entityType, 'statusField']);
@@ -126,6 +132,8 @@ class Subscribers implements Cleanup
)
->build();
print_r($query);
$this->entityManager->getQueryExecutor()->execute($query);
}
}
@@ -1,6 +1,7 @@
{
"followingUsersField": "users",
"subscribersCleanup": {
"enabled": true,
"dateField": "dateStart",
"statusList": ["Held", "Not Held"]
}
@@ -1,6 +1,7 @@
{
"followingUsersField": "users",
"subscribersCleanup": {
"enabled": true,
"dateField": "dateStart",
"statusList": ["Held", "Not Held"]
}
@@ -1,5 +1,6 @@
{
"subscribersCleanup": {
"enabled": true,
"statusList": ["Completed", "Canceled"]
}
}