vendordataexchangemanager.php

См. документацию.

<?php
 
namespace Bitrix\Calendar\Sync\Managers;
 
use Bitrix\Calendar\Core;
use Bitrix\Calendar\Core\Base\BaseException;
use Bitrix\Calendar\Core\Event\Event;
use Bitrix\Calendar\Core\Handlers\UpdateMasterExdateHandler;
use Bitrix\Calendar\Core\Managers\Compare\EventCompareManager;
use Bitrix\Calendar\Integration\Pull\PushCommand;
use Bitrix\Calendar\Sync\Util\FlagRegistry;
use Bitrix\Calendar\Sync\Util\HandleStatusTrait;
use Bitrix\Calendar\Sync;
use Bitrix\Calendar\Sync\Connection\Connection;
use Bitrix\Calendar\Sync\Entities\SyncEvent;
use Bitrix\Calendar\Sync\Exceptions\AuthException;
use Bitrix\Calendar\Sync\Exceptions\RemoteAccountException;
use Bitrix\Calendar\Sync\Handlers\MasterPushHandler;
use Bitrix\Calendar\Sync\Handlers\SyncEventMergeHandler;
use Bitrix\Calendar\UserField\ResourceBooking;
use Bitrix\Calendar\Util;
use Bitrix\Main\ArgumentException;
use Bitrix\Main\DI\ServiceLocator;
use Bitrix\Main\Loader;
use Bitrix\Main\LoaderException;
use Bitrix\Main\ObjectException;
use Bitrix\Main\ObjectNotFoundException;
use Bitrix\Main\ObjectPropertyException;
use Bitrix\Main\SystemException;
use Bitrix\Main\Web\Uri;
use CCalendar;
use CCalendarSect;
use Exception;
 
class VendorDataExchangeManager
{
    use HandleStatusTrait;
 
    private static array $outgoingManagersCache = [];
 
    protected Sync\Entities\SyncEventMap $syncEventMap;
    protected SyncEventMergeHandler $handlerMerge;
    protected bool $isFullSync = false;
 
    private Sync\Factories\SyncEventFactory $syncEventFactory;
    private Core\Mappers\EventConnection $eventConnectionMapper;
    private Core\Mappers\Event $eventMapper;
    private Core\Mappers\Section $sectionMapper;
    private Core\Mappers\SectionConnection $sectionConnectionMapper;
    protected Sync\Factories\FactoryBase $factory;
    protected Sync\Entities\SyncSectionMap $syncSectionMap;
    protected array $importedLocalEventUidList = [];

    public function __construct(Sync\Factories\FactoryBase $factory, Sync\Entities\SyncSectionMap $syncSectionMap)
    {
        $this->factory = $factory;
        $this->syncSectionMap = $syncSectionMap;
        $this->isFullSync = !$this->factory->getConnection()->getToken();

        $mapperHelper = ServiceLocator::getInstance()->get('calendar.service.mappers.factory');
        $this->sectionConnectionMapper = $mapperHelper->getSectionConnection();
        $this->sectionMapper = $mapperHelper->getSection();
        $this->eventConnectionMapper = $mapperHelper->getEventConnection();
        $this->eventMapper = $mapperHelper->getEvent();
        $this->syncEventFactory = new Sync\Factories\SyncEventFactory();
 
 
        $handlerMergeClass = Core\Handlers\HandlersMap::getHandler('syncEventMergeHandler');
        $this->handlerMerge = new $handlerMergeClass();
    }

    public function exchange(): self
    {
        $pushManager = new PushManager();
        $push = $pushManager->getPush(PushManager::TYPE_CONNECTION, $this->factory->getConnection()->getId());
        // TODO: what could to do, if push is blocked ?
        $pushManager->setBlockPush($push);
        try
        {
            $this->exchangeSections();
 
            $this->sendResult(MasterPushHandler::MASTER_STAGE[1]);
 
            $this->blockSectionPush($this->syncSectionMap);
            try
            {
                $this->exchangeEvents();
            }
            catch(BaseException $e)
            {}
            finally
            {
                $this->unblockSectionPush($this->syncSectionMap);
            }
 
            $this->sendResult(MasterPushHandler::MASTER_STAGE[2]);
            $this->sendResult(MasterPushHandler::MASTER_STAGE[3]);
 
            $this
                ->updateConnection($this->factory->getConnection())
                ->clearCache() // Clear legacy cache after whole sync
            ;
        }
        catch(BaseException $e)
        {
        }
        finally
        {
            $pushManager->setUnblockPush($push);
        }
 
        return $this;
    }
 
    private function sendResult(string $stage): void
    {
        $this->sendStatus([
            'vendorName'  => $this->factory->getConnection()->getVendor()->getCode(),
            'accountName' => $this->factory->getConnection()->getName(),
            'stage'       => $stage,
        ]);
    }
 
    public function clearCache(): void
    {
        CCalendar::ClearCache();
    }

    public function importEvents(): self
    {
        $importEventManager = (new ImportEventManager($this->factory, $this->syncSectionMap));
 
        $syncEventMap = $importEventManager->import()->getEvents();
 
        $this->prepareLocalSyncEventMapWithVendorEventId($syncEventMap);
        $this->handleEventsToLocalStorage($syncEventMap);
        $this->handleSectionsToLocalStorage($this->syncSectionMap);
 
        return $this;
    }

    public function importSections(): self
    {
        //sections
        $sectionImporter = (new ImportSectionManager($this->factory))->import();
 
        $this->handleImportedSections($sectionImporter->getSyncSectionMap());
 
        return $this;
    }

