synceventmergehandler.php

<?php
 
namespace Bitrix\Calendar\Sync\Handlers;
 
use Bitrix\Calendar\Sync\Entities\SyncEvent;
use Bitrix\Calendar\Core;
use Bitrix\Calendar\Core\Event\Event;
 
class SyncEventMergeHandler extends Core\Handlers\HandlerBase
{
    public function __invoke(
        SyncEvent $savedSyncEvent,
        SyncEvent $externalSyncEvent,
        ?int $id = null,
        ?int $eventConnectionId = null
    ): SyncEvent
    {
        $localEvent = $savedSyncEvent->getEvent();
        $externalEvent = $externalSyncEvent->getEvent();
 
        $externalEvent
            ->setOwner($localEvent->getOwner())
            ->setSection($localEvent->getSection())
            ->setId($id)
            ->setCreator($localEvent->getCreator())
            ->setCalendarType($localEvent->getCalendarType())
            ->setSpecialLabel($localEvent->getSpecialLabel())
            ->setMeetingDescription($localEvent->getMeetingDescription())
            ->setEventHost($localEvent->getEventHost())
            ->setAttendeesCollection($localEvent->getAttendeesCollection())
            ->setIsMeeting($localEvent->isMeeting())
            ->setMeetingStatus($localEvent->getMeetingStatus())
            ->setRelations($localEvent->getRelations())
            ->setVersion($localEvent->getVersion())
            ->setRemindCollection($this->prepareReminders($localEvent, $externalEvent))
        ;
 
        $externalEventConnection = $externalSyncEvent->getEventConnection();
 
        if ($externalEventConnection)
        {
            $externalEventConnection
                ->setId($eventConnectionId)
                ->setVersion($localEvent->getVersion())
                ->setRetryCount(0)
            ;
        }
 
        return $externalSyncEvent;
    }
 
    private function prepareReminders(Event $localEvent, Event $externalEvent): ?Core\Event\Properties\RemindCollection
    {
        $localRemindCollection = $localEvent->getRemindCollection();
        $externalRemindCollection = $externalEvent->getRemindCollection();
        if (!$externalRemindCollection || $externalRemindCollection->count() === 0)
        {
            if ($localRemindCollection)
            {
                // if reminders count more than one, we don't know which reminder was deleted,
                // and leave all of them
                return ($localRemindCollection->count() > 1)
                    ? $localEvent->getRemindCollection()
                    : null
                    ;
            }
            else
            {
                return null;
            }
        }
 
        if ((!$localRemindCollection || $localRemindCollection->count() < 2))
        {
            return $externalEvent->getRemindCollection()->setSingle(false);
        }
        else
        {
            if ($externalRemindCollection->isSingle())
            {
                $this->removeClosestRemind($localRemindCollection);
                $localRemindCollection->add($externalRemindCollection->fetch());
                return $localRemindCollection;
            }
            else
            {
                return $this->mergeRemindCollections(
                    $externalRemindCollection,
                    $localRemindCollection,
                );
            }
        }
    }
 
    private function removeClosestRemind(?Core\Event\Properties\RemindCollection $remindCollection)
    {
        $minValue = null;
        $minIndex = null;
 
        foreach ($remindCollection->getCollection() as $index => $item)
        {
            $offset = $item->getTimeBeforeStartInMinutes();
            if ($offset < 0)
            {
                continue;
            }
 
            if ($minValue === null || $offset < $minValue)
            {
                $minValue = $offset;
                $minIndex = $index;
            }
        }
        if ($minIndex !== null)
        {
            $remindCollection->remove($minIndex);
        }
    }
 
    private function mergeRemindCollections(
        Core\Event\Properties\RemindCollection $externalRemindCollection,
        Core\Event\Properties\RemindCollection $localRemindCollection
    ): Core\Event\Properties\RemindCollection
    {
        $prepareMap = function (?Core\Event\Properties\RemindCollection $collection)
        {
            $result = [];
            foreach ($collection as $index => $item)
            {
                $result[$item->getTimeBeforeStartInMinutes()] = $index;
            }
            return $result;
        };
 
        $externalMap = $prepareMap($externalRemindCollection);
        $localMap = $prepareMap($localRemindCollection);
 
        foreach ($localMap as $key => $index)
        {
            if (!array_key_exists($key, $externalMap))
            {
                $localRemindCollection->remove($index);
            }
        }
 
        return $localRemindCollection->addItems($externalRemindCollection->getCollection());
    }
}