eventmanager.php

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

<?php
 
namespace Bitrix\Calendar\Sync\Icloud;
 
use Bitrix\Calendar;
use Bitrix\Calendar\Core;
use Bitrix\Calendar\Core\Event\Event;
use Bitrix\Calendar\Sync\Connection\Connection;
use Bitrix\Calendar\Sync\Connection\EventConnection;
use Bitrix\Calendar\Sync\Connection\SectionConnection;
use Bitrix\Calendar\Sync\Connection\Server;
use Bitrix\Calendar\Sync\Entities\SyncEvent;
use Bitrix\Calendar\Sync\Managers\EventManagerInterface;
use Bitrix\Calendar\Sync\Util\EventContext;
use Bitrix\Calendar\Sync\Util\Context;
use Bitrix\Calendar\Sync\Util\Result;
use Bitrix\Main\Error;
use Generator;
 
class EventManager extends AbstractManager implements EventManagerInterface
{
    public function create(Event $event, EventContext $context): Result
    {
        $result = new Result();
 
        $data = $this->getApiService()->createEvent($context->getSectionConnection()->getVendorSectionId(), $event);
 
        if ($this->getApiService()->getError())
        {
            $this->processConnectionError($this->connection, $this->getApiService()->getError());
        }
 
        if ($data && is_array($data))
        {
            $result->setData([
                'event' => [
                    'id' => $data['XML_ID'],
                    'version' => $data['MODIFICATION_LABEL'],
                    'etag' => $data['MODIFICATION_LABEL'],
                ],
            ]);
        }
        else
        {
            $result->addError(new Error('Error while trying to save event'));
        }
 
        return $result;
    }

    public function update(Event $event, EventContext $context): Result
    {
        $result = new Result();
        $event->setUid($context->getEventConnection()->getVendorEventId());
 
        $context->getEventConnection()->setData($context->getEventConnection()->fetchData());
 
        if ($event->getRecurringRule())
        {
            return $this->saveInstance($event, $context);
        }
 
        $data = $this->getApiService()->updateEvent(
            $context->getSectionConnection()->getVendorSectionId(),
            $event,
            $context->getEventConnection()->getData()
        );
 
        if ($this->getApiService()->getError())
        {
            $this->processConnectionError($this->connection, $this->getApiService()->getError());
        }
 
        if ($data && is_array($data))
        {
            $result->setData([
                'event' => [
                    'id' => $data['XML_ID'],
                    'version' => $data['MODIFICATION_LABEL'],
                    'etag' => $data['MODIFICATION_LABEL'],
                ],
            ]);
        }
        else
        {
            $result->addError(new Error('Error while trying to update event'));
        }
 
        return $result;
    }

    public function delete(Event $event, EventContext $context): Result
    {
        $result = new Result();
        $sectionId = $context->getSectionConnection()->getVendorSectionId();
        $event->setUid($context->getEventConnection()->getVendorEventId());
 
        $data = $this->getApiService()->deleteEvent($sectionId, $event);
 
        if ($this->getApiService()->getError())
        {
            $this->processConnectionError($this->connection, $this->getApiService()->getError());
        }
        
        if (!$data)
        {
            $result->addError(new Error('Error while trying delete event'));
        }
 
        return $result;
    }

    public function createInstance(Event $event, EventContext $context): Result
    {
        return $this->saveInstance($event, $context);
    }

    public function updateInstance(Event $event, EventContext $context): Result
    {
        return $this->saveInstance($event, $context);
    }

    private function saveInstance(Event $event, EventContext $context): Result
    {
        $result = new Result();
        $masterLink = $context->getEventConnection();
 
        if (!$masterLink)
        {
            $result->addError(new Error('Master link not found'));
 
            return $result;
        }
 
        $sectionId = $context->getSectionConnection()->getVendorSectionId();
        $masterEvent = $masterLink->getEvent();
        $masterEvent->setUid($masterLink->getVendorEventId());
 
        $data = $this->getApiService()->saveInstance(
            $sectionId,
            $masterEvent,
            $masterLink->getData()
        );
 
        if ($this->getApiService()->getError())
        {
            $this->processConnectionError($this->connection, $this->getApiService()->getError());
        }
 
        if ($data && is_array($data))
        {
            $result->setData([
                'event' => [
                    'id' => $data['XML_ID'],
                    'version' => $data['MODIFICATION_LABEL'],
                    'etag' => $data['MODIFICATION_LABEL'],
                ],
            ]);
        }
        else
        {
            $result->addError(new Error('Error while trying to save instance'));
        }
 
        return $result;
    }