    public function updateConnection(Connection $connection): self
    {
        $connection->setLastSyncTime(new Core\Base\Date());
        (new Core\Mappers\Connection())->update($connection);
 
        $accountType = $connection->getAccountType() === Sync\Google\Helper::GOOGLE_ACCOUNT_TYPE_API
            ? 'google'
            : $connection->getAccountType()
        ;
 
        Util::addPullEvent(
            PushCommand::RefreshSyncStatus,
            $connection->getOwner()->getId(),
            [
                'syncInfo' => [
                    $accountType => [
                        'status' => $this->getSyncStatus($connection->getStatus()),
                        'type' => $accountType,
                        'connected' => true,
                        'id' => $connection->getId(),
                        'syncOffset' => 0,
                    ],
                ],
                'requestUid' => Util::getRequestUid(),
            ]
        );
 
        return $this;
    }
 
    private function getSyncStatus(?string $status): bool
    {
        return $status && preg_match("/^\[(2\d\d|0)\][a-z0-9 _]*/i", $status);
    }

    public function handleImportedSections(Sync\Entities\SyncSectionMap $externalSyncSectionMap): void
    {
        $this->mergeSyncedSyncSectionsWithSavedSections($externalSyncSectionMap);
        $this->handleSectionsToLocalStorage($externalSyncSectionMap);
        $this->removeDeletedExternalSections($externalSyncSectionMap);
    }

    public function handleSyncEvent(
        Sync\Entities\SyncEvent $syncEvent,
        ?string $key = null,
        ?Sync\Entities\SyncEvent $masterSyncEvent = null
    ): void
    {
        if ($syncEvent->getEventConnection() === null)
        {
            return;
        }
 
        if ($masterSyncEvent !== null)
        {
            $syncEvent->getEvent()->setRecurrenceId($masterSyncEvent->getId());
        }
 
        $this->mergeExternalEventWithLocalParams($syncEvent);
 
        if ($syncEvent->getAction() === Sync\Dictionary::SYNC_EVENT_ACTION['delete'])
        {
            //if we drag out an old event that has not been saved in our system
            if ($syncEvent->getEvent()->getId() === null)
            {
                if ($syncEvent->isInstance())
                {
                    if ($masterSyncEvent === null)
                    {
                        $masterSyncEvent = $this->getMasterSyncEvent($syncEvent);
                    }
                    if (!$masterSyncEvent)
                    {
                        return;
                    }
 
                    if ($masterSyncEvent->getAction() === Sync\Dictionary::SYNC_EVENT_ACTION['delete'])
                    {
                        return;
                    }
 
                    if ($masterSyncEvent->getId() === null)
                    {
                        $this->handleSyncEvent($masterSyncEvent);
 
                        return;
                    }
 
                    $this->updateMasterExdate($this->addExdateToMasterEvent($masterSyncEvent, $syncEvent));
                }
 
                return;
            }
 
            $this->deleteEvent($syncEvent);
 
            return;
        }
 
        $this->saveEvent($syncEvent);
 
        if (
            $masterSyncEvent
            && $masterSyncEvent->getId()
            && $syncEvent->isInstance()
        )
        {
            $this->updateMasterExdate($this->addExdateToMasterEvent($masterSyncEvent, $syncEvent));
        }
    }

    public function filterUnchangedSections(
        Sync\Entities\SyncSectionMap $externalSyncSectionMap,
        Sync\Entities\SyncSection $syncSection
    ): bool
    {
        if (
            ($externalSyncSection = $externalSyncSectionMap->getItem($syncSection->getSectionConnection()
                ->getVendorSectionId()))
            && $syncSection->getSectionConnection()->getVersionId() !== $externalSyncSection->getSectionConnection()
                ->getVersionId()
        )
        {
            $syncSection->getSectionConnection()->setVersionId($externalSyncSection->getSectionConnection()->getVersionId());
 
            return true;
        }
 
        return false;
    }

    public function handleDeleteInstance(Sync\Entities\SyncEvent $syncEvent): void
    {
        $masterSyncEvent = $this->getMasterSyncEvent($syncEvent);
        if (!$masterSyncEvent)
        {
            return;
        }
 
        $this->prepareExcludedDatesMasterEvent(
            $masterSyncEvent,
            $syncEvent->getEvent()->getOriginalDateFrom()
        );
 
        if ($masterSyncEvent->getId() === null)
        {
            return;
        }
 
        $this->updateMasterExdate($masterSyncEvent->getEvent());
        $masterSyncEvent->setEvent($masterSyncEvent->getEvent());
 
        $this->syncEventMap->updateItem($masterSyncEvent, $masterSyncEvent->getVendorEventId());
    }

    public function getMeetingDescriptionForNewEvent(Core\Role\Role $owner): Core\Event\Properties\MeetingDescription
    {
        return (new Core\Event\Properties\MeetingDescription())
            ->setHostName($owner->getFullName())
            ->setMeetingCreator($owner->getId())
            ->setReInvite(false)
            ->setLanguageId(($owner->getRoleEntity() instanceof Core\Role\User)
                ? $owner->getRoleEntity()->getLanguageId()
                : LANGUAGE_ID
            )
            ->setIsNotify(true)
            ->setAllowInvite(true)
        ;
    }

    public function deleteEvent(Sync\Entities\SyncEvent $syncEvent): Event
    {
        $event = $syncEvent->getEvent();
 
        // todo handle meeting status
        if ($event->isInstance())
        {
            $this->handleDeleteInstance($syncEvent);
        }
 
        if ($event->isRecurrence())
        {
            $this->handleDeleteRecurrenceEvent($syncEvent);
        }
 
        if ($event->isSingle())
        {
            $this->handleDeleteSingleEvent($syncEvent);
        }
 
        $this->eventMapper->delete($event, [
            'softDelete' => true,
            'originalFrom' => $syncEvent->getEventConnection()->getConnection()->getVendor()->getCode(),
        ]);
 
        $this->eventConnectionMapper->delete($syncEvent->getEventConnection());
 
        return $event;
    }

