Cavemanon/piratepoet
8
Fork 0
Code Pull Requests Actions Releases 16 Activity

Fix formatting

Browse Source 
[MAILPOET-5555]
This commit is contained in:
David Remer
2023-09-05 09:31:26 +03:00
committed by Aschepikov
parent ce4f19bd77
commit 79999f53c3
1 changed files with 26 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

39
mailpoet/lib/Subscribers/SubscriberSegmentRepository.php
View File

@@ -82,27 +82,40 @@ class SubscriberSegmentRepository extends Repository {
public function resetSubscriptions(SubscriberEntity $subscriber, array $segments): void {
$existingSegments = array_values(array_filter(array_map(
function(SubscriberSegmentEntity $subscriberSegmentEntity): ?SegmentEntity { return $subscriberSegmentEntity->getSegment();
function(SubscriberSegmentEntity $subscriberSegmentEntity): ?SegmentEntity {
return $subscriberSegmentEntity->getSegment();
},
$this->findBy(['subscriber' => $subscriber, 'status' => SubscriberEntity::STATUS_SUBSCRIBED])
)));
$existingSegmentIds = array_map(function(SegmentEntity $segment): int { return $segment->getId() ?? 0;
}, $existingSegments);
$segmentIds = array_map(function(SegmentEntity $segment): int { return $segment->getId() ?? 0;
}, $segments);
$existingSegmentIds = array_map(
function(SegmentEntity $segment): int {
return $segment->getId() ?? 0;
},
$existingSegments
);
$segmentIds = array_map(
function(SegmentEntity $segment): int {
return $segment->getId() ?? 0;
},
$segments
);
$unsubscribedSegments = array_diff($existingSegmentIds, $segmentIds);
$newlySubscribedSegments = array_diff($segmentIds, $existingSegmentIds);
if (!$newlySubscribedSegments && !$unsubscribedSegments) {
return;
}
$unsubscribe = array_filter($existingSegments, function(SegmentEntity $segment) use ($unsubscribedSegments): bool {
return in_array($segment->getId(), $unsubscribedSegments);
});
$subscribe = array_filter($segments, function(SegmentEntity $segment) use ($newlySubscribedSegments): bool {
return in_array($segment->getId(), $newlySubscribedSegments);
});
$unsubscribe = array_filter(
$existingSegments,
function(SegmentEntity $segment) use ($unsubscribedSegments): bool {
return in_array($segment->getId(), $unsubscribedSegments);
}
);
$subscribe = array_filter(
$segments,
function(SegmentEntity $segment) use ($newlySubscribedSegments): bool {
return in_array($segment->getId(), $newlySubscribedSegments);
}
);
if ($unsubscribe) {
$this->unsubscribeFromSegments($subscriber, $unsubscribe);
}