    public function deleteInstance(Event $event, EventContext $context): Result
    {
        $result = new Result();
        $masterLink = $context->getEventConnection();
 
        if (!$masterLink)
        {
            $result->addError(new Error('Master link not found'));
 
            return $result;
        }
 
        $sectionId = $context->getSectionConnection()->getVendorSectionId();
        $excludeDate = $context->sync['excludeDate'];
        $masterEvent = $masterLink->getEvent();
        $masterEvent->setUid($masterLink->getVendorEventId());
 
        $data = $this->getApiService()->saveInstance(
            $sectionId,
            $masterEvent,
            $masterLink->getData(),
            $excludeDate
        );
 
        if ($this->getApiService()->getError())
        {
            $this->processConnectionError($this->connection, $this->getApiService()->getError());
        }
 
        if ($data && is_array($data))
        {
            $result->setData([
                'event' => [
                    'id' => $data['XML_ID'],
                    'version' => $data['MODIFICATION_LABEL'],
                    'etag' => $data['MODIFICATION_LABEL'],
                ],
            ]);
        }
        else
        {
            $result->addError(new Error('Error while trying to delete instance'));
        }
 
        return $result;
    }

    public function saveRecurrence(
        SyncEvent $recurrenceEvent,
        SectionConnection $sectionConnection,
        Context $context
    ): Result
    {
        $result = new Result();
        $sectionId = $context->sync['vendorSectionId'];
 
        $data = $this->getApiService()->saveRecurrence($sectionId, $recurrenceEvent);
 
        if ($this->getApiService()->getError())
        {
            $this->processConnectionError($sectionConnection->getConnection(), $this->getApiService()->getError());
        }
 
        if ($data && is_array($data))
        {
            $masterEvent = $recurrenceEvent;
 
            $this->prepareLink($masterEvent, $sectionConnection, $data['XML_ID'], $data['MODIFICATION_LABEL']);

            foreach ($recurrenceEvent->getInstanceMap()->getCollection() as $instance)
            {
                $this->prepareLink($instance, $sectionConnection, $data['XML_ID']);
                $instance->getEventConnection()->setRecurrenceId($data['XML_ID']);
            }
        }
        else
        {
            $result->addError(new Error('Error while trying to save recurrence event'));
        }
 
        return $result;
    }

    public function createRecurrence(
        SyncEvent $recurrenceEvent,
        SectionConnection $sectionConnection,
        Context $context
    ): Result
    {
        return $this->saveRecurrence($recurrenceEvent, $sectionConnection, $context);
    }

    public function updateRecurrence(
        SyncEvent $recurrenceEvent,
        SectionConnection $sectionConnection,
        Context $context
    ): Result
    {
        return $this->saveRecurrence($recurrenceEvent, $sectionConnection, $context);
    }

    private function getApiService(): ApiService
    {
        if (!$this->apiService)
        {
            $this->apiService = new ApiService();
        }
 
        return $this->apiService;
    }

    private function prepareLink(
        SyncEvent $event,
        SectionConnection $connection,
        string $vendorId,
        ?string $entityTag = null
    ): void
    {
        if ($event->getEventConnection())
        {
            $event->getEventConnection()
                ->setLastSyncStatus(Calendar\Sync\Dictionary::SYNC_STATUS['success'])
                ->setEntityTag($entityTag);
        }
        else
        {
            $link = (new EventConnection())
                ->setId(null)
                ->setEvent($event->getEvent())
                ->setVersion($event->getEvent()->getVersion())
                ->setConnection($connection->getConnection())
                ->setVendorEventId($vendorId)
                ->setEntityTag($entityTag)
                ->setLastSyncStatus(Calendar\Sync\Dictionary::SYNC_STATUS['success'])
            ;
            $event->setEventConnection($link);
        }
    }

    private function processConnectionError(Connection $connection, array $error): void
    {
        $parsedError = '[' . $error[0] . '] ' . $error[1];
        \CDavConnection::SetLastResult($connection->getId(), $parsedError);
    }
}