    public function saveEvent(Sync\Entities\SyncEvent $syncEvent): void
    {
        $event = $syncEvent->getEvent();
        $event = $event->isNew()
            ? $this->eventMapper->create($event, [
                'originalFrom' => $this->factory->getServiceName(),
            ])
            : $this->eventMapper->update($event, [
                'originalFrom' => $this->factory->getServiceName(),
            ])
        ;
 
        if ($event)
        {
            $syncEvent->setEvent($event);
            $eventConnection = $syncEvent->getEventConnection();
            if ($eventConnection)
            {
                $eventConnection
                    ->setEvent($event)
                    ->setVersion($event->getVersion())
                ;
 
                $eventConnection->getId()
                    ? $this->eventConnectionMapper->update($eventConnection)
                    : $this->eventConnectionMapper->create($eventConnection)
                ;
            }
        }
    }

    public function handleImportedEvents(Sync\Entities\SyncEventMap $externalEventMap): void
    {
        $this->prepareLocalSyncEventMapWithVendorEventId($externalEventMap);
        $this->handleEventsToLocalStorage($externalEventMap);
    }

    public function savePermissions(Sync\Entities\SyncSection $syncSection): void
    {
        CCalendarSect::SavePermissions(
            $syncSection->getSection()->getId(),
            CCalendarSect::GetDefaultAccess(
                $syncSection->getSection()->getType(),
                $syncSection->getSection()->getOwner()->getId()
            )
        );
    }

    private function exchangeSections(): void
    {
        //sections
        $sectionImporter = (new ImportSectionManager($this->factory))->import();
 
        $sectionExporter = (new OutgoingSectionManager(
            $this->factory,
            $this->prepareSyncSectionBeforeExport(
                $this->getFilteredSectionMapForExport($sectionImporter->getSyncSectionMap())
            )
        ))->export();
 
        $this->handleImportedSections($sectionImporter->getSyncSectionMap());
        $this->handleExportedSections($sectionExporter->getSyncSectionMap());
 
        $this->filterBrokenSyncSections();
    }

    private function handleExportedSections(Sync\Entities\SyncSectionMap $syncSectionMap): void
    {
        $this->handleSectionsToLocalStorage($syncSectionMap);
    }

    private function exchangeEvents(): void
    {
        $eventImporter = (new ImportEventManager($this->factory, $this->syncSectionMap))->import();
        $this->handleImportedEvents($eventImporter->getEvents());
 
        $savedSyncEventMap = $this->getLocalEventsForExport();
 
        if ($savedSyncEventMap)
        {
            (new ExportEventManager($this->factory, $this->syncSectionMap))->export($savedSyncEventMap);
            $this->updateExportedEvents($savedSyncEventMap);
        }
 
        $this->handleSectionsToLocalStorage($this->syncSectionMap);
    }

    private function handleExportedInstances(Sync\Entities\SyncEvent $syncEvent): void
    {
        foreach ($syncEvent->getInstanceMap() as $instance)
        {
            if ($instance->getAction() !== Sync\Dictionary::SYNC_EVENT_ACTION['success'])
            {
                $this->handleExportedFailedSyncEvent($syncEvent);
                continue;
            }
 
            if ($instanceEventConnection = $instance->getEventConnection())
            {
                $instanceEventConnection
                    ->setEvent($instance->getEvent())
                    ->setConnection($syncEvent->getEventConnection()->getConnection())
                ;
 
                if ($instanceEventConnection->getId())
                {
                    $this->eventConnectionMapper->update($instanceEventConnection);
                }
                else
                {
                    $this->eventConnectionMapper->create($instanceEventConnection);
                }
            }
        }
    }

    public function validateSyncEventChange(
        Sync\Entities\SyncEvent $syncEvent,
        Sync\Entities\SyncEvent $existsSyncEvent = null
    ): bool
    {
        if (!$existsSyncEvent)
        {
            return true;
        }
 
        if (
            $syncEvent->getEventConnection() !== null
            && (
                ($syncEvent->getEventConnection()->getVendorVersionId() === $existsSyncEvent->getEventConnection()->getVendorVersionId())
                || ($syncEvent->getEventConnection()->getEntityTag() === $existsSyncEvent->getEventConnection()->getEntityTag())
            )
        )
        {
            if (
                (
                    $syncEvent->getEventConnection()->getConnection()->getVendor()->getCode()
                    !== Sync\Google\Helper::GOOGLE_ACCOUNT_TYPE_API
                )
                || !$this->hasDifferentEventFields($syncEvent, $existsSyncEvent))
            {
                return false;
            }
        }
 
        // Changing an event for an invitee
        // TODO: move it check to core.
        if ($existsSyncEvent->getEventId() !== $existsSyncEvent->getParentId())
        {
            // temporary this functionality is turned off
            // if (!$existsSyncEvent->getEvent()->isDeleted() && $this->hasDifferentEventFields($syncEvent, $existsSyncEvent))
            // {
            //  $this->rollbackEvent(
            //      $existsSyncEvent,
            //      $syncEvent,
            //      'CALENDAR_IMPORT_BLOCK_FROM_ATTENDEE'
            //  );
            // }
 
            return false;
        }
 
        // Prevent changing events with booking
        if ($existsSyncEvent->getEvent()->getSpecialLabel() === ResourceBooking::EVENT_LABEL)
        {
            // temporary this functionality is turned off
            // if ($this->hasDifferentEventFields($syncEvent, $existsSyncEvent))
            // {
            //
                // $this->rollbackEvent(
                //  $existsSyncEvent,
                //  $syncEvent,
                //  'CALENDAR_IMPORT_BLOCK_RESOURCE_BOOKING'
                // );
            // }
 
            return false;
        }
 
        // temporary this functionality is turned off
 
        // if ($syncEvent->getAction() !== Sync\Dictionary::SYNC_EVENT_ACTION['delete']
        //  && !$this->checkAttendeesAccessibility($existsSyncEvent->getEvent(), $syncEvent->getEvent()))
        // {
        //  if ($this->hasDifferentEventFields($syncEvent, $existsSyncEvent))
        //  {
        //      $this->rollbackEvent(
        //          $existsSyncEvent,
        //          $syncEvent,
        //          'CALENDAR_IMPORT_BLOCK_ATTENDEE_ACCESSIBILITY'
        //      );
        //  }
        //
        //  return false;
        // }
 
        if ($syncEvent->isSingle() && $syncEvent->getEntityTag() !== $existsSyncEvent->getEntityTag())
        {
            return true;
        }
 
        if ($syncEvent->isRecurrence())
        {
            if ($syncEvent->getEntityTag() !== $existsSyncEvent->getEntityTag())
            {
                return true;
            }
 
            if ($syncEvent->hasInstances())
            {
                foreach ($syncEvent->getInstanceMap() as $key => $instance)
                {
                    $existsInstanceMap = $existsSyncEvent->getInstanceMap();
 
                    if (!$existsInstanceMap)
                    {
                        return true;
                    }

                    $existsInstance = $existsInstanceMap->getItem($key);
 
                    if (!$existsInstance)
                    {
                        return true;
                    }
 
                    if ($existsInstance->getEntityTag() !== $instance->getEntityTag())
                    {
                        return true;
                    }
                }
            }
        }
 
        if ($syncEvent->isInstance())
        {
            return true;
        }
 
        return false;
    }
 
