importeventmanager.php

<?php
 
namespace Bitrix\Calendar\Sync\Managers;
 
use Bitrix\Calendar\Core;
use Bitrix\Calendar\Sync;
use Bitrix\Main\ArgumentException;
use Bitrix\Main\DI\ServiceLocator;
use Bitrix\Main\ObjectNotFoundException;
 
class ImportEventManager
{
    private Sync\Entities\SyncEventMap $externalEventMap;
    private Core\Base\Map $syncSectionCollection;
    private IncomingEventManagerInterface $importManager;
    private $mapperFactory;
 
    public function __construct(Sync\Factories\FactoryBase $factory, Core\Base\Map $syncSectionCollection)
    {
        $this->importManager = $factory->getIncomingEventManager();
        $this->syncSectionCollection = $syncSectionCollection;
        $this->externalEventMap = new Sync\Entities\SyncEventMap();
        $this->mapperFactory = ServiceLocator::getInstance()->get('calendar.service.mappers.factory');
    }
 
    public function import(): ImportEventManager
    {
        foreach ($this->syncSectionCollection as $syncSection)
        {
            if (
                $syncSection->getSectionConnection() === null
                || !$syncSection->getSectionConnection()->isActive()
            )
            {
                continue;
            }
 
            try
            {
                $result = $this->importManager->getEvents($syncSection);
 
                if ($result->isSuccess())
                {
                    $this->handleCalendarChange(($result->getData()['externalSyncEventMap'])->getCollection());
                    $this->externalEventMap->addItems(($result->getData()['externalSyncEventMap'])->getCollection());
                    $syncSection
                        ->getSectionConnection()
                        ->setLastSyncDate(new Core\Base\Date())
                        ->setSyncToken($this->importManager->getSyncToken())
                        ->setPageToken($this->importManager->getPageToken())
                        ->setLastSyncStatus($this->importManager->getStatus())
                        ->setVersionId($this->importManager->getEtag())
                    ;
                    $syncSection->setSectionConnection(
                        $this->saveSectionConnection($syncSection->getSectionConnection())
                    );
                }
            }
            catch (Sync\Exceptions\NotFoundException $e)
            {
                $syncSection->getSectionConnection()
                    ->setActive(false)
                    ->setLastSyncStatus(Sync\Dictionary::SYNC_STATUS['deleted']);
                $syncSection->setSectionConnection(
                    $this->saveSectionConnection($syncSection->getSectionConnection())
                );
            }
            catch (Sync\Exceptions\AuthException | Sync\Exceptions\RemoteAccountException $e)
            {
                $syncSection->getSectionConnection()
                    ->setLastSyncStatus(Sync\Dictionary::SYNC_STATUS['failed']);
                $syncSection->setSectionConnection(
                    $this->saveSectionConnection($syncSection->getSectionConnection())
                );
            }
        }
 
        return $this;
    }
 
    private function saveSectionConnection(Sync\Connection\SectionConnection $link): Sync\Connection\SectionConnection
    {
        $mapper = $this->mapperFactory->getSectionConnection();
        return $link->getId()
            ? $mapper->update($link)
            : $mapper->create($link)
            ;
    }
 
    public function getEvents(): Sync\Entities\SyncEventMap
    {
        return $this->externalEventMap;
    }
 
    private function handleCalendarChange(array $collection)
    {
        $handledCollection = $this->externalEventMap->getCollection();
 
        foreach ($collection as $key => $value)
        {
            if (
                array_key_exists($key, $handledCollection)
                && $value->getAction() === 'save'
            )
            {
                $this->externalEventMap->remove($key);
                $this->externalEventMap->add($value, $key);
            }
        }
    }
}