    private function hasDifferentEventFields(
        Sync\Entities\SyncEvent $syncEvent,
        Sync\Entities\SyncEvent $existSyncEvent
    ): bool
    {
        if (!$syncEvent->getEvent() && !$existSyncEvent->getEvent())
        {
            return false;
        }
 
        if ($syncEvent->getAction() === Sync\Dictionary::SYNC_EVENT_ACTION['delete']
            && !$existSyncEvent->getEvent()->isDeleted()
        )
        {
            return true;
        }
 
        $comparator = new EventCompareManager($syncEvent->getEvent(), $existSyncEvent->getEvent());
 
        $diff = $comparator->getDiff();
        $significantFields = [
            EventCompareManager::COMPARE_FIELDS['name'] => true,
            EventCompareManager::COMPARE_FIELDS['start'] => true,
            EventCompareManager::COMPARE_FIELDS['end'] => true,
            EventCompareManager::COMPARE_FIELDS['recurringRule'] => true,
            EventCompareManager::COMPARE_FIELDS['description'] => true,
            'excludedDates' => true,
        ];
        $significantDiff = array_intersect_key($diff, $significantFields);
 
        return !empty($significantDiff);
    }

    public function addExdateToMasterEvent(Sync\Entities\SyncEvent $masterSyncEvent, Sync\Entities\SyncEvent $instance): Event
    {
        $masterEvent = $masterSyncEvent->getEvent();
        $exdateCollection = $masterEvent->getExcludedDateCollection();
        if ($exdateCollection === null)
        {
            $exdateCollection = new Core\Event\Properties\ExcludedDatesCollection();
            $masterEvent->setExcludedDateCollection($exdateCollection);
        }
 
        if ($instance->getEvent()->getOriginalDateFrom() instanceof Core\Base\Date)
        {
            $exdateCollection->add(
                (clone $instance->getEvent()->getOriginalDateFrom())
                    ->setDateTimeFormat(Core\Event\Properties\ExcludedDatesCollection::EXCLUDED_DATE_FORMAT)
            );
        }
 
        return $masterEvent;
    }

    private function rollbackEvent(
        Sync\Entities\SyncEvent $existsExternalSyncEvent,
        Sync\Entities\SyncEvent $syncEvent,
        string $messageCode
    ): void
    {
        $muteNotice = $this->isNoticesMuted();
        if ($existsExternalSyncEvent->getEvent()->isDeleted())
        {
            $muteNotice = true;
            $syncStatus = Sync\Dictionary::SYNC_EVENT_ACTION['delete'];
        }
        else
        {
            $syncStatus = ($existsExternalSyncEvent->getEvent()->isRecurrence() || $syncEvent->getEvent()->isRecurrence())
                ? Sync\Dictionary::SYNC_EVENT_ACTION['recreate']
                : Sync\Dictionary::SYNC_EVENT_ACTION['update']
            ;
        }
        $existsExternalSyncEvent->getEventConnection()
            ->setLastSyncStatus($syncStatus)
            ->setVersion($existsExternalSyncEvent->getEvent()->getVersion() - 1);
        $this->eventConnectionMapper->update($existsExternalSyncEvent->getEventConnection());
 
        if (!$muteNotice)
        {
            $this->noticeUser($existsExternalSyncEvent, $messageCode);
        }
    }

    private function isNoticesMuted(): bool
    {
        return FlagRegistry::getInstance()->isFlag(Sync\Dictionary::FIRST_SYNC_FLAG_NAME);
    }

    private function createPusher(): Sync\Handlers\MasterPushHandler
    {
        return new Sync\Handlers\MasterPushHandler(
            $this->factory->getConnection()->getOwner(),
            'google',
            $this->factory->getConnection()->getName()
        );
    }

    private function mergeSyncedSyncSectionsWithSavedSections(Sync\Entities\SyncSectionMap $externalSyncSectionMap): void
    {
        foreach ($externalSyncSectionMap as $key => $externalSyncSection)
        {
            if ($externalSyncSection->getSectionConnection() === null)
            {
                $externalSyncSectionMap->remove($key);
 
                continue;
            }

            if ($savedSyncSection = $this->syncSectionMap->has(
                $externalSyncSection->getSectionConnection()->getVendorSectionId()
            ))
            {
                $savedSyncSection = $this->syncSectionMap->getItem(
                    $externalSyncSection->getSectionConnection()->getVendorSectionId()
                );
                $externalSyncSection
                    ->getSectionConnection()
                        ->setId($savedSyncSection->getSectionConnection()->getId())
                        ->setSyncToken($savedSyncSection->getSectionConnection()->getSyncToken())
                        ->setPageToken($savedSyncSection->getSectionConnection()->getPageToken())
                ;
 
                $savedSection = $savedSyncSection->getSection();
                $externalSyncSection
                    ->getSection()
                        ->setId($savedSection->getId())
                        ->setXmlId($savedSection->getXmlId())
                        ->setCreator($savedSection->getCreator())
                        ->setExternalType($savedSection->getExternalType())
                        ->setIsActive($savedSection->isActive())
                        ->setType($savedSection->getType())
                ;
                if (empty($externalSyncSection->getSection()->getColor()))
                {
                    $externalSyncSection->getSection()->setColor(
                        $savedSection->getColor()
                            ?: Core\Property\ColorHelper::getOurColorRandom()
                    );
                }
                if ($savedSection->isLocal())
                {
                    $externalSyncSection->getSection()->setName($savedSection->getName());
                }
            }
        }
    }

    private function handleSectionsToLocalStorage(Sync\Entities\SyncSectionMap $syncSectionMap): void
    {
        foreach ($syncSectionMap as $key => $syncSection)
        {
            if (!$this->validateSyncSectionBeforeSave($syncSection))
            {
                $this->updateFailedSyncSection($syncSection);
 
                continue;
            }
 
            if ($syncSection->getAction() === Sync\Dictionary::SYNC_STATUS['delete'])
            {
                if ($syncSection->getSection()->isLocal())
                {
                    $this->createLocalDeletedSection($syncSection);
                }
                else
                {
                    $this->deleteSyncSectionFromLocalStorage($syncSection);
                    continue;
                }
            }
 
            if ($syncSection->getSection()->isNew())
            {
                // TODO: change later to saveManager
                $this->sectionMapper->create($syncSection->getSection());
                $this->savePermissions($syncSection);
 
                $this->sectionConnectionMapper->create(
                    $syncSection->getSectionConnection()->setSection($syncSection->getSection())
                );
            }
            else
            {
                $this->sectionMapper->update($syncSection->getSection());
                $sectionConnection = $syncSection->getSectionConnection();
                $sectionConnection->setSection($syncSection->getSection());
 
                $sectionConnection->isNew()
                    ? $this->sectionConnectionMapper->create($sectionConnection)
                    : $this->sectionConnectionMapper->update($sectionConnection)
                ;
            }
 
            $syncSection->setAction(Sync\Dictionary::SYNC_SECTION_ACTION['success']);
 
            $this->syncSectionMap->add($syncSection, $key);
        }
    }

    private function removeDeletedExternalSections(Sync\Entities\SyncSectionMap $externalSectionMap): void
    {
        if (!$this->isFullSync)
        {
            return;
        }
 
        $deleteCandidates = (new Sync\Entities\SyncSectionMap(
            array_diff_key($this->syncSectionMap->getCollection(), $externalSectionMap->getCollection()),
        ))->getNonLocalSections();

        foreach ($deleteCandidates as $syncSection)
        {
            if (
                ($syncSection->getSection() === null)
                || ($syncSection->getSectionConnection() === null)
            )
            {
                continue;
            }
            $this->deleteSyncSectionFromLocalStorage($syncSection);
        }
    }
 
    private function createLocalDeletedSection(Sync\Entities\SyncSection $syncSection)
    {
 
    }

    private function deleteSyncSectionFromLocalStorage(Sync\Entities\SyncSection $syncSection): void
    {
        if ($syncSection->getSectionConnection()->getId() !== null)
        {
            $this->sectionConnectionMapper->delete($syncSection->getSectionConnection());
            $this->syncSectionMap->remove($syncSection->getSectionConnection()->getVendorSectionId());
        }
 
        if ($syncSection->getSection()->getId() !== null)
        {
            $this->sectionMapper->delete($syncSection->getSection(), ['softDelete' => false]);
            $this->syncSectionMap->remove($syncSection->getSection()->getId());
        }
    }

    private function getFilteredSectionMapForExport(
        Sync\Entities\SyncSectionMap $externalSectionMap
    ): Sync\Entities\SyncSectionMap
    {
        return (new Sync\Entities\SyncSectionMap(
            array_diff_key(
                $this->isFullSync
                    ? $this->syncSectionMap->getCollection()
                    : $this->syncSectionMap
                        ->getItemsByKeys(array_keys($externalSectionMap->getCollection()))
                        ->getCollection(),
                $externalSectionMap->getCollection()
            ),
        ))->getLocalSections();
    }

    public function getSyncSectionMapBySyncSectionMap(
        Sync\Entities\SyncSectionMap $syncSectionMap
    ): Sync\Entities\SyncSectionMap
    {
        $syncSectionList = $this->isFullSync
            ? $this->syncSectionMap->getCollection()
            : $this->syncSectionMap
                ->getItemsByKeys(array_keys($syncSectionMap->getCollection()))
                ->getCollection();
 
        return new Sync\Entities\SyncSectionMap(
            array_diff_key($syncSectionList, $syncSectionMap->getCollection()),
        );
    }

    private function getLocalEventsForExport(): ?Sync\Entities\SyncEventMap
    {
        $sectionIdCollection = [];
        foreach ($this->syncSectionMap as $syncSection)
        {
            $sectionIdCollection[] = $syncSection->getSection()->getId();
        }
 
        // foreach ($this->importedLocalEventUidList as $eventUid)
        // {
        //  $candidatesForExport->remove($eventUid);
        // }
 
        return $this->syncEventFactory->getSyncEventMapBySyncSectionIdCollectionForExport(
            $sectionIdCollection,
            $this->factory->getConnection()->getOwner()->getId(),
            $this->factory->getConnection()->getId()
        )->getNotSuccessSyncEvent();
    }

    private function handleEventsToLocalStorage(Sync\Entities\SyncEventMap $externalSyncEventMap): void
    {
        foreach ($externalSyncEventMap as $key => $syncEvent)
        {
            $existsExternalSyncEvent = $this->syncEventMap->getItem($key);
 
            if (!$this->validateSyncEventChange($syncEvent, $existsExternalSyncEvent))
            {
                continue;
            }
 
            $masterSyncEvent = $this->getMasterSyncEvent($syncEvent);
            if (
                $masterSyncEvent
                && ($syncEvent->isInstance() || $syncEvent->getVendorRecurrenceId())
                && $masterSyncEvent->getId() !== $masterSyncEvent->getParentId()
            )
            {
                continue;
            }
 
            $this->handleSyncEvent($syncEvent, $syncEvent->getVendorEventId(), $masterSyncEvent);
 
            if (
                $existsExternalSyncEvent
                && (
                    $syncEvent->isRecurrence()
                    || ($syncEvent->getAction() === Sync\Dictionary::SYNC_EVENT_ACTION['delete'])
                )
            )
            {
                $this->removeDeprecatedInstances($existsExternalSyncEvent, $syncEvent);
            }
 
            if ($syncEvent->hasInstances())
            {
                $collection = $syncEvent->getInstanceMap()->getCollection();
                array_walk($collection, [$this, 'handleSyncEvent'], $syncEvent);
            }
 
            $this->syncEventMap->updateItem($syncEvent, $syncEvent->getVendorEventId());
        }
    }

    private function getMasterSyncEvent(Sync\Entities\SyncEvent $syncEvent): ?Sync\Entities\SyncEvent
    {
        $recurrenceId = [];
        $eventConnection = $syncEvent->getEventConnection();
 
        if ($eventConnection === null)
        {
            throw new BaseException('you should set EventConnection in SyncEvent');
        }
 
        if ($masterSyncEvent = $this->syncEventMap->getItem($eventConnection->getRecurrenceId()))
        {
            return $masterSyncEvent;
        }
 
        if ($eventConnection->getRecurrenceId())
        {
            $recurrenceId[] = $eventConnection->getRecurrenceId();
        }
 
        return $this->syncEventFactory->getSyncEventCollectionByVendorIdList(
            $recurrenceId,
            $this->factory->getConnection()->getId()
        )->fetch();
    }

    private function prepareExcludedDatesMasterEvent(Sync\Entities\SyncEvent $masterSyncEvent, Core\Base\Date $excludedDate): void
    {
        $masterEvent = $masterSyncEvent->getEvent();
 
        $date = clone $excludedDate;
        $date->format(Core\Event\Properties\ExcludedDatesCollection::EXCLUDED_DATE_FORMAT);
 
        if ($masterEvent->getExcludedDateCollection())
        {
            $masterEvent->getExcludedDateCollection()->add($date);
        }
        else
        {
            $masterEvent->setExcludedDateCollection(new Core\Event\Properties\ExcludedDatesCollection([$date]));
        }
    }

    private function prepareNewEvent(Event $event, Sync\Entities\SyncSection $syncSection): void
    {
        $section = $syncSection->getSection();
        $owner = $section->getOwner();
        if ($owner === null)
        {
            throw new BaseException('section has not owner');
        }
 
        $event
            ->setSection($syncSection->getSection())
            ->setOwner($owner)
            ->setCreator($owner)
            ->setEventHost($owner)
            ->setMeetingDescription($this->getMeetingDescriptionForNewEvent($owner))
            ->setIsActive(true)
            ->setIsDeleted(false)
            ->setCalendarType($owner->getType())
        ;
    }

    public function handleMerge(
        Sync\Entities\SyncEventMap $localEventCollection,
        string $vendorId,
        SyncEventMergeHandler $handlerMerge,
        Sync\Entities\SyncEvent $syncEvent,
        ?Sync\Connection\EventConnection $eventConnection,
        Core\Event\Event $event,
        Sync\Entities\SyncSection $syncSection
    ): Core\Event\Event
    {
        $mergedSyncEvent = null;
        if ($localEventCollection->has($vendorId))
        {
            $mergedSyncEvent = $handlerMerge(
                $localEventCollection->getItem($vendorId),
                $syncEvent,
                $localEventCollection->getItem($vendorId)->getEvent()->getId()
            );
            $eventConnection->setId($localEventCollection->getItem($vendorId)->getEventConnection()->getId());
        }
        elseif (
            $syncEvent->getEventConnection()
            && $localEventCollection->has($syncEvent->getEventConnection()
                ->getRecurrenceId())
        )
        {
            $masterSyncEvent = $localEventCollection->getItem($syncEvent->getEventConnection()->getRecurrenceId());
            // merge with master event
            $mergedSyncEvent = $handlerMerge(
                $masterSyncEvent,
                $syncEvent
            );
            $mergedSyncEvent->getEvent()->setRecurrenceId($masterSyncEvent->getEvent()->getId())
            ;
        }
        if ($mergedSyncEvent !== null)
        {
            $event = $mergedSyncEvent->getEvent();
        }
        else
        {
            $this->prepareNewEvent($event, $syncSection);
        }
        return $event;
    }

    private function mergeExternalEventWithLocalParams(Sync\Entities\SyncEvent $syncEvent): void
    {
        if ($existsSyncEvent = $this->syncEventMap->getItem($syncEvent->getEventConnection()->getVendorEventId()))
        {
            $this->mergeSyncEvent(
                $existsSyncEvent,
                $syncEvent,
                $existsSyncEvent->getEventId(),
                $existsSyncEvent->getEventConnection()->getId()
            );
 
            if (
                $syncEvent->isRecurrence()
                && $syncEvent->hasInstances()
            )
            {
                foreach ($syncEvent->getInstanceMap() as $instanceSyncEvent)
                {
                    if (
                        $existsSyncEvent->hasInstances()
                        && $instanceSyncEvent->getEvent()->getOriginalDateFrom()
                        && $existsInstanceSyncEvent = $existsSyncEvent->getInstanceMap()->getItem(
                            Sync\Entities\InstanceMap::getKeyByDate(
                                $instanceSyncEvent->getEvent()->getOriginalDateFrom()
                            )
                        )
                    )
                    {
                        $this->mergeSyncEvent(
                            $existsInstanceSyncEvent,
                            $instanceSyncEvent,
                            $existsInstanceSyncEvent->getEventId(),
                            $existsInstanceSyncEvent->getEventConnection()->getId()
                        );
                    }
                    else
                    {
                        $this->prepareNewSyncEvent($syncEvent);
                    }
                }
            }
 
            return;
        }

        if ($existsMasterSyncEvent = $this->syncEventMap->getItem($syncEvent->getEventConnection()->getRecurrenceId()))
        {
            if (
                $existsMasterSyncEvent->hasInstances()
                && $syncEvent->getEvent()->getOriginalDateFrom()
                && $existsInstanceSyncEvent = $existsMasterSyncEvent->getInstanceMap()->getItem(
                    Sync\Entities\InstanceMap::getKeyByDate(
                        $syncEvent->getEvent()->getOriginalDateFrom()
                    )
                )
            )
            {
                $this->mergeSyncEvent(
                    $existsInstanceSyncEvent,
                    $syncEvent,
                    $existsInstanceSyncEvent->getEventId(),
                    $existsInstanceSyncEvent->getEventConnection()->getId()
                );
 
                return;
            }
 
            $this->mergeSyncEvent($existsMasterSyncEvent, $syncEvent);
 
            return;
        }
 
        if ($syncEvent->getAction() !== Sync\Dictionary::SYNC_EVENT_ACTION['delete'])
        {
            $this->prepareNewSyncEvent($syncEvent);
        }
    }

    private function mergeSyncEvent(
        Sync\Entities\SyncEvent $existsSyncEvent,
        Sync\Entities\SyncEvent $externalSyncEvent,
        int $id = null,
        int $eventConnectionId = null
    ): void
    {
        $handler = new SyncEventMergeHandler();
        $handler($existsSyncEvent, $externalSyncEvent, $id, $eventConnectionId);
    }

    private function prepareLocalSyncEventMapWithVendorEventId(Sync\Entities\SyncEventMap $externalSyncEventMap): void
    {
        $vendorEventIdList = [];
        foreach ($externalSyncEventMap->getCollection() as $item)
        {
            $vendorEventIdList[] = $item->getVendorEventId();
            if ($item->isInstance())
            {
                $vendorEventIdList[] = $item->getVendorRecurrenceId();
            }
            $this->importedLocalEventUidList[] = $item->getUid();
        }
 
        $this->syncEventMap = $this->syncEventFactory->getSyncEventCollectionByVendorIdList(
            array_unique($vendorEventIdList),
            $this->factory->getConnection()->getId()
        );
    }

    private function prepareNewSyncEvent(Sync\Entities\SyncEvent $syncEvent): void
    {
 
    }

    private function updateExportedEvents(Sync\Entities\SyncEventMap $localEventMap): void
    {
        foreach ($localEventMap as $syncEvent)
        {
            if ($syncEvent->getAction() !== Sync\Dictionary::SYNC_EVENT_ACTION['success'])
            {
                $this->handleExportedFailedSyncEvent($syncEvent);
                continue;
            }
 
            if ($eventConnection = $syncEvent->getEventConnection())
            {
                if ($eventConnection->getId())
                {
                    $this->eventConnectionMapper->update($eventConnection);
                }
                else
                {
                    $this->eventConnectionMapper->create($eventConnection);
                }
 
                if ($syncEvent->hasInstances())
                {
                    $this->handleExportedInstances($syncEvent);
                }
            }
        }
    }

    private function updateMasterExdate(Event $masterEvent): void
    {
        $handler = new UpdateMasterExdateHandler();
        $handler($masterEvent);
    }

    private function validateSyncSectionBeforeSave(Sync\Entities\SyncSection $syncSection): bool
    {
        return $syncSection->getSection() && $syncSection->getSectionConnection();
    }

    private function updateFailedSyncSection(Sync\Entities\SyncSection $syncSection): void
    {
 
    }

    private function filterBrokenSyncSections(): void
    {
        foreach ($this->syncSectionMap as $key => $item)
        {
            if ($item->getSectionConnection() === null)
            {
                $this->syncSectionMap->remove($key);
            }
        }
    }

    private function handleDeleteRecurrenceEvent(SyncEvent $syncEvent)
    {
 
    }

    private function handleDeleteSingleEvent(SyncEvent $syncEvent)
    {
 
    }

    private function handleExportedFailedSyncEvent(Sync\Entities\SyncEvent $syncEvent): void
    {
        if (
            ($syncEvent->getEventConnection() === null)
            || ($syncEvent->getEventConnection()->getId() === null)
        )
        {
            return;
        }
 
        $eventConnection = $syncEvent->getEventConnection();
 
        switch ($syncEvent->getAction())
        {
            case Sync\Dictionary::SYNC_EVENT_ACTION['delete']:
                $eventConnection->setLastSyncStatus(Sync\Dictionary::SYNC_STATUS['delete']);
                break;
            default:
                $eventConnection->setLastSyncStatus(Sync\Dictionary::SYNC_STATUS['update']);
                break;
        }
 
        $this->eventConnectionMapper->update($eventConnection);
    }

    private function blockSectionPush(Sync\Entities\SyncSectionMap $syncSectionMap): void
    {
        $pushManager = new PushManager();
        foreach ($syncSectionMap as $syncSection)
        {
            $pushManager->setBlockPush(
                $pushManager->getPush(PushManager::TYPE_SECTION, $syncSection->getSection()->getId())
            );
 
            if (
                ($syncSection->getSectionConnection() !== null)
                && ($syncSection->getSectionConnection()->getId() !== null)
            )
            {
                $pushManager->setBlockPush(
                    $pushManager->getPush(
                        PushManager::TYPE_SECTION_CONNECTION,
                        $syncSection->getSectionConnection()->getId()
                    )
                );
            }
        }
    }

    private function unblockSectionPush(Sync\Entities\SyncSectionMap $syncSectionMap): void
    {
        $pushManager = new PushManager();
        foreach ($syncSectionMap as $syncSection)
        {
            $pushManager->setUnblockPush(
                $pushManager->getPush(PushManager::TYPE_SECTION, $syncSection->getSection()->getId())
            );
 
            if ($syncSection->getSectionConnection() !== null
                && $syncSection->getSectionConnection()->getId() !== null
            )
            {
                $pushManager->setUnblockPush(
                    $pushManager->getPush(
                        PushManager::TYPE_SECTION_CONNECTION,
                        $syncSection->getSectionConnection()->getId()
                    )
                );
            }
        }
    }

    private function removeDeprecatedInstances(
        Sync\Entities\SyncEvent $existsExternalSyncEvent,
        Sync\Entities\SyncEvent $syncEvent
    ): void
    {
        if ($existsExternalSyncEvent->hasInstances())
        {
            foreach ($existsExternalSyncEvent->getInstanceMap() as $key => $oldInstance)
            {
                if (!$syncEvent->hasInstances() || empty($syncEvent->getInstanceMap()->getItem($key)))
                {
                    $this->eventConnectionMapper->delete($oldInstance->getEventConnection(), ['softDelete' => false]);
                    $this->eventMapper->delete($oldInstance->getEvent(), [
                        'softDelete' => false,
                        'originalFrom' => $syncEvent->getEventConnection()?->getConnection()->getVendor()->getCode(),
                        'recursionMode' => 'this',
                    ]);
                }
            }
        }
    }

    private function prepareSyncSectionBeforeExport(Sync\Entities\SyncSectionMap $syncSectionMap): Sync\Entities\SyncSectionMap
    {
        $syncSectionKeyIdList = [];
        foreach ($syncSectionMap as $key => $syncSection)
        {
            if ($syncSection->getSectionConnection() === null)
            {
                continue;
            }
 
            if (in_array($syncSection->getSection()->getId(), $syncSectionKeyIdList, true))
            {
                $syncSectionMap->remove($key);
            }
            else
            {
                $syncSectionKeyIdList[$syncSection->getSectionConnection()->getVendorSectionId()] = $syncSection->getSection()->getId();
            }
 
            $this->sectionConnectionMapper->delete($syncSection->getSectionConnection(), ['softDelete' => false]);
            $this->syncSectionMap->remove($key);
            $syncSection->setSectionConnection(null);
        }
 
        // todo optimize this process after update mappers
        if ($syncSectionKeyIdList)
        {
            $syncEventMap = $this->syncEventFactory->getSyncEventMapBySyncSectionIdCollectionForExport(
                $syncSectionKeyIdList,
                $this->factory->getConnection()->getOwner()->getId(),
                $this->factory->getConnection()->getId()
            );
            if ($syncEventMap->count())
            {
                foreach ($syncEventMap as $syncEvent)
                {
                    if ($syncEvent->getEventConnection() === null)
                    {
                        continue;
                    }
 
                    $this->eventConnectionMapper->delete($syncEvent->getEventConnection(), ['softDelete' => false]);
                }
            }
        }
 
        return $syncSectionMap;
    }

    private function noticeUser(Sync\Entities\SyncEvent $syncEvent, string $messageCode = '')
    {
        if (Loader::includeModule('im') && Loader::includeModule('pull'))
        {
            $path = CCalendar::GetPath(
                $syncEvent->getEvent()->getOwner()->getType(),
                $syncEvent->getEvent()->getOwner()->getId(),
                true);
            $uri = (new Uri($path))
                ->deleteParams(["action", "sessid", "bx_event_calendar_request", "EVENT_ID", "EVENT_DATE"])
                ->addParams([
                    'EVENT_ID' => $syncEvent->getEvent()->getId()])
            ;
 
            NotificationManager::sendBlockChangeNotification(
                $syncEvent->getEventConnection()->getConnection()->getOwner()->getId(),
                $messageCode,
                [
                    '#EVENT_URL#' => $uri->getUri(),
                    '#EVENT_TITLE#' => $syncEvent->getEvent()->getName(),
                    'EVENT_ID' => $syncEvent->getEvent()->getId(),
                ]
            );
        }
    }

    public function renewSubscription(Connection $connection)
    {
        $mapperFactory = ServiceLocator::getInstance()->get('calendar.service.mappers.factory');
        $links = $mapperFactory->getSectionConnection()->getMap([
            '=CONNECTION_ID' => $connection->getId(),
            '=ACTIVE' => 'Y'
        ]);
 
        $manager = $this->getOutgoingManager($connection);
        foreach ($links as $link)
        {
            $manager->subscribeSection($link);
        }
 
        $manager->subscribeConnection();
    }

    private function getOutgoingManager(Connection $connection)
    {
        if (empty(static::$outgoingManagersCache[$connection->getId()]))
        {
            static::$outgoingManagersCache[$connection->getId()] = new OutgoingManager($connection);
        }
 
        return static::$outgoingManagersCache[$connection->getId()];
    